Searched refs:rq_thread_info (Results 1 – 3 of 3) sorted by relevance
93 xport->rq_thread_info == NULL) { in ocs_xport_rq_threads_teardown()99 if (xport->rq_thread_info[i].thread_started) { in ocs_xport_rq_threads_teardown()100 ocs_thread_terminate(&xport->rq_thread_info[i].thread); in ocs_xport_rq_threads_teardown()103 while (xport->rq_thread_info[i].thread_started) { in ocs_xport_rq_threads_teardown()108 if (xport->rq_thread_info[i].seq_cbuf != NULL) { in ocs_xport_rq_threads_teardown()109 ocs_cbuf_free(xport->rq_thread_info[i].seq_cbuf); in ocs_xport_rq_threads_teardown()110 xport->rq_thread_info[i].seq_cbuf = NULL; in ocs_xport_rq_threads_teardown()141 …xport->rq_thread_info = ocs_malloc(ocs, sizeof(ocs_xport_rq_thread_info_t) * num_rq_threads, OCS_M… in ocs_xport_rq_threads_create()142 if (xport->rq_thread_info == NULL) { in ocs_xport_rq_threads_create()149 xport->rq_thread_info[i].ocs = ocs; in ocs_xport_rq_threads_create()[all …]
196 ocs_xport_rq_thread_info_t *rq_thread_info; member
175 rc = ocs_cbuf_put(xport->rq_thread_info[thr_index].seq_cbuf, seq); in ocs_unsolicited_cb()