Home
last modified time | relevance | path

Searched refs:io (Results 1 – 25 of 147) sorted by relevance

123456

/spdk/lib/ftl/
H A Dftl_io.c17 ftl_io_inc_req(struct ftl_io *io) in ftl_io_inc_req() argument
19 io->dev->num_inflight++; in ftl_io_inc_req()
20 io->req_cnt++; in ftl_io_inc_req()
24 ftl_io_dec_req(struct ftl_io *io) in ftl_io_dec_req() argument
26 assert(io->dev->num_inflight > 0); in ftl_io_dec_req()
27 assert(io->req_cnt > 0); in ftl_io_dec_req()
29 io->dev->num_inflight--; in ftl_io_dec_req()
30 io->req_cnt--; in ftl_io_dec_req()
34 ftl_io_iovec(struct ftl_io *io) in ftl_io_iovec() argument
36 return &io in ftl_io_iovec()
40 ftl_io_get_lba(const struct ftl_io * io,size_t offset) ftl_io_get_lba() argument
47 ftl_io_current_lba(const struct ftl_io * io) ftl_io_current_lba() argument
53 ftl_io_advance(struct ftl_io * io,size_t num_blocks) ftl_io_advance() argument
97 ftl_io_iovec_addr(struct ftl_io * io) ftl_io_iovec_addr() argument
107 ftl_io_iovec_len_left(struct ftl_io * io) ftl_io_iovec_len_left() argument
118 ftl_io_cb(struct ftl_io * io,void * arg,int status) ftl_io_cb() argument
164 ftl_io_init(struct spdk_io_channel * _ioch,struct ftl_io * io,uint64_t lba,size_t num_blocks,struct iovec * iov,size_t iov_cnt,spdk_ftl_fn cb_fn,void * cb_ctx,int type) ftl_io_init() argument
191 ftl_io_complete_verify(struct ftl_io * io) ftl_io_complete_verify() argument
221 ftl_io_complete(struct ftl_io * io) ftl_io_complete() argument
235 ftl_io_fail(struct ftl_io * io,int status) ftl_io_fail() argument
242 ftl_io_clear(struct ftl_io * io) ftl_io_clear() argument
[all...]
H A Dftl_core.c32 struct ftl_io *io = cb_arg; in ftl_io_cmpl_cb() local
33 struct spdk_ftl_dev *dev = io->dev; in ftl_io_cmpl_cb()
38 io->status = -EIO; in ftl_io_cmpl_cb()
41 ftl_trace_completion(dev, io, FTL_TRACE_COMPLETION_DISK); in ftl_io_cmpl_cb()
43 ftl_io_dec_req(io); in ftl_io_cmpl_cb()
44 if (ftl_io_done(io)) { in ftl_io_cmpl_cb()
45 ftl_io_complete(io); in ftl_io_cmpl_cb()
175 ftl_get_next_read_addr(struct ftl_io *io, ftl_addr *addr) in ftl_get_next_read_addr() argument
177 struct spdk_ftl_dev *dev = io->dev; in ftl_get_next_read_addr()
182 *addr = ftl_l2p_get(dev, ftl_io_current_lba(io)); in ftl_get_next_read_addr()
222 struct ftl_io *io = _io; _ftl_submit_read() local
228 ftl_submit_read(struct ftl_io * io) ftl_submit_read() argument
315 struct ftl_io *io = pin_ctx->cb_ctx; ftl_io_pin_cb() local
329 ftl_io_pin(struct ftl_io * io) ftl_io_pin() argument
345 start_io(struct ftl_io * io) start_io() argument
374 queue_io(struct spdk_ftl_dev * dev,struct ftl_io * io) queue_io() argument
388 spdk_ftl_writev(struct spdk_ftl_dev * dev,struct ftl_io * io,struct spdk_io_channel * ch,uint64_t lba,uint64_t lba_cnt,struct iovec * iov,size_t iov_cnt,spdk_ftl_fn cb_fn,void * cb_arg) spdk_ftl_writev() argument
421 spdk_ftl_readv(struct spdk_ftl_dev * dev,struct ftl_io * io,struct spdk_io_channel * ch,uint64_t lba,uint64_t lba_cnt,struct iovec * iov,size_t iov_cnt,spdk_ftl_fn cb_fn,void * cb_arg) spdk_ftl_readv() argument
453 ftl_trim(struct spdk_ftl_dev * dev,struct ftl_io * io,struct spdk_io_channel * ch,uint64_t lba,uint64_t lba_cnt,spdk_ftl_fn cb_fn,void * cb_arg) ftl_trim() argument
467 spdk_ftl_unmap(struct spdk_ftl_dev * dev,struct ftl_io * io,struct spdk_io_channel * ch,uint64_t lba,uint64_t lba_cnt,spdk_ftl_fn cb_fn,void * cb_arg) spdk_ftl_unmap() argument
529 struct ftl_io *io = ios[i]; ftl_io_channel_poll() local
548 struct ftl_io *io = ios[i]; ftl_process_io_channel() local
562 ftl_trim_finish(struct ftl_io * io,int status) ftl_trim_finish() argument
582 struct ftl_io *io = cb_arg; ftl_trim_log_close_cb() local
588 ftl_trim_log_persist(struct ftl_io * io,ftl_md_io_entry_cb cb) ftl_trim_log_persist() argument
600 struct ftl_io *io = cb_arg; ftl_trim_md_cb() local
613 struct ftl_io *io = cb_arg; ftl_trim_log_open_cb() local
667 ftl_process_trim(struct ftl_io * io) ftl_process_trim() argument
696 struct ftl_io *io; ftl_process_io_queue() local
[all...]
H A Dftl_io.h164 } io; member
240 } io; member
285 } io; member
305 void ftl_io_fail(struct ftl_io *io, int status);
306 void ftl_io_clear(struct ftl_io *io);
307 void ftl_io_inc_req(struct ftl_io *io);
308 void ftl_io_dec_req(struct ftl_io *io);
309 struct iovec *ftl_io_iovec(struct ftl_io *io);
310 uint64_t ftl_io_current_lba(const struct ftl_io *io);
311 uint64_t ftl_io_get_lba(const struct ftl_io *io, size_t offset);
[all …]
H A Dftl_band_ops.c30 assert(rq->io.band->queue_depth > 0); in write_rq_end()
31 rq->io.band->queue_depth--; in write_rq_end()
44 struct ftl_band *band = rq->io.band; in ftl_band_rq_bdev_write()
49 rq->io_payload, rq->io.addr, rq->num_blocks, in ftl_band_rq_bdev_write()
55 rq->io.bdev_io_wait.bdev = bdev; in ftl_band_rq_bdev_write()
56 rq->io.bdev_io_wait.cb_fn = ftl_band_rq_bdev_write; in ftl_band_rq_bdev_write()
57 rq->io.bdev_io_wait.cb_arg = rq; in ftl_band_rq_bdev_write()
58 spdk_bdev_queue_io_wait(bdev, dev->base_ioch, &rq->io.bdev_io_wait); in ftl_band_rq_bdev_write()
71 rq->io.band = band; in ftl_band_rq_write()
72 rq->io.addr = band->md->iter.addr; in ftl_band_rq_write()
[all …]
/spdk/lib/nbd/
H A Dnbd.c103 static int nbd_submit_bdev_io(struct spdk_nbd_disk *nbd, struct nbd_io *io);
242 * a NBD_CMD_DISC type io to nbd server in order to inform server. in nbd_disconnect()
250 struct nbd_io *io; in nbd_get_io() local
252 io = calloc(1, sizeof(*io)); in nbd_get_io()
253 if (!io) { in nbd_get_io()
257 io->nbd = nbd; in nbd_get_io()
258 to_be32(&io->resp.magic, NBD_REPLY_MAGIC); in nbd_get_io()
262 return io; in nbd_get_io()
266 nbd_put_io(struct spdk_nbd_disk *nbd, struct nbd_io *io) in nbd_put_io() argument
433 struct nbd_io *io = cb_arg; nbd_io_done() local
462 struct nbd_io *io = (struct nbd_io *)arg; nbd_resubmit_io() local
474 nbd_queue_io(struct nbd_io * io) nbd_queue_io() argument
491 nbd_submit_bdev_io(struct spdk_nbd_disk * nbd,struct nbd_io * io) nbd_submit_bdev_io() argument
539 struct nbd_io *io, *io_tmp; nbd_io_exec() local
560 struct nbd_io *io; nbd_io_recv_internal() local
704 struct nbd_io *io; nbd_io_xmit_internal() local
857 struct nbd_io *io, *io_tmp; nbd_bdev_hot_remove() local
[all...]
/spdk/module/bdev/ocf/
H A Dvolume.c296 * so we have to get io channel ourselves */ in vbdev_ocf_volume_submit_io()
55 vbdev_ocf_volume_io_set_data(struct ocf_io * io,ctx_data_t * data,uint32_t offset) vbdev_ocf_volume_io_set_data() argument
72 vbdev_ocf_volume_io_get_data(struct ocf_io * io) vbdev_ocf_volume_io_get_data() argument
78 vbdev_ocf_volume_io_get(struct ocf_io * io) vbdev_ocf_volume_io_get() argument
86 vbdev_ocf_volume_io_put(struct ocf_io * io) vbdev_ocf_volume_io_put() argument
140 struct ocf_io *io; vbdev_ocf_volume_submit_io_cb() local
177 prepare_submit(struct ocf_io * io) prepare_submit() argument
231 vbdev_ocf_volume_submit_flush(struct ocf_io * io) vbdev_ocf_volume_submit_flush() argument
258 vbdev_ocf_volume_submit_io(struct ocf_io * io) vbdev_ocf_volume_submit_io() argument
347 vbdev_ocf_volume_submit_discard(struct ocf_io * io) vbdev_ocf_volume_submit_discard() argument
374 vbdev_ocf_volume_submit_metadata(struct ocf_io * io) vbdev_ocf_volume_submit_metadata() argument
/spdk/test/nvmf/target/
H A Drpc.sh52 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s $NVMF_SERIAL
53 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc1
54 $rpc_py nvmf_subsystem_allow_any_host -d nqn.2016-06.io.spdk:cnode1
55 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
58 NOT $NVME_CONNECT "${NVME_HOST[@]}" -t $TEST_TRANSPORT -n nqn.2016-06.io.spdk:cnode1 -q "$NVME_HOST…
61 $rpc_py nvmf_subsystem_add_host nqn.2016-06.io.spdk:cnode1 "$NVME_HOSTNQN"
62 $NVME_CONNECT "${NVME_HOST[@]}" -t $TEST_TRANSPORT -n nqn.2016-06.io.spdk:cnode1 -a "$NVMF_FIRST_TA…
64 nvme disconnect -n nqn.2016-06.io.spdk:cnode1
68 $rpc_py nvmf_subsystem_remove_host nqn.2016-06.io.spdk:cnode1 "$NVME_HOSTNQN"
69 NOT $NVME_CONNECT "${NVME_HOST[@]}" -t $TEST_TRANSPORT -n nqn.2016-06.io.spdk:cnode1 -a "$NVMF_FIRS…
[all …]
H A Dtls.sh53 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -s SPDK00000000000001 -m 10
54 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT \
57 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 malloc0 -n 1
59 $rpc_py nvmf_subsystem_add_host nqn.2016-06.io.spdk:cnode1 nqn.2016-06.io.spdk:host1 \
140 subnqn:nqn.2016-06.io.spdk:cnode1 hostnqn:nqn.2016-06.io.spdk:host1" \
144 run_bdevperf nqn.2016-06.io.spdk:cnode1 nqn.2016-06.io.spdk:host1 "$key_path"
147 NOT run_bdevperf nqn.2016-06.io
[all...]
H A Dhost_management.sh25 nvmf_create_subsystem nqn.2016-06.io.spdk:cnode0 -s SPDK0
26 nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode0 Malloc0
27 …nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode0 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP…
28 nvmf_subsystem_add_host nqn.2016-06.io.spdk:cnode0 nqn.2016-06.io.spdk:host0
84 $rpc_py nvmf_subsystem_remove_host nqn.2016-06.io.spdk:cnode0 nqn.2016-06.io.spdk:host0
85 $rpc_py nvmf_subsystem_add_host nqn.2016-06.io.spdk:cnode0 nqn.2016-06.io.spdk:host0
H A Dns_hotplug_stress.sh29 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001 -m 10
30 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
34 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Delay0
36 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 NULL1
45 $rpc_py nvmf_subsystem_remove_ns nqn.2016-06.io.spdk:cnode1 1
46 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Delay0
54 "$rpc_py" nvmf_subsystem_remove_ns nqn.2016-06.io.spdk:cnode1 1
55 "$rpc_py" nvmf_subsystem_remove_ns nqn.2016-06.io.spdk:cnode1 2
H A Dnmic.sh21 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s $NVMF_SERIAL
22 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc0
23 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
26 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode2 -a -s SPDK2
27 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode2 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
29 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode2 Malloc0 || nmic_status=$?
40 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
H A Ddelete_subsystem.sh16 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001 -m 10
17 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
24 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Delay0
32 $rpc_py nvmf_delete_subsystem nqn.2016-06.io.spdk:cnode1
48 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001 -m 10
49 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
50 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Delay0
/spdk/test/sma/
H A Dvfiouser_qemu.sh173 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-0
174 vm_check_subsys_nqn $vm_no nqn.2016-06.io.spdk:vfiouser-0
180 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-0
181 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-1
183 vm_check_subsys_nqn $vm_no nqn.2016-06.io.spdk:vfiouser-1
201 NOT rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-0
202 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-1
207 NOT rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-0
208 NOT rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-1
224 [[ $(rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:vfiouser-0 | jq -r '.[0].namespaces | length')…
[all …]
H A Dnvmf_tcp.sh95 devid0=$(create_device nqn.2016-06.io.spdk:cnode0 | jq -r '.handle')
96 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:cnode0
98 devid1=$(create_device nqn.2016-06.io.spdk:cnode1 | jq -r '.handle')
99 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:cnode0
100 rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:cnode1
108 tmp0=$(create_device nqn.2016-06.io.spdk:cnode0 | jq -r '.handle')
109 tmp1=$(create_device nqn.2016-06.io.spdk:cnode1 | jq -r '.handle')
117 NOT rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:cnode0
121 NOT rpc_cmd nvmf_get_subsystems nqn.2016-06.io.spdk:cnode1
129 devid0=$(create_device nqn.2016-06.io.spdk:cnode0 | jq -r '.handle')
[all …]
/spdk/test/nvmf/host/
H A Dmulticontroller.sh30 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001
31 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc0
33 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
34 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_SECOND_PORT
37 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode2 -a -s SPDK00000000000002
38 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode2 Malloc1
40 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode2 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
41 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode2 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_SECOND_PORT
51 -s $NVMF_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 -i $NVMF_FIRST_INITIATOR_IP
61 -s $NVMF_PORT -f ipv4 -n nqn.2016-06.io
[all...]
H A Dfailover.sh24 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001
25 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc0
26 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
27 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_SECOND_PORT
28 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_THIRD_PORT
35 $rpc_py -s $bdevperf_rpc_sock bdev_nvme_attach_controller -b NVMe0 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 -x failover
36 $rpc_py -s $bdevperf_rpc_sock bdev_nvme_attach_controller -b NVMe0 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_SECOND_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 -x failover
43 $rpc_py nvmf_subsystem_remove_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
47 $rpc_py -s $bdevperf_rpc_sock bdev_nvme_attach_controller -b NVMe0 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_THIRD_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 -x failover
48 $rpc_py nvmf_subsystem_remove_listener nqn.2016-06.io
[all...]
H A Dtimeout.sh27 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001
28 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc0
29 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
47 -s $NVMF_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 \
55 $rpc_py nvmf_subsystem_remove_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST…
71 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
80 -s $NVMF_PORT -f ipv4 -n nqn.2016-06.io.spdk:cnode1 \
81 --ctrlr-loss-timeout-sec 5 --fast-io-fail-timeout-sec 2 --reconnect-delay-sec 1
87 $rpc_py nvmf_subsystem_remove_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST…
91 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TA…
[all …]
H A Dasync_init.sh29 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode0 -a
30 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode0 $null_bdev -g $nguid
31 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode0 -t $TEST_TRANSPORT \
38 -f ipv4 -s $NVMF_PORT -n nqn.2016-06.io.spdk:cnode0
57 $rpc_py nvmf_subsystem_allow_any_host nqn.2016-06.io.spdk:cnode0 --disable
58 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode0 -t $TEST_TRANSPORT \
60 $rpc_py nvmf_subsystem_add_host nqn.2016-06.io.spdk:cnode0 nqn.2016-06.io.spdk:host1 \
67 -f ipv4 -s $NVMF_SECOND_PORT -n nqn.2016-06.io.spdk:cnode0 -q nqn.2016-06.io
[all...]
H A Dfio.sh33 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001
34 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 Malloc1
35 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
47 $rpc_py nvmf_delete_subsystem nqn.2016-06.io.spdk:cnode1
56 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode2 -a -s SPDK00000000000001
57 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode2 lvs_0/lbd_0
58 $rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode2 -t $TEST_TRANSPORT -a $NVMF_FIRST_TARGET_IP -s $NVMF_PORT
61 $rpc_py nvmf_delete_subsystem nqn.2016-06.io.spdk:cnode2
67 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode3 -a -s SPDK00000000000001
68 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io
[all...]
/spdk/lib/ublk/
H A Dublk.c53 static void _ublk_submit_bdev_io(struct ublk_queue *q, struct ublk_io *io);
77 typedef void (*ublk_get_buf_cb)(struct ublk_io *io);
235 /* io uring */ in ublk_set_sqe_cmd_op()
1105 ublk_mark_io_done(struct ublk_io *io, int res) in ublk_io_done()
1108 * mark io done by target, so that SPDK can commit its in ublk_io_done()
1111 io->cmd_op = UBLK_IO_COMMIT_AND_FETCH_REQ; in ublk_io_done()
1112 io->result = res; in ublk_io_done()
1113 io->need_data = false; in ublk_io_done()
1119 struct ublk_io *io = cb_arg; in ublk_io_done()
1120 struct ublk_queue *q = io in ublk_io_done()
1089 ublk_mark_io_done(struct ublk_io * io,int res) ublk_mark_io_done() argument
1103 struct ublk_io *io = cb_arg; ublk_io_done() local
1126 ublk_queue_user_copy(struct ublk_io * io,bool is_write) ublk_queue_user_copy() argument
1155 struct ublk_io *io = cb_arg; ublk_user_copy_read_done() local
1170 struct ublk_io *io = (struct ublk_io *)arg; ublk_resubmit_io() local
1176 ublk_queue_io(struct ublk_io * io) ublk_queue_io() argument
1196 struct ublk_io *io = SPDK_CONTAINEROF(iobuf, struct ublk_io, iobuf); ublk_io_get_buffer_cb() local
1205 ublk_io_get_buffer(struct ublk_io * io,struct spdk_iobuf_channel * iobuf_ch,ublk_get_buf_cb get_buf_cb) ublk_io_get_buffer() argument
1220 ublk_io_put_buffer(struct ublk_io * io,struct spdk_iobuf_channel * iobuf_ch) ublk_io_put_buffer() argument
1230 _ublk_submit_bdev_io(struct ublk_queue * q,struct ublk_io * io) _ublk_submit_bdev_io() argument
1282 read_get_buffer_done(struct ublk_io * io) read_get_buffer_done() argument
1288 user_copy_write_get_buffer_done(struct ublk_io * io) user_copy_write_get_buffer_done() argument
1294 ublk_submit_bdev_io(struct ublk_queue * q,struct ublk_io * io) ublk_submit_bdev_io() argument
1321 ublksrv_queue_io_cmd(struct ublk_queue * q,struct ublk_io * io,unsigned tag) ublksrv_queue_io_cmd() argument
1368 struct ublk_io *io; ublk_io_xmit() local
1419 write_get_buffer_done(struct ublk_io * io) write_get_buffer_done() argument
1435 struct ublk_io *io; ublk_io_recv() local
1625 struct ublk_io *io; ublk_dev_queue_io_init() local
[all...]
/spdk/test/app/fuzz/llvm_vfio_fuzz/
H A Dllvm_vfio_fuzz.c326 struct io_thread *io = (struct io_thread *)arg; in read_complete() local
329 spdk_nvme_qpair_print_completion(io->io_qpair, (struct spdk_nvme_cpl *)completion); in read_complete()
332 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in read_complete()
337 if (memcmp(io->read_buf, io->write_buf, io->buf_size)) { in read_complete()
339 io->state = IO_POLLER_STATE_TERMINATE_WAIT; in read_complete()
344 sectors_num = spdk_nvme_ns_get_num_sectors(io->io_ns); in read_complete()
345 io->lba_num = (io in read_complete()
355 struct io_thread *io = (struct io_thread *)arg; write_complete() local
379 struct io_thread *io = (struct io_thread *)ctx; terminate_io_thread() local
395 struct io_thread *io = (struct io_thread *)ctx; io_poller() local
451 struct io_thread *io = (struct io_thread *)ctx; start_io_poller() local
[all...]
/spdk/lib/nvme/
H A Dnvme_io_msg.c19 struct spdk_nvme_io_msg *io; in nvme_io_msg_send() local
24 io = (struct spdk_nvme_io_msg *)calloc(1, sizeof(struct spdk_nvme_io_msg)); in nvme_io_msg_send()
25 if (!io) { in nvme_io_msg_send()
31 io->ctrlr = ctrlr; in nvme_io_msg_send()
32 io->nsid = nsid; in nvme_io_msg_send()
33 io->fn = fn; in nvme_io_msg_send()
34 io->arg = arg; in nvme_io_msg_send()
36 rc = spdk_ring_enqueue(ctrlr->external_io_msgs, (void **)&io, 1, NULL); in nvme_io_msg_send()
39 free(io); in nvme_io_msg_send()
54 struct spdk_nvme_io_msg *io; in nvme_io_msg_process() local
[all...]
/spdk/test/unit/lib/ftl/ftl_io.c/
H A Dftl_io_ut.c84 DEFINE_STUB_V(ftl_trace_submission, (struct spdk_ftl_dev *dev, const struct ftl_io *io,
86 DEFINE_STUB_V(ftl_trace_lba_io_init, (struct spdk_ftl_dev *dev, const struct ftl_io *io));
89 DEFINE_STUB_V(ftl_trace_completion, (struct spdk_ftl_dev *dev, const struct ftl_io *io,
190 setup_io(struct ftl_io *io, struct spdk_ftl_dev *dev, spdk_ftl_fn cb, void *ctx) in free_device()
192 io->dev = dev; in free_device()
193 io->user_fn = cb;
194 io->cb_ctx = ctx;
195 io->flags = 0; in setup_io() argument
196 io->ioch = dev->ioch; in setup_io()
210 struct ftl_io io
215 struct ftl_io io = { 0 }, *io_ring; test_completion() local
263 struct ftl_io io[2] = { 0 }, *io_ring[2]; test_multiple_ios() local
[all...]
/spdk/lib/ftl/utils/
H A Dftl_md.c424 spdk_dma_free(md->io.data); in io_cleanup()
425 md->io.data = NULL; in io_cleanup()
427 spdk_dma_free(md->io.md); in io_cleanup()
428 md->io.md = NULL; in io_cleanup()
461 if (md->io.op == FTL_MD_OP_RESTORE && has_mirror(md)) { in read_write_blocks_cb()
462 md->io.status = -EAGAIN; in read_write_blocks_cb()
464 md->io.status = -EIO; in read_write_blocks_cb()
470 if (md->io.op == FTL_MD_OP_RESTORE) { in read_write_blocks_cb()
471 memcpy(md->data + md->io.data_offset, md->io in read_write_blocks_cb()
[all...]
/spdk/doc/
H A Dusdt.md56 nvmf_create_subsystem nqn.2016-06.io.spdk:cnode1 -a -s SPDK00000000000001 -m 10
57 nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode1 -t tcp -a 127.0.0.1 -s 4420
59 nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode1 null0
80 2189.921492: nqn.2016-06.io.spdk:cnode1 change state from INACTIVE to ACTIVE start
81 2189.952508: nqn.2016-06.io.spdk:cnode1 on thread 2 state to ACTIVE start
82 2189.959125: nqn.2016-06.io.spdk:cnode1 on thread 2 state to ACTIVE done
83 2190.005832: nqn.2016-06.io.spdk:cnode1 change state from INACTIVE to ACTIVE done
84 2189.969058: nqn.2016-06.io.spdk:cnode1 on thread 3 state to ACTIVE start
85 2189.999889: nqn.2016-06.io.spdk:cnode1 on thread 3 state to ACTIVE done
86 2197.859104: nqn.2016-06.io.spdk:cnode1 change state from ACTIVE to PAUSED start
[all …]

123456