Home
last modified time | relevance | path

Searched refs:entry (Results 1 – 25 of 77) sorted by relevance

1234

/spdk/test/unit/lib/thread/iobuf.c/
H A Diobuf_ut.c31 ut_iobuf_get_buf_cb(struct spdk_iobuf_entry *entry, void *buf) in ut_iobuf_get_buf_cb()
33 struct ut_iobuf_entry *ut_entry = SPDK_CONTAINEROF(entry, struct ut_iobuf_entry, iobuf); in ut_iobuf_get_buf_cb()
39 ut_iobuf_foreach_cb(struct spdk_iobuf_channel *ch, struct spdk_iobuf_entry *entry, void *cb_arg) in ut_iobuf_foreach_cb()
41 struct ut_iobuf_entry *ut_entry = SPDK_CONTAINEROF(entry, struct ut_iobuf_entry, iobuf); in ut_iobuf_foreach_cb()
60 struct ut_iobuf_entry *entry; in iobuf()
122 entry = &mod0_entries[0]; in iobuf()
123 entry->buf = spdk_iobuf_get(entry->ioch, LARGE_BUFSIZE, &entry->iobuf, ut_iobuf_get_buf_cb); in iobuf()
124 CU_ASSERT_PTR_NOT_NULL(entry in iobuf()
30 ut_iobuf_get_buf_cb(struct spdk_iobuf_entry * entry,void * buf) ut_iobuf_get_buf_cb() argument
38 ut_iobuf_foreach_cb(struct spdk_iobuf_channel * ch,struct spdk_iobuf_entry * entry,void * cb_arg) ut_iobuf_foreach_cb() argument
59 struct ut_iobuf_entry *entry; iobuf() local
481 struct ut_iobuf_entry *entry; iobuf_cache() local
[all...]
/spdk/module/bdev/rbd/
H A Dbdev_rbd.c121 bdev_rbd_cluster_free(struct bdev_rbd_cluster *entry) in bdev_rbd_cluster_free() argument
123 assert(entry != NULL); in bdev_rbd_cluster_free()
125 bdev_rbd_free_config(entry->config_param); in bdev_rbd_cluster_free()
126 free(entry->config_file); in bdev_rbd_cluster_free()
127 free(entry->key_file); in bdev_rbd_cluster_free()
128 free(entry->user_id); in bdev_rbd_cluster_free()
129 free(entry->name); in bdev_rbd_cluster_free()
130 free(entry->core_mask); in bdev_rbd_cluster_free()
131 free(entry); in bdev_rbd_cluster_free()
137 struct bdev_rbd_cluster *entry; in bdev_rbd_put_cluster() local
[all …]
/spdk/lib/ftl/utils/
H A Dftl_layout_tracker_bdev.c78 struct layout_tracker_entry *entry; in layout_tracker_free_entries() local
80 while ((entry = TAILQ_FIRST(&tracker->layout_head))) { in layout_tracker_free_entries()
81 TAILQ_REMOVE(&tracker->layout_head, entry, layout_entry); in layout_tracker_free_entries()
82 free(entry); in layout_tracker_free_entries()
100 struct layout_tracker_entry *entry; in layout_region_find_min_free() local
104 TAILQ_FOREACH(entry, &tracker->layout_head, layout_entry) { in layout_region_find_min_free()
107 if (entry->reg.type != FTL_LAYOUT_REGION_TYPE_FREE) { in layout_region_find_min_free()
111 align_offs = entry->reg.blk_offs; in layout_region_find_min_free()
112 align_sz = entry->reg.blk_sz; in layout_region_find_min_free()
115 align_sz -= (align_offs - entry->reg.blk_offs); in layout_region_find_min_free()
[all …]
H A Dftl_property.c49 LIST_ENTRY(ftl_property) entry;
55 struct ftl_property *entry; in get_property() local
57 LIST_FOREACH(entry, &properties->list, entry) { in get_property()
59 if (0 == strcmp(entry->name, name)) { in get_property()
60 return entry; in get_property()
97 LIST_INSERT_HEAD(&properties->list, prop, entry); in ftl_property_register()
125 LIST_REMOVE(prop, entry); in ftl_properties_deinit()
178 LIST_FOREACH(prop, &properties->list, entry) { in ftl_property_dump()
/spdk/lib/ftl/nvc/
H A Dftl_nvc_dev.c18 struct ftl_nv_cache_device_type *entry; in ftl_nv_cache_device_type_get_type() local
20 TAILQ_FOREACH(entry, &g_devs, internal.entry) { in ftl_nv_cache_device_type_get_type()
21 if (0 == strcmp(entry->name, name)) { in ftl_nv_cache_device_type_get_type()
22 return entry; in ftl_nv_cache_device_type_get_type()
45 TAILQ_INSERT_TAIL(&g_devs, type, internal.entry); in ftl_nv_cache_device_register()
58 struct ftl_nv_cache_device_type *entry; in ftl_nv_cache_device_get_type_by_bdev() local
62 TAILQ_FOREACH(entry, &g_devs, internal.entry) { in ftl_nv_cache_device_get_type_by_bdev()
63 if (entry->ops.is_bdev_compatible) { in ftl_nv_cache_device_get_type_by_bdev()
64 if (entry->ops.is_bdev_compatible(dev, bdev)) { in ftl_nv_cache_device_get_type_by_bdev()
65 type = entry; in ftl_nv_cache_device_get_type_by_bdev()
/spdk/app/trace/
H A Dtrace.cpp109 print_object_id(const struct spdk_trace_tpoint *d, struct spdk_trace_parser_entry *entry) in print_object_id() argument
115 if (entry->related_type != OBJECT_NONE) { in print_object_id()
117 g_file->object[entry->related_type].id_prefix, in print_object_id()
118 entry->related_index); in print_object_id()
122 entry->object_index, related_id); in print_object_id()
133 print_event(struct spdk_trace_parser_entry *entry, uint64_t tsc_rate, uint64_t tsc_offset) in print_event() argument
135 struct spdk_trace_entry *e = entry->entry; in print_event()
144 printf("%-*s ", (int)sizeof(g_file->tname[entry->lcore]), g_file->tname[entry->lcore]); in print_event()
145 printf("%2d: %10.3f ", entry->lcore, us); in print_event()
161 print_object_id(d, entry); in print_event()
[all …]
/spdk/test/nvme/reset/
H A Dreset.c29 struct ns_entry *entry; member
72 struct ns_entry *entry; in register_ns() local
80 entry = malloc(sizeof(struct ns_entry)); in register_ns()
81 if (entry == NULL) { in register_ns()
88 entry->ns = ns; in register_ns()
89 entry->ctrlr = ctrlr; in register_ns()
90 entry->size_in_ios = spdk_nvme_ns_get_size(ns) / in register_ns()
92 entry->io_size_blocks = g_io_size_bytes / spdk_nvme_ns_get_sector_size(ns); in register_ns()
94 snprintf(entry->name, 44, "%-20.20s (%-20.20s)", cdata->mn, cdata->sn); in register_ns()
97 TAILQ_INSERT_TAIL(&g_namespaces, entry, lin in register_ns()
105 struct ctrlr_entry *entry = malloc(sizeof(struct ctrlr_entry)); register_ctrlr() local
135 struct ns_entry *entry = ns_ctx->entry; submit_single_io() local
528 struct ctrlr_entry *entry, *tmp; unregister_controllers() local
545 struct ns_entry *entry = TAILQ_FIRST(&g_namespaces); associate_workers_with_ns() local
[all...]
/spdk/test/nvme/overhead/
H A Doverhead.c95 struct ns_entry *entry; in register_ns() local
116 entry = calloc(1, sizeof(struct ns_entry)); in register_ns()
117 if (entry == NULL) { in register_ns()
122 entry->type = ENTRY_TYPE_NVME_NS; in register_ns()
123 entry->u.nvme.ctrlr = ctrlr; in register_ns()
124 entry->u.nvme.ns = ns; in register_ns()
126 entry->size_in_ios = spdk_nvme_ns_get_size(ns) / in register_ns()
128 entry->io_size_blocks = g_io_size_bytes / spdk_nvme_ns_get_sector_size(ns); in register_ns()
129 entry->submit_histogram = spdk_histogram_data_alloc(); in register_ns()
130 entry in register_ns()
142 struct ctrlr_entry *entry = malloc(sizeof(struct ctrlr_entry)); register_ctrlr() local
170 struct ns_entry *entry; register_aio_file() local
268 struct ns_entry *entry = g_ns; submit_single_io() local
[all...]
/spdk/lib/nvmf/
H A Dctrlr_discovery.c103 struct spdk_nvmf_discovery_log_page_entry *entry; in nvmf_generate_discovery_log() local
140 size_t new_size = cur_size + sizeof(*entry); in nvmf_generate_discovery_log()
151 entry = &disc_log->entries[numrec]; in nvmf_generate_discovery_log()
152 memset(entry, 0, sizeof(*entry)); in nvmf_generate_discovery_log()
153 entry->portid = listener->id; in nvmf_generate_discovery_log()
154 entry->cntlid = 0xffff; in nvmf_generate_discovery_log()
155 entry->asqsz = listener->transport->opts.max_aq_depth; in nvmf_generate_discovery_log()
156 entry->subtype = subsystem->subtype; in nvmf_generate_discovery_log()
157 snprintf(entry in nvmf_generate_discovery_log()
[all...]
/spdk/lib/ftl/
H A Dftl_io.h46 TAILQ_ENTRY(ftl_io_channel) entry;
289 ftl_rq_entry_loop_assert(struct ftl_rq *rq, struct ftl_rq_entry *entry, uint32_t count) in ftl_rq_entry_loop_assert() argument
291 assert(entry >= rq->entries); in ftl_rq_entry_loop_assert()
292 assert(((uintptr_t)entry - (uintptr_t)rq->entries) % sizeof(*entry) == 0); in ftl_rq_entry_loop_assert()
298 #define FTL_RQ_ENTRY_LOOP_FROM(rq, from, entry, count) \ argument
299 for ((entry) = (from); \
300 (entry) < (&(rq)->entries[count]) && ftl_rq_entry_loop_assert(rq, entry, count); (entry)++)
302 #define FTL_RQ_ENTRY_LOOP(rq, entry, count) \ argument
303 FTL_RQ_ENTRY_LOOP_FROM(rq, (rq)->entries, entry, count)
342 ftl_rq_from_entry(struct ftl_rq_entry *entry) in ftl_rq_from_entry() argument
[all …]
H A Dftl_rq.c16 struct ftl_rq_entry *entry; in ftl_rq_new() local
50 entry = rq->entries; in ftl_rq_new()
52 uint64_t *index = (uint64_t *)&entry->index; in ftl_rq_new()
55 entry->addr = FTL_ADDR_INVALID; in ftl_rq_new()
56 entry->lba = FTL_LBA_INVALID; in ftl_rq_new()
57 entry->io_payload = io_payload; in ftl_rq_new()
58 entry->seq_id = 0; in ftl_rq_new()
61 entry->io_md = io_md; in ftl_rq_new()
64 entry++; in ftl_rq_new()
H A Dftl_nv_cache.c281 TAILQ_INSERT_TAIL(&nv_cache->chunk_free_list, chunk, entry); in ftl_nv_cache_init()
285 TAILQ_INSERT_TAIL(&nv_cache->chunk_inactive_list, chunk, entry); in ftl_nv_cache_init()
300 TAILQ_INSERT_TAIL(&nv_cache->compactor_list, compactor, entry); in ftl_nv_cache_init()
313 /* One entry per open chunk */ in ftl_nv_cache_init()
363 TAILQ_REMOVE(&nv_cache->compactor_list, compactor, entry); in ftl_nv_cache_deinit()
417 TAILQ_REMOVE(&nv_cache->chunk_open_list, chunk, entry); in ftl_nv_cache_get_wr_buffer()
550 TAILQ_INSERT_TAIL(&nv_cache->needs_free_persist_list, chunk, entry); in ftl_chunk_free_chunk_free_entry()
587 TAILQ_INSERT_TAIL(&nv_cache->chunk_free_list, chunk, entry); in ftl_chunk_persist_free_state()
612 TAILQ_FOREACH_SAFE(chunk, &nv_cache->needs_free_persist_list, entry, tchunk) { in compaction_stats_update()
619 TAILQ_REMOVE(&nv_cache->needs_free_persist_list, chunk, entry); in compaction_stats_update()
730 struct ftl_rq_entry *entry; compaction_process_pin_lba() local
752 struct ftl_rq_entry *entry = arg; compaction_process_read_entry_cb() local
778 struct ftl_rq_entry *entry = arg; compaction_process_read_entry() local
871 compaction_process_invalidate_entry(struct ftl_rq_entry * entry) compaction_process_invalidate_entry() argument
883 struct ftl_rq_entry *entry; compaction_process_pad() local
897 struct ftl_rq_entry *entry, *io; compaction_process_read() local
948 compaction_entry_read_pos(struct ftl_nv_cache * nv_cache,struct ftl_rq_entry * entry) compaction_entry_read_pos() argument
986 struct ftl_rq_entry *entry; compaction_process_start() local
1032 struct ftl_rq_entry *entry; compaction_process_ftl_done() local
1072 struct ftl_rq_entry *entry; compaction_process_finish_read() local
1125 struct ftl_rq_entry *entry; compactor_alloc() local
[all...]
H A Dftl_band_ops.c91 struct ftl_rq_entry *entry = arg; in read_rq_end() local
92 struct ftl_band *band = entry->io.band; in read_rq_end()
93 struct ftl_rq *rq = ftl_rq_from_entry(entry); in read_rq_end()
99 ftl_band_rq_bdev_read(entry); in read_rq_end()
114 struct ftl_rq_entry *entry = _entry; in ftl_band_rq_bdev_read() local
115 struct ftl_rq *rq = ftl_rq_from_entry(entry); in ftl_band_rq_bdev_read()
119 rc = spdk_bdev_read_blocks(dev->base_bdev_desc, dev->base_ioch, entry->io_payload, in ftl_band_rq_bdev_read()
120 entry->bdev_io.offset_blocks, entry->bdev_io.num_blocks, in ftl_band_rq_bdev_read()
121 read_rq_end, entry); in ftl_band_rq_bdev_read()
125 entry->bdev_io.wait_entry.bdev = bdev; in ftl_band_rq_bdev_read()
[all …]
H A Dftl_reloc.c298 struct ftl_rq_entry *entry = &rq->entries[rq->iter.idx]; in move_advance_rq() local
308 entry->lba = band->p2l_map.band_map[offset].lba; in move_advance_rq()
309 entry->addr = rq->io.addr; in move_advance_rq()
310 entry->owner.priv = band; in move_advance_rq()
311 entry->seq_id = band->p2l_map.band_map[offset].seq_id; in move_advance_rq()
313 entry++; in move_advance_rq()
370 struct ftl_rq_entry *entry = &rq->entries[rq->iter.idx]; in move_rq_pad() local
373 entry->addr = rq->io.addr; in move_rq_pad()
374 entry->owner.priv = band; in move_rq_pad()
375 entry->lba = FTL_LBA_INVALID; in move_rq_pad()
[all …]
/spdk/lib/sock/
H A Dsock.c51 struct spdk_sock_placement_id_entry *entry; in _sock_map_entry_alloc() local
53 entry = calloc(1, sizeof(*entry)); in _sock_map_entry_alloc()
54 if (!entry) { in _sock_map_entry_alloc()
55 SPDK_ERRLOG("Cannot allocate an entry for placement_id=%u\n", placement_id); in _sock_map_entry_alloc()
59 entry->placement_id = placement_id; in _sock_map_entry_alloc()
61 STAILQ_INSERT_TAIL(&map->entries, entry, link); in _sock_map_entry_alloc()
63 return entry; in _sock_map_entry_alloc()
70 struct spdk_sock_placement_id_entry *entry; in spdk_sock_map_insert() local
74 STAILQ_FOREACH(entry, in spdk_sock_map_insert()
112 struct spdk_sock_placement_id_entry *entry; spdk_sock_map_release() local
134 struct spdk_sock_placement_id_entry *entry; spdk_sock_map_lookup() local
174 struct spdk_sock_placement_id_entry *entry, *tmp; spdk_sock_map_cleanup() local
187 struct spdk_sock_placement_id_entry *entry; spdk_sock_map_find_free() local
[all...]
/spdk/lib/trace_parser/
H A Dtrace.cpp39 spdk_trace_entry *entry;
44 argument_context(spdk_trace_entry *entry, uint16_t lcore) : in argument_context()
45 entry(entry), lcore(lcore) in argument_context()
47 buffer = reinterpret_cast<spdk_trace_entry_buffer *>(entry); in argument_context()
72 bool next_entry(spdk_trace_parser_entry *entry);
125 spdk_trace_entry *entry = argctx->entry; in build_arg()
139 buffer->tsc != entry->tsc)) { in build_arg()
164 spdk_trace_entry *entry; in next_entry()
38 spdk_trace_entry *entry; global() member
124 spdk_trace_entry *entry = argctx->entry; build_arg() local
163 spdk_trace_entry *entry; next_entry() local
425 spdk_trace_parser_next_entry(struct spdk_trace_parser * parser,struct spdk_trace_parser_entry * entry) spdk_trace_parser_next_entry() argument
[all...]
/spdk/test/common/lib/
H A Dtest_iobuf.c18 struct spdk_iobuf_entry *entry, uint64_t len));
72 struct spdk_iobuf_entry *entry, spdk_iobuf_get_cb cb_fn) in spdk_iobuf_get()
99 if (entry) { in spdk_iobuf_get()
100 entry->cb_fn = cb_fn; in spdk_iobuf_get()
101 STAILQ_INSERT_TAIL(&g_iobuf_entries, entry, stailq); in spdk_iobuf_get()
116 struct spdk_iobuf_entry *entry; in spdk_iobuf_put()
132 entry = STAILQ_FIRST(&g_iobuf_entries); in spdk_iobuf_put()
134 entry->cb_fn(entry, buf); in spdk_iobuf_put()
68 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
109 struct spdk_iobuf_entry *entry; spdk_iobuf_put() local
/spdk/scripts/bpf/
H A Dtrace.py239 def _parse_entry(self, entry): argument
240 tpoint = self._tpoints[entry['tpoint']]
241 obj = entry.get('object', {})
242 return TraceEntry(tpoint=tpoint, lcore=entry['lcore'], tsc=entry['tsc'],
243 size=entry.get('size'), object_id=obj.get('id'),
244 object_ptr=obj.get('value'), related=entry.get('related'),
245 time=obj.get('time'), owner=entry.get('owner'),
246 args={n.name: v for n, v in zip(tpoint.args, entry.get('args', []))})
393 entry = pe.entry.contents
395 tpoint = self._tpoints[entry.tpoint_id]
[all …]
/spdk/test/nvme/startup/
H A Dstartup.c43 struct ctrlr_entry *entry; in attach_cb() local
46 entry = malloc(sizeof(struct ctrlr_entry)); in attach_cb()
47 if (entry == NULL) { in attach_cb()
64 snprintf(entry->name, sizeof(entry->name), "%-20.20s (%-20.20s)", cdata->mn, cdata->sn); in attach_cb()
66 entry->ctrlr = ctrlr; in attach_cb()
67 TAILQ_INSERT_TAIL(&g_controllers, entry, link); in attach_cb()
/spdk/test/unit/lib/nvmf/ctrlr_discovery.c/
H A Dctrlr_discovery_ut.c143 struct spdk_nvmf_discovery_log_page_entry *entry) in nvmf_transport_listener_discover()
145 transport->ops->listener_discover(transport, trid, entry); in nvmf_transport_listener_discover()
150 struct spdk_nvme_transport_id *trid, struct spdk_nvmf_discovery_log_page_entry *entry) in test_dummy_listener_discover()
152 entry->trtype = 42; in test_dummy_listener_discover()
286 struct spdk_nvmf_discovery_log_page_entry *entry; in test_discovery_log()
352 /* Get just the first entry, no header */ in test_discovery_log()
354 entry = (struct spdk_nvmf_discovery_log_page_entry *)buffer; in test_discovery_log()
356 offsetof(struct spdk_nvmf_discovery_log_page, entries[0]), sizeof(*entry), &trid); in test_discovery_log()
357 CU_ASSERT(entry->trtype == 42); in test_discovery_log()
389 struct spdk_nvmf_discovery_log_page_entry *entry) in test_rdma_discover()
142 nvmf_transport_listener_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) nvmf_transport_listener_discover() argument
149 test_dummy_listener_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_dummy_listener_discover() argument
285 struct spdk_nvmf_discovery_log_page_entry *entry; test_discovery_log() local
388 test_rdma_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_rdma_discover() argument
398 test_tcp_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_tcp_discover() argument
[all...]
/spdk/lib/ftl/base/
H A Dftl_base_dev.c19 struct ftl_base_device_type *entry; in ftl_base_device_type_get_desc() local
21 TAILQ_FOREACH(entry, &g_devs, base_devs_entry) { in ftl_base_device_type_get_desc()
22 if (0 == strcmp(entry->name, name)) { in ftl_base_device_type_get_desc()
23 return entry; in ftl_base_device_type_get_desc()
/spdk/lib/thread/
H A Diobuf.c511 struct spdk_iobuf_entry *entry __attribute__((unused)); in spdk_iobuf_entry_abort()
515 STAILQ_FOREACH(entry, cache->small.queue, stailq) { in spdk_iobuf_entry_abort()
516 assert(entry->module != ch->module);
518 STAILQ_FOREACH(entry, cache->large.queue, stailq) {
519 assert(entry->module != ch->module);
610 struct spdk_iobuf_entry *entry, *tmp; in spdk_iobuf_put()
613 STAILQ_FOREACH_SAFE(entry, pool->queue, stailq, tmp) { in spdk_iobuf_put()
615 if (entry->module != ch->module) { in spdk_iobuf_put()
619 rc = cb_fn(ch, entry, cb_ctx); in spdk_iobuf_put()
654 struct spdk_iobuf_entry *entry, uint64_ in iobuf_get_channel_stats()
393 struct spdk_iobuf_entry *entry __attribute__((unused)); spdk_iobuf_channel_fini() local
483 struct spdk_iobuf_entry *entry, *tmp; spdk_iobuf_for_each_entry() local
502 spdk_iobuf_entry_abort(struct spdk_iobuf_channel * ch,struct spdk_iobuf_entry * entry,uint64_t len) spdk_iobuf_entry_abort() argument
521 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
574 struct spdk_iobuf_entry *entry; spdk_iobuf_put() local
[all...]
/spdk/lib/nvme/
H A Dnvme_fabric.c283 nvme_fabric_discover_probe(struct spdk_nvmf_discovery_log_page_entry *entry, in nvme_fabric_discover_probe() argument
293 if (entry->subtype == SPDK_NVMF_SUBTYPE_DISCOVERY_CURRENT || in nvme_fabric_discover_probe()
294 entry->subtype == SPDK_NVMF_SUBTYPE_DISCOVERY) { in nvme_fabric_discover_probe()
298 } else if (entry->subtype != SPDK_NVMF_SUBTYPE_NVME) { in nvme_fabric_discover_probe()
299 SPDK_WARNLOG("Skipping unknown subtype %u\n", entry->subtype); in nvme_fabric_discover_probe()
303 trid.trtype = entry->trtype; in nvme_fabric_discover_probe()
304 spdk_nvme_transport_id_populate_trstring(&trid, spdk_nvme_transport_id_trtype_str(entry->trtype)); in nvme_fabric_discover_probe()
311 trid.adrfam = entry->adrfam; in nvme_fabric_discover_probe()
314 end = memchr(entry->subnqn, '\0', SPDK_NVMF_NQN_MAX_LEN + 1); in nvme_fabric_discover_probe()
316 SPDK_ERRLOG("Discovery entry SUBNQ in nvme_fabric_discover_probe()
[all...]
/spdk/test/app/stub/
H A Dstub.c74 struct ctrlr_entry *entry; in attach_cb()
76 entry = malloc(sizeof(struct ctrlr_entry)); in attach_cb()
77 if (entry == NULL) { in attach_cb()
82 entry->ctrlr = ctrlr; in attach_cb()
83 TAILQ_INSERT_TAIL(&g_controllers, entry, link); in attach_cb()
73 struct ctrlr_entry *entry; attach_cb() local
/spdk/lib/ftl/mngt/
H A Dftl_mngt.c18 TAILQ_ENTRY(ftl_mngt_step) entry;
93 TAILQ_INSERT_TAIL(&mngt->action_queue_todo, step, action.entry); in init_step()
108 TAILQ_CONCAT(&steps, &mngt->action_queue_todo, action.entry); in free_mngt()
109 TAILQ_CONCAT(&steps, &mngt->action_queue_done, action.entry); in free_mngt()
113 TAILQ_REMOVE(&steps, step, action.entry); in free_mngt()
197 rollback.entry); in _ftl_mngt_process_execute()
259 TAILQ_FOREACH(step, &mngt->action_queue_todo, action.entry) { in ftl_mngt_process_rollback()
262 rollback.entry); in ftl_mngt_process_rollback()
524 TAILQ_REMOVE(&mngt->action_queue_todo, step, action.entry); in action_done()
526 TAILQ_INSERT_TAIL(&mngt->action_queue_done, step, action.entry); in action_done()
[all …]

1234