| /spdk/include/spdk/ |
| H A D | histogram_data.h | 67 __spdk_histogram_increment(struct spdk_histogram_data *h, uint32_t range, uint32_t index) in __spdk_histogram_increment() argument 71 count = &h->bucket[(range << SPDK_HISTOGRAM_BUCKET_SHIFT(h)) + index]; in __spdk_histogram_increment() 76 __spdk_histogram_get_count(const struct spdk_histogram_data *h, uint32_t range, uint32_t index) in __spdk_histogram_get_count() argument 78 return h->bucket[(range << SPDK_HISTOGRAM_BUCKET_SHIFT(h)) + index]; in __spdk_histogram_get_count() 82 __spdk_histogram_get_bucket(const struct spdk_histogram_data *h, uint32_t range, uint32_t index) in __spdk_histogram_get_bucket() argument 84 return &h->bucket[(range << SPDK_HISTOGRAM_BUCKET_SHIFT(h)) + index]; in __spdk_histogram_get_bucket() 96 uint32_t clz, range; in __spdk_histogram_data_get_bucket_range() local 101 range = SPDK_HISTOGRAM_BUCKET_LSB(h) - clz; in __spdk_histogram_data_get_bucket_range() 103 range = 0; in __spdk_histogram_data_get_bucket_range() 106 return range; in __spdk_histogram_data_get_bucket_range() [all …]
|
| H A D | zipf.h | 33 struct spdk_zipf *spdk_zipf_create(uint64_t range, double theta, uint32_t seed);
|
| /spdk/lib/util/ |
| H A D | zipf.c | 11 uint64_t range; member 27 zeta(uint64_t range, double theta) in zeta() argument 38 calc = spdk_min(ZIPF_MAX_ZETA_CALC, range); in zeta() 52 while (i < range) { in zeta() 53 count = spdk_min(ZIPF_ZETA_ESTIMATE, range - i); in zeta() 64 spdk_zipf_create(uint64_t range, double theta, uint32_t seed) in spdk_zipf_create() argument 73 zipf->range = range; in spdk_zipf_create() 78 zipf->zetan = zeta(range, theta); in spdk_zipf_create() 79 zipf->eta = (1.0 - pow(2.0 / zipf->range, 1.0 - zipf->theta)) / in spdk_zipf_create() 108 val = zipf->range * pow(zipf->eta * (randu - 1.0) + 1.0, zipf->alpha); in spdk_zipf_generate() [all …]
|
| /spdk/examples/util/zipf/ |
| H A D | zipf.c | 22 char range[64]; in print_bucket() local 29 snprintf(range, sizeof(range), "[%ju, %ju)", start, end); in print_bucket() 30 printf("%24s: %9.4f%% (%9ju)\n", range, so_far_pct, count); in print_bucket() 39 int range, count, i; in main() local 47 range = spdk_strtol(argv[2], 10); in main() 50 if (range <= 0 || count <= 0) { in main() 56 zipf = spdk_zipf_create(range, theta, time(NULL)); in main()
|
| /spdk/scripts/ |
| H A D | histogram.py | 26 for i in range(0, 64 - bucket_shift): 27 for j in range(0, (1 << bucket_shift)): 31 for i in range(0, 64 - bucket_shift): 32 for j in range(0, (1 << bucket_shift)):
|
| H A D | iostat.py | 97 item_sizes = [0 for i in range(header_len)] 99 for i in range(0, list_len): 109 _format = ' '.join('%%-%ss' % item_sizes[i] for i in range(0, header_len)) 122 for i in range(0, 7):
|
| H A D | gdb_macros.py | 73 for i in range(0, self.num_elements): 197 for i in range(0, max_nsid): 319 for i in range(count):
|
| H A D | rpc.py | 3485 p.add_argument('-i', '--locking-range-id', help='locking range id', type=int, required=True) 3486 p.add_argument('-s', '--range-start', help='locking range start LBA', type=int, required=True) 3487 p.add_argument('-l', '--range-length', help='locking range length (in blocks)', type=int, required=True) 3496 p = subparsers.add_parser('bdev_opal_get_info', help='get opal locking range info for this bdev') 3788 return [buf[i:i+step] for i in range(0, len(buf), step)] 4023 for i in range(len(args)):
|
| /spdk/test/unit/lib/bdev/bdev.c/ |
| H A D | bdev_ut.c | 1037 /* Offset near end of uint64_t range (2^64 - 1) */ in io_valid_test() 4055 /* Trigger range locking */ in bdev_compare_and_write() 4062 /* Trigger range unlocking */ in bdev_compare_and_write() 4081 /* Trigger range locking */ in bdev_compare_and_write() 4085 /* Trigger range unlocking earlier because we expect error here */ in bdev_compare_and_write() 4882 lock_lba_range_done(struct lba_range *range, void *ctx, int status) in unlock_lba_range_done() argument 4888 unlock_lba_range_done(struct lba_range *range, void *ctx, int status) in lock_lba_range_check_ranges() 4900 struct lba_range *range; in lock_lba_range_check_ranges() 4921 range = TAILQ_FIRST(&channel->locked_ranges); in lock_lba_range_check_ranges() 4922 SPDK_CU_ASSERT_FATAL(range ! in lock_lba_range_check_ranges() 4876 lock_lba_range_done(struct lba_range * range,void * ctx,int status) lock_lba_range_done() argument 4894 struct lba_range *range; lock_lba_range_check_ranges() local 4948 struct lba_range *range; lock_lba_range_with_io_outstanding() local 5042 struct lba_range *range; lock_lba_range_overlapped() local 5203 struct lba_range *range; bdev_quiesce() local [all...] |
| /spdk/test/nvme/simple_copy/ |
| H A D | simple_copy.c | 158 struct spdk_nvme_scc_source_range range = {}; in simple_copy_test() local 243 range.nlb = NUM_LBAS - 1; in simple_copy_test() 244 range.slba = 0; in simple_copy_test() 247 &range, 1, DEST_LBA, simple_copy_complete, &context); in simple_copy_test()
|
| /spdk/scripts/perf/nvmf/ |
| H A D | run_nvmf.py | 116 for i in range(core_mask_int.bit_length()): 129 core_range = range(int(start), int(end) + 1) 652 for i in range(chunks_no): 663 initiator_chunks = self._chunks(range(0, req_disks), len(self.initiator_info)) 924 for _ in range(num_jobs): 957 threads = range(0, self.num_cores) 960 threads = range(0, int(self.num_cores)) 963 threads = range(0, len(self.subsystem_info_list)) 1142 nvme_list = ["/dev/nullb{}".format(x) for x in range(self.null_block)] 1272 for i in range(null_block_coun [all...] |
| H A D | README.md | 124 use certain CPU cores. Important: upper bound of the range is inclusive!
|
| /spdk/module/bdev/uring/ |
| H A D | bdev_uring.c | 414 struct blk_zone_range range; in bdev_uring_fill_zone_type() 437 range.sector = (zone_id << uring->zd.lba_shift); in bdev_uring_fill_zone_state() 438 range.nr_sectors = (uring->bdev.zone_size << uring->zd.lba_shift); in bdev_uring_fill_zone_state() 440 if (ioctl(uring->fd, zone_mgmt_op, &range)) { in bdev_uring_fill_zone_state() 468 struct blk_zone_range range; bdev_uring_zone_management_op() local
|
| /spdk/lib/nvmf/ |
| H A D | ctrlr_bdev.c | 202 /* For now we support just one source range for copy command */ in nvmf_bdev_ctrlr_get_rw_params() 799 struct spdk_nvme_scc_source_range range = { 0 }; in nvmf_bdev_ctrlr_nvme_passthru_io() 823 * We support only one source range, and rely on this with the xfer in spdk_nvmf_bdev_ctrlr_nvme_passthru_admin() 839 spdk_iov_xfer_to_buf(&ix, &range, sizeof(range)); in spdk_nvmf_bdev_ctrlr_nvme_passthru_admin() 841 rc = spdk_bdev_copy_blocks(desc, ch, sdlba, range.slba, range.nlb + 1, 723 struct spdk_nvme_scc_source_range range = { 0 }; nvmf_bdev_ctrlr_copy_cmd() local
|
| /spdk/scripts/perf/nvme/ |
| H A D | run_fio_test.py | 155 for i in range(0, num_ssds):
|
| /spdk/test/unit/lib/bdev/mt/bdev.c/ |
| H A D | bdev_ut.c | 2252 lock_lba_range_done(struct lba_range *range, void *ctx, int status) in lock_lba_range_then_submit_io() 2258 unlock_lba_range_done(struct lba_range *range, void *ctx, int status) in lock_lba_range_then_submit_io() 2283 struct lba_range *range; in lock_lba_range_then_submit_io() 2313 range = TAILQ_FIRST(&bdev_ch[0]->locked_ranges); in lock_lba_range_then_submit_io() 2314 SPDK_CU_ASSERT_FATAL(range != NULL); in lock_lba_range_then_submit_io() 2315 CU_ASSERT(range->offset == 20); in lock_lba_range_then_submit_io() 2316 CU_ASSERT(range->length == 10); in lock_lba_range_then_submit_io() 2317 CU_ASSERT(range->owner_ch == bdev_ch[0]); in lock_lba_range_then_submit_io() 2355 /* Try to unlock the lba range using thread 1's io_ch. This should fail. */ in unregister_during_reset() 2382 /* The LBA range i in unregister_during_reset() 2186 lock_lba_range_done(struct lba_range * range,void * ctx,int status) lock_lba_range_done() argument 2192 unlock_lba_range_done(struct lba_range * range,void * ctx,int status) unlock_lba_range_done() argument 2217 struct lba_range *range; lock_lba_range_then_submit_io() local [all...] |
| /spdk/test/unit/lib/nvmf/ctrlr_bdev.c/ |
| H A D | ctrlr_bdev_ut.c | 726 struct spdk_nvme_scc_source_range range = {}; in test_nvmf_bdev_ctrlr_cmd() 741 /* SLBA out of range */ in test_nvmf_bdev_ctrlr_cmd() 809 /* SLBA out of range */ in test_nvmf_bdev_ctrlr_cmd() 836 range.slba = 512; in test_nvmf_bdev_ctrlr_read_write_cmd() 837 range.nlb = 511; in test_nvmf_bdev_ctrlr_read_write_cmd() 839 SPDK_IOV_ONE(req.iov, &req.iovcnt, &range, req.length); in test_nvmf_bdev_ctrlr_read_write_cmd() 865 /* Unsupported source range descriptor format */ in test_nvmf_bdev_ctrlr_nvme_passthru() 665 struct spdk_nvme_scc_source_range range = {}; test_nvmf_bdev_ctrlr_cmd() local
|
| /spdk/doc/ |
| H A D | blobfs.md | 85 …may run into issues. BlobFS will be tested in a broader range of use cases after this initial rel…
|
| H A D | applications.md | 148 - Comma separated list of CPUs or list of CPU ranges. Use '-' to define range.
|
| H A D | ftl.md | 15 are contiguous and in range from 0 to the number of surfaced blocks (the number of spare blocks
|
| H A D | two.min.js | 34 …{return a?d.isArray(a)?x.call(a):q(a)?d.map(a,d.identity):d.values(a):[]},range:function(a,c,f){nu… method 60 …I);var R=p.Resolution,T=(new p.Matrix).translate(k,r).rotate(B);k=d.map(d.range(R),function(a){a=(… 66 ….RecursionLimit;var y=v+1;return a===t&&c===h?[new p.Anchor(t,h)]:d.map(d.range(0,y),function(d){v… 70 … p.Matrix).translate(a.x,a.y).rotate(c);var v=p.Resolution;return d.map(d.range(v),function(a){a=(… 201 …=c.Utils,e=c.Ellipse=function(a,e,h,f){d.isNumber(f)||(f=h);var g=d.map(d.range(c.Resolution),func… 203 …,l=Math.cos,h=Math.sin,d=c.Utils,e=c.Circle=function(a,e,h){var g=d.map(d.range(c.Resolution),func… 205 …,d=c.Utils,e=c.Polygon=function(a,e,h,f){f=Math.max(f||0,3);var g=d.map(d.range(f),function(a){ret… 208 …PI,h=Math.PI/2,d=c.Utils,e=c.ArcSegment=function(a,e,h,f,k,l,B){B=d.map(d.range(B||3*c.Resolution)… 213 …e,h,f,l){d.isNumber(f)||(f=h/2);if(!d.isNumber(l)||0>=l)l=5;var g=d.map(d.range(2*l),function(a){r… 216 …(h,d,e,a,g){m.isNumber(g)||(g=Math.floor(Math.min(e,a)/12));var l=m.map(m.range(10),function(a){re…
|
| H A D | blob.md | 407 freed, depending on whether the clone already owns a cluster for a particular block range.
|
| /spdk/python/spdk/rpc/ |
| H A D | client.py | 59 for i in range(connect_retries):
|
| /spdk/test/iscsi_tgt/rpc_config/ |
| H A D | rpc_config.py | 181 for i in range(1, rpc_param['lun_total'] + 1):
|
| /spdk/module/bdev/nvme/ |
| H A D | bdev_nvme.c | 8536 struct spdk_nvme_dsm_range *range; in bdev_nvme_get_ctrlr() 8552 range = &dsm_ranges[0]; in nvme_io_path_is_current() 8554 /* Fill max-size ranges until the remaining blocks fit into one range */ in nvme_io_path_is_current() 8556 range->attributes.raw = 0; in nvme_io_path_is_current() 8557 range->length = SPDK_NVME_DATASET_MANAGEMENT_RANGE_MAX_BLOCKS; in nvme_io_path_is_current() 8558 range->starting_lba = offset; in nvme_io_path_is_current() 8562 range++; in nvme_io_path_is_current() 8565 /* Final range describes the remaining blocks */ in nvme_io_path_is_current() 8566 range->attributes.raw = 0; in nvme_io_path_is_current() 8567 range in nvme_io_path_is_current() 7997 struct spdk_nvme_dsm_range *range; bdev_nvme_unmap() local 8288 struct spdk_nvme_scc_source_range range = { bdev_nvme_copy() local [all...] |