Lines Matching refs:group
85 thread_call_group_t group),
88 thread_call_group_t group,
92 thread_call_group_t group);
95 thread_call_group_t group);
99 thread_call_group_t group);
111 thread_call_group_t group),
113 thread_call_group_t group);
132 thread_call_group_t group = &thread_call_group0;
146 queue_init(&group->pending_queue);
147 queue_init(&group->delayed_queue);
149 timer_call_setup(&group->delayed_timer, thread_call_delayed_timer, group);
151 wait_queue_init(&group->idle_wqueue, SYNC_POLICY_FIFO);
167 result = kernel_thread_start_priority((thread_continue_t)thread_call_daemon, group, BASEPRI_PREEMPT + 1, &thread);
234 thread_call_group_t group)
238 old_queue = call_entry_enqueue_tail(call, &group->pending_queue);
240 group->pending_count++;
260 thread_call_group_t group,
265 old_queue = call_entry_enqueue_deadline(call, &group->delayed_queue, deadline);
267 if (old_queue == &group->pending_queue)
268 group->pending_count--;
285 thread_call_group_t group)
291 if (old_queue == &group->pending_queue)
292 group->pending_count--;
308 thread_call_group_t group)
310 timer_call_enter(&group->delayed_timer, call->deadline);
332 thread_call_group_t group = &thread_call_group0;
334 call = TC(queue_first(&group->pending_queue));
336 while (!queue_end(&group->pending_queue, qe(call))) {
341 _call_dequeue(call, group);
377 thread_call_group_t group = &thread_call_group0;
379 call = TC(queue_first(&group->delayed_queue));
381 while (!queue_end(&group->delayed_queue, qe(call))) {
386 _call_dequeue(call, group);
418 thread_call_group_t group = &thread_call_group0;
424 call = TC(queue_first(&group->pending_queue));
426 while (unique_call && !queue_end(&group->pending_queue, qe(call))) {
435 if (!unique_call || queue_end(&group->pending_queue, qe(call))) {
441 _pending_call_enqueue(call, group);
443 if (group->active_count == 0)
444 thread_call_wake(group);
464 thread_call_group_t group = &thread_call_group0;
475 _delayed_call_enqueue(call, group, deadline);
477 if (queue_first(&group->delayed_queue) == qe(call))
478 _set_delayed_call_timer(call, group);
580 thread_call_group_t group = &thread_call_group0;
586 if (call->queue != &group->pending_queue) {
587 result = _pending_call_enqueue(call, group);
589 if (group->active_count == 0)
590 thread_call_wake(group);
607 thread_call_group_t group = &thread_call_group0;
613 if (call->queue != &group->pending_queue) {
614 result = _pending_call_enqueue(call, group);
616 if (group->active_count == 0)
617 thread_call_wake(group);
643 thread_call_group_t group = &thread_call_group0;
649 result = _delayed_call_enqueue(call, group, deadline);
651 if (queue_first(&group->delayed_queue) == qe(call))
652 _set_delayed_call_timer(call, group);
669 thread_call_group_t group = &thread_call_group0;
675 result = _delayed_call_enqueue(call, group, deadline);
677 if (queue_first(&group->delayed_queue) == qe(call))
678 _set_delayed_call_timer(call, group);
701 thread_call_group_t group = &thread_call_group0;
707 result = _call_dequeue(call, group);
729 thread_call_group_t group = &thread_call_group0;
735 if (call->queue == &group->delayed_queue) {
759 thread_call_group_t group)
761 if (group->idle_count > 0 && wait_queue_wakeup_one(&group->idle_wqueue, NULL, THREAD_AWAKENED) == KERN_SUCCESS) {
762 group->idle_count--; group->active_count++;
781 thread_call_group_t group = &thread_call_group0;
788 if (--group->active_count == 0 && group->pending_count > 0)
789 thread_call_wake(group);
793 group->active_count++;
805 thread_call_group_t group)
814 while (group->pending_count > 0) {
819 call = TC(dequeue_head(&group->pending_queue));
820 group->pending_count--;
846 group->active_count--;
848 if (group->idle_count < thread_call_thread_min) {
849 group->idle_count++;
851 wait_queue_assert_wait(&group->idle_wqueue, NULL, THREAD_UNINT, 0);
856 thread_block_parameter((thread_continue_t)thread_call_thread, group);
872 thread_call_group_t group)
880 while (group->active_count == 0 && group->pending_count > 0) {
881 group->active_count++;
886 result = kernel_thread_start_priority((thread_continue_t)thread_call_thread, group, BASEPRI_PREEMPT, &thread);
902 thread_block_parameter((thread_continue_t)thread_call_daemon_continue, group);
908 thread_call_group_t group)
915 thread_call_daemon_continue(group);
926 thread_call_group_t group = p0;
934 call = TC(queue_first(&group->delayed_queue));
936 while (!queue_end(&group->delayed_queue, qe(call))) {
938 _pending_call_enqueue(call, group);
944 call = TC(queue_first(&group->delayed_queue));
947 if (!queue_end(&group->delayed_queue, qe(call)))
948 _set_delayed_call_timer(call, group);
950 if (new_pending && group->active_count == 0)
951 thread_call_wake(group);