Lines Matching defs:workers
76 Hashmap *workers;
150 hashmap_remove(workers, UINT_TO_PTR(worker->pid));
162 HASHMAP_FOREACH(worker, workers, i)
165 hashmap_free(workers);
166 workers = NULL;
189 r = hashmap_ensure_allocated(&workers, NULL);
193 r = hashmap_put(workers, UINT_TO_PTR(pid), worker);
447 HASHMAP_FOREACH(worker, workers, i) {
465 if (hashmap_size(workers) >= arg_children_max) {
467 log_debug("maximum number (%i) of children reached", hashmap_size(workers));
506 HASHMAP_FOREACH(worker, workers, i) {
669 worker = hashmap_get(workers, UINT_TO_PTR(ucred->pid));
939 worker = hashmap_get(workers, UINT_TO_PTR(pid));
986 * udev.children-max=<number of workers> events are fully serialized if set to 1
1039 " -c --children-max=INT Set maximum number of workers\n"
1328 /* unnamed socket from workers to the main daemon */
1384 /* discard queued events and kill workers */
1389 if (udev_list_node_is_empty(&event_list) && hashmap_isempty(workers))
1392 /* timeout at exit for workers to finish */
1394 } else if (udev_list_node_is_empty(&event_list) && hashmap_isempty(workers)) {
1398 /* kill idle or hanging workers */
1415 log_error("timeout, giving up waiting for workers to finish");
1419 /* kill idle workers */
1421 log_debug("cleanup idle workers");
1426 HASHMAP_FOREACH(worker, workers, j) {