/spdk/include/spdk/ |
H A D | mmio.h | 28 spdk_mmio_read_1(const volatile uint8_t *addr) in spdk_mmio_read_1() argument 31 return *addr; in spdk_mmio_read_1() 35 spdk_mmio_write_1(volatile uint8_t *addr, uint8_t val) in spdk_mmio_write_1() argument 38 *addr = val; in spdk_mmio_write_1() 42 spdk_mmio_read_2(const volatile uint16_t *addr) in spdk_mmio_read_2() argument 45 return *addr; in spdk_mmio_read_2() 49 spdk_mmio_write_2(volatile uint16_t *addr, uint16_t val) in spdk_mmio_write_2() argument 52 *addr = val; in spdk_mmio_write_2() 56 spdk_mmio_read_4(const volatile uint32_t *addr) in spdk_mmio_read_4() argument 59 return *addr; in spdk_mmio_read_4() [all …]
|
/spdk/test/unit/lib/ftl/ftl_band.c/ |
H A D | ftl_band_ut.c | 40 ftl_addr addr, size_t addr_cnt)); 123 DEFINE_STUB(ftl_nv_cache_read, int, (struct ftl_io *io, ftl_addr addr, uint32_t num_blocks, 219 ftl_addr addr; in addr_from_zone_id() local 221 addr = zone_id * g_geo.zone_size; in addr_from_zone_id() 222 return addr; in addr_from_zone_id() 228 ftl_addr addr; in test_band_block_offset_from_addr_base() local 232 addr = addr_from_zone_id(0); in test_band_block_offset_from_addr_base() 233 addr += TEST_BAND_IDX * ftl_get_num_blocks_in_band(g_dev); in test_band_block_offset_from_addr_base() 235 offset = ftl_band_block_offset_from_addr(g_band, addr); in test_band_block_offset_from_addr_base() 243 ftl_addr addr; in test_band_block_offset_from_addr_offset() local [all …]
|
/spdk/test/unit/lib/iscsi/tgt_node.c/ |
H A D | tgt_node_ut.c | 166 char *addr; in allow_ipv6_allowed() local 169 addr = "2001:ad6:1234:5678:9abc::"; in allow_ipv6_allowed() 171 result = iscsi_ipv6_netmask_allow_addr(netmask, addr); in allow_ipv6_allowed() 174 result = iscsi_netmask_allow_addr(netmask, addr); in allow_ipv6_allowed() 179 addr = "2001:ad6:1234:5678:9abc::1"; in allow_ipv6_allowed() 180 result = iscsi_ipv6_netmask_allow_addr(netmask, addr); in allow_ipv6_allowed() 189 char *addr; in allow_ipv6_denied() local 192 addr = "2001:ad6:1234:5678:9abc::"; in allow_ipv6_denied() 194 result = iscsi_ipv6_netmask_allow_addr(netmask, addr); in allow_ipv6_denied() 197 result = iscsi_netmask_allow_addr(netmask, addr); in allow_ipv6_denied() [all …]
|
/spdk/test/env/memory/ |
H A D | memory_ut.c | 207 uint64_t addr; in test_mem_map_translation() local 215 addr = spdk_mem_map_translate(map, 10, NULL); in test_mem_map_translation() 216 CU_ASSERT(addr == default_translation); in test_mem_map_translation() 236 addr = spdk_mem_map_translate(map, 0, &mapping_length); in test_mem_map_translation() 237 CU_ASSERT(addr == 0); in test_mem_map_translation() 242 addr = spdk_mem_map_translate(map, VALUE_4KB, &mapping_length); in test_mem_map_translation() 243 CU_ASSERT(addr == 0); in test_mem_map_translation() 251 addr = spdk_mem_map_translate(map, 0, NULL); in test_mem_map_translation() 252 CU_ASSERT(addr == 0); in test_mem_map_translation() 256 addr in test_mem_map_translation() [all...] |
/spdk/python/spdk/rpc/ |
H A D | client.py | 22 def get_addr_type(addr): argument 24 socket.inet_pton(socket.AF_INET, addr) 29 socket.inet_pton(socket.AF_INET6, addr) 33 if os.path.exists(addr): 44 def __init__(self, addr, port=None, timeout=None, **kwargs): argument 49 self._logger = logging.getLogger("JSONRPCClient(%s)" % addr) 61 self._connect(addr, port) 68 self._connect(addr, port) 76 def _connect(self, addr, port): argument 78 addr_type = get_addr_type(addr) [all …]
|
/spdk/test/unit/lib/ftl/ftl_l2p/ |
H A D | ftl_l2p_ut.c | 67 ftl_l2p_set(struct spdk_ftl_dev *dev, uint64_t lba, ftl_addr addr) in ftl_l2p_set() argument 69 ((uint64_t *)dev->l2p)[lba] = addr; in ftl_l2p_set() 81 ftl_addr addr; in test_addr_cached() local 86 addr = ftl_addr_from_nvc_offset(g_dev, i); in test_addr_cached() 87 ftl_l2p_set(g_dev, i, addr); in test_addr_cached() 92 addr = ftl_l2p_get(g_dev, i); in test_addr_cached() 95 CU_ASSERT_TRUE(ftl_addr_in_nvc(g_dev, addr)); in test_addr_cached() 96 CU_ASSERT_EQUAL(ftl_addr_to_nvc_offset(g_dev, addr), i); in test_addr_cached() 98 CU_ASSERT_FALSE(ftl_addr_in_nvc(g_dev, addr)); in test_addr_cached()
|
/spdk/test/iscsi_tgt/sock/ |
H A D | sock.sh | 12 local ap=$1 pid=$2 addr port proc 13 addr=${ap%:*} port=${ap#*:} 15 IFS="." read -ra addr <<< "$addr" 16 printf -v addr '%02X%02X%02X%02X:%04X' \ 21 [[ $(< "$proc") == *"$addr 00000000:0000 0A"* ]] # TCP_LISTEN == 0x0A 25 local addr="$2" 27 echo "Waiting for process to start up and listen on address $addr..." 39 tcp_sock "$addr" "$1" && return 0 44 echo "ERROR: timeout while waiting for process (pid: $1) to start listening on '$addr'"
|
/spdk/module/event/subsystems/vmd/ |
H A D | vmd_rpc.c | 27 char *addr; member 31 {"addr", offsetof(struct rpc_vmd_remove_device, addr), spdk_json_decode_string}, 38 struct spdk_pci_addr addr; in rpc_vmd_remove_device() local 55 rc = spdk_pci_addr_parse(&addr, req.addr); in rpc_vmd_remove_device() 61 rc = spdk_vmd_remove_device(&addr); in rpc_vmd_remove_device() 69 free(req.addr); in rpc_vmd_remove_device()
|
/spdk/lib/ftl/ |
H A D | ftl_band.h | 57 ftl_addr addr; member 164 uint64_t ftl_band_block_offset_from_addr(struct ftl_band *band, ftl_addr addr); 173 ftl_addr ftl_band_next_xfer_addr(struct ftl_band *band, ftl_addr addr, size_t num_blocks); 174 ftl_addr ftl_band_next_addr(struct ftl_band *band, ftl_addr addr, size_t offset); 177 void ftl_band_set_p2l(struct ftl_band *band, uint64_t lba, ftl_addr addr, uint64_t seq_id); 178 void ftl_band_set_addr(struct ftl_band *band, uint64_t lba, ftl_addr addr); 179 struct ftl_band *ftl_band_from_addr(struct spdk_ftl_dev *dev, ftl_addr addr); 249 band->md->iter.addr = band->start_addr; in ftl_band_iter_init() 257 band->md->iter.addr = ftl_band_next_xfer_addr(band, band->md->iter.addr, num_blocks); in ftl_band_iter_advance() 258 assert(band->md->iter.addr != FTL_ADDR_INVALID); in ftl_band_iter_advance() [all …]
|
H A D | ftl_band.c | 129 ftl_addr addr; in ftl_band_tail_md_addr() local 134 addr = ftl_band_tail_md_offset(band) + band->start_addr; in ftl_band_tail_md_addr() 136 return addr; in ftl_band_tail_md_addr() 209 ftl_band_set_p2l(struct ftl_band *band, uint64_t lba, ftl_addr addr, uint64_t seq_id) in ftl_band_set_p2l() argument 214 offset = ftl_band_block_offset_from_addr(band, addr); in ftl_band_set_p2l() 221 ftl_band_set_addr(struct ftl_band *band, uint64_t lba, ftl_addr addr) in ftl_band_set_addr() argument 224 ftl_bitmap_set(band->dev->valid_map, addr); in ftl_band_set_addr() 247 ftl_addr_get_band(const struct spdk_ftl_dev *dev, ftl_addr addr) in ftl_addr_get_band() argument 249 return (addr - dev->bands->start_addr) / ftl_get_num_blocks_in_band(dev); in ftl_addr_get_band() 253 ftl_band_from_addr(struct spdk_ftl_dev *dev, ftl_addr addr) in ftl_band_from_addr() argument [all …]
|
H A D | ftl_core.h | 216 void ftl_invalidate_addr(struct spdk_ftl_dev *dev, ftl_addr addr); 285 ftl_addr_in_nvc(const struct spdk_ftl_dev *dev, ftl_addr addr) in ftl_addr_to_nvc_offset() argument 287 assert(addr != FTL_ADDR_INVALID); in ftl_addr_to_nvc_offset() 288 return addr >= dev->layout.base.total_blocks; in ftl_addr_to_nvc_offset() 292 ftl_addr_to_nvc_offset(const struct spdk_ftl_dev *dev, ftl_addr addr) in ftl_addr_from_nvc_offset() 294 assert(ftl_addr_in_nvc(dev, addr)); in ftl_addr_from_nvc_offset() 295 return addr - dev->layout.base.total_blocks; in ftl_addr_from_nvc_offset() 278 ftl_addr_in_nvc(const struct spdk_ftl_dev * dev,ftl_addr addr) ftl_addr_in_nvc() argument
|
H A D | ftl_core.c | 139 ftl_invalidate_addr(struct spdk_ftl_dev *dev, ftl_addr addr) in ftl_invalidate_addr() argument 144 if (ftl_addr_in_nvc(dev, addr)) { in ftl_invalidate_addr() 145 ftl_bitmap_clear(dev->valid_map, addr); in ftl_invalidate_addr() 149 band = ftl_band_from_addr(dev, addr); in ftl_invalidate_addr() 154 if (ftl_bitmap_get(dev->valid_map, addr)) { in ftl_invalidate_addr() 156 ftl_bitmap_clear(dev->valid_map, addr); in ftl_invalidate_addr() 163 p2l_map->band_map[ftl_band_block_offset_from_addr(band, addr)].lba = FTL_LBA_INVALID; in ftl_invalidate_addr() 164 p2l_map->band_map[ftl_band_block_offset_from_addr(band, addr)].seq_id = 0; in ftl_invalidate_addr() 175 ftl_get_next_read_addr(struct ftl_io *io, ftl_addr *addr) in ftl_get_next_read_addr() argument 182 *addr in ftl_get_next_read_addr() 231 ftl_addr addr; ftl_submit_read() local [all...] |
H A D | ftl_reloc.c | 303 offset = ftl_band_block_offset_from_addr(band, rq->io.addr); in move_advance_rq() 309 entry->addr = rq->io.addr; in move_advance_rq() 314 rq->io.addr = ftl_band_next_addr(band, rq->io.addr, 1); in move_advance_rq() 335 iter->addr = FTL_ADDR_INVALID; in move_init_entries() 373 entry->addr = rq->io.addr; in move_rq_pad() 378 rq->io.addr = ftl_band_next_addr(band, rq->io.addr, 1); in move_rq_pad() 507 ftl_addr addr = rq->io.addr; in move_finish_write() local 520 ftl_l2p_update_base(dev, iter->lba, addr, iter->addr); in move_finish_write() 523 addr = ftl_band_next_addr(rq_band, addr, 1); in move_finish_write()
|
/spdk/test/external_code/nvme/ |
H A D | identify.c | 30 print_controller(struct nvme_ctrlr *ctrlr, const struct spdk_pci_addr *addr) in print_controller() argument 36 spdk_pci_addr_fmt(fmtaddr, sizeof(fmtaddr), addr); in print_controller() 78 attach_cb(void *cb_ctx, const struct spdk_pci_addr *addr, in attach_cb() argument 83 print_controller(ctrlr, addr); in attach_cb() 91 struct spdk_pci_addr addr; in main() local 105 rc = spdk_pci_addr_parse(&addr, argv[1]); in main() 111 ctrlr = nvme_connect(&addr); in main() 118 print_controller(ctrlr, &addr); in main()
|
H A D | nvme.c | 108 find_ctrlr_by_addr(struct spdk_pci_addr *addr) in find_ctrlr_by_addr() argument 115 if (spdk_pci_addr_compare(addr, &ctrlr_addr) == 0) { in find_ctrlr_by_addr() 279 char addr[32] = {}; in pcie_enum_cb() local 284 spdk_pci_addr_fmt(addr, sizeof(addr), &pci_dev->addr); in pcie_enum_cb() 288 SPDK_ERRLOG("Failed to allocate NVMe controller: %s\n", addr); in pcie_enum_cb() 293 SPDK_ERRLOG("Failed to claim PCI device: %s\n", addr); in pcie_enum_cb() 299 SPDK_ERRLOG("Failed to allocate BAR0 for NVMe controller: %s\n", addr); in pcie_enum_cb() 320 SPDK_ERRLOG("Failed to allocate identify data for NVMe controller: %s\n", addr); in pcie_enum_cb() 548 probe_internal(struct spdk_pci_addr * addr,nvme_attach_cb attach_cb,void * cb_ctx) probe_internal() argument 604 nvme_connect(struct spdk_pci_addr * addr) nvme_connect() argument [all...] |
/spdk/lib/ftl/utils/ |
H A D | ftl_addr_utils.h | 16 ftl_addr addr = b32[offset]; in ftl_addr_load() local 18 if (addr == (uint32_t)FTL_ADDR_INVALID) { in ftl_addr_load() 21 return addr; in ftl_addr_load() 30 ftl_addr_store(struct spdk_ftl_dev *dev, void *buffer, uint64_t offset, ftl_addr addr) in ftl_addr_store() argument 34 b32[offset] = addr; in ftl_addr_store() 37 b64[offset] = addr; in ftl_addr_store()
|
/spdk/lib/vmd/ |
H A D | vmd.c | 39 vmd_is_valid_cfg_addr(struct vmd_pci_bus *bus, uint64_t addr) in vmd_is_valid_cfg_addr() argument 41 return addr >= (uint64_t)bus->vmd->cfg_vaddr && in vmd_is_valid_cfg_addr() 42 addr < bus->vmd->cfgbar_size + (uint64_t)bus->vmd->cfg_vaddr; in vmd_is_valid_cfg_addr() 89 if (prev != NULL && (prev->addr + prev->size == region->addr)) { in vmd_hotplug_coalesce_regions() 109 assert(region->addr >= hp->bar.start && region->addr < hp->bar.start + hp->bar.size); in vmd_hotplug_free_region() 112 if (current->addr > region->addr) { in vmd_hotplug_free_region() 120 assert(prev->addr in vmd_hotplug_free_region() 131 vmd_hotplug_free_addr(struct vmd_hot_plug * hp,uint64_t addr) vmd_hotplug_free_addr() argument 787 vmd_dev_unmap_bar(struct spdk_pci_device * _dev,uint32_t bar,void * addr) vmd_dev_unmap_bar() argument 1264 vmd_find_device(const struct spdk_pci_addr * addr) vmd_find_device() argument 1452 spdk_vmd_remove_device(const struct spdk_pci_addr * addr) spdk_vmd_remove_device() argument 1484 vmd_attach_device(const struct spdk_pci_addr * addr) vmd_attach_device() argument [all...] |
/spdk/lib/env_dpdk/ |
H A D | pci_event.c | 22 struct sockaddr_nl addr; in spdk_pci_event_listen() local 29 memset(&addr, 0, sizeof(addr)); in spdk_pci_event_listen() 30 addr.nl_family = AF_NETLINK; in spdk_pci_event_listen() 31 addr.nl_pid = 0; in spdk_pci_event_listen() 32 addr.nl_groups = 0xffffffff; in spdk_pci_event_listen() 74 if (bind(netlink_fd, (struct sockaddr *) &addr, sizeof(addr)) < 0) { in spdk_pci_event_listen()
|
/spdk/lib/ftl/mngt/ |
H A D | ftl_mngt_self_test.c | 84 ftl_addr addr = ftl_l2p_get(dev, lba); in test_valid_map_pin_cb() local 87 if (FTL_ADDR_INVALID == addr) { in test_valid_map_pin_cb() 91 if (ftl_bitmap_get(ctx->valid_map.bitmap, addr)) { in test_valid_map_pin_cb() 94 "address 0x%.16"PRIX64"\n", addr); in test_valid_map_pin_cb() 97 ftl_bitmap_set(ctx->valid_map.bitmap, addr); in test_valid_map_pin_cb() 100 if (ftl_addr_in_nvc(dev, addr)) { in test_valid_map_pin_cb() 106 valid = ftl_bitmap_get(dev->valid_map, addr); in test_valid_map_pin_cb() 112 lba, addr); in test_valid_map_pin_cb()
|
/spdk/test/env/pci/ |
H A D | pci_ut.c | 62 ut_unmap_bar(struct spdk_pci_device *device, uint32_t bar, void *addr) in ut_unmap_bar() argument 104 ut_attach_cb(const struct spdk_pci_addr *addr) in ut_attach_cb() argument 136 spdk_pci_addr_parse(&ut_dev.pci.addr, "10000:00:01.0"); in pci_hook_test() 137 CU_ASSERT(ut_dev.pci.addr.domain == 0x10000); in pci_hook_test() 138 CU_ASSERT(ut_dev.pci.addr.bus == 0x0); in pci_hook_test() 139 CU_ASSERT(ut_dev.pci.addr.dev == 0x1); in pci_hook_test() 140 CU_ASSERT(ut_dev.pci.addr.func == 0x0); in pci_hook_test() 152 rc = spdk_pci_device_attach(&ut_pci_driver, ut_enum_cb, NULL, &ut_dev.pci.addr); in pci_hook_test() 201 rc = spdk_pci_device_attach(&ut_pci_driver, ut_enum_cb, NULL, &ut_dev.pci.addr); in pci_hook_test()
|
/spdk/test/env/mem_callbacks/ |
H A D | mem_callbacks.c | 27 memory_hotplug_cb(enum rte_mem_event event_type, const void *addr, size_t len, void *arg) in memory_hotplug_cb() argument 35 printf("register %p %ju\n", addr, len); in memory_hotplug_cb() 36 allocation->vaddr = (uintptr_t)addr; in memory_hotplug_cb() 41 if (allocation->vaddr == (uintptr_t)addr && allocation->len == len) { in memory_hotplug_cb() 45 printf("unregister %p %ju %s\n", addr, len, allocation == NULL ? "FAILED" : "PASSED"); in memory_hotplug_cb() 61 printf("register %p %ju\n", ms->addr, len); in memory_iter_cb() 62 allocation->vaddr = (uintptr_t)ms->addr; in memory_iter_cb()
|
/spdk/test/unit/lib/env_dpdk/pci_event.c/ |
H A D | pci_event_ut.c | 26 struct spdk_pci_addr addr = {}; in test_pci_parse_event() local 31 spdk_pci_addr_parse(&addr, "0000:81:00.0"); in test_pci_parse_event() 64 CU_ASSERT(spdk_pci_addr_compare(&addr, &event.traddr) == 0); in test_pci_parse_event() 74 CU_ASSERT(spdk_pci_addr_compare(&addr, &event.traddr) == 0); in test_pci_parse_event() 83 CU_ASSERT(spdk_pci_addr_compare(&addr, &event.traddr) == 0); in test_pci_parse_event()
|
/spdk/lib/nvme/ |
H A D | nvme_pcie.c | 323 void *addr = NULL; in nvme_pcie_ctrlr_map_cmb() local 352 rc = spdk_pci_device_map_bar(pctrlr->devhandle, bir, &addr, in nvme_pcie_ctrlr_map_cmb() 354 if ((rc != 0) || addr == NULL) { in nvme_pcie_ctrlr_map_cmb() 366 pctrlr->cmb.bar_va = addr; in nvme_pcie_ctrlr_map_cmb() 386 void *addr = pctrlr->cmb.bar_va; in nvme_pcie_ctrlr_unmap_cmb() local 388 if (addr) { in nvme_pcie_ctrlr_unmap_cmb() 397 rc = spdk_pci_device_unmap_bar(pctrlr->devhandle, cmbloc.bits.bir, addr); in nvme_pcie_ctrlr_unmap_cmb() 504 void *addr = NULL; in nvme_pcie_ctrlr_map_pmr() local 525 rc = spdk_pci_device_map_bar(pctrlr->devhandle, bir, &addr, &bar_phys_addr, &bar_size); in nvme_pcie_ctrlr_map_pmr() 526 if ((rc != 0) || addr in nvme_pcie_ctrlr_map_pmr() 576 void *addr = pctrlr->pmr.bar_va; nvme_pcie_ctrlr_unmap_pmr() local 770 void *addr = NULL; nvme_pcie_ctrlr_allocate_bars() local 795 void *addr = (void *)pctrlr->regs; nvme_pcie_ctrlr_free_bars() local [all...] |
/spdk/scripts/ |
H A D | dpdk_mem_info.py | 115 def __init__(self, size, status, addr): argument 118 self.addr = addr 122 …print("{}element at address: {} with size: {:>15}".format(header, hex(self.addr), B_to_MiB(self.si… 125 ele_fini_addr = self.addr + self.size 127 if (self.addr <= memzone.address and ele_fini_addr >= memzone_fini_addr): 248 name, length, addr, trash = info.split(',', 3) 254 trash, addr = addr.split(':', 1) 256 return memzone(name, int(length, 0), int(addr, 0)) 260 trash, addr, iova, length, pagesz = line.split(':') 261 addr, trash = addr.strip().split(' ') [all …]
|
/spdk/lib/idxd/ |
H A D | idxd_user.c | 63 void *addr = NULL; in idxd_unmap_pci_bar() local 66 addr = (void *)user_idxd->registers; in idxd_unmap_pci_bar() 68 addr = (void *)user_idxd->idxd.portal; in idxd_unmap_pci_bar() 71 if (addr) { in idxd_unmap_pci_bar() 72 rc = spdk_pci_device_unmap_bar(user_idxd->device, 0, addr); in idxd_unmap_pci_bar() 81 void *addr; in idxd_map_pci_bars() local 84 rc = spdk_pci_device_map_bar(user_idxd->device, IDXD_MMIO_BAR, &addr, &phys_addr, &size); in idxd_map_pci_bars() 85 if (rc != 0 || addr == NULL) { in idxd_map_pci_bars() 89 user_idxd->registers = (struct idxd_registers *)addr; in idxd_map_pci_bars() 91 rc = spdk_pci_device_map_bar(user_idxd->device, IDXD_WQ_BAR, &addr, &phys_addr, &size); in idxd_map_pci_bars() [all …]
|