| /dports/net/haproxy17/haproxy-1.7.14/src/ |
| H A D | task.c | 38 static unsigned int rqueue_ticks; /* insertion count */ variable
51 t->rq.key = ++rqueue_ticks; in __task_wakeup()
213 rq_next = eb32_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK); in process_runnable_tasks()
|
| /dports/net/haproxy18/haproxy-1.8.30/src/ |
| H A D | task.c | 49 static unsigned int rqueue_ticks; /* insertion count */ variable
63 t->rq.key = ++rqueue_ticks; in __task_wakeup()
205 rq_next = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
278 rq_next = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy19/haproxy-1.9.16/src/ |
| H A D | task.c | 56 static unsigned int rqueue_ticks; /* insertion count */ variable
86 t->rq.key = HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
302 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
318 lrq = eb32sc_lookup_ge(&task_per_thread[tid].rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy20/haproxy-2.0.26/src/ |
| H A D | task.c | 55 static unsigned int rqueue_ticks; /* insertion count */ variable
84 t->rq.key = _HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
330 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
346 lrq = eb32sc_lookup_ge(&task_per_thread[tid].rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy21/haproxy-2.1.12/src/ |
| H A D | task.c | 55 static unsigned int rqueue_ticks; /* insertion count */ variable
84 t->rq.key = _HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
339 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
355 lrq = eb32sc_lookup_ge(&tt->rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/nuster/nuster-5.0.4.21/src/ |
| H A D | task.c | 55 static unsigned int rqueue_ticks; /* insertion count */ variable
84 t->rq.key = _HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
336 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
352 lrq = eb32sc_lookup_ge(&tt->rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy23/haproxy-2.3.16/src/ |
| H A D | task.c | 54 static unsigned int rqueue_ticks; /* insertion count */ variable
134 t->rq.key = _HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
647 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
663 lrq = eb32sc_lookup_ge(&tt->rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy22/haproxy-2.2.19/src/ |
| H A D | task.c | 56 static unsigned int rqueue_ticks; /* insertion count */ variable
138 t->rq.key = _HA_ATOMIC_ADD(&rqueue_ticks, 1); in __task_wakeup()
609 grq = eb32sc_lookup_ge(&rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
625 lrq = eb32sc_lookup_ge(&tt->rqueue, rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|
| /dports/net/haproxy/haproxy-2.4.10/include/haproxy/ |
| H A D | task-t.h | 89 unsigned int rqueue_ticks; /* Insertion counter for the run queue */ member
|
| /dports/net/haproxy/haproxy-2.4.10/src/ |
| H A D | task.c | 174 t->rq.key = ++sched->rqueue_ticks; in __task_wakeup()
741 lrq = eb32sc_lookup_ge(&tt->rqueue, tt->rqueue_ticks - TIMER_LOOK_BACK, tid_bit); in process_runnable_tasks()
|