/spdk/lib/util/ |
H A D | cpuset.c | 192 parse_list(const char *mask, struct spdk_cpuset *set) in parse_list() argument 195 const char *ptr = mask; in parse_list() 215 SPDK_ERRLOG("Conversion of core mask in '%s' failed\n", mask); in parse_list() 220 SPDK_ERRLOG("Core number %" PRIu32 " is out of range in '%s'\n", lcore, mask); in parse_list() 256 SPDK_ERRLOG("Unexpected end of core list '%s'\n", mask); in parse_list() 258 SPDK_ERRLOG("Parsing of core list '%s' failed on character '%c'\n", mask, *end); in parse_list() 264 parse_mask(const char *mask, struct spdk_cpuset *set, size_t len) in parse_mask() argument 271 if (mask[0] == '0' && (mask[1] == 'x' || mask[1] == 'X')) { in parse_mask() 272 mask += 2; in parse_mask() 278 c = mask[i]; in parse_mask() [all …]
|
H A D | bit_array.c | 118 spdk_bit_array_word mask; in spdk_bit_array_resize() local 121 mask = bit_array_word_mask(last_word_bits); in spdk_bit_array_resize() 122 new_ba->words[old_word_count - 1] &= mask; in spdk_bit_array_resize() 289 spdk_bit_array_store_mask(const struct spdk_bit_array *ba, void *mask) in spdk_bit_array_store_mask() argument 295 memcpy(mask, ba->words, size); in spdk_bit_array_store_mask() 299 ((uint8_t *)mask)[size] |= (1U << i); in spdk_bit_array_store_mask() 301 ((uint8_t *)mask)[size] &= ~(1U << i); in spdk_bit_array_store_mask() 307 spdk_bit_array_load_mask(struct spdk_bit_array *ba, const void *mask) in spdk_bit_array_load_mask() argument 313 memcpy(ba->words, mask, size); in spdk_bit_array_load_mask() 316 if (((uint8_t *)mask)[size] & (1U << i)) { in spdk_bit_array_load_mask() [all …]
|
/spdk/scripts/perf/nvmf/ |
H A D | set_xps_rxqs | 42 mask=$(printf "%X%s" $mask_tmp $mask_fill) 45 mask=$(printf "%X" $mask_tmp) 47 echo $mask 52 mask=$(CPUMASK $j) 53 echo ${mask} > $i 54 CHECK echo ${mask} > $i
|
/spdk/test/vhost/ |
H A D | irqs.sh | 164 local irq=$1 mask=$2 166 [[ -n $irq && -e /proc/irq/$irq || -n $mask ]] || return 1 175 if [[ -n $mask ]]; then 176 IFS="," read -ra smp_affinity <<< "$mask" 209 local _mask=() mask="" 222 mask=${mask:+$mask,}${_mask[dword]} 225 echo "$mask" 229 local mask 231 mask=$(build_irq_cpu_mask "$@")
|
/spdk/scripts/ |
H A D | calc-iobuf.py | 98 def calc(self, config, mask): argument 104 cpucnt = mask.bit_count() 122 def calc(self, config, mask): argument 124 cpucnt = mask.bit_count() 130 pool.add(self.get('accel').calc(config, mask)) 148 def calc(self, config, mask): argument 154 cpucnt = mask.bit_count() 162 pool.add(self.get('bdev').calc(config, mask)) 204 def calc(self, config, mask): argument 212 pool.add(self.get('bdev').calc(config, mask)) [all …]
|
/spdk/test/unit/lib/iscsi/tgt_node.c/ |
H A D | tgt_node_ut.c | 332 snprintf(imask.mask, sizeof(imask.mask), "192.168.2.0/24"); in node_access_allowed() 515 snprintf(imask1.mask, sizeof(imask1.mask), IP1); in node_access_multi_initiator_groups_cases() 532 snprintf(imask1.mask, sizeof(imask1.mask), IP2); in node_access_multi_initiator_groups_cases() 550 snprintf(imask1.mask, sizeof(imask1.mask), IP2); in node_access_multi_initiator_groups_cases() 552 snprintf(imask2.mask, sizeof(imask2.mask), IP1); in node_access_multi_initiator_groups_cases() 569 snprintf(imask1.mask, sizeof(imask1.mask), IP2); in node_access_multi_initiator_groups_cases() 571 snprintf(imask2.mask, sizeof(imask2.mask), IP2); in node_access_multi_initiator_groups_cases() 588 snprintf(imask1.mask, sizeof(imask1.mask), IP2); in node_access_multi_initiator_groups_cases() 624 snprintf(imask2.mask, sizeof(imask2.mask), IP1); in node_access_multi_initiator_groups_cases() 642 snprintf(imask2.mask, sizeof(imask2.mask), IP2); in node_access_multi_initiator_groups_cases()
|
/spdk/lib/iscsi/ |
H A D | init_grp.c | 168 iscsi_init_grp_find_netmask(struct spdk_iscsi_init_grp *ig, const char *mask) in iscsi_init_grp_find_netmask() argument 173 if (!strcmp(netmask->mask, mask)) { in iscsi_init_grp_find_netmask() 181 iscsi_init_grp_add_netmask(struct spdk_iscsi_init_grp *ig, char *mask) in iscsi_init_grp_add_netmask() argument 192 len = strlen(mask); in iscsi_init_grp_add_netmask() 198 imask = iscsi_init_grp_find_netmask(ig, mask); in iscsi_init_grp_add_netmask() 209 memcpy(imask->mask, mask, len); in iscsi_init_grp_add_netmask() 212 p = strstr(imask->mask, "ALL"); in iscsi_init_grp_add_netmask() 222 SPDK_DEBUGLOG(iscsi, "Netmask %s\n", mask); in iscsi_init_grp_add_netmask() 227 iscsi_init_grp_delete_netmask(struct spdk_iscsi_init_grp *ig, char *mask) in iscsi_init_grp_delete_netmask() argument 231 imask = iscsi_init_grp_find_netmask(ig, mask); in iscsi_init_grp_delete_netmask() [all …]
|
H A D | tgt_node.c | 35 char mask[MAX_MASKBUF]; in iscsi_ipv6_netmask_allow_addr() local 49 if (n + 1 > sizeof mask) { in iscsi_ipv6_netmask_allow_addr() 53 memcpy(mask, netmask + 1, n); in iscsi_ipv6_netmask_allow_addr() 54 mask[n] = '\0'; in iscsi_ipv6_netmask_allow_addr() 68 SPDK_DEBUGLOG(iscsi, "mask %s / %d\n", mask, bits); in iscsi_ipv6_netmask_allow_addr() 72 if (inet_pton(AF_INET6, mask, &in6_mask) <= 0 in iscsi_ipv6_netmask_allow_addr() 99 char mask[MAX_MASKBUF]; in iscsi_ipv4_netmask_allow_addr() local 110 if (n + 1 > sizeof mask) { in iscsi_ipv4_netmask_allow_addr() 114 memcpy(mask, netmask, n); in iscsi_ipv4_netmask_allow_addr() 115 mask[n] = '\0'; in iscsi_ipv4_netmask_allow_addr() [all …]
|
H A D | init_grp.h | 19 char mask[MAX_INITIATOR_ADDR + 1]; member
|
/spdk/test/thread/lock/ |
H A D | spdk_lock.c | 130 const uint32_t mask = 1 << data->bit; in contend_worker_fn() local 139 ASSERT((g_contend_word & mask) == 0); in contend_worker_fn() 140 g_contend_word |= mask; in contend_worker_fn() 143 ASSERT((g_contend_word & mask) == mask); in contend_worker_fn() 144 g_contend_word ^= mask; in contend_worker_fn() 493 char mask[8]; in main() local 497 snprintf(mask, sizeof(mask), "0x%x", (1 << SPDK_COUNTOF(g_thread)) - 1); in main() 498 opts.reactor_mask = mask; in main()
|
/spdk/test/unit/lib/util/bit_array.c/ |
H A D | bit_array_ut.c | 259 uint8_t mask[TEST_MASK_SIZE] = { 0 }; in test_mask_store_load() local 269 spdk_bit_array_store_mask(ba, mask); in test_mask_store_load() 273 CU_ASSERT((mask[i / 8] & (1U << (i % 8)))); in test_mask_store_load() 275 CU_ASSERT(!(mask[i / 8] & (1U << (i % 8)))); in test_mask_store_load() 280 memset(mask, 0, TEST_MASK_SIZE); in test_mask_store_load() 281 mask[0] = 1; in test_mask_store_load() 282 mask[TEST_MASK_SIZE - 1] = 1U << 4; in test_mask_store_load() 284 spdk_bit_array_load_mask(ba, mask); in test_mask_store_load()
|
/spdk/module/event/subsystems/nvmf/ |
H A D | nvmf_rpc.c | 133 char *mask = spdk_json_strdup(val); in nvmf_decode_poll_groups_mask() 136 if (mask == NULL) { in nvmf_decode_poll_groups_mask() 141 SPDK_ERRLOG("Unable to allocate a poll groups mask object in nvmf_decode_poll_groups_mask.\n"); in nvmf_decode_poll_groups_mask() 142 free(mask); in nvmf_decode_poll_groups_mask() 146 ret = spdk_cpuset_parse(g_poll_groups_mask, mask); in nvmf_decode_poll_groups_mask() 147 free(mask); in nvmf_decode_poll_groups_mask() 132 char *mask = spdk_json_strdup(val); nvmf_decode_poll_groups_mask() local
|
/spdk/include/spdk/ |
H A D | bit_pool.h | 142 void spdk_bit_pool_store_mask(const struct spdk_bit_pool *pool, void *mask); 150 void spdk_bit_pool_load_mask(struct spdk_bit_pool *pool, const void *mask);
|
H A D | bit_array.h | 154 void spdk_bit_array_store_mask(const struct spdk_bit_array *ba, void *mask); 162 void spdk_bit_array_load_mask(struct spdk_bit_array *ba, const void *mask);
|
H A D | cpuset.h | 160 int spdk_cpuset_parse(struct spdk_cpuset *set, const char *mask);
|
H A D | nvme_ocssd_spec.h | 267 } mask; member
|
/spdk/test/unit/lib/util/cpuset.c/ |
H A D | cpuset_ut.c | 244 uint64_t *mask = ctx; in set_bit() local 247 (*mask) |= (1 << cpu); in set_bit() 254 uint64_t mask = 0; in test_cpuset_foreach() local 257 spdk_cpuset_for_each_cpu(&cpuset, set_bit, &mask); in test_cpuset_foreach() 258 CU_ASSERT(mask == 0xF135704); in test_cpuset_foreach()
|
/spdk/lib/vhost/ |
H A D | vhost.c | 59 vhost_parse_core_mask(const char *mask, struct spdk_cpuset *cpumask) in vhost_parse_core_mask() 68 if (mask == NULL) { in vhost_parse_core_mask() 73 rc = spdk_cpuset_parse(cpumask, mask); in vhost_parse_core_mask() 75 SPDK_ERRLOG("invalid cpumask %s\n", mask); in vhost_parse_core_mask() 84 SPDK_ERRLOG("one of selected cpu is outside of core mask(=%s)\n", in vhost_parse_core_mask() 92 SPDK_ERRLOG("no cpu is selected among core mask(=%s)\n", in vhost_parse_core_mask() 130 SPDK_ERRLOG("cpumask %s is invalid (core mask is 0x%s)\n", in vhost_dev_register() 55 vhost_parse_core_mask(const char * mask,struct spdk_cpuset * cpumask) vhost_parse_core_mask() argument
|
/spdk/doc/ |
H A D | applications.md | 36 -m | --cpumask | CPU mask | 0x1 | application @ref cpu_mask 38 -p | --main-core | integer | first core in CPU mask | main (primary) core for DPDK 60 ### Tracepoint group mask {#cmd_arg_limit_tpoint_group_mask} 143 ## CPU mask {#cpu_mask} 145 Whenever the `CPU mask` is mentioned it is a string in one of the following formats:
|
H A D | bdevperf.md | 65 cpumask | Maximum available | CPU mask. Format is defined at @ref cpu_mask
|
/spdk/lib/trace/ |
H A D | trace_flags.c | 76 uint64_t mask = 0x0; in spdk_trace_get_tpoint_group_mask() local 81 mask |= (1ULL << i); in spdk_trace_get_tpoint_group_mask() 85 return mask; in spdk_trace_get_tpoint_group_mask()
|
/spdk/lib/vfu_tgt/ |
H A D | tgt_endpoint.c | 490 vfu_parse_core_mask(const char *mask, struct spdk_cpuset *cpumask) in vfu_parse_core_mask() 499 if (mask == NULL) { in vfu_parse_core_mask() 504 rc = spdk_cpuset_parse(cpumask, mask); in vfu_parse_core_mask() 506 SPDK_ERRLOG("invalid cpumask %s\n", mask); in vfu_parse_core_mask() 515 SPDK_ERRLOG("one of selected cpu is outside of core mask(=%s)\n", in vfu_parse_core_mask() 523 SPDK_ERRLOG("no cpu is selected among core mask(=%s)\n", in vfu_parse_core_mask() 488 vfu_parse_core_mask(const char * mask,struct spdk_cpuset * cpumask) vfu_parse_core_mask() argument
|
/spdk/module/bdev/rbd/ |
H A D | bdev_rbd.c | 1046 cpu_set_t mask; in rbd_thread_set_cpumask() local 1049 CPU_ZERO(&mask); in rbd_thread_set_cpumask() 1054 CPU_SET(lcore, &mask); in rbd_thread_set_cpumask() 1059 if (sched_setaffinity(0, sizeof(mask), &mask) < 0) { in rbd_thread_set_cpumask()
|
/spdk/app/fio/nvme/ |
H A D | README.md | 130 application tag and application tag mask in end-to-end data protection. Application tag and applic… 131 tag mask are set to 0x1234 and 0xFFFF by default.
|
/spdk/lib/nvmf/ |
H A D | ctrlr.c | 468 SPDK_ERRLOG("Failed to allocate controller qpair mask\n"); in nvmf_ctrlr_create() 1842 rsp->cdw0 = ns->mask; 1861 ns->mask = cmd->cdw11; in nvmf_ctrlr_set_features_reservation_notification_mask() 1872 ns->mask = cmd->cdw11; 2285 enum spdk_nvme_async_event_mask_bit mask) in nvmf_ctrlr_mask_aen() 2287 ctrlr->notice_aen_mask &= ~(1 << mask); 2292 enum spdk_nvme_async_event_mask_bit mask) in nvmf_ctrlr_get_ana_state() 2294 if (ctrlr->notice_aen_mask & (1 << mask)) { in nvmf_ctrlr_get_ana_state() 2297 ctrlr->notice_aen_mask |= (1 << mask); in nvmf_ctrlr_get_ana_state() 4236 if (ns->mask in nvmf_ctrlr_process_io_fused_cmd() 2270 nvmf_ctrlr_unmask_aen(struct spdk_nvmf_ctrlr * ctrlr,enum spdk_nvme_async_event_mask_bit mask) nvmf_ctrlr_unmask_aen() argument 2277 nvmf_ctrlr_mask_aen(struct spdk_nvmf_ctrlr * ctrlr,enum spdk_nvme_async_event_mask_bit mask) nvmf_ctrlr_mask_aen() argument [all...] |