Home
last modified time | relevance | path

Searched refs:STAILQ_FOREACH_SAFE (Results 1 – 23 of 23) sorted by relevance

/spdk/test/unit/lib/nvme/nvme_poll_group.c/
H A Dnvme_poll_group_ut.c108 STAILQ_FOREACH_SAFE(iter_qp, &tgroup->connected_qpairs, poll_group_stailq, tmp_iter_qp) { in nvme_transport_poll_group_disconnect_qpair()
133 STAILQ_FOREACH_SAFE(iter_qp, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_iter_qp) { in nvme_transport_poll_group_connect_qpair()
188 STAILQ_FOREACH_SAFE(iter_qp, &tgroup->connected_qpairs, poll_group_stailq, tmp_iter_qp) { in nvme_transport_poll_group_remove()
195 STAILQ_FOREACH_SAFE(iter_qp, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_iter_qp) { in nvme_transport_poll_group_process_completions()
326 STAILQ_FOREACH_SAFE(tgroup, &group->tgroups, link, tmp_tgroup) { in test_spdk_nvme_poll_group_add_remove()
454 STAILQ_FOREACH_SAFE(tgroup, &group->tgroups, link, tmp_tgroup) {
501 STAILQ_FOREACH_SAFE(tgroup, &group->tgroups, link, tmp_tgroup) { in main()
/spdk/lib/init/
H A Drpc.c208 STAILQ_FOREACH_SAFE(init_server, &g_init_rpc_servers, link, tmp) { in spdk_rpc_finish()
/spdk/lib/nvme/
H A Dnvme_io_msg.c182 STAILQ_FOREACH_SAFE(io_msg_producer, &ctrlr->io_producers, link, tmp) { in nvme_io_msg_ctrlr_detach()
H A Dnvme_poll_group.c435 STAILQ_FOREACH_SAFE(tgroup, &group->tgroups, link, tmp_tgroup) {
H A Dnvme_qpair.c618 STAILQ_FOREACH_SAFE(req, &qpair->queued_req, stailq, tmp) { in nvme_qpair_abort_queued_reqs_with_cbarg()
732 STAILQ_FOREACH_SAFE(ctx, &ctrlr->register_operations, stailq, tmp) { in nvme_complete_register_operations()
795 STAILQ_FOREACH_SAFE(req, &qpair->err_req_head, stailq, tmp) { in spdk_nvme_qpair_process_completions()
H A Dnvme_pcie_common.c352 STAILQ_FOREACH_SAFE(req, &proc->active_reqs, stailq, tmp_req) { in nvme_pcie_ctrlr_cmd_create_io_cq()
1803 STAILQ_FOREACH_SAFE(qpair, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_qpair) { in nvme_pcie_poll_group_get_stats()
1807 STAILQ_FOREACH_SAFE(qpair, &tgroup->connected_qpairs, poll_group_stailq, tmp_qpair) { in nvme_pcie_poll_group_get_stats()
1826 STAILQ_FOREACH_SAFE(qpair, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_qpair) {
H A Dnvme_rdma.c506 STAILQ_FOREACH_SAFE(entry, &rctrlr->pending_cm_events, link, tmp) { in nvme_rdma_poll_events()
2049 STAILQ_FOREACH_SAFE(entry, &rctrlr->pending_cm_events, link, tmp) { in nvme_rdma_ctrlr_delete_io_qpair()
3288 STAILQ_FOREACH_SAFE(poller, &group->pollers, link, tmp_poller) {
3461 STAILQ_FOREACH_SAFE(qpair, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_qpair) {
3489 STAILQ_FOREACH_SAFE(qpair, &tgroup->connected_qpairs, poll_group_stailq, tmp_qpair) {
H A Dnvme_ctrlr_cmd.c603 STAILQ_FOREACH_SAFE(next, &ctrlr->queued_aborts, stailq, tmp) { in nvme_ctrlr_retry_queued_abort()
H A Dnvme_ctrlr.c1703 STAILQ_FOREACH_SAFE(req, &ctrlr->queued_aborts, stailq, tmp) {
3326 STAILQ_FOREACH_SAFE(nvme_event, &active_proc->async_events, link, nvme_event_tmp) { in nvme_ctrlr_async_event_cb()
3574 STAILQ_FOREACH_SAFE(req, &proc->active_reqs, stailq, tmp_req) {
H A Dnvme_tcp.c2831 STAILQ_FOREACH_SAFE(qpair, &tgroup->disconnected_qpairs, poll_group_stailq, tmp_qpair) { in nvme_tcp_poll_group_disconnect_qpair()
/spdk/lib/sock/
H A Dsock.c177 STAILQ_FOREACH_SAFE(entry, &map->entries, link, tmp) { in spdk_sock_map_cleanup()
815 STAILQ_FOREACH_SAFE(group_impl, &(*group)->group_impls, link, tmp) {
822 STAILQ_FOREACH_SAFE(group_impl, &(*group)->group_impls, link, tmp) { in sock_get_impl_by_name()
/spdk/include/spdk/
H A Dqueue_extras.h149 #define STAILQ_FOREACH_SAFE(var, head, field, tvar) \ macro
/spdk/module/bdev/delay/
H A Dvbdev_delay.c150 STAILQ_FOREACH_SAFE(io_ctx, head, link, tmp) { in _process_io_stailq()
331 STAILQ_FOREACH_SAFE(io_ctx, head, link, tmp) { in _abort_all_delayed_io()
/spdk/module/accel/dsa/
H A Daccel_dsa.c429 STAILQ_FOREACH_SAFE(task, &chan->queued_tasks, link, tmp) { in dsa_create_cb()
/spdk/lib/iscsi/
H A Discsi_subsystem.c968 STAILQ_FOREACH_SAFE(conn, &group->connections, pg_link, tmp) { in iscsi_poll_group_poll()
983 STAILQ_FOREACH_SAFE(conn, &group->connections, pg_link, tmp) { in iscsi_poll_group_handle_nop()
/spdk/lib/nvmf/
H A Drdma.c891 STAILQ_FOREACH_SAFE(rdma_recv, &rqpair->resources->incoming_queue, link, recv_tmp) { in nvmf_rdma_qpair_destroy()
3388 STAILQ_FOREACH_SAFE(rdma_req, &rqpair->pending_rdma_send_queue, state_link, req_tmp) { in nvmf_rdma_qpair_process_pending()
3395 STAILQ_FOREACH_SAFE(rdma_req, &rqpair->pending_rdma_read_queue, state_link, req_tmp) { in nvmf_rdma_qpair_process_pending()
3408 STAILQ_FOREACH_SAFE(rdma_req, &rqpair->pending_rdma_write_queue, state_link, req_tmp) { in nvmf_rdma_poller_process_pending_buf_queue()
3415 STAILQ_FOREACH_SAFE(req, &rqpair->poller->group->group.pending_buf_queue, buf_link, tmp) { in nvmf_rdma_can_ignore_last_wqe_reached()
3454 STAILQ_FOREACH_SAFE(req, &rpoller->group->group.pending_buf_queue, buf_link, tmp) { in nvmf_rdma_destroy_drained_qpair()
H A Dctrlr.c635 STAILQ_FOREACH_SAFE(event, &ctrlr->async_events, link, event_tmp) { in _nvmf_ctrlr_destruct()
2144 STAILQ_FOREACH_SAFE(event, &ctrlr->async_events, link, event_tmp) { in spdk_nvmf_ctrlr_save_migr_data()
H A Dfc.c1737 STAILQ_FOREACH_SAFE(req, &hwqp->fgroup->group.pending_buf_queue, buf_link, tmp) { in nvmf_fc_hwqp_process_pending_reqs()
H A Dtcp.c563 STAILQ_FOREACH_SAFE(abort_req, &tcp_group->control_msg_list->waiting_for_msg_reqs, control_msg_link, in _nvmf_tcp_qpair_destroy()
/spdk/lib/thread/
H A Diobuf.c613 STAILQ_FOREACH_SAFE(entry, pool->queue, stailq, tmp) { in spdk_iobuf_put()
/spdk/lib/idxd/
H A Didxd.c2091 STAILQ_FOREACH_SAFE(op, &chan->ops_outstanding, link, tmp) {
/spdk/test/unit/lib/nvmf/ctrlr.c/
H A Dctrlr_ut.c1673 STAILQ_FOREACH_SAFE(event, &ctrlr->async_events, link, event_tmp) { in test_reservation_notification_log_page()
/spdk/module/bdev/nvme/
H A Dbdev_nvme.c930 STAILQ_FOREACH_SAFE(io_path, &nbdev_ch->io_path_list, stailq, tmp_io_path) { in nvme_ctrlr_is_failed()