/spdk/test/fuzz/ |
H A D | llvm.sh |
|
/spdk/scripts/perf/nvmf/ |
H A D | run_nvmf.py | 90 self.log.info("Please use a name which contains only letters, numbers or dashes") 202 self.log.info("Loading drivers") 216 self.log.info("Loaded irdma driver with RoCE enabled") 218 self.log.info("Leaving irdma driver with RoCE enabled") 221 self.log.info("Loaded irdma driver with iWARP enabled") 230 self.log.info("Keeping NIC's default pause frames setting") 233 self.log.info("Turning off pause frames") 236 self.log.info("Turning on pause frames") 246 self.log.info(f"Setting rps_flow_cnt={rps_flow_cnt} for {nic_name} rx queues") 256 self.log.info( [all...] |
H A D | common.py | 114 logging.info("Getting FIO stats for %s" % fio_config) 152 logging.info("Matching result files for current fio config %s:" % job_name) 154 logging.info("\t %s" % j) 161 logging.info("\tGetting stats for initiator %s" % i) 171 logging.info([float("{0:.3f}".format(x)) for x in stats]) 180 logging.info("\tAverage results for initiator %s" % i) 181 logging.info(init_results) 224 logging.info("You can find the test results in the file %s" % os.path.join(results_dir, csv_file))
|
/spdk/scripts/bpf/ |
H A D | sched.bt | 30 $info = (struct spdk_scheduler_thread_info *)arg1; 31 $stats = (struct spdk_thread_stats *)$info->current_stats; 34 …$core_pct = $stats->busy_tsc * 100 / (@cores_busy_tsc[$info->lcore] + @cores_idle_tsc[$info->lcore… 40 $info->thread_id, $info->lcore, arg2, $thread_pct, $core_pct); 51 $info = (struct spdk_scheduler_core_info *)arg2; 52 $busy = $info->current_busy_tsc; 53 $idle = $info->current_idle_tsc; 59 …printf("core:%2d busy:%10d idle:%10d pct:%2d% td_count:%2d\n", arg1, $busy, $idle, $pct, $info->th…
|
/spdk/module/accel/error/ |
H A D | accel_error.c | 97 struct accel_error_inject_info *info = &errch->injects[task->op_code]; in accel_error_submit_tasks() 99 if (info->opts.type == ACCEL_ERROR_INJECT_DISABLE) { in accel_error_submit_tasks() 103 info->interval++; in accel_error_inject_channel() 104 if (info->interval >= info->opts.interval) { in accel_error_inject_channel() 105 info->interval = 0; in accel_error_inject_channel() 106 info->count++; in accel_error_inject_channel() 108 if (info->count <= info->opts.count) { in accel_error_inject_channel() local 111 info in accel_error_inject_channel() 59 struct accel_error_inject_info *info = &ch->injects[task->op_code]; accel_error_task_complete_cb() local [all...] |
/spdk/lib/vfio_user/host/ |
H A D | vfio_user_pci.c | 178 vfio_device_get_info_cap(struct vfio_region_info *info, int cap) in vfio_device_get_info_cap() argument 183 if ((info->flags & VFIO_REGION_INFO_FLAG_CAPS) == 0) { in vfio_device_get_info_cap() 187 offset = info->cap_offset; in vfio_device_get_info_cap() 189 h = (struct vfio_info_cap_header *)((uintptr_t)info + offset); in vfio_device_get_info_cap() 201 struct vfio_region_info *info, int *fds) in vfio_device_setup_sparse_mmaps() argument 209 hdr = vfio_device_get_info_cap(info, VFIO_REGION_INFO_CAP_SPARSE_MMAP); in vfio_device_setup_sparse_mmaps() 220 prot |= info->flags & VFIO_REGION_INFO_FLAG_READ ? PROT_READ : 0; in vfio_device_setup_sparse_mmaps() 221 prot |= info->flags & VFIO_REGION_INFO_FLAG_WRITE ? PROT_WRITE : 0; in vfio_device_setup_sparse_mmaps() 279 struct vfio_region_info *info; in vfio_device_map_bars_and_config_region() local 287 info = (struct vfio_region_info *)buf; in vfio_device_map_bars_and_config_region() [all …]
|
/spdk/test/rpc/ |
H A D | rpc.sh | 40 local info 42 info=$($rpc trace_get_info) 43 [ "$(jq length <<< "$info")" -gt 2 ] 44 [ "$(jq 'has("tpoint_group_mask")' <<< "$info")" = "true" ] 45 [ "$(jq 'has("tpoint_shm_path")' <<< "$info")" = "true" ] 46 [ "$(jq 'has("bdev")' <<< "$info")" = "true" ] 47 [ "$(jq -r .bdev.tpoint_mask <<< "$info")" != "0x0" ]
|
/spdk/python/spdk/spdkcli/ |
H A D | ui_node.py | 153 self.shell.log.info(json.dumps(ret, indent=2)) 195 self.shell.log.info(ret_name) 230 self.shell.log.info(ret_name) 275 self.shell.log.info(ret_uuid) 302 self.shell.log.info(ret_name) 352 self.shell.log.info(ret_name) 414 self.shell.log.info(ret_name) 440 self.shell.log.info(ret_name) 473 self.shell.log.info(ret_name) 502 self.shell.log.info(re [all...] |
H A D | ui_node_nvmf.py | 143 self.shell.log.info(json.dumps(vars(self.lvs), indent=2)) 165 info = ", ".join(filter(None, [sn, st, allow_any_host])) 166 return info, None 367 info = ", ".join([self.namespace['name'], str(self.namespace['nsid'])]) 368 return info, None 386 info = ", ".join([self.address['trtype'], "Secure channel"]) if self.secure_channel \ 388 return info, None
|
/spdk/test/unit/ |
H A D | unittest.sh | 186 $LCOV -q -c --no-external -i -d . -t "Baseline" -o $UT_COVERAGE/ut_cov_base.info 275 $LCOV -q -d . -c --no-external -t "$(hostname)" -o $UT_COVERAGE/ut_cov_test.info 276 $LCOV -q -a $UT_COVERAGE/ut_cov_base.info -a $UT_COVERAGE/ut_cov_test.info -o $UT_COVERAGE/ut_cov_total.info 277 $LCOV -q -a $UT_COVERAGE/ut_cov_total.info -o $UT_COVERAGE/ut_cov_unit.info 278 $LCOV -q -r $UT_COVERAGE/ut_cov_unit.info "$rootdir/app/*" -o $UT_COVERAGE/ut_cov_unit.info 279 $LCOV -q -r $UT_COVERAGE/ut_cov_unit.info " [all...] |
/spdk/lib/vfu_tgt/ |
H A D | tgt_endpoint.c | 235 tgt_memory_region_add_cb(vfu_ctx_t *vfu_ctx, vfu_dma_info_t *info) in tgt_memory_region_add_cb() 241 if (!info->vaddr) { in tgt_memory_region_add_cb() 245 map_start = info->mapping.iov_base; in tgt_memory_region_add_cb() 246 map_end = info->mapping.iov_base + info->mapping.iov_len; in tgt_memory_region_add_cb() 248 if (((uintptr_t)info->mapping.iov_base & MASK_2MB) || in tgt_memory_region_add_cb() 249 (info->mapping.iov_len & MASK_2MB)) { in tgt_memory_region_add_cb() 251 info->vaddr, map_start, map_end); in tgt_memory_region_add_cb() 255 if (info->prot == (PROT_WRITE | PROT_READ)) { in tgt_memory_region_add_cb() 256 ret = spdk_mem_register(info in tgt_memory_region_add_cb() 233 tgt_memory_region_add_cb(vfu_ctx_t * vfu_ctx,vfu_dma_info_t * info) tgt_memory_region_add_cb() argument 267 tgt_memory_region_remove_cb(vfu_ctx_t * vfu_ctx,vfu_dma_info_t * info) tgt_memory_region_remove_cb() argument [all...] |
/spdk/module/blobfs/bdev/ |
H A D | blobfs_fuse.c | 140 fuse_open(const char *path, struct fuse_file_info *info) in fuse_open() argument 150 info->fh = (uintptr_t)file; in fuse_open() 155 fuse_release(const char *path, struct fuse_file_info *info) in fuse_release() argument 157 struct spdk_file *file = (struct spdk_file *)info->fh; in fuse_release() 163 fuse_read(const char *path, char *buf, size_t len, off_t offset, struct fuse_file_info *info) in fuse_read() argument 165 struct spdk_file *file = (struct spdk_file *)info->fh; in fuse_read() 172 struct fuse_file_info *info) in fuse_write() argument 174 struct spdk_file *file = (struct spdk_file *)info->fh; in fuse_write() 186 fuse_flush(const char *path, struct fuse_file_info *info) in fuse_flush() argument 192 fuse_fsync(const char *path, int datasync, struct fuse_file_info *info) in fuse_fsync() argument
|
/spdk/module/bdev/virtio/ |
H A D | bdev_virtio_scsi.c | 131 struct virtio_scsi_scan_info info; member 137 struct virtio_scsi_scan_info info; member 376 if (disk->info.target == target_id) { in virtio_scsi_dev_get_disk_by_id() 457 req->lun[1] = disk->info.target; in bdev_virtio_init_io_vreq() 480 tmf_req->lun[1] = disk->info.target; in bdev_virtio_init_tmf_vreq() 524 if (disk->info.num_blocks > (1ULL << 32)) { in bdev_virtio_rw() 640 if (!disk->info.unmap_supported) { in _bdev_virtio_submit_request() 680 return disk->info.unmap_supported; in bdev_virtio_io_type_supported() 1063 req->lun[1] = base->info.target; in send_scan_io() 1257 base->info in process_scan_inquiry_vpd_block_thin_provision() 1315 virtio_scsi_dev_add_tgt(struct virtio_scsi_dev * svdev,struct virtio_scsi_scan_info * info) virtio_scsi_dev_add_tgt() argument 1650 struct virtio_scsi_scan_info *info; virtio_scsi_dev_scan_tgt() local [all...] |
/spdk/lib/nvmf/ |
H A D | subsystem.c | 910 /* Save host info to use for any future controllers. */ in nvmf_ns_visible() 2054 const struct spdk_nvmf_reservation_info *info); in spdk_nvmf_subsystem_add_ns_ext() 2056 struct spdk_nvmf_reservation_info *info); in spdk_nvmf_subsystem_add_ns_ext() 2058 struct spdk_nvmf_reservation_info *info); in spdk_nvmf_subsystem_add_ns_ext() 2087 struct spdk_nvmf_reservation_info info = {0}; in spdk_nvmf_subsystem_add_ns_ext() 2263 rc = nvmf_ns_reservation_load(ns, &info); in spdk_nvmf_subsystem_get_next_ns() 2269 rc = nvmf_ns_reservation_restore(ns, &info); 2676 struct spdk_nvmf_reservation_info *info) in nvmf_ns_reservation_restore() 2733 info->ptpl_activated = res.ptpl_activated; in nvmf_ns_reservation_update_json() 2734 info in nvmf_ns_reservation_update_json() 2015 struct spdk_nvmf_reservation_info info = {0}; spdk_nvmf_subsystem_add_ns_ext() local 2552 nvmf_ns_reservation_load_json(const struct spdk_nvmf_ns * ns,struct spdk_nvmf_reservation_info * info) nvmf_ns_reservation_load_json() argument 2636 nvmf_ns_reservation_restore(struct spdk_nvmf_ns * ns,struct spdk_nvmf_reservation_info * info) nvmf_ns_reservation_restore() argument 2722 nvmf_ns_reservation_update_json(const struct spdk_nvmf_ns * ns,const struct spdk_nvmf_reservation_info * info) nvmf_ns_reservation_update_json() argument 2763 struct spdk_nvmf_reservation_info info; nvmf_ns_update_reservation_info() local 3608 nvmf_ns_reservation_update(const struct spdk_nvmf_ns * ns,const struct spdk_nvmf_reservation_info * info) nvmf_ns_reservation_update() argument 3614 nvmf_ns_reservation_load(const struct spdk_nvmf_ns * ns,struct spdk_nvmf_reservation_info * info) nvmf_ns_reservation_load() argument [all...] |
/spdk/test/unit/lib/nvmf/subsystem.c/ |
H A D | subsystem_ut.c | 1081 struct spdk_nvmf_reservation_info info; in test_reservation_register_with_ptpl() 1113 memset(&info, 0, sizeof(info)); in test_reservation_register_with_ptpl() 1114 rc = nvmf_ns_reservation_load(&g_ns, &info); in test_reservation_register_with_ptpl() 1116 SPDK_CU_ASSERT_FATAL(info.ptpl_activated == true); in test_reservation_register_with_ptpl() 1128 rc = nvmf_ns_reservation_load(&g_ns, &info); in test_reservation_acquire_preempt_1() 1216 struct spdk_nvmf_reservation_info info; in test_reservation_acquire_release_with_ptpl() 1238 memset(&info, 0, sizeof(info)); in test_reservation_acquire_release_with_ptpl() 1239 rc = nvmf_ns_reservation_load(&g_ns, &info); in test_reservation_acquire_release_with_ptpl() 1069 struct spdk_nvmf_reservation_info info; test_reservation_register_with_ptpl() local 1204 struct spdk_nvmf_reservation_info info; test_reservation_acquire_release_with_ptpl() local 1953 struct spdk_nvmf_reservation_info info = {}; test_nvmf_ns_reservation_restore() local 2113 ut_update_reservation(const struct spdk_nvmf_ns * ns,const struct spdk_nvmf_reservation_info * info) ut_update_reservation() argument 2121 ut_load_reservation(const struct spdk_nvmf_ns * ns,struct spdk_nvmf_reservation_info * info) ut_load_reservation() argument [all...] |
/spdk/module/bdev/nvme/ |
H A D | vbdev_opal_rpc.c | 232 struct spdk_opal_locking_range_info *info; in rpc_bdev_opal_get_info() local 242 info = vbdev_opal_get_info_from_bdev(req.bdev_name, req.password); in rpc_bdev_opal_get_info() 243 if (info == NULL) { in rpc_bdev_opal_get_info() 253 spdk_json_write_named_uint64(w, "range_start", info->range_start); in rpc_bdev_opal_get_info() 254 spdk_json_write_named_uint64(w, "range_length", info->range_length); in rpc_bdev_opal_get_info() 255 spdk_json_write_named_bool(w, "read_lock_enabled", info->read_lock_enabled); in rpc_bdev_opal_get_info() 256 spdk_json_write_named_bool(w, "write_lock_enabled", info->write_lock_enabled); in rpc_bdev_opal_get_info() 257 spdk_json_write_named_bool(w, "read_locked", info->read_locked); in rpc_bdev_opal_get_info() 258 spdk_json_write_named_bool(w, "write_locked", info->write_locked); in rpc_bdev_opal_get_info()
|
/spdk/lib/accel/ |
H A D | accel_internal.h | 46 typedef void (*_accel_for_each_module_fn)(struct module_info *info); 47 void _accel_for_each_module(struct module_info *info, _accel_for_each_module_fn fn);
|
/spdk/scripts/ |
H A D | get-pmr | 36 info() { function 94 info "$pci" || ((++missing_buf))
|
/spdk/lib/log/ |
H A D | log.c | 120 struct tm *info; in spdk_log_to_syslog_level() 131 info = localtime(&ts.tv_sec); in spdk_log_to_syslog_level() 133 if (info == NULL) { 138 strftime(date, sizeof(date), "%Y-%m-%d %H:%M:%S", info); in spdk_vlog() 79 struct tm *info; get_timestamp_prefix() local
|
/spdk/module/bdev/rbd/ |
H A D | bdev_rbd.c | 55 rbd_image_info_t info; member 440 rc = rbd_stat(rbd->image, &rbd->info, sizeof(rbd->info)); in bdev_rbd_init_context() 1250 struct cluster_register_info *info = arg; in _bdev_rbd_register_cluster() local 1254 rc = rbd_register_cluster((const char *)info->name, (const char *)info->user_id, in _bdev_rbd_register_cluster() 1255 (const char *const *)info->config_param, (const char *)info->config_file, in _bdev_rbd_register_cluster() 1256 (const char *)info->key_file, info->core_mask); in _bdev_rbd_register_cluster() 1265 bdev_rbd_register_cluster(struct cluster_register_info *info) in bdev_rbd_register_cluster() argument 1267 assert(info != NULL); in bdev_rbd_register_cluster() 1271 if (spdk_call_unaffinitized(_bdev_rbd_register_cluster, info) == NULL) { in bdev_rbd_register_cluster() 1354 rbd->disk.blockcnt = rbd->info.size / rbd->disk.blocklen; in bdev_rbd_create()
|
H A D | bdev_rbd.h | 55 int bdev_rbd_register_cluster(struct cluster_register_info *info);
|
/spdk/python/spdk/rpc/ |
H A D | client.py | 110 self._logger.info("Setting log level to %s", lvl) 112 self._logger.info("Log level set to %s", lvl) 140 self._logger.info("Requests:\n%s\n", reqstr) 181 self._logger.info("response:\n%s\n", json.dumps(response, indent=2)) 195 … self._logger.info("Connection terminated but ignoring since method is '%s'" % method)
|
/spdk/lib/env_dpdk/ |
H A D | sigbus_handler.c | 22 sigbus_fault_sighandler(int signum, siginfo_t *info, void *ctx) in sigbus_fault_sighandler() argument 28 sigbus_handler->func(info->si_addr, sigbus_handler->ctx); in sigbus_fault_sighandler()
|
/spdk/python/spdk/sma/device/ |
H A D | nvmf_tcp.py | 135 logging.info(f'Tried to delete a non-existing device: {nqn}') 189 logging.info(f'Tried to detach non-existing volume: {volume}') 197 logging.info(f'Tried to detach volume: {volume} from non-existing ' +
|
/spdk/lib/nvme/ |
H A D | nvme_opal.c | 1506 struct spdk_opal_locking_range_info *info) in opal_get_locking_range_info_done() argument 1515 info->range_start = opal_response_get_u64(&sess->parsed_resp, 4); in opal_get_locking_range_info_done() 1516 info->range_length = opal_response_get_u64(&sess->parsed_resp, 8); in opal_get_locking_range_info_done() 1517 info->read_lock_enabled = opal_response_get_u8(&sess->parsed_resp, 12); in opal_get_locking_range_info_done() 1518 info->write_lock_enabled = opal_response_get_u8(&sess->parsed_resp, 16); in opal_get_locking_range_info_done() 1519 info->read_locked = opal_response_get_u8(&sess->parsed_resp, 20); in opal_get_locking_range_info_done() 1520 info->write_locked = opal_response_get_u8(&sess->parsed_resp, 24); in opal_get_locking_range_info_done() 1533 struct spdk_opal_locking_range_info *info; in opal_get_locking_range_info() local 1538 info = &dev->locking_ranges[locking_range_id]; in opal_get_locking_range_info() 1539 memset(info, 0, sizeof(*info)); in opal_get_locking_range_info() [all …]
|