| /spdk/lib/vmd/ |
| H A D | led.c | 35 vmd_led_set_indicator_control(struct vmd_pci_device *vmd_device, enum spdk_vmd_led_state state) in vmd_led_set_indicator_control() argument
40 assert(state >= SPDK_VMD_LED_STATE_OFF && state <= SPDK_VMD_LED_STATE_REBUILD); in vmd_led_set_indicator_control()
41 config = &g_led_config[state]; in vmd_led_set_indicator_control()
61 unsigned int state; in vmd_led_get_state() local
64 for (state = SPDK_VMD_LED_STATE_OFF; state <= SPDK_VMD_LED_STATE_REBUILD; ++state) { in vmd_led_get_state()
65 config = &g_led_config[state]; in vmd_led_get_state()
69 return state; in vmd_led_get_state()
106 spdk_vmd_set_led_state(struct spdk_pci_device *pci_device, enum spdk_vmd_led_state state) in spdk_vmd_set_led_state() argument
110 if (state < SPDK_VMD_LED_STATE_OFF || state > SPDK_VMD_LED_STATE_REBUILD) { in spdk_vmd_set_led_state()
121 vmd_led_set_indicator_control(vmd_device, state); in spdk_vmd_set_led_state()
[all …]
|
| /spdk/test/unit/lib/nvmf/auth.c/ |
| H A D | auth_ut.c | 38 nvmf_qpair_set_state(struct spdk_nvmf_qpair *qpair, enum spdk_nvmf_qpair_state state) in nvmf_qpair_set_state() argument
40 qpair->state = state; in nvmf_qpair_set_state()
247 CU_ASSERT_EQUAL(auth->state, NVMF_QPAIR_AUTH_FAILURE1); in test_auth_send_recv_error()
250 auth->state = NVMF_QPAIR_AUTH_NEGOTIATE; in test_auth_send_recv_error()
281 auth->state = NVMF_QPAIR_AUTH_NEGOTIATE; in test_auth_negotiate()
304 CU_ASSERT_EQUAL(auth->state, NVMF_QPAIR_AUTH_CHALLENGE); in test_auth_negotiate()
306 /* Invalid auth state */ in test_auth_negotiate()
308 auth->state = NVMF_QPAIR_AUTH_ERROR; in test_auth_negotiate()
314 CU_ASSERT_EQUAL(auth->state, NVMF_QPAIR_AUTH_FAILURE in test_auth_negotiate()
[all...] |
| /spdk/test/unit/lib/nvme/nvme_ctrlr.c/ |
| H A D | nvme_ctrlr_ut.c | 723 * Initial state: CC.EN = 1, CSTS.RDY = 0 in test_nvme_ctrlr_init_en_1_rdy_0()
731 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_INIT); in test_nvme_ctrlr_init_en_1_rdy_0()
732 while (ctrlr.state != NVME_CTRLR_STATE_CHECK_EN) { in test_nvme_ctrlr_init_en_1_rdy_0()
736 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_DISABLE_WAIT_FOR_READY_1); in test_nvme_ctrlr_init_en_1_rdy_0()
744 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_SET_EN_0); in test_nvme_ctrlr_init_en_1_rdy_0()
746 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_DISABLE_WAIT_FOR_READY_0); in test_nvme_ctrlr_init_en_1_rdy_0()
754 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_DISABLED); in test_nvme_ctrlr_init_en_1_rdy_0()
760 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_ENABLE); in test_nvme_ctrlr_init_en_1_rdy_0()
766 CU_ASSERT(ctrlr.state == NVME_CTRLR_STATE_ENABLE_WAIT_FOR_READY_1); in test_nvme_ctrlr_init_en_1_rdy_0()
774 CU_ASSERT(ctrlr.state in test_nvme_ctrlr_init_en_1_rdy_0()
[all...] |
| /spdk/doc/ |
| H A D | usdt.md | 49 group info state transitions.
69 2110.935735: nvmf_tgt reached state NONE
70 2110.954316: nvmf_tgt reached state CREATE_TARGET
71 2110.967905: nvmf_tgt reached state CREATE_POLL_GROUPS
72 2111.235982: nvmf_tgt reached state START_SUBSYSTEMS
73 2111.253560: nqn.2014-08.org.nvmexpress.discovery change state from INACTIVE to ACTIVE start
74 2111.260278: nqn.2014-08.org.nvmexpress.discovery on thread 2 state to ACTIVE start
75 2111.264281: nqn.2014-08.org.nvmexpress.discovery on thread 2 state to ACTIVE done
76 2111.284083: nqn.2014-08.org.nvmexpress.discovery change state from INACTIVE to ACTIVE done
77 2111.289197: nvmf_tgt reached state RUNNING
[all …]
|
| /spdk/test/external_code/accel/ |
| H A D | app_module.c | 21 enum test_state state; member
32 ctx->state = TEST_STATE_DONE; in test_ctx_fail()
56 ctx->state = TEST_STATE_COPY; in fill_cb()
77 ctx->state = TEST_STATE_COMPARE; in copy_cb()
98 ctx->state = TEST_STATE_DONE; in compare_cb()
111 prev_state = ctx->state; in process_accel()
113 switch (ctx->state) { in process_accel()
117 ctx->state = TEST_STATE_WAIT_COMPLETION; in process_accel()
127 ctx->state = TEST_STATE_WAIT_COMPLETION; in process_accel()
137 ctx->state = TEST_STATE_WAIT_COMPLETION; in process_accel()
[all …]
|
| /spdk/lib/json/ |
| H A D | json_parse.c | 436 } state = STATE_VALUE; in spdk_json_parse() local
462 if (state != STATE_VALUE) { goto done_invalid; } in spdk_json_parse()
469 state = depth ? STATE_VALUE_SEPARATOR : STATE_END; in spdk_json_parse()
474 if (state != STATE_VALUE && state != STATE_NAME) { goto done_invalid; } in spdk_json_parse()
484 ADD_VALUE(state == STATE_VALUE ? SPDK_JSON_VAL_STRING : SPDK_JSON_VAL_NAME, in spdk_json_parse()
487 if (state == STATE_NAME) { in spdk_json_parse()
488 state = STATE_NAME_SEPARATOR; in spdk_json_parse()
490 state = depth ? STATE_VALUE_SEPARATOR : STATE_END; in spdk_json_parse()
506 if (state != STATE_VALUE) { goto done_invalid; } in spdk_json_parse()
511 state = depth ? STATE_VALUE_SEPARATOR : STATE_END; in spdk_json_parse()
[all …]
|
| /spdk/test/interrupt/ |
| H A D | common.sh | 12 local state=$3
16 if [[ $state != "busy" ]] && [[ $state != "idle" ]]; then
30 if [[ $state = "busy" ]] && ((cpu_rate < busy_threshold)); then
32 elif [[ $state = "idle" ]] && ((cpu_rate > idle_threshold)); then
39 if [[ $state = "busy" ]]; then
|
| /spdk/lib/vhost/ |
| H A D | vhost_scsi.c | 85 /** Local copy of the device state */
187 struct spdk_scsi_dev_vhost_state *state; in remove_scsi_tgt() local
190 state = &svdev->scsi_dev_state[scsi_tgt_num]; in remove_scsi_tgt()
191 dev = state->dev; in remove_scsi_tgt()
192 state->dev = NULL; in remove_scsi_tgt()
193 assert(state->status == VHOST_SCSI_DEV_REMOVING); in remove_scsi_tgt()
194 state->status = VHOST_SCSI_DEV_EMPTY; in remove_scsi_tgt()
196 if (state->remove_cb) { in remove_scsi_tgt()
197 state->remove_cb(&svdev->vdev, state in remove_scsi_tgt()
232 struct spdk_scsi_dev_session_state *state = &svsession->scsi_dev_state[scsi_tgt_num]; vhost_scsi_session_process_removed() local
250 struct spdk_scsi_dev_session_state *state; process_removed_devs() local
401 struct spdk_scsi_dev_session_state *state; vhost_scsi_task_init_target() local
1103 struct spdk_scsi_dev_vhost_state *state; spdk_vhost_scsi_dev_add_tgt() local
1207 struct spdk_scsi_dev_session_state *state = &svsession->scsi_dev_state[scsi_tgt_num]; vhost_scsi_session_remove_tgt() local
1286 struct spdk_scsi_dev_session_state *state = &svsession->scsi_dev_state[scsi_tgt_num]; vhost_scsi_session_param_changed() local
1415 struct spdk_scsi_dev_vhost_state *state; vhost_scsi_start() local
1478 struct spdk_scsi_dev_session_state *state; destroy_session_poller_cb() local
[all...] |
| /spdk/scripts/bpf/ |
| H A D | gen_enums.sh | 33 for state in "${!state_enums[@]}"; do
34 _print_enums "$state" "${state_enums["$state"]}" "${state_prefix["$state"]}"
|
| /spdk/lib/ftl/ |
| H A D | ftl_band.c | 40 assert(band->md->state == FTL_BAND_STATE_CLOSED || in ftl_band_free_p2l_map()
41 band->md->state == FTL_BAND_STATE_FREE); in ftl_band_free_p2l_map()
57 assert(band->md->state == FTL_BAND_STATE_CLOSED || in ftl_band_free_md_entry()
58 band->md->state == FTL_BAND_STATE_FREE); in ftl_band_free_md_entry()
105 band->md->state = FTL_BAND_STATE_CLOSED; in _ftl_band_set_closed_cb()
147 assert(band->md->state < SPDK_COUNTOF(names)); in ftl_band_get_state_name()
148 if (band->md->state < SPDK_COUNTOF(names)) { in ftl_band_get_state_name()
149 return names[band->md->state]; in ftl_band_get_state_name()
157 ftl_band_set_state(struct ftl_band *band, enum ftl_band_state state) in ftl_band_set_state() argument
159 switch (state) { in ftl_band_set_state()
[all …]
|
| H A D | ftl_writer.c | 31 return writer->band->md->state == FTL_BAND_STATE_OPEN; in can_write()
39 switch (band->md->state) { in ftl_writer_band_state_change()
92 if (FTL_BAND_STATE_OPEN == writer->next_band->md->state) { in get_band()
98 assert(FTL_BAND_STATE_OPEN == writer->next_band->md->state); in get_band()
130 if (spdk_likely(writer->band->md->state == FTL_BAND_STATE_OPEN)) { in get_band()
133 if (spdk_unlikely(writer->band->md->state == FTL_BAND_STATE_PREP)) { in get_band()
196 if (writer->band->md->state == FTL_BAND_STATE_OPEN) { in ftl_writer_pad_band()
210 if (writer->band->md->state != FTL_BAND_STATE_OPEN) { in ftl_writer_is_halted()
|
| H A D | ftl_l2p_cache.c | 45 enum ftl_l2p_page_state state; member
116 enum ftl_l2p_cache_state state; member
288 page->state = L2P_CACHE_PAGE_INIT; in ftl_l2p_cache_page_alloc()
297 page->state != L2P_CACHE_PAGE_INIT && in ftl_l2p_cache_page_can_remove()
350 if (!page->pin_ref_cnt && !page->on_lru_list && page->state != L2P_CACHE_PAGE_FLUSHING) { in ftl_l2p_cache_page_unpin()
368 return (page->state == L2P_CACHE_PAGE_FLUSHING || in ftl_l2p_cache_page_can_evict()
369 page->state == L2P_CACHE_PAGE_PERSISTING || in ftl_l2p_cache_page_can_evict()
370 page->state == L2P_CACHE_PAGE_INIT || in ftl_l2p_cache_page_can_evict()
544 assert(cache->state == L2P_CACHE_SHUTDOWN_DONE || cache->state in ftl_l2p_cache_deinit()
[all...] |
| H A D | ftl_reloc.c | 38 enum ftl_reloc_move_state state; member
74 static void move_set_state(struct ftl_reloc_move *mv, enum ftl_reloc_move_state state);
89 mv->state = FTL_RELOC_STATE_HALT; in move_init()
203 move_set_state(struct ftl_reloc_move *mv, enum ftl_reloc_move_state state) in move_set_state() argument
207 switch (state) { in move_set_state()
231 if (mv->state != state) { in move_set_state()
233 TAILQ_REMOVE(&reloc->move_queue[mv->state], mv, qentry); in move_set_state()
235 TAILQ_INSERT_TAIL(&reloc->move_queue[state], mv, qentry); in move_set_state()
237 mv->state = state; in move_set_state()
564 switch (mv->state) { in move_run()
[all …]
|
| /spdk/scripts/ |
| H A D | dpdk_mem_info.py | 277 state = parse_state.PARSE_MEMORY_SIZE
282 if state == parse_state.PARSE_MEMORY_SIZE:
286 state = parse_state.PARSE_MEMZONES
289 if state == parse_state.PARSE_MEMZONES:
293 state = parse_state.PARSE_MEMZONE_SEGMENTS
296 if state == parse_state.PARSE_MEMZONE_SEGMENTS:
298 state = parse_state.PARSE_MEMZONES
304 state = parse_state.PARSE_MEMPOOLS
308 if state == parse_state.PARSE_MEMPOOLS:
312 state = parse_state.PARSE_MEMPOOL_INFO
[all …]
|
| /spdk/lib/util/ |
| H A D | fd_group.c | 33 enum event_handler_state state;
431 ehdlr->state = EVENT_HANDLER_STATE_WAITING; in spdk_fd_group_wait()
479 assert(ehdlr->state != EVENT_HANDLER_STATE_REMOVED); in spdk_fd_group_wait()
494 if (ehdlr->state == EVENT_HANDLER_STATE_RUNNING) { in spdk_fd_group_wait()
495 ehdlr->state = EVENT_HANDLER_STATE_REMOVED; in spdk_fd_group_wait()
522 assert(ehdlr->state != EVENT_HANDLER_STATE_REMOVED);
635 /* Tag ehdlr as running state in case that it is removed
638 assert(ehdlr->state == EVENT_HANDLER_STATE_WAITING);
639 ehdlr->state = EVENT_HANDLER_STATE_RUNNING;
653 if (ehdlr->state
38 enum event_handler_state state; global() member
[all...] |
| /spdk/lib/virtio/ |
| H A D | virtio_vhost_user.c | 332 memcpy(&msg.payload.state, arg, sizeof(msg.payload.state)); in vhost_user_sock()
333 msg.size = sizeof(msg.payload.state); in vhost_user_sock()
337 memcpy(&msg.payload.state, arg, sizeof(msg.payload.state)); in vhost_user_sock()
338 msg.size = sizeof(msg.payload.state); in vhost_user_sock()
412 if (msg.size != sizeof(msg.payload.state)) { in vhost_user_sock()
416 memcpy(arg, &msg.payload.state, in vhost_user_sock()
521 struct vhost_vring_state state; in virtio_user_kick_queue() local
525 state in virtio_user_kick_queue()
554 struct vhost_vring_state state; virtio_user_stop_queue() local
865 struct vhost_vring_state state; virtio_user_setup_queue() local
[all...] |
| /spdk/lib/iscsi/ |
| H A D | conn.c | 150 if (conn->state < ISCSI_CONN_STATE_EXITING) { in login_timeout()
151 conn->state = ISCSI_CONN_STATE_EXITING; in login_timeout()
203 conn->state = ISCSI_CONN_STATE_INVALID; in iscsi_conn_construct()
495 if (conn->state >= ISCSI_CONN_STATE_EXITING) { in _iscsi_conn_hotremove_lun()
576 assert(conn->state == ISCSI_CONN_STATE_EXITED); in iscsi_conn_stop()
670 if (conn->state >= ISCSI_CONN_STATE_EXITED) { in iscsi_conn_destruct()
674 conn->state = ISCSI_CONN_STATE_EXITED; in iscsi_conn_destruct()
785 if (conn->state < ISCSI_CONN_STATE_EXITING) {
786 conn->state = ISCSI_CONN_STATE_EXITING;
802 if (conn->state > ISCSI_CONN_STATE_RUNNIN
[all...] |
| /spdk/lib/nvmf/ |
| H A D | auth.c | 44 enum nvmf_qpair_auth_state state;
76 nvmf_auth_get_state_name(enum nvmf_qpair_auth_state state) in nvmf_auth_get_state_name()
89 return state_names[state]; in nvmf_auth_get_state_name()
93 nvmf_auth_set_state(struct spdk_nvmf_qpair *qpair, enum nvmf_qpair_auth_state state) in nvmf_auth_set_state()
97 if (auth->state == state) { in nvmf_auth_set_state()
101 AUTH_DEBUGLOG(qpair, "auth state: %s\n", nvmf_auth_get_state_name(state)); in nvmf_auth_set_state()
102 auth->state = state; in nvmf_auth_set_state()
43 enum nvmf_qpair_auth_state state; global() member
75 nvmf_auth_get_state_name(enum nvmf_qpair_auth_state state) nvmf_auth_get_state_name() argument
92 nvmf_auth_set_state(struct spdk_nvmf_qpair * qpair,enum nvmf_qpair_auth_state state) nvmf_auth_set_state() argument
[all...] |
| H A D | nvmf.c | 140 enum spdk_nvmf_qpair_state state) in nvmf_qpair_set_state() argument
145 qpair->state = state; in nvmf_qpair_set_state()
187 * Callback to unregister a poll group from the target, and clean up its state. in nvmf_tgt_cleanup_poll_group()
202 assert(!(tgt->state == NVMF_TGT_PAUSING || tgt->state == NVMF_TGT_RESUMING)); in nvmf_tgt_cleanup_poll_group()
394 tgt->state = NVMF_TGT_RUNNING; in spdk_nvmf_tgt_create()
469 assert(!(tgt->state == NVMF_TGT_PAUSING || tgt->state == NVMF_TGT_RESUMING)); in nvmf_tgt_destroy_cb()
964 ctx->tgt->state in spdk_nvmf_tgt_add_transport()
[all...] |
| /spdk/test/external_code/nvme/ |
| H A D | nvme.c | 89 enum nvme_ctrlr_state state; member
378 ctrlr->state = NVME_CTRLR_STATE_ERROR; in identify_ctrlr_done()
382 ctrlr->state = NVME_CTRLR_STATE_READY; in identify_ctrlr_done()
466 if (ctrlr->state == NVME_CTRLR_STATE_READY) { in process_ctrlr_init()
473 switch (ctrlr->state) { in process_ctrlr_init()
477 ctrlr->state = NVME_CTRLR_STATE_DISABLE_WAIT_FOR_READY_1; in process_ctrlr_init()
484 ctrlr->state = NVME_CTRLR_STATE_DISABLE_WAIT_FOR_READY_0; in process_ctrlr_init()
490 ctrlr->state = NVME_CTRLR_STATE_DISABLE_WAIT_FOR_READY_0; in process_ctrlr_init()
495 ctrlr->state = NVME_CTRLR_STATE_ENABLE; in process_ctrlr_init()
511 ctrlr->state in process_ctrlr_init()
[all...] |
| /spdk/test/app/fuzz/llvm_vfio_fuzz/ |
| H A D | llvm_vfio_fuzz.c | 54 enum IO_POLLER_STATE state; member
260 ((struct io_thread *)ctx)->state = IO_POLLER_STATE_TERMINATE_INIT; in io_terminate()
332 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in read_complete()
339 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in read_complete()
346 if (io->state != IO_POLLER_STATE_TERMINATE_INIT) { in read_complete()
347 io->state = IO_POLLER_STATE_IDLE; in read_complete()
362 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in write_complete()
371 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in write_complete()
386 io->state = IO_POLLER_STATE_TERMINATE_DONE; in terminate_io_thread()
400 switch (io->state) { in io_poller()
[all...] |
| /spdk/lib/thread/ |
| H A D | thread.c | 76 /* Current state of the poller; should only be accessed from the poller's thread. */ member
77 enum spdk_poller_state state;
144 enum spdk_thread_state state;
399 if (poller->state != SPDK_POLLER_STATE_UNREGISTERED) { in _free_thread()
408 if (poller->state != SPDK_POLLER_STATE_UNREGISTERED) { in _free_thread()
610 thread->state = SPDK_THREAD_STATE_RUNNING; in spdk_thread_is_app_thread()
664 SPDK_ERRLOG("thread %s got timeout, and move it to the exited state forcefully\n", in thread_exit()
681 if (poller->state != SPDK_POLLER_STATE_UNREGISTERED) { in thread_exit()
690 if (poller->state != SPDK_POLLER_STATE_UNREGISTERED) { in thread_exit()
720 thread->state in spdk_thread_exit()
134 enum spdk_thread_state state; global() member
[all...] |
| /spdk/test/unit/lib/nvmf/rdma.c/ |
| H A D | rdma_ut.c | 82 if (qp->state == IBV_QPS_ERR) { in ibv_query_qp()
466 rdma_req->state = RDMA_REQUEST_STATE_NEW; in create_req()
498 rqpair->qpair.state = SPDK_NVMF_QPAIR_ENABLED; in qpair_reset()
553 CU_ASSERT(rdma_req->state == RDMA_REQUEST_STATE_EXECUTING); in test_spdk_nvmf_rdma_request_process()
556 rdma_req->state = RDMA_REQUEST_STATE_EXECUTED; in test_spdk_nvmf_rdma_request_process()
559 CU_ASSERT(rdma_req->state == RDMA_REQUEST_STATE_TRANSFERRING_CONTROLLER_TO_HOST); in test_spdk_nvmf_rdma_request_process()
562 rdma_req->state = RDMA_REQUEST_STATE_COMPLETED; in test_spdk_nvmf_rdma_request_process()
565 CU_ASSERT(rdma_req->state == RDMA_REQUEST_STATE_FREE); in test_spdk_nvmf_rdma_request_process()
579 CU_ASSERT(rdma_req->state == RDMA_REQUEST_STATE_TRANSFERRING_HOST_TO_CONTROLLER); in test_spdk_nvmf_rdma_request_process()
583 rdma_req->state in test_spdk_nvmf_rdma_request_process()
[all...] |
| /spdk/module/bdev/ocf/ |
| H A D | vbdev_ocf.c | 138 if (cmp->state.doing_finish || cmp == vbdev) { in get_other_cache_instance()
184 spdk_bdev_destruct_done(&vbdev->exp_bdev, vbdev->state.stop_status); in unregister_finish()
250 vbdev->state.stop_status = vbdev->mngt_ctx.status; in detach_cache()
376 unregister_path = vbdev->state.doing_clean_delete ? in unregister_cb()
425 if (vbdev->state.doing_finish) { in vbdev_ocf_destruct()
429 if (vbdev->state.starting && !vbdev->state.started) { in vbdev_ocf_destruct()
435 vbdev->state.doing_finish = true; in vbdev_ocf_destruct()
437 if (vbdev->state.started) { in vbdev_ocf_destruct()
443 if (vbdev->state in vbdev_ocf_destruct()
[all...] |
| /spdk/module/bdev/raid/ |
| H A D | bdev_raid.c | 69 enum raid_bdev_process_state state;
268 assert(raid_bdev->state == RAID_BDEV_STATE_ONLINE); in raid_bdev_create_cb()
380 SPDK_DEBUGLOG(bdev_raid, "raid_bdev_cleanup, %p name %s, state %s\n", in raid_bdev_free()
381 raid_bdev, raid_bdev->bdev.name, raid_bdev_state_to_str(raid_bdev->state)); in raid_bdev_free()
382 assert(raid_bdev->state != RAID_BDEV_STATE_ONLINE); in raid_bdev_free()
439 if (raid_bdev->state != RAID_BDEV_STATE_CONFIGURING) { in raid_bdev_free_base_bdev_resource()
481 if (raid_bdev->state != RAID_BDEV_STATE_CONFIGURING) { in _raid_bdev_destruct()
507 raid_bdev->state = RAID_BDEV_STATE_OFFLINE; in raid_bdev_destruct()
1078 spdk_json_write_named_string(w, "state", raid_bdev_state_to_str(raid_bdev->state)); in raid_bdev_write_info_json()
57 enum raid_bdev_process_state state; global() member
1327 raid_bdev_state_to_str(enum raid_bdev_state state) raid_bdev_state_to_str() argument
[all...] |