Home
last modified time | relevance | path

Searched refs:ch (Results 1 – 25 of 128) sorted by relevance

123456

/spdk/test/unit/lib/bdev/vbdev_zone_block.c/
H A Dvbdev_zone_block_ut.c33 struct spdk_io_channel *ch; member
312 struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in set_io_output() argument
318 output->ch = ch; in set_io_output()
327 spdk_bdev_unmap_blocks(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_unmap_blocks() argument
334 set_io_output(output, desc, ch, offset_blocks, num_blocks, cb, cb_arg, in spdk_bdev_unmap_blocks()
346 spdk_bdev_writev_blocks_with_md(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_writev_blocks_with_md() argument
356 set_io_output(output, desc, ch, offset_blocks, num_blocks, cb, cb_arg, in spdk_bdev_writev_blocks_with_md()
376 spdk_bdev_writev_blocks(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_writev_blocks() argument
382 return spdk_bdev_writev_blocks_with_md(desc, ch, io in spdk_bdev_writev_blocks()
387 spdk_bdev_readv_blocks_with_md(struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct iovec * iov,int iovcnt,void * md,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg) spdk_bdev_readv_blocks_with_md() argument
408 spdk_bdev_readv_blocks(struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct iovec * iov,int iovcnt,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg) spdk_bdev_readv_blocks() argument
809 send_zone_info(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint64_t wp,enum spdk_bdev_zone_state state,uint32_t output_index,bool success) send_zone_info() argument
840 struct spdk_io_channel *ch; test_get_zone_info() local
917 send_zone_management(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint32_t output_index,enum spdk_bdev_zone_action action,bool success) send_zone_management() argument
936 send_reset_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint32_t output_index,bool success) send_reset_zone() argument
943 send_open_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint32_t output_index,bool success) send_open_zone() argument
950 send_close_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint32_t output_index,bool success) send_close_zone() argument
957 send_finish_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t zone_id,uint32_t output_index,bool success) send_finish_zone() argument
966 struct spdk_io_channel *ch; test_reset_zone() local
1015 send_write_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t lba,uint64_t blocks,uint32_t output_index,bool success) send_write_zone() argument
1034 send_read_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t lba,uint64_t blocks,uint32_t output_index,bool success) send_read_zone() argument
1053 send_append_zone(struct bdev_zone_block * bdev,struct spdk_io_channel * ch,uint64_t lba,uint64_t blocks,uint32_t output_index,bool success,uint64_t wp) send_append_zone() argument
1077 struct spdk_io_channel *ch; test_open_zone() local
1144 struct spdk_io_channel *ch; test_zone_write() local
1220 struct spdk_io_channel *ch; test_zone_read() local
1280 struct spdk_io_channel *ch; test_close_zone() local
1339 struct spdk_io_channel *ch; test_finish_zone() local
1399 struct spdk_io_channel *ch; test_append_zone() local
[all...]
/spdk/lib/thread/
H A Diobuf.c88 struct iobuf_channel *ch = ctx; in iobuf_channel_destroy_cb()
93 node = &ch->node[i]; in iobuf_channel_destroy_cb()
104 struct iobuf_channel *ch = ctx; in spdk_iobuf_initialize()
109 node = &ch->node[i]; in spdk_iobuf_initialize()
381 iobuf_channel_node_init(struct spdk_iobuf_channel *ch, struct iobuf_channel *iobuf_ch, in spdk_iobuf_channel_init()
385 struct spdk_iobuf_node_cache *cache = &ch->cache[numa_id]; in spdk_iobuf_channel_init()
404 iobuf_channel_node_populate(struct spdk_iobuf_channel *ch, const char *name, int32_t numa_id) in spdk_iobuf_channel_fini()
407 struct spdk_iobuf_node_cache *cache = &ch->cache[numa_id]; in spdk_iobuf_channel_fini()
442 spdk_iobuf_channel_init(struct spdk_iobuf_channel *ch, const char *name, in spdk_iobuf_register_module()
473 iobuf_ch->channels[i] = ch; in spdk_iobuf_unregister_module()
78 struct iobuf_channel *ch = ctx; iobuf_channel_create_cb() local
89 struct iobuf_channel *ch __attribute__((unused)) = ctx; iobuf_channel_destroy_cb() local
302 spdk_iobuf_channel_init(struct spdk_iobuf_channel * ch,const char * name,uint32_t small_cache_size,uint32_t large_cache_size) spdk_iobuf_channel_init() argument
391 spdk_iobuf_channel_fini(struct spdk_iobuf_channel * ch) spdk_iobuf_channel_fini() argument
480 spdk_iobuf_for_each_entry(struct spdk_iobuf_channel * ch,struct spdk_iobuf_pool * pool,spdk_iobuf_for_each_entry_fn cb_fn,void * cb_ctx) spdk_iobuf_for_each_entry() argument
502 spdk_iobuf_entry_abort(struct spdk_iobuf_channel * ch,struct spdk_iobuf_entry * entry,uint64_t len) spdk_iobuf_entry_abort() argument
520 spdk_iobuf_get(struct spdk_iobuf_channel * ch,uint64_t len,struct spdk_iobuf_entry * entry,spdk_iobuf_get_cb cb_fn) spdk_iobuf_get() argument
572 spdk_iobuf_put(struct spdk_iobuf_channel * ch,void * buf,uint64_t len) spdk_iobuf_put() argument
635 struct spdk_io_channel *ch = spdk_io_channel_iter_get_channel(iter); iobuf_get_channel_stats() local
[all...]
H A Dthread.c389 struct spdk_io_channel *ch; in _free_thread()
393 RB_FOREACH(ch, io_channel_tree, &thread->io_channels) { in _free_thread()
395 thread->name, ch->dev->name); in _free_thread()
661 struct spdk_io_channel *ch; in thread_exit()
705 RB_FOREACH(ch, io_channel_tree, &thread->io_channels) { in spdk_thread_exit()
708 thread->name, ch->dev->name); in spdk_thread_exit()
2348 struct spdk_io_channel *ch; in spdk_get_io_channel()
2374 ch = thread_get_io_channel(thread, dev); in spdk_get_io_channel()
2375 if (ch != NULL) { in spdk_get_io_channel()
2376 ch in spdk_get_io_channel()
366 struct spdk_io_channel *ch; _free_thread() local
636 struct spdk_io_channel *ch; thread_exit() local
2303 struct spdk_io_channel *ch; spdk_get_io_channel() local
2386 struct spdk_io_channel *ch = arg; put_io_channel() local
2441 spdk_put_io_channel(struct spdk_io_channel * ch) spdk_put_io_channel() argument
2481 spdk_io_channel_get_thread(struct spdk_io_channel * ch) spdk_io_channel_get_thread() argument
2487 spdk_io_channel_get_io_device(struct spdk_io_channel * ch) spdk_io_channel_get_io_device() argument
2493 spdk_io_channel_get_io_device_name(struct spdk_io_channel * ch) spdk_io_channel_get_io_device_name() argument
2499 spdk_io_channel_get_ref_count(struct spdk_io_channel * ch) spdk_io_channel_get_ref_count() argument
2510 struct spdk_io_channel *ch; global() member
2554 struct spdk_io_channel *ch; _call_channel() local
2577 struct spdk_io_channel *ch; spdk_for_each_channel() local
2648 struct spdk_io_channel *ch; spdk_for_each_channel_continue() local
[all...]
/spdk/module/bdev/daos/
H A Dbdev_daos.c232 bdev_daos_writev(struct bdev_daos *daos, struct bdev_daos_io_channel *ch, in bdev_daos_writev() argument
241 assert(ch != NULL); in bdev_daos_writev()
252 if ((rc = daos_event_init(&task->ev, ch->queue, NULL))) { in bdev_daos_writev()
267 if ((rc = dfs_write(ch->dfs, ch->obj, &task->sgl, offset, &task->ev))) { in bdev_daos_writev()
278 bdev_daos_readv(struct bdev_daos *daos, struct bdev_daos_io_channel *ch, in bdev_daos_readv() argument
287 assert(ch != NULL); in bdev_daos_readv()
298 if ((rc = daos_event_init(&task->ev, ch->queue, NULL))) { in bdev_daos_readv()
313 if ((rc = dfs_read(ch->dfs, ch->obj, &task->sgl, offset, &task->read_size, &task->ev))) { in bdev_daos_readv()
324 bdev_daos_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io, in bdev_daos_get_buf_cb() argument
328 struct bdev_daos_io_channel *dch = spdk_io_channel_get_ctx(ch); in bdev_daos_get_buf_cb()
[all …]
/spdk/test/common/lib/
H A Dtest_iobuf.c14 DEFINE_STUB_V(spdk_iobuf_channel_fini, (struct spdk_iobuf_channel *ch));
15 DEFINE_STUB(spdk_iobuf_for_each_entry, int, (struct spdk_iobuf_channel *ch,
17 DEFINE_STUB_V(spdk_iobuf_entry_abort, (struct spdk_iobuf_channel *ch,
54 spdk_iobuf_channel_init(struct spdk_iobuf_channel *ch, const char *name, in spdk_iobuf_channel_init() argument
59 cache = &ch->cache[0]; in spdk_iobuf_channel_init()
71 spdk_iobuf_get(struct spdk_iobuf_channel *ch, uint64_t len, in spdk_iobuf_get()
81 cache = &ch->cache[0]; in spdk_iobuf_get()
114 spdk_iobuf_put(struct spdk_iobuf_channel *ch, void *buf, uint64_t len) in spdk_iobuf_put()
121 cache = &ch->cache[0]; in spdk_iobuf_put()
67 spdk_iobuf_get(struct spdk_iobuf_channel * ch,uint64_t len,struct spdk_iobuf_entry * entry,spdk_iobuf_get_cb cb_fn) spdk_iobuf_get() argument
107 spdk_iobuf_put(struct spdk_iobuf_channel * ch,void * buf,uint64_t len) spdk_iobuf_put() argument
/spdk/module/bdev/aio/
H A Dbdev_aio.c58 struct bdev_aio_io_channel *ch; member
172 struct spdk_io_channel *ch, struct bdev_aio_task *aio_task, in bdev_aio_submit_io()
176 struct bdev_aio_io_channel *aio_ch = spdk_io_channel_get_ctx(ch); in bdev_aio_submit_io()
188 aio_task->ch = aio_ch; in bdev_aio_submit_io()
199 struct spdk_io_channel *ch, struct bdev_aio_task *aio_task, in bdev_aio_submit_io()
203 struct bdev_aio_io_channel *aio_ch = spdk_io_channel_get_ctx(ch); in bdev_aio_submit_io()
221 aio_task->ch = aio_ch; in bdev_aio_rw()
229 struct spdk_io_channel *ch, struct bdev_aio_task *aio_task, in bdev_aio_rw()
232 struct bdev_aio_io_channel *aio_ch = spdk_io_channel_get_ctx(ch); in bdev_aio_rw()
243 rc = bdev_aio_submit_io(type, fdisk, ch, aio_tas in bdev_aio_flush()
158 bdev_aio_submit_io(enum spdk_bdev_io_type type,struct file_disk * fdisk,struct spdk_io_channel * ch,struct bdev_aio_task * aio_task,struct iovec * iov,int iovcnt,uint64_t nbytes,uint64_t offset) bdev_aio_submit_io() argument
185 bdev_aio_submit_io(enum spdk_bdev_io_type type,struct file_disk * fdisk,struct spdk_io_channel * ch,struct bdev_aio_task * aio_task,struct iovec * iov,int iovcnt,uint64_t nbytes,uint64_t offset) bdev_aio_submit_io() argument
210 bdev_aio_rw(enum spdk_bdev_io_type type,struct file_disk * fdisk,struct spdk_io_channel * ch,struct bdev_aio_task * aio_task,struct iovec * iov,int iovcnt,uint64_t nbytes,uint64_t offset) bdev_aio_rw() argument
513 struct spdk_io_channel *ch = spdk_io_channel_iter_get_channel(i); _bdev_aio_get_io_inflight() local
565 bdev_aio_get_buf_cb(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io,bool success) bdev_aio_get_buf_cb() argument
592 _bdev_aio_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) _bdev_aio_submit_request() argument
639 bdev_aio_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) bdev_aio_submit_request() argument
669 bdev_aio_create_io(struct bdev_aio_io_channel * ch) bdev_aio_create_io() argument
681 bdev_aio_destroy_io(struct bdev_aio_io_channel * ch) bdev_aio_destroy_io() argument
687 bdev_aio_create_io(struct bdev_aio_io_channel * ch) bdev_aio_create_io() argument
699 bdev_aio_destroy_io(struct bdev_aio_io_channel * ch) bdev_aio_destroy_io() argument
708 struct bdev_aio_io_channel *ch = ctx_buf; bdev_aio_create_cb() local
725 struct bdev_aio_io_channel *ch = ctx_buf; bdev_aio_destroy_cb() local
807 bdev_aio_register_interrupt(struct bdev_aio_group_channel * ch) bdev_aio_register_interrupt() argument
827 bdev_aio_unregister_interrupt(struct bdev_aio_group_channel * ch) bdev_aio_unregister_interrupt() argument
843 struct bdev_aio_group_channel *ch = ctx_buf; bdev_aio_group_create_cb() local
866 struct bdev_aio_group_channel *ch = ctx_buf; bdev_aio_group_destroy_cb() local
[all...]
/spdk/lib/bdev/
H A Dbdev_zone.c67 spdk_bdev_get_zone_info(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_get_zone_info() argument
73 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in spdk_bdev_get_zone_info()
80 bdev_io->internal.ch = channel; in spdk_bdev_get_zone_info()
93 spdk_bdev_zone_management(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_zone_management() argument
99 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in spdk_bdev_zone_management()
106 bdev_io->internal.ch = channel; in spdk_bdev_zone_management()
119 zone_bdev_append_with_md(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in zone_bdev_append_with_md() argument
125 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in zone_bdev_append_with_md()
132 bdev_io->internal.ch = channel; in zone_bdev_append_with_md()
149 spdk_bdev_zone_append(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, in spdk_bdev_zone_append() argument
[all …]
/spdk/module/bdev/xnvme/
H A Dbdev_xnvme.c31 struct bdev_xnvme_io_channel *ch; member
187 _xnvme_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in _xnvme_submit_request()
191 struct bdev_xnvme_io_channel *xnvme_ch = spdk_io_channel_get_ctx(ch); in _xnvme_submit_request()
232 xnvme_task->ch = xnvme_ch; in bdev_xnvme_submit_request()
267 bdev_xnvme_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io, bool success) in bdev_xnvme_cmd_cb()
269 struct bdev_xnvme_io_channel *xnvme_ch = spdk_io_channel_get_ctx(ch); in bdev_xnvme_cmd_cb()
277 _xnvme_submit_request(ch, bdev_io);
281 bdev_xnvme_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in bdev_xnvme_poll()
298 _xnvme_submit_request(ch, bdev_io); in bdev_xnvme_queue_create_cb()
349 struct bdev_xnvme_io_channel *ch in create_xnvme_bdev()
130 _xnvme_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) _xnvme_submit_request() argument
203 bdev_xnvme_get_buf_cb(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io,bool success) bdev_xnvme_get_buf_cb() argument
217 bdev_xnvme_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) bdev_xnvme_submit_request() argument
280 struct bdev_xnvme_io_channel *ch = arg; bdev_xnvme_poll() local
296 struct bdev_xnvme_io_channel *ch = ctx_buf; bdev_xnvme_queue_create_cb() local
316 struct bdev_xnvme_io_channel *ch = ctx_buf; bdev_xnvme_queue_destroy_cb() local
[all...]
/spdk/test/unit/lib/nvmf/ctrlr_bdev.c/
H A Dctrlr_bdev_ut.c30 struct spdk_io_channel *ch, struct iovec *iov, int iovcnt,
35 struct spdk_io_channel *ch, struct iovec *iov, int iovcnt, uint64_t offset_blocks,
40 struct spdk_io_channel *ch, struct iovec *iov, int iovcnt, uint64_t offset_blocks,
45 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
50 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
179 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
198 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
204 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
213 (struct spdk_bdev *bdev, struct spdk_io_channel *ch,
218 (struct spdk_bdev_desc *desc, struct spdk_io_channel *ch, voi
369 struct spdk_io_channel ch = {}; test_spdk_nvmf_bdev_ctrlr_compare_and_write_cmd() local
575 struct spdk_io_channel ch = {}; test_nvmf_bdev_ctrlr_zcopy_start() local
660 struct spdk_io_channel ch = {}; test_nvmf_bdev_ctrlr_cmd() local
867 struct spdk_io_channel ch = {}; test_nvmf_bdev_ctrlr_nvme_passthru() local
[all...]
/spdk/lib/nvmf/
H A Dctrlr_bdev.c334 struct spdk_io_channel *ch, spdk_bdev_io_wait_cb cb_fn, void *cb_arg) in nvmf_bdev_ctrlr_write_cmd()
342 rc = spdk_bdev_queue_io_wait(bdev, ch, &req->bdev_io_wait); in nvmf_bdev_ctrlr_write_cmd()
357 struct spdk_io_channel *ch, struct spdk_nvmf_request *req) in nvmf_bdev_ctrlr_write_cmd()
393 rc = spdk_bdev_readv_blocks_ext(desc, ch, req->iov, req->iovcnt, start_lba, num_blocks, in nvmf_bdev_ctrlr_compare_cmd()
397 nvmf_bdev_ctrl_queue_io(req, bdev, ch, nvmf_ctrlr_process_io_cmd_resubmit, req); in nvmf_bdev_ctrlr_compare_cmd()
410 struct spdk_io_channel *ch, struct spdk_nvmf_request *req) in nvmf_bdev_ctrlr_compare_cmd()
446 rc = spdk_bdev_writev_blocks_ext(desc, ch, req->iov, req->iovcnt, start_lba, num_blocks, in nvmf_bdev_ctrlr_compare_and_write_cmd()
450 nvmf_bdev_ctrl_queue_io(req, bdev, ch, nvmf_ctrlr_process_io_cmd_resubmit, req); in nvmf_bdev_ctrlr_compare_and_write_cmd()
463 struct spdk_io_channel *ch, struct spdk_nvmf_request *req) in nvmf_bdev_ctrlr_compare_and_write_cmd()
490 rc = spdk_bdev_comparev_blocks(desc, ch, re in nvmf_bdev_ctrlr_write_zeroes_cmd()
260 nvmf_bdev_ctrl_queue_io(struct spdk_nvmf_request * req,struct spdk_bdev * bdev,struct spdk_io_channel * ch,spdk_bdev_io_wait_cb cb_fn,void * cb_arg) nvmf_bdev_ctrl_queue_io() argument
283 nvmf_bdev_ctrlr_read_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_read_cmd() argument
335 nvmf_bdev_ctrlr_write_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_write_cmd() argument
388 nvmf_bdev_ctrlr_compare_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_compare_cmd() argument
432 nvmf_bdev_ctrlr_compare_and_write_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * cmp_req,struct spdk_nvmf_request * write_req) nvmf_bdev_ctrlr_compare_and_write_cmd() argument
487 nvmf_bdev_ctrlr_write_zeroes_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_write_zeroes_cmd() argument
537 nvmf_bdev_ctrlr_flush_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_flush_cmd() argument
570 struct spdk_io_channel *ch; global() member
611 struct spdk_io_channel *ch = unmap_ctx->ch; nvmf_bdev_ctrlr_unmap_resubmit() local
618 nvmf_bdev_ctrlr_unmap(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,struct nvmf_bdev_ctrlr_unmap * unmap_ctx) nvmf_bdev_ctrlr_unmap() argument
702 nvmf_bdev_ctrlr_dsm_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_dsm_cmd() argument
718 nvmf_bdev_ctrlr_copy_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_copy_cmd() argument
783 nvmf_bdev_ctrlr_nvme_passthru_io(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_nvme_passthru_io() argument
806 spdk_nvmf_bdev_ctrlr_nvme_passthru_admin(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,spdk_nvmf_nvme_passthru_cmd_cb cb_fn) spdk_nvmf_bdev_ctrlr_nvme_passthru_admin() argument
856 spdk_nvmf_bdev_ctrlr_abort_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,struct spdk_nvmf_request * req_to_abort) spdk_nvmf_bdev_ctrlr_abort_cmd() argument
952 nvmf_bdev_ctrlr_zcopy_start(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_zcopy_start() argument
[all...]
/spdk/test/external_code/accel/
H A Dapp_driver.c19 struct spdk_io_channel *ch; member
54 spdk_put_io_channel(ctx->ch); in test_seq_complete_cb()
65 ctx->ch = spdk_accel_get_io_channel(); in start_driver()
66 if (ctx->ch == NULL) { in start_driver()
96 rc = spdk_accel_append_copy(&seq, ctx->ch, &ctx->iov1_bck, IOVCNT, NULL, NULL, in start_driver()
103 rc = spdk_accel_append_fill(&seq, ctx->ch, &ctx->buf1, TEST_XFER_SIZE, in start_driver()
110 rc = spdk_accel_append_copy(&seq, ctx->ch, &ctx->iov2_bck, IOVCNT, NULL, NULL, in start_driver()
117 rc = spdk_accel_append_fill(&seq, ctx->ch, &ctx->buf2, TEST_XFER_SIZE, in start_driver()
128 spdk_put_io_channel(ctx->ch); in start_driver()
H A Dapp_module.c25 struct spdk_io_channel *ch; member
119 rc = spdk_accel_submit_fill(ctx->ch, ctx->buf1, FILL_PATTERN, in process_accel()
129 rc = spdk_accel_submit_copy(ctx->ch, ctx->buf1, ctx->buf2, in process_accel()
139 rc = spdk_accel_submit_compare(ctx->ch, ctx->buf1, ctx->buf2, in process_accel()
149 spdk_put_io_channel(ctx->ch); in process_accel()
161 ctx->ch = spdk_accel_get_io_channel(); in start_accel()
162 if (ctx->ch == NULL) { in start_accel()
/spdk/test/app/stub/
H A Dstub.c139 int ch; in main()
150 while ((ch = getopt(argc, argv, "i:m:n:p:q:s:t:HL:")) != -1) { in main()
151 if (ch == 'm') { in main()
153 } else if (ch == 'L') { in main()
162 } else if (ch == '?' || ch == 'H') { in main()
171 switch (ch) { in main()
205 ch = spdk_app_start(&opts, stub_start, (void *)(intptr_t)opts.shm_id);
210 return ch;
138 int ch; main() local
/spdk/module/accel/ioat/
H A Daccel_ioat.c78 static int ioat_submit_tasks(struct spdk_io_channel *ch, struct spdk_accel_task *accel_task);
162 ioat_submit_tasks(struct spdk_io_channel *ch, struct spdk_accel_task *accel_task) in ioat_submit_tasks() argument
164 struct ioat_io_channel *ioat_ch = spdk_io_channel_get_ctx(ch); in ioat_submit_tasks()
199 struct ioat_io_channel *ch = ctx_buf; in ioat_create_cb() local
207 ch->ioat_dev = ioat_dev; in ioat_create_cb()
208 ch->ioat_ch = ioat_dev->ioat; in ioat_create_cb()
209 ch->poller = SPDK_POLLER_REGISTER(ioat_poll, ch->ioat_ch, 0); in ioat_create_cb()
217 struct ioat_io_channel *ch = ctx_buf; in ioat_destroy_cb() local
219 ioat_free_device(ch->ioat_dev); in ioat_destroy_cb()
220 spdk_poller_unregister(&ch->poller); in ioat_destroy_cb()
/spdk/module/bdev/gpt/
H A Dvbdev_gpt.c44 struct spdk_io_channel *ch; member
58 struct spdk_io_channel *ch; member
155 _vbdev_gpt_submit_request(io->ch, io->bdev_io); in vbdev_gpt_resubmit_request()
161 struct gpt_channel *ch = spdk_io_channel_get_ctx(io->ch); in vbdev_gpt_queue_io() local
169 ch->part_ch.base_ch, &io->bdev_io_wait); in vbdev_gpt_queue_io()
177 vbdev_gpt_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io, bool success) in vbdev_gpt_get_buf_cb() argument
184 _vbdev_gpt_submit_request(ch, bdev_io); in vbdev_gpt_get_buf_cb()
190 struct gpt_channel *ch = spdk_io_channel_get_ctx(_ch); in _vbdev_gpt_submit_request() local
194 rc = spdk_bdev_part_submit_request(&ch in _vbdev_gpt_submit_request()
[all...]
/spdk/module/bdev/null/
H A Dbdev_null.c69 bdev_null_abort_io(struct null_io_channel *ch, struct spdk_bdev_io *bio_to_abort) in bdev_null_abort_io() argument
74 TAILQ_FOREACH(null_io, &ch->io, link) { in bdev_null_abort_io()
78 TAILQ_REMOVE(&ch->io, null_io, link); in bdev_null_abort_io()
91 struct null_io_channel *ch = spdk_io_channel_get_ctx(_ch); in bdev_null_submit_request() local
146 TAILQ_INSERT_TAIL(&ch->io, null_io, link); in bdev_null_submit_request()
165 TAILQ_INSERT_TAIL(&ch->io, null_io, link); in bdev_null_submit_request()
169 TAILQ_INSERT_TAIL(&ch->io, null_io, link); in bdev_null_submit_request()
172 if (bdev_null_abort_io(ch, bdev_io->u.abort.bio_to_abort)) { in bdev_null_submit_request()
389 struct null_io_channel *ch = arg;
394 TAILQ_SWAP(&ch in null_bdev_destroy_cb()
358 struct null_io_channel *ch = arg; null_io_poll() local
381 struct null_io_channel *ch = ctx_buf; null_bdev_create_cb() local
392 struct null_io_channel *ch = ctx_buf; null_bdev_destroy_cb() local
[all...]
/spdk/module/bdev/virtio/
H A Dbdev_virtio_blk.c87 bdev_virtio_blk_init_io_vreq(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in bdev_virtio_blk_init_io_vreq() argument
113 bdev_virtio_blk_send_io(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in bdev_virtio_blk_send_io() argument
115 struct bdev_virtio_blk_io_channel *virtio_channel = spdk_io_channel_get_ctx(ch); in bdev_virtio_blk_send_io()
143 bdev_virtio_command(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in bdev_virtio_command() argument
145 struct virtio_blk_io_ctx *io_ctx = bdev_virtio_blk_init_io_vreq(ch, bdev_io); in bdev_virtio_command()
165 bdev_virtio_blk_send_io(ch, bdev_io); in bdev_virtio_command()
169 bdev_virtio_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io, in bdev_virtio_get_buf_cb() argument
177 bdev_virtio_command(ch, bdev_io); in bdev_virtio_get_buf_cb()
181 _bdev_virtio_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io) in _bdev_virtio_submit_request() argument
194 bdev_virtio_command(ch, bdev_io); in _bdev_virtio_submit_request()
[all …]
/spdk/test/unit/lib/thread/thread.c/
H A Dthread_ut.c837 struct spdk_io_channel *ch; in channel_destroy_races() local
844 ch = spdk_get_io_channel(&device); in channel_destroy_races()
845 SPDK_CU_ASSERT_FATAL(ch != NULL); in channel_destroy_races()
847 spdk_put_io_channel(ch); in channel_destroy_races()
849 ch = spdk_get_io_channel(&device); in channel_destroy_races()
850 SPDK_CU_ASSERT_FATAL(ch != NULL); in channel_destroy_races()
852 spdk_put_io_channel(ch); in channel_destroy_races()
867 struct spdk_io_channel *ch; in thread_exit_test() local
914 ch = spdk_get_io_channel(&g_device1); in thread_exit_test()
916 SPDK_CU_ASSERT_FATAL(ch ! in thread_exit_test()
1157 ut_check_nested_ch_create(struct spdk_io_channel * ch,struct io_device * dev) ut_check_nested_ch_create() argument
1165 ut_check_nested_ch_destroy_pre(struct spdk_io_channel * ch,struct io_device * dev) ut_check_nested_ch_destroy_pre() argument
1661 struct spdk_io_channel *ch; io_device_lookup() local
[all...]
/spdk/include/spdk/
H A Dbdev_zone.h152 int spdk_bdev_get_zone_info(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
174 int spdk_bdev_zone_management(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
197 int spdk_bdev_zone_append(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
223 int spdk_bdev_zone_appendv(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
250 int spdk_bdev_zone_append_with_md(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
280 int spdk_bdev_zone_appendv_with_md(struct spdk_bdev_desc *desc, struct spdk_io_channel *ch,
/spdk/test/unit/lib/bdev/mt/bdev.c/
H A Dbdev_ut.c98 struct ut_bdev_channel *ch = ctx_buf; in ut_accel_ch_create_cb()
104 TAILQ_INIT(&ch->outstanding_io); in ut_accel_ch_destroy_cb()
105 ch->outstanding_cnt = 0; in ut_accel_ch_destroy_cb()
112 ch->avail_cnt = 2048; in stub_create_ch()
113 ch->thread = spdk_get_thread(); in stub_create_ch()
115 TAILQ_INSERT_TAIL(&g_ut_channels, ch, link); in stub_create_ch()
123 struct ut_bdev_channel *ch = ctx_buf; in stub_create_ch()
125 TAILQ_REMOVE(&g_ut_channels, ch, link); in stub_create_ch()
149 struct ut_bdev_channel *ch = ctx; in stub_get_io_channel()
152 while (!TAILQ_EMPTY(&ch in stub_get_io_channel()
111 struct ut_bdev_channel *ch = ctx_buf; stub_create_ch() local
136 struct ut_bdev_channel *ch = ctx_buf; stub_destroy_ch() local
162 struct ut_bdev_channel *ch = ctx; stub_reset_channel() local
177 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch), *tmp_ch; stub_submit_request() local
218 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch); stub_complete_io() local
836 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch); count_queued_resets() local
1871 struct spdk_io_channel *ch[2]; bdev_histograms_mt() local
1966 bdev_channel_count_submitted_io(struct spdk_bdev_channel * ch) bdev_channel_count_submitted_io() argument
2004 struct spdk_io_channel *ch[3]; bdev_set_io_timeout_mt() local
2201 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch); stub_channel_outstanding_cnt() local
[all...]
/spdk/module/accel/error/
H A Daccel_error.c30 struct accel_error_channel *ch;
94 accel_error_should_inject(struct spdk_io_channel *ch, struct spdk_accel_task *task) in accel_error_submit_tasks()
96 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch); in accel_error_submit_tasks()
121 accel_error_submit_tasks(struct spdk_io_channel *ch, struct spdk_accel_task *task) in accel_error_inject_error()
123 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch); in accel_error_inject_error()
127 if (!accel_error_should_inject(ch, task)) { in accel_error_inject_error()
133 errtask->ch = errch; in accel_error_inject_error()
184 struct spdk_io_channel *ch = spdk_io_channel_iter_get_channel(iter);
185 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch);
26 struct accel_error_channel *ch; global() member
58 struct accel_error_channel *ch = errtask->ch; accel_error_task_complete_cb() local
88 accel_error_submit_tasks(struct spdk_io_channel * ch,struct spdk_accel_task * task) accel_error_submit_tasks() argument
105 struct spdk_io_channel *ch = spdk_io_channel_iter_get_channel(iter); accel_error_inject_channel() local
/spdk/lib/ftl/
H A Dftl_nv_cache_io.h16 struct spdk_io_channel *ch, in ftl_nv_cache_bdev_read_blocks_with_md() argument
22 return spdk_bdev_read_blocks_with_md(desc, ch, buf, md ? : g_ftl_read_buf, in ftl_nv_cache_bdev_read_blocks_with_md()
25 return spdk_bdev_read_blocks(desc, ch, buf, offset_blocks, num_blocks,
33 struct spdk_io_channel *ch, in ftl_nv_cache_bdev_write_blocks_with_md()
39 return spdk_bdev_write_blocks_with_md(desc, ch, buf, md ? : g_ftl_write_buf,
42 return spdk_bdev_write_blocks(desc, ch, buf, offset_blocks, num_blocks,
29 ftl_nv_cache_bdev_write_blocks_with_md(struct spdk_ftl_dev * dev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,void * buf,void * md,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg) ftl_nv_cache_bdev_write_blocks_with_md() argument
/spdk/module/bdev/uring/
H A Dbdev_uring.c48 struct bdev_uring_io_channel *ch;
176 bdev_uring_readv(struct bdev_uring *uring, struct spdk_io_channel *ch, in bdev_uring_readv()
180 struct bdev_uring_io_channel *uring_ch = spdk_io_channel_get_ctx(ch); in bdev_uring_readv()
193 uring_task->ch = uring_ch; in bdev_uring_readv()
203 bdev_uring_writev(struct bdev_uring *uring, struct spdk_io_channel *ch, in bdev_uring_writev()
207 struct bdev_uring_io_channel *uring_ch = spdk_io_channel_get_ctx(ch); in bdev_uring_writev()
220 uring_task->ch = uring_ch; in bdev_uring_writev()
271 uring_task->ch->group_ch->io_inflight--; in bdev_uring_reap()
315 bdev_uring_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io, in bdev_uring_get_buf_cb()
328 ch, in bdev_uring_get_buf_cb()
47 struct bdev_uring_io_channel *ch; global() member
175 bdev_uring_readv(struct bdev_uring * uring,struct spdk_io_channel * ch,struct bdev_uring_task * uring_task,struct iovec * iov,int iovcnt,uint64_t nbytes,uint64_t offset) bdev_uring_readv() argument
202 bdev_uring_writev(struct bdev_uring * uring,struct spdk_io_channel * ch,struct bdev_uring_task * uring_task,struct iovec * iov,int iovcnt,size_t nbytes,uint64_t offset) bdev_uring_writev() argument
314 bdev_uring_get_buf_cb(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io,bool success) bdev_uring_get_buf_cb() argument
652 _bdev_uring_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) _bdev_uring_submit_request() argument
674 bdev_uring_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) bdev_uring_submit_request() argument
700 struct bdev_uring_io_channel *ch = ctx_buf; bdev_uring_create_cb() local
710 struct bdev_uring_io_channel *ch = ctx_buf; bdev_uring_destroy_cb() local
781 struct bdev_uring_group_channel *ch = ctx_buf; bdev_uring_group_create_cb() local
797 struct bdev_uring_group_channel *ch = ctx_buf; bdev_uring_group_destroy_cb() local
[all...]
/spdk/module/bdev/ocf/
H A Dvolume.c151 struct spdk_io_channel *ch; in vbdev_ocf_volume_submit_io_cb()
157 ch = vbdev_forward_get_channel(volume, token); in vbdev_ocf_volume_submit_io_cb()
158 if (unlikely(ch == NULL)) { in vbdev_ocf_volume_submit_io_cb()
191 status = spdk_bdev_readv(base->desc, ch, iovs, iovcnt, in prepare_submit()
194 status = spdk_bdev_writev(base->desc, ch, iovs, iovcnt, in prepare_submit()
214 struct spdk_io_channel *ch; in prepare_submit()
218 ch = vbdev_forward_get_channel(volume, token); in prepare_submit()
219 if (unlikely(ch == NULL)) { in prepare_submit()
225 base->desc, ch, 0, bytes, in prepare_submit()
240 struct spdk_io_channel *ch; in vbdev_ocf_volume_submit_flush()
[all...]
/spdk/module/bdev/malloc/
H A Dbdev_malloc.c363 bdev_malloc_readv(struct malloc_disk *mdisk, struct spdk_io_channel *ch, in bdev_malloc_readv()
387 res = spdk_accel_append_copy(&bdev_io->u.bdev.accel_sequence, ch, in bdev_malloc_writev()
408 res = spdk_accel_submit_copy(ch, bdev_io->u.bdev.md_buf, malloc_get_md_buf(bdev_io), in bdev_malloc_writev()
416 bdev_malloc_writev(struct malloc_disk *mdisk, struct spdk_io_channel *ch, in bdev_malloc_writev()
440 res = spdk_accel_append_copy(&bdev_io->u.bdev.accel_sequence, ch, &task->iov, 1, NULL, NULL, in bdev_malloc_copy()
459 res = spdk_accel_submit_copy(ch, malloc_get_md_buf(bdev_io), bdev_io->u.bdev.md_buf, in _bdev_malloc_submit_request()
468 struct spdk_io_channel *ch, in _bdev_malloc_submit_request()
476 return spdk_accel_submit_fill(ch, mdisk->malloc_buf + offset, 0, in _bdev_malloc_submit_request()
481 bdev_malloc_copy(struct malloc_disk *mdisk, struct spdk_io_channel *ch, in _bdev_malloc_submit_request()
495 res = spdk_accel_submit_copy(ch, ds in _bdev_malloc_submit_request()
320 bdev_malloc_readv(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,struct spdk_bdev_io * bdev_io) bdev_malloc_readv() argument
373 bdev_malloc_writev(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,struct spdk_bdev_io * bdev_io) bdev_malloc_writev() argument
425 bdev_malloc_unmap(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,uint64_t offset,uint64_t byte_count) bdev_malloc_unmap() argument
438 bdev_malloc_copy(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,uint64_t dst_offset,uint64_t src_offset,size_t len) bdev_malloc_copy() argument
548 bdev_malloc_submit_request(struct spdk_io_channel * ch,struct spdk_bdev_io * bdev_io) bdev_malloc_submit_request() argument
871 struct malloc_channel *ch = ctx; malloc_completion_poller() local
892 struct malloc_channel *ch = ctx; malloc_create_channel_cb() local
915 struct malloc_channel *ch = ctx; malloc_destroy_channel_cb() local
[all...]

123456