Home
last modified time | relevance | path

Searched refs:STAILQ_EMPTY (Results 1 – 25 of 39) sorted by relevance

12

/spdk/test/unit/lib/nvme/nvme_transport.c/
H A Dnvme_transport_ut.c87 CU_ASSERT(STAILQ_EMPTY(&tgroup.disconnected_qpairs)); in test_nvme_transport_poll_group_connect_qpair()
88 CU_ASSERT(!STAILQ_EMPTY(&tgroup.connected_qpairs)); in test_nvme_transport_poll_group_connect_qpair()
90 CU_ASSERT(STAILQ_EMPTY(&tgroup.connected_qpairs)); in test_nvme_transport_poll_group_connect_qpair()
132 CU_ASSERT(STAILQ_EMPTY(&tgroup.connected_qpairs)); in test_nvme_transport_poll_group_disconnect_qpair()
134 CU_ASSERT(!STAILQ_EMPTY(&tgroup.disconnected_qpairs)); in test_nvme_transport_poll_group_disconnect_qpair()
136 CU_ASSERT(STAILQ_EMPTY(&tgroup.disconnected_qpairs)); in test_nvme_transport_poll_group_disconnect_qpair()
176 SPDK_CU_ASSERT_FATAL(!STAILQ_EMPTY(&tgroup.disconnected_qpairs)); in test_nvme_transport_poll_group_add_remove()
180 CU_ASSERT(STAILQ_EMPTY(&tgroup.disconnected_qpairs)); in test_nvme_transport_poll_group_add_remove()
/spdk/test/unit/lib/accel/dpdk_compressdev.c/
H A Daccel_dpdk_compressdev_ut.c530 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == true); in test_compress_operation()
533 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == false); in test_compress_operation()
534 while (!STAILQ_EMPTY(&g_comp_ch->queued_tasks)) { in test_compress_operation()
537 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == true); in test_compress_operation()
542 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == true); in test_compress_operation()
544 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == false); in test_compress_operation()
545 while (!STAILQ_EMPTY(&g_comp_ch->queued_tasks)) { in test_compress_operation()
548 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == true); in test_compress_operation()
554 CU_ASSERT(STAILQ_EMPTY(&g_comp_ch->queued_tasks) == true); in test_compress_operation()
556 CU_ASSERT(STAILQ_EMPTY( in test_compress_operation()
[all...]
/spdk/test/unit/lib/init/rpc.c/
H A Drpc_ut.c85 CU_ASSERT(STAILQ_EMPTY(&g_init_rpc_servers)); in initialize_servers()
102 CU_ASSERT(!STAILQ_EMPTY(&g_init_rpc_servers)); in test_run_multiple_servers_stop_all()
105 CU_ASSERT(STAILQ_EMPTY(&g_init_rpc_servers)); in test_run_multiple_servers_stop_all()
112 CU_ASSERT(!STAILQ_EMPTY(&g_init_rpc_servers)); in test_run_multiple_servers_stop_singles()
116 CU_ASSERT(!STAILQ_EMPTY(&g_init_rpc_servers)); in test_run_multiple_servers_stop_singles()
120 CU_ASSERT(STAILQ_EMPTY(&g_init_rpc_servers)); in test_run_multiple_servers_stop_singles()
/spdk/test/unit/lib/nvme/nvme_io_msg.c/
H A Dnvme_io_msg_ut.c133 CU_ASSERT(!STAILQ_EMPTY(&ctrlr.io_producers)); in test_nvme_io_msg_ctrlr_register_unregister()
139 CU_ASSERT(STAILQ_EMPTY(&ctrlr.io_producers)); in test_nvme_io_msg_ctrlr_register_unregister()
150 CU_ASSERT(!STAILQ_EMPTY(&ctrlr.io_producers)); in test_nvme_io_msg_ctrlr_register_unregister()
152 CU_ASSERT(STAILQ_EMPTY(&ctrlr.io_producers)); in test_nvme_io_msg_ctrlr_register_unregister()
165 CU_ASSERT(STAILQ_EMPTY(&ctrlr.io_producers)); in test_nvme_io_msg_ctrlr_register_unregister()
/spdk/test/unit/lib/nvme/nvme_qpair.c/
H A Dnvme_qpair_ut.c187 CU_ASSERT(!STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
198 CU_ASSERT(!STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
209 CU_ASSERT(STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
227 CU_ASSERT(!STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
237 CU_ASSERT(!STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
247 CU_ASSERT(STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_process_completions()
602 CU_ASSERT(STAILQ_EMPTY(&qpair.queued_req)); in test_nvme_qpair_resubmit_request_with_transport_failed()
633 SPDK_CU_ASSERT_FATAL(STAILQ_EMPTY(&qpair.free_req)); in test_nvme_qpair_manual_complete_request()
638 CU_ASSERT(!STAILQ_EMPTY(&qpair.free_req)); in test_nvme_qpair_manual_complete_request()
671 SPDK_CU_ASSERT_FATAL(!STAILQ_EMPTY( in test_nvme_qpair_init_deinit()
[all...]
/spdk/test/unit/lib/nvme/nvme_poll_group.c/
H A Dnvme_poll_group_ut.c227 CU_ASSERT(STAILQ_EMPTY(&group->tgroups)); in test_spdk_nvme_poll_group_create()
236 CU_ASSERT(STAILQ_EMPTY(&group->tgroups)); in test_spdk_nvme_poll_group_add_remove()
274 CU_ASSERT(STAILQ_EMPTY(&group->tgroups)); in test_spdk_nvme_poll_group_add_remove()
291 CU_ASSERT(STAILQ_EMPTY(&tmp_tgroup->connected_qpairs)); in test_spdk_nvme_poll_group_add_remove()
310 CU_ASSERT(STAILQ_EMPTY(&tmp_tgroup->connected_qpairs)); in test_spdk_nvme_poll_group_add_remove()
327 CU_ASSERT(STAILQ_EMPTY(&tgroup->connected_qpairs)); in test_spdk_nvme_poll_group_add_remove()
333 CU_ASSERT(STAILQ_EMPTY(&group->tgroups)); in test_spdk_nvme_poll_group_add_remove()
341 CU_ASSERT(STAILQ_EMPTY(&group->tgroups)); in test_spdk_nvme_poll_group_add_remove()
359 CU_ASSERT(STAILQ_EMPTY(&tmp_tgroup->connected_qpairs)); in test_spdk_nvme_poll_group_add_remove()
391 CU_ASSERT(STAILQ_EMPTY( in test_spdk_nvme_poll_group_process_completions()
[all...]
/spdk/include/spdk/
H A Dqueue_extras.h140 #define STAILQ_EMPTY(head) ((head)->stqh_first == NULL) macro
160 (STAILQ_EMPTY((head)) ? NULL : \
178 if (STAILQ_EMPTY(head1)) \
180 if (STAILQ_EMPTY(head2)) \
/spdk/test/unit/lib/nvme/nvme_pcie_common.c/
H A Dnvme_pcie_common_ut.c244 CU_ASSERT(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_cmd_create_delete_io_queue()
258 CU_ASSERT(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_cmd_create_delete_io_queue()
275 CU_ASSERT(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_cmd_create_delete_io_queue()
284 CU_ASSERT(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_cmd_create_delete_io_queue()
362 CU_ASSERT(STAILQ_EMPTY(&pctrlr.ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_connect_qpair()
413 CU_ASSERT(STAILQ_EMPTY(&pctrlr.ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_connect_qpair()
445 CU_ASSERT(STAILQ_EMPTY(&pctrlr.ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_connect_qpair()
488 CU_ASSERT(STAILQ_EMPTY(&pctrlr.ctrlr.adminq->free_req)); in test_nvme_pcie_ctrlr_connect_qpair()
/spdk/lib/init/
H A Drpc.c107 } else if (!STAILQ_EMPTY(&g_init_rpc_servers)) { in rpc_set_spdk_log_opts()
198 if (STAILQ_EMPTY(&g_init_rpc_servers)) { in spdk_rpc_server_finish()
/spdk/lib/nvme/
H A Dnvme_io_msg.c120 if (!STAILQ_EMPTY(&ctrlr->io_producers) || ctrlr->is_resetting) { in nvme_io_msg_ctrlr_register()
213 if (STAILQ_EMPTY(&ctrlr->io_producers)) { in nvme_io_msg_ctrlr_unregister()
H A Dnvme_qpair.c575 while (!STAILQ_EMPTY(&tmp)) { in nvme_qpair_abort_queued_reqs()
597 if (spdk_likely(STAILQ_EMPTY(&qpair->aborting_queued_req))) { in _nvme_qpair_complete_abort_queued_reqs()
604 while (!STAILQ_EMPTY(&tmp)) { in _nvme_qpair_complete_abort_queued_reqs()
661 while (!STAILQ_EMPTY(&qpair->queued_req)) { in nvme_qpair_check_enabled()
744 while (!STAILQ_EMPTY(&operations)) { in nvme_complete_register_operations()
794 if (spdk_unlikely(!STAILQ_EMPTY(&qpair->err_req_head))) { in spdk_nvme_qpair_process_completions()
923 while (!STAILQ_EMPTY(&qpair->err_req_head)) {
1101 if (spdk_unlikely(!STAILQ_EMPTY(&qpair->queued_req) && req->num_children == 0)) { in nvme_qpair_submit_request()
H A Dnvme_poll_group.c401 if (!STAILQ_EMPTY(&tgroup->disconnected_qpairs)) {
/spdk/test/unit/lib/nvme/nvme_ctrlr_cmd.c/
H A Dnvme_ctrlr_cmd_ut.c905 CU_ASSERT(STAILQ_EMPTY(&admin_qpair.free_req)); in test_nvme_request_add_abort()
918 CU_ASSERT(!STAILQ_EMPTY(&admin_qpair.free_req)); in test_nvme_request_add_abort()
920 CU_ASSERT(STAILQ_EMPTY(&admin_qpair.free_req)); in test_nvme_request_add_abort()
954 CU_ASSERT(STAILQ_EMPTY(&admin_qpair.free_req)); in test_spdk_nvme_ctrlr_cmd_abort()
979 CU_ASSERT(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_nvme_ctrlr_cmd_identify()
1000 SPDK_CU_ASSERT_FATAL(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_spdk_nvme_ctrlr_cmd_security_receive_send()
1012 SPDK_CU_ASSERT_FATAL(STAILQ_EMPTY(&ctrlr.adminq->free_req)); in test_spdk_nvme_ctrlr_cmd_security_receive_send()
/spdk/lib/thread/
H A Diobuf.c110 assert(STAILQ_EMPTY(&node->small_queue)); in spdk_iobuf_initialize()
111 assert(STAILQ_EMPTY(&node->large_queue)); in spdk_iobuf_initialize()
523 while (!STAILQ_EMPTY(&cache->small.cache)) { in spdk_iobuf_get()
529 while (!STAILQ_EMPTY(&cache->large.cache)) { in spdk_iobuf_get()
772 if (STAILQ_EMPTY(pool->queue)) {
/spdk/module/accel/iaa/
H A Daccel_iaa.c181 if (!STAILQ_EMPTY(&chan->queued_tasks)) { in iaa_submit_tasks()
227 if (!STAILQ_EMPTY(&chan->queued_tasks)) { in idxd_poll()
/spdk/test/common/lib/
H A Dtest_iobuf.c131 if (!STAILQ_EMPTY(&g_iobuf_entries)) { in spdk_iobuf_put()
/spdk/test/unit/lib/nvme/nvme_pcie.c/
H A Dnvme_pcie_ut.c299 if (STAILQ_EMPTY(&g_events)) { in spdk_pci_get_event()
340 CU_ASSERT(STAILQ_EMPTY(&g_events)); in test_nvme_pcie_hotplug_monitor()
345 CU_ASSERT(STAILQ_EMPTY(&g_events)); in test_nvme_pcie_hotplug_monitor()
352 CU_ASSERT(STAILQ_EMPTY(&g_events)); in test_nvme_pcie_hotplug_monitor()
359 CU_ASSERT(STAILQ_EMPTY(&g_events)); in test_nvme_pcie_hotplug_monitor()
379 CU_ASSERT(STAILQ_EMPTY(&g_events)); in test_nvme_pcie_hotplug_monitor()
/spdk/test/external_code/accel/
H A Dmodule.c77 if (STAILQ_EMPTY(&ex_ch->tasks_to_complete)) { in ex_accel_comp_poll()
/spdk/test/unit/lib/nvme/nvme_fabric.c/
H A Dnvme_fabric_ut.c387 CU_ASSERT(!STAILQ_EMPTY(&qpair.free_req)); in test_nvme_fabric_qpair_connect()
409 CU_ASSERT(!STAILQ_EMPTY(&qpair.free_req)); in test_nvme_fabric_qpair_connect()
/spdk/test/unit/lib/nvme/nvme_rdma.c/
H A Dnvme_rdma_ut.c640 CU_ASSERT(STAILQ_EMPTY(&group.pollers)); in test_nvme_rdma_poller_create()
1281 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
1295 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
1305 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
1328 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
1339 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
1357 CU_ASSERT(STAILQ_EMPTY(&group->pollers)); in test_nvme_rdma_qpair_set_poller()
/spdk/module/accel/dsa/
H A Daccel_dsa.c398 if (!STAILQ_EMPTY(&chan->queued_tasks)) { in dsa_supports_opcode()
452 if (!STAILQ_EMPTY(&chan->queued_tasks)) {
/spdk/module/accel/dpdk_compressdev/
H A Daccel_dpdk_compressdev.c613 if (!STAILQ_EMPTY(&chan->queued_tasks)) {
649 if (!STAILQ_EMPTY(&chan->queued_tasks)) { in compress_submit_tasks()
/spdk/lib/jsonrpc/
H A Djsonrpc_server_tcp.c140 assert(STAILQ_EMPTY(&conn->send_queue)); in jsonrpc_server_conn_remove()
/spdk/module/sock/uring/
H A During.c904 if (STAILQ_EMPTY(&sock->recv_stream)) { in uring_sock_readv_no_pipe()
931 if (STAILQ_EMPTY(&sock->recv_stream)) { in uring_sock_readv_no_pipe()
977 if (STAILQ_EMPTY(&sock->recv_stream)) { in uring_sock_readv()
1934 assert(STAILQ_EMPTY(&sock->recv_stream)); in uring_sock_group_impl_close()
/spdk/lib/nvmf/
H A Drdma.c3423 while (!STAILQ_EMPTY(&resources->free_queue) && !STAILQ_EMPTY(&resources->incoming_queue)) { in nvmf_rdma_destroy_drained_qpair()
3442 if (!STAILQ_EMPTY(&resources->incoming_queue) && STAILQ_EMPTY(&resources->free_queue)) { in nvmf_rdma_destroy_drained_qpair()
4545 while (!STAILQ_EMPTY(&rpoller->qpairs_pending_recv)) { in _qp_reset_failed_sends()
4626 while (!STAILQ_EMPTY(&rpoller->qpairs_pending_send)) { in nvmf_rdma_poller_poll()

12