Searched refs:num_worker (Results 1 – 8 of 8) sorted by relevance
/third_party/nghttp2/src/ |
D | nghttpd.cc | 274 config.num_worker = strtoul(optarg, &end, 10); in main() 275 if (errno == ERANGE || *end != '\0' || config.num_worker == 0) { in main()
|
D | HttpServer.h | 69 size_t num_worker; member
|
D | HttpServer.cc | 96 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()
|
D | shrpx_config.h | 950 num_worker{0}, 993 size_t num_worker; member
|
D | shrpx_worker_process.cc | 516 rv = conn_handler->create_worker_thread(config->num_worker); in worker_process_event_loop()
|
D | shrpx.cc | 1415 config->num_worker = 1; in fill_default_config() 1953 << config->num_worker << R"( in print_help() 2945 config->num_worker = 1; in process_options()
|
D | shrpx_config.cc | 2693 return parse_uint(&config->num_worker, opt, optarg); in parse_config()
|
/third_party/mindspore/mindspore/dataset/engine/ |
D | datasets.py | 3708 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 …]
|