Home
last modified time | relevance | path

Searched refs:num_worker (Results 1 – 8 of 8) sorted by relevance

/third_party/nghttp2/src/
Dnghttpd.cc274 config.num_worker = strtoul(optarg, &end, 10); in main()
275 if (errno == ERANGE || *end != '\0' || config.num_worker == 0) { in main()
DHttpServer.h69 size_t num_worker; member
DHttpServer.cc96 num_worker(1), in Config()
1823 if (config_->num_worker == 1) { in AcceptHandler()
1826 for (size_t i = 0; i < config_->num_worker; ++i) { in AcceptHandler()
1844 if (config_->num_worker == 1) { in accept_connection()
1852 if (next_worker_ == config_->num_worker - 1) { in accept_connection()
Dshrpx_config.h950 num_worker{0},
993 size_t num_worker; member
Dshrpx_worker_process.cc516 rv = conn_handler->create_worker_thread(config->num_worker); in worker_process_event_loop()
Dshrpx.cc1415 config->num_worker = 1; in fill_default_config()
1953 << config->num_worker << R"( in print_help()
2945 config->num_worker = 1; in process_options()
Dshrpx_config.cc2693 return parse_uint(&config->num_worker, opt, optarg); in parse_config()
/third_party/mindspore/mindspore/dataset/engine/
Ddatasets.py3708 num_worker = len(workers)
3711 workers[idx % num_worker].put(indices[idx])
3718 def _check_shm_usage(num_worker, queue_size, max_rowsize, num_queues=1): argument
3725 shm_estimate_usage = _get_device_num() * num_worker * num_queues * \
3760 def __init__(self, dataset, num_worker, multi_process, max_rowsize): argument
3762 self.num_worker = num_worker
3780 queue_size = min(queue_size, queue_size * 4 // num_worker)
3784 _check_shm_usage(num_worker, queue_size, max_rowsize)
3785 for _ in range(num_worker):
3831 … if self.multi_process is True and not psutil.pid_exists(self.workers[i % self.num_worker].pid):
[all …]