Home
last modified time | relevance | path

Searched refs:channel (Results 1 – 25 of 49) sorted by relevance

12

/spdk/test/unit/lib/blobfs/blobfs_sync_ut/
H A Dblobfs_sync_ut.c146 struct spdk_fs_thread_ctx *channel; in cache_read_after_write() local
151 channel = spdk_fs_alloc_thread_ctx(g_fs); in cache_read_after_write()
153 rc = spdk_fs_open_file(g_fs, channel, "testfile", SPDK_BLOBFS_OPEN_CREATE, &g_file); in cache_read_after_write()
158 rc = spdk_file_truncate(g_file, channel, length); in cache_read_after_write()
162 spdk_file_write(g_file, channel, w_buf, 0, sizeof(w_buf)); in cache_read_after_write()
166 rc = spdk_file_truncate(g_file, channel, sizeof(w_buf)); in cache_read_after_write()
169 spdk_file_close(g_file, channel); in cache_read_after_write()
173 rc = spdk_fs_file_stat(g_fs, channel, "testfile", &stat); in cache_read_after_write()
177 rc = spdk_fs_open_file(g_fs, channel, "testfile", 0, &g_file); in cache_read_after_write()
182 spdk_file_read(g_file, channel, r_buf, 0, sizeof(r_buf)); in cache_read_after_write()
[all …]
/spdk/module/blob/bdev/
H A Dblob_bdev.c30 struct spdk_io_channel *channel; member
64 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, bserrno); in bdev_blob_io_complete()
69 bdev_blob_queue_io(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in bdev_blob_queue_io() argument
82 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, -ENOMEM); in bdev_blob_queue_io()
88 ctx->channel = channel; in bdev_blob_queue_io()
100 rc = spdk_bdev_queue_io_wait(bdev, channel, &ctx->bdev_io_wait); in bdev_blob_queue_io()
103 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, rc); in bdev_blob_queue_io()
110 bdev_blob_read(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in bdev_blob_read() argument
115 rc = spdk_bdev_read_blocks(__get_desc(dev), channel, payloa in bdev_blob_read()
126 bdev_blob_write(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,void * payload,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_write() argument
142 bdev_blob_readv(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_readv() argument
159 bdev_blob_writev(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_writev() argument
185 bdev_blob_readv_ext(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args,struct spdk_blob_ext_io_opts * io_opts) bdev_blob_readv_ext() argument
205 bdev_blob_writev_ext(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args,struct spdk_blob_ext_io_opts * io_opts) bdev_blob_writev_ext() argument
225 bdev_blob_write_zeroes(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_write_zeroes() argument
241 bdev_blob_unmap(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_unmap() argument
267 bdev_blob_copy(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t dst_lba,uint64_t src_lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) bdev_blob_copy() argument
373 bdev_blob_destroy_channel(struct spdk_bs_dev * dev,struct spdk_io_channel * channel) bdev_blob_destroy_channel() argument
[all...]
/spdk/lib/rocksdb/
H A Denv_spdk.cc37 struct spdk_fs_thread_ctx *channel; member in rocksdb::SpdkThreadCtx
39 SpdkThreadCtx(void) : channel(NULL) in SpdkThreadCtx()
46 if (channel) { in ~SpdkThreadCtx()
47 spdk_fs_free_thread_ctx(channel); in ~SpdkThreadCtx()
48 channel = NULL; in ~SpdkThreadCtx()
62 if (g_fs != NULL && g_sync_args.channel == NULL) { in set_channel()
63 g_sync_args.channel = spdk_fs_alloc_thread_ctx(g_fs); in set_channel()
121 spdk_file_close(mFile, g_sync_args.channel); in ~SpdkSequentialFile()
130 ret = spdk_file_read(mFile, g_sync_args.channel, scratch, mOffset, n); in Read()
169 spdk_file_close(mFile, g_sync_args.channel); in ~SpdkRandomAccessFile()
[all …]
/spdk/module/blobfs/bdev/
H A Dblobfs_fuse.c24 struct spdk_fs_thread_ctx *channel; member
67 rc = spdk_fs_file_stat(thd_bfuse->fs, thd_bfuse->channel, path, &stat); in fuse_getattr()
103 return spdk_fs_create_file(thd_bfuse->fs, thd_bfuse->channel, path); in fuse_mknod()
109 return spdk_fs_delete_file(thd_bfuse->fs, thd_bfuse->channel, path); in fuse_unlink()
118 rc = spdk_fs_open_file(thd_bfuse->fs, thd_bfuse->channel, path, 0, &file); in fuse_truncate()
123 rc = spdk_file_truncate(file, thd_bfuse->channel, size); in fuse_truncate()
128 spdk_file_close(file, thd_bfuse->channel); in fuse_truncate()
145 rc = spdk_fs_open_file(thd_bfuse->fs, thd_bfuse->channel, path, 0, &file); in fuse_open()
159 return spdk_file_close(file, thd_bfuse->channel); in fuse_release()
167 return spdk_file_read(file, thd_bfuse->channel, buf, offset, len); in fuse_read()
[all …]
/spdk/lib/bdev/
H A Dbdev_zone.c73 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in spdk_bdev_get_zone_info() local
75 bdev_io = bdev_channel_get_io(channel); in spdk_bdev_get_zone_info()
80 bdev_io->internal.ch = channel; in spdk_bdev_get_zone_info()
99 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in spdk_bdev_zone_management() local
101 bdev_io = bdev_channel_get_io(channel); in spdk_bdev_zone_management()
106 bdev_io->internal.ch = channel; in spdk_bdev_zone_management()
125 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in zone_bdev_append_with_md() local
127 bdev_io = bdev_channel_get_io(channel); in zone_bdev_append_with_md()
132 bdev_io->internal.ch = channel; in zone_bdev_append_with_md()
174 struct spdk_bdev_channel *channel = spdk_io_channel_get_ctx(ch); in spdk_bdev_zone_appendv_with_md() local
[all …]
H A Dbdev_internal.h17 struct spdk_bdev_io *bdev_channel_get_io(struct spdk_bdev_channel *channel);
/spdk/test/unit/lib/blob/blob.c/
H A Desnap_dev.c121 ut_esnap_destroy_channel(struct spdk_bs_dev *dev, struct spdk_io_channel *channel) in ut_esnap_destroy_channel() argument
123 spdk_put_io_channel(channel); in ut_esnap_destroy_channel()
159 ut_esnap_read(struct spdk_bs_dev *bs_dev, struct spdk_io_channel *channel, void *payload, in ut_esnap_read() argument
163 struct ut_esnap_channel *ut_ch = spdk_io_channel_get_ctx(channel); in ut_esnap_read()
182 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, 0); in ut_esnap_read()
186 ut_esnap_readv(struct spdk_bs_dev *bs_dev, struct spdk_io_channel *channel, in ut_esnap_readv() argument
190 struct ut_esnap_channel *ut_ch = spdk_io_channel_get_ctx(channel); in ut_esnap_readv()
198 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, -ENOTSUP); in ut_esnap_readv()
201 ut_esnap_read(bs_dev, channel, iov->iov_base, lba, lba_count, cb_args); in ut_esnap_readv()
205 ut_esnap_readv_ext(struct spdk_bs_dev *bs_dev, struct spdk_io_channel *channel, in ut_esnap_readv_ext() argument
[all …]
H A Dext_dev.c21 ext_dev_destroy_channel(struct spdk_bs_dev *dev, struct spdk_io_channel *channel) in ext_dev_destroy_channel() argument
32 ext_dev_read(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in ext_dev_read() argument
46 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, 0); in ext_dev_read()
50 ext_dev_write(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in ext_dev_write() argument
62 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, 0); in ext_dev_write()
H A Dblob_ut.c890 struct spdk_io_channel *channel; in blob_snapshot_freeze_io()
906 channel = spdk_bs_alloc_io_channel(bs); in blob_snapshot_freeze_io()
907 bs_channel = spdk_io_channel_get_ctx(channel); in blob_snapshot_freeze_io()
931 spdk_blob_io_write(blob, channel, payload_write, 0, num_of_pages, blob_op_complete, NULL); in blob_snapshot_freeze_io()
949 spdk_blob_io_read(blob, channel, payload_read, 0, num_of_pages, blob_op_complete, NULL); in blob_snapshot_freeze_io()
954 spdk_bs_free_io_channel(channel); in blob_snapshot_freeze_io()
1085 struct spdk_io_channel *channel; in _blob_inflate()
1088 channel = spdk_bs_alloc_io_channel(bs); in _blob_inflate()
1089 SPDK_CU_ASSERT_FATAL(channel != NULL); in _blob_inflate()
1106 spdk_bs_blob_decouple_parent(bs, channel, blobi in _blob_inflate()
889 struct spdk_io_channel *channel; blob_snapshot_freeze_io() local
1084 struct spdk_io_channel *channel; _blob_inflate() local
1423 struct spdk_io_channel *channel; channel_ops() local
1437 struct spdk_io_channel *channel; blob_write() local
1489 struct spdk_io_channel *channel; blob_read() local
1541 struct spdk_io_channel *channel; blob_rw_verify() local
1572 struct spdk_io_channel *channel; blob_rw_verify_iov() local
1642 struct spdk_bs_channel *channel = spdk_io_channel_get_ctx(_channel); bs_channel_get_req_count() local
1658 struct spdk_io_channel *channel; blob_rw_verify_iov_nomem() local
1697 struct spdk_io_channel *channel; blob_rw_iov_read_only() local
1730 _blob_io_read_no_split(struct spdk_blob * blob,struct spdk_io_channel * channel,uint8_t * payload,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg) _blob_io_read_no_split() argument
1754 _blob_io_write_no_split(struct spdk_blob * blob,struct spdk_io_channel * channel,uint8_t * payload,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg) _blob_io_write_no_split() argument
1782 struct spdk_io_channel *channel; blob_operation_split_rw() local
1922 struct spdk_io_channel *channel; blob_operation_split_rw_iov() local
2084 struct spdk_io_channel *channel; blob_unmap() local
4418 struct spdk_io_channel *channel, *channel_thread1; blob_thin_prov_rw() local
4859 struct spdk_io_channel *channel; blob_thin_prov_rle() local
4954 struct spdk_io_channel *channel; blob_thin_prov_rw_iov() local
5134 struct spdk_io_channel *channel; blob_snapshot_rw() local
5251 struct spdk_io_channel *channel; blob_snapshot_rw_iov() local
5374 struct spdk_io_channel *channel; _blob_inflate_rw() local
6375 struct spdk_io_channel *channel; blob_relations3() local
6745 test_io_write(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel) test_io_write() argument
6861 test_io_read(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel) test_io_read() argument
6972 test_io_unmap(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel) test_io_unmap() argument
6997 test_io_zeroes(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel) test_io_zeroes() argument
7022 test_blob_io_writev(struct spdk_blob * blob,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg,struct spdk_blob_ext_io_opts * io_opts) test_blob_io_writev() argument
7043 test_iov_write(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel,bool ext_api) test_iov_write() argument
7187 test_blob_io_readv(struct spdk_blob * blob,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg,struct spdk_blob_ext_io_opts * io_opts) test_blob_io_readv() argument
7207 test_iov_read(struct spdk_bs_dev * dev,struct spdk_blob * blob,struct spdk_io_channel * channel,bool ext_api) test_iov_read() argument
7368 struct spdk_io_channel *channel; blob_io_unit() local
7618 struct spdk_io_channel *channel; blob_simultaneous_operations() local
7730 struct spdk_io_channel *channel; blob_persist_test() local
7834 struct spdk_io_channel *channel; blob_decouple_snapshot() local
7913 struct spdk_io_channel *channel; blob_seek_io_unit() local
8610 struct spdk_io_channel *channel[2]; blob_nested_freezes() local
8886 struct spdk_io_channel *channel; _blob_esnap_clone_hydrate() local
9123 struct spdk_io_channel *channel; blob_clone_resize() local
9362 bs_dev_io_complete_cb(struct spdk_io_channel * channel,void * cb_arg,int bserrno) bs_dev_io_complete_cb() argument
[all...]
/spdk/test/unit/lib/blob/
H A Dbs_dev_common.c95 dev_destroy_channel(struct spdk_bs_dev *dev, struct spdk_io_channel *channel) in dev_destroy()
111 cb_args->cb_fn(cb_args->channel, cb_args->cb_arg, g_power_failure_rc); in dev_complete()
121 dev_read(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in dev_read()
155 dev_write(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, void *payload, in dev_write()
199 dev_readv(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, in dev_readv()
238 dev_readv_ext(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, in dev_readv_ext()
246 dev_readv(dev, channel, iov, iovcnt, lba, lba_count, cb_args); in dev_writev()
250 dev_writev(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, in dev_writev()
289 dev_writev_ext(struct spdk_bs_dev *dev, struct spdk_io_channel *channel, in dev_writev_ext()
297 dev_writev(dev, channel, io in dev_flush()
90 dev_destroy_channel(struct spdk_bs_dev * dev,struct spdk_io_channel * channel) dev_destroy_channel() argument
116 dev_read(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,void * payload,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_read() argument
150 dev_write(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,void * payload,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_write() argument
194 dev_readv(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_readv() argument
233 dev_readv_ext(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args,struct spdk_blob_ext_io_opts * io_opts) dev_readv_ext() argument
245 dev_writev(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_writev() argument
284 dev_writev_ext(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t lba,uint32_t lba_count,struct spdk_bs_dev_cb_args * cb_args,struct spdk_blob_ext_io_opts * io_opts) dev_writev_ext() argument
296 dev_flush(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,struct spdk_bs_dev_cb_args * cb_args) dev_flush() argument
318 dev_unmap(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_unmap() argument
348 dev_write_zeroes(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_write_zeroes() argument
386 dev_copy(struct spdk_bs_dev * dev,struct spdk_io_channel * channel,uint64_t dst_lba,uint64_t src_lba,uint64_t lba_count,struct spdk_bs_dev_cb_args * cb_args) dev_copy() argument
[all...]
/spdk/include/spdk/
H A Dblobfs.h159 void spdk_fs_free_io_channel(struct spdk_io_channel *channel);
395 void spdk_file_readv_async(struct spdk_file *file, struct spdk_io_channel *channel,
411 void spdk_file_writev_async(struct spdk_file *file, struct spdk_io_channel *channel,
508 void spdk_file_write_async(struct spdk_file *file, struct spdk_io_channel *channel,
523 void spdk_file_read_async(struct spdk_file *file, struct spdk_io_channel *channel,
539 void spdk_file_sync_async(struct spdk_file *file, struct spdk_io_channel *channel,
/spdk/lib/blob/
H A Drequest.h92 struct spdk_bs_channel *channel; member
132 spdk_bs_sequence_t *bs_sequence_start_bs(struct spdk_io_channel *channel,
135 spdk_bs_sequence_t *bs_sequence_start_blob(struct spdk_io_channel *channel,
138 spdk_bs_sequence_t *bs_sequence_start_esnap(struct spdk_io_channel *channel,
177 spdk_bs_batch_t *bs_batch_open(struct spdk_io_channel *channel,
201 spdk_bs_user_op_t *bs_user_op_alloc(struct spdk_io_channel *channel, struct spdk_bs_cpl *cpl,
/spdk/examples/blob/hello_world/
H A Dhello_blob.c24 struct spdk_io_channel *channel; member
70 if (hello_context->channel) { in unload_bs()
71 spdk_bs_free_io_channel(hello_context->channel); in unload_bs()
165 spdk_blob_io_read(hello_context->blob, hello_context->channel, in read_blob()
212 hello_context->channel = spdk_bs_alloc_io_channel(hello_context->bs); in blob_write()
213 if (hello_context->channel == NULL) { in blob_write()
220 spdk_blob_io_write(hello_context->blob, hello_context->channel, in blob_write()
/spdk/test/accel/dif/
H A Ddif.c80 struct spdk_io_channel *channel;
471 rc = spdk_accel_submit_dif_verify(req->channel, req->src_iovs, req->src_iovcnt,
486 rc = spdk_accel_submit_dix_verify(req->channel, req->src_iovs, req->src_iovcnt, req->md_iov, in accel_dif_verify_op_apptag_correct_apptag_check()
501 rc = spdk_accel_submit_dix_generate(req->channel, req->src_iovs, req->src_iovcnt, in accel_dif_verify_op_apptag_correct_apptag_check()
515 rc = spdk_accel_submit_dif_verify_copy(req->channel, req->dst_iovs, req->dst_iovcnt, in accel_dif_verify_op_apptag_incorrect_apptag_check()
531 rc = spdk_accel_submit_dif_generate_copy(req->channel, req->dst_iovs, req->dst_iovcnt, in accel_dif_verify_op_apptag_incorrect_apptag_check()
548 rc = spdk_accel_append_dif_generate_copy(&req->sequence, req->channel, in accel_dif_verify_op_apptag_incorrect_apptag_check()
557 rc = spdk_accel_append_copy(&req->sequence, req->channel, in accel_dif_verify_op_apptag_incorrect_apptag_check()
579 rc = spdk_accel_append_dif_verify_copy(&req->sequence, req->channel, in accel_dif_verify_op_tag_incorrect_no_check_or_ignore()
589 rc = spdk_accel_append_copy(&req->sequence, req->channel, in accel_dif_verify_op_tag_incorrect_no_check_or_ignore()
76 struct spdk_io_channel *channel; global() member
[all...]
/spdk/lib/thread/
H A Diobuf.c465 SPDK_ERRLOG("Couldn't get iobuf IO channel\n"); in spdk_iobuf_unregister_module()
827 struct spdk_iobuf_channel *channel;
834 channel = iobuf_ch->channels[j];
835 if (channel == NULL) {
840 module = (struct iobuf_module *)channel->module;
846 cache = &channel->cache[i].small;
851 cache = &channel->cache[i].large;
637 struct spdk_iobuf_channel *channel; iobuf_get_channel_stats() local
/spdk/test/unit/lib/blobfs/blobfs_async_ut/
H A Dblobfs_async_ut.c572 struct spdk_io_channel *channel; in channel_ops() local
583 channel = spdk_fs_alloc_io_channel(fs); in channel_ops()
584 CU_ASSERT(channel != NULL); in channel_ops()
586 spdk_fs_free_io_channel(channel); in channel_ops()
600 struct spdk_fs_thread_ctx *channel; in channel_ops_sync() local
611 channel = spdk_fs_alloc_thread_ctx(fs); in channel_ops_sync()
612 CU_ASSERT(channel != NULL); in channel_ops_sync()
614 spdk_fs_free_thread_ctx(channel); in channel_ops_sync()
/spdk/scripts/
H A Dsma-client.py39 with grpc.insecure_channel(f'{self.addr}:{self.port}') as channel:
40 stub = sma_pb2_grpc.StorageManagementAgentStub(channel)
/spdk/test/nvmf/target/
H A Dperf_adq.sh24 "${NVMF_TARGET_NS_CMD[@]}" ethtool --set-priv-flags $NVMF_TARGET_INTERFACE channel-pkt-inspect-optimize off
32 mqprio num_tc 2 map 0 1 queues 2@0 2@2 hw 1 mode channel
/spdk/include/spdk_internal/
H A Dlvolstore.h45 struct spdk_io_channel *channel; member
53 struct spdk_io_channel *channel; member
/spdk/test/unit/lib/bdev/vbdev_lvol.c/
H A Dvbdev_lvol_ut.c682 spdk_blob_io_read(struct spdk_blob *blob, struct spdk_io_channel *channel, in spdk_blob_io_read() argument
687 CU_ASSERT(channel == g_ch); in spdk_blob_io_read()
694 spdk_blob_io_write(struct spdk_blob *blob, struct spdk_io_channel *channel, in spdk_blob_io_write() argument
699 CU_ASSERT(channel == g_ch); in spdk_blob_io_write()
706 spdk_blob_io_unmap(struct spdk_blob *blob, struct spdk_io_channel *channel, in spdk_blob_io_unmap() argument
710 CU_ASSERT(channel == g_ch); in spdk_blob_io_unmap()
717 spdk_blob_io_write_zeroes(struct spdk_blob *blob, struct spdk_io_channel *channel, in spdk_blob_io_write_zeroes() argument
721 CU_ASSERT(channel == g_ch); in spdk_blob_io_write_zeroes()
728 spdk_blob_io_writev(struct spdk_blob *blob, struct spdk_io_channel *channel, in spdk_blob_io_writev() argument
733 CU_ASSERT(channel in spdk_blob_io_writev()
740 spdk_blob_io_writev_ext(struct spdk_blob * blob,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg,struct spdk_blob_ext_io_opts * io_opts) spdk_blob_io_writev_ext() argument
757 spdk_blob_io_readv(struct spdk_blob * blob,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg) spdk_blob_io_readv() argument
769 spdk_blob_io_readv_ext(struct spdk_blob * blob,struct spdk_io_channel * channel,struct iovec * iov,int iovcnt,uint64_t offset,uint64_t length,spdk_blob_op_complete cb_fn,void * cb_arg,struct spdk_blob_ext_io_opts * io_opts) spdk_blob_io_readv_ext() argument
[all...]
/spdk/test/unit/lib/nvmf/transport.c/
H A Dtransport_ut.c46 DEFINE_STUB(rdma_create_id, int, (struct rdma_event_channel *channel,
57 DEFINE_STUB_V(rdma_destroy_event_channel, (struct rdma_event_channel *channel));
69 DEFINE_STUB(rdma_get_cm_event, int, (struct rdma_event_channel *channel,
75 struct ibv_comp_channel *channel,
/spdk/doc/
H A Dnvme_multipath.md28 qpair is created as a dynamic context of an I/O channel for an NVMe-oF controller.
30 For each SPDK thread, the NVMe bdev module creates an I/O channel for an NVMe bdev and provides it …
31 the upper layer. The I/O channel for the NVMe bdev has an I/O path for each namespace. I/O path is
33 namespace. If an NVMe bdev has multiple namespaces, an I/O channel for the NVMe bdev has a list of
34 multiple I/O paths. The I/O channel for the NVMe bdev has a retry I/O list and has a path selection
60 For active-passive policy, each I/O channel for an NVMe bdev has a cache to store the first found
85 Each I/O has a timer to schedule an I/O retry at a particular time in the future. Each I/O channel
H A Dbdev_pg.md40 associated I/O channel. The motivation and design of I/O channels is described
97 However, for each thread a separate I/O channel must be obtained by calling
100 a channel, call spdk_put_io_channel(). A descriptor cannot be closed until
105 Once a descriptor and a channel have been obtained, I/O may be sent by calling
140 a message to every other thread for which an I/O channel exists for the bdev,
/spdk/test/dma/test_dma/
H A Dtest_dma.c41 struct spdk_io_channel *channel;
194 spdk_put_io_channel(task->channel); in dma_test_task_update_stats()
317 rc = spdk_bdev_readv_blocks_ext(task->desc, task->channel, req->iovs, g_iovcnt, in dma_test_memzero_cb()
506 rc = spdk_bdev_readv_blocks_ext(task->desc, task->channel, req->iovs, g_iovcnt, in dma_test_construct_task_done()
510 rc = spdk_bdev_writev_blocks_ext(task->desc, task->channel, req->iovs, g_iovcnt, in dma_test_construct_task_done()
645 task->channel = spdk_bdev_get_io_channel(task->desc); in allocate_task()
646 if (!task->channel) { in allocate_task()
36 struct spdk_io_channel *channel; global() member
/spdk/lib/nvmf/
H A Dnvmf.c149 * Reset and clean up the poll group (I/O channel code will actually free the in nvmf_poll_group_poll()
170 if (sgroup->ns_info[nsid].channel) {
171 spdk_put_io_channel(sgroup->ns_info[nsid].channel);
172 sgroup->ns_info[nsid].channel = NULL; in nvmf_tgt_cleanup_poll_group()
1185 SPDK_ERRLOG("Unable to get I/O channel for target\n"); in spdk_nvmf_tgt_new_qpair()
1498 ch = ns_info->channel; in poll_group_update_subsystem()
1503 /* There was a channel here, but the namespace is gone. */ in poll_group_update_subsystem()
1506 ns_info->channel = NULL; in poll_group_update_subsystem()
1508 /* A namespace appeared but there is no channel yet */ in poll_group_update_subsystem()
1512 SPDK_ERRLOG("Could not allocate I/O channel in poll_group_update_subsystem()
[all...]

12