Lines Matching defs:g_iobuf
63 for (i = g_iobuf.opts.enable_numa ? spdk_env_get_first_numa_id() : 0; \
65 i = g_iobuf.opts.enable_numa ? spdk_env_get_next_numa_id(i) : INT32_MAX)
67 static struct iobuf g_iobuf = {
68 .modules = TAILQ_HEAD_INITIALIZER(g_iobuf.modules),
118 struct spdk_iobuf_opts *opts = &g_iobuf.opts;
123 if (!g_iobuf.opts.enable_numa) {
189 if (spdk_ring_count(node->small_pool) != g_iobuf.opts.small_pool_count) {
191 spdk_ring_count(node->small_pool), g_iobuf.opts.small_pool_count);
194 if (spdk_ring_count(node->large_pool) != g_iobuf.opts.large_pool_count) {
196 spdk_ring_count(node->large_pool), g_iobuf.opts.large_pool_count);
213 struct spdk_iobuf_opts *opts = &g_iobuf.opts;
223 node = &g_iobuf.node[i];
230 spdk_io_device_register(&g_iobuf, iobuf_channel_create_cb, iobuf_channel_destroy_cb,
238 node = &g_iobuf.node[i];
251 while (!TAILQ_EMPTY(&g_iobuf.modules)) {
252 module = TAILQ_FIRST(&g_iobuf.modules);
253 TAILQ_REMOVE(&g_iobuf.modules, module, tailq);
259 node = &g_iobuf.node[i];
263 if (g_iobuf.finish_cb != NULL) {
264 g_iobuf.finish_cb(g_iobuf.finish_arg);
277 g_iobuf.finish_cb = cb_fn;
278 g_iobuf.finish_arg = cb_arg;
280 spdk_io_device_unregister(&g_iobuf, iobuf_unregister_cb);
331 g_iobuf.opts.field = opts->field; \
340 g_iobuf.opts.opts_size = opts->opts_size;
364 opts->field = g_iobuf.opts.field; \
384 struct iobuf_node *node = &g_iobuf.node[numa_id];
392 cache->small.bufsize = g_iobuf.opts.small_bufsize;
393 cache->large.bufsize = g_iobuf.opts.large_bufsize;
406 struct iobuf_node *node = &g_iobuf.node[numa_id];
417 name, i, small_cache_size, g_iobuf.opts.small_pool_count);
429 name, i, large_cache_size, g_iobuf.opts.large_pool_count);
452 TAILQ_FOREACH(module, &g_iobuf.modules, tailq) {
463 ioch = spdk_get_io_channel(&g_iobuf);
510 struct iobuf_node *node = &g_iobuf.node[numa_id];
567 TAILQ_FOREACH(module, &g_iobuf.modules, tailq) {
584 TAILQ_INSERT_TAIL(&g_iobuf.modules, module, tailq);
594 TAILQ_FOREACH(module, &g_iobuf.modules, tailq) {
596 TAILQ_REMOVE(&g_iobuf.modules, module, tailq);
757 if (g_iobuf.opts.enable_numa) {
876 TAILQ_FOREACH(module, &g_iobuf.modules, tailq) {
887 TAILQ_FOREACH(module, &g_iobuf.modules, tailq) {
895 spdk_for_each_channel(&g_iobuf, iobuf_get_channel_stats, ctx,