ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

iscsi: allocate/free I/O channels when connections start/stop on a core

Browse Source 
This will start testing the I/O channel allocation paths.  I/O channels
are not actually used for submitting I/O yet however.

Signed-off-by: Jim Harris <james.r.harris@intel.com>
Change-Id: I901402633248170324db1e2fc8fb813f7629c2b0
This commit is contained in:
Jim Harris 2016-09-20 12:45:37 -07:00
parent b5c1e5ada7
commit 68ca0b6315
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/iscsi/conn.c
View File

@ -683,6 +683,9 @@ spdk_iscsi_conn_stop_poller(struct spdk_iscsi_conn *conn, spdk_event_fn fn_after
pthread_mutex_lock(&target->mutex); pthread_mutex_lock(&target->mutex);
target->num_active_conns--; target->num_active_conns--;
pthread_mutex_unlock(&target->mutex); pthread_mutex_unlock(&target->mutex);
RTE_VERIFY(conn->dev != NULL);
spdk_scsi_dev_free_io_channels(conn->dev);
} }
rte_atomic32_dec(&g_num_connections[spdk_app_get_current_core()]); rte_atomic32_dec(&g_num_connections[spdk_app_get_current_core()]);
spdk_net_framework_clear_socket_association(conn->sock); spdk_net_framework_clear_socket_association(conn->sock);
@ -1268,6 +1271,11 @@ spdk_iscsi_conn_full_feature_migrate(struct spdk_event *event)
{ {
struct spdk_iscsi_conn *conn = spdk_event_get_arg1(event); struct spdk_iscsi_conn *conn = spdk_event_get_arg1(event);
if (conn->sess->session_type == SESSION_TYPE_NORMAL) {
RTE_VERIFY(conn->dev != NULL);
spdk_scsi_dev_allocate_io_channels(conn->dev);
}
/* The poller has been unregistered, so now we can re-register it on the new core. */ /* The poller has been unregistered, so now we can re-register it on the new core. */
conn->lcore = spdk_app_get_current_core(); conn->lcore = spdk_app_get_current_core();
spdk_poller_register(&conn->poller, spdk_iscsi_conn_full_feature_do_work, conn, spdk_poller_register(&conn->poller, spdk_iscsi_conn_full_feature_do_work, conn,