Lines Matching defs:ch

88 	struct iobuf_channel *ch = ctx;
93 node = &ch->node[i];
104 struct iobuf_channel *ch = ctx;
109 node = &ch->node[i];
381 iobuf_channel_node_init(struct spdk_iobuf_channel *ch, struct iobuf_channel *iobuf_ch,
385 struct spdk_iobuf_node_cache *cache = &ch->cache[numa_id];
404 iobuf_channel_node_populate(struct spdk_iobuf_channel *ch, const char *name, int32_t numa_id)
407 struct spdk_iobuf_node_cache *cache = &ch->cache[numa_id];
442 spdk_iobuf_channel_init(struct spdk_iobuf_channel *ch, const char *name,
473 iobuf_ch->channels[i] = ch;
484 ch->parent = ioch;
485 ch->module = module;
488 iobuf_channel_node_init(ch, iobuf_ch, numa_id,
493 rc = iobuf_channel_node_populate(ch, name, numa_id);
501 spdk_iobuf_channel_fini(ch);
507 iobuf_channel_node_fini(struct spdk_iobuf_channel *ch, int32_t numa_id)
509 struct spdk_iobuf_node_cache *cache = &ch->cache[numa_id];
516 assert(entry->module != ch->module);
519 assert(entry->module != ch->module);
541 spdk_iobuf_channel_fini(struct spdk_iobuf_channel *ch)
547 iobuf_channel_node_fini(ch, i);
550 iobuf_ch = spdk_io_channel_get_ctx(ch->parent);
552 if (iobuf_ch->channels[i] == ch) {
558 spdk_put_io_channel(ch->parent);
559 ch->parent = NULL;
607 iobuf_pool_for_each_entry(struct spdk_iobuf_channel *ch, struct spdk_iobuf_pool_cache *pool,
614 /* We only want to iterate over the entries requested by the module which owns ch */
615 if (entry->module != ch->module) {
619 rc = cb_fn(ch, entry, cb_ctx);
629 spdk_iobuf_for_each_entry(struct spdk_iobuf_channel *ch,
637 cache = &ch->cache[i];
639 rc = iobuf_pool_for_each_entry(ch, &cache->small, cb_fn, cb_ctx);
643 rc = iobuf_pool_for_each_entry(ch, &cache->large, cb_fn, cb_ctx);
653 iobuf_entry_abort_node(struct spdk_iobuf_channel *ch, int32_t numa_id,
660 cache = &ch->cache[numa_id];
680 spdk_iobuf_entry_abort(struct spdk_iobuf_channel *ch, struct spdk_iobuf_entry *entry,
686 iobuf_entry_abort_node(ch, i, entry, len);
693 spdk_iobuf_get(struct spdk_iobuf_channel *ch, uint64_t len,
700 cache = &ch->cache[0];
702 assert(spdk_io_channel_get_thread(ch->parent) == spdk_get_thread());
726 entry->module = ch->module;
748 spdk_iobuf_put(struct spdk_iobuf_channel *ch, void *buf, uint64_t len)
763 cache = &ch->cache[numa_id];
765 assert(spdk_io_channel_get_thread(ch->parent) == spdk_get_thread());
825 struct spdk_io_channel *ch = spdk_io_channel_iter_get_channel(iter);
826 struct iobuf_channel *iobuf_ch = spdk_io_channel_get_ctx(ch);