Home
last modified time | relevance | path

Searched refs:nbpend (Results 1 – 25 of 140) sorted by relevance

123456

/dports/net/haproxy17/haproxy-1.7.14/src/
H A Dqueue.c159 srv->nbpend++; in pendconn_add()
160 strm->logs.srv_queue_size += srv->nbpend; in pendconn_add()
161 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
162 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
165 strm->be->nbpend++; in pendconn_add()
166 strm->logs.prx_queue_size += strm->be->nbpend; in pendconn_add()
167 if (strm->be->nbpend > strm->be->be_counters.nbpend_max) in pendconn_add()
168 strm->be->be_counters.nbpend_max = strm->be->nbpend; in pendconn_add()
239 p->srv->nbpend--; in pendconn_free()
241 p->strm->be->nbpend--; in pendconn_free()
/dports/net/haproxy18/haproxy-1.8.30/src/
H A Dqueue.c75 p->srv->nbpend--; in pendconn_unlink()
77 p->px->nbpend--; in pendconn_unlink()
111 if (srv->nbpend) { in pendconn_process_next_strm()
221 srv->nbpend++; in pendconn_add()
222 strm->logs.srv_queue_size += srv->nbpend; in pendconn_add()
224 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
230 px->nbpend++; in pendconn_add()
231 strm->logs.prx_queue_size += px->nbpend; in pendconn_add()
233 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
391 p->srv->nbpend--; in pendconn_free()
[all …]
/dports/net/haproxy17/haproxy-1.7.14/include/proto/
H A Dqueue.h53 if (!s->nbpend) in pendconn_from_srv()
63 if (!px->nbpend) in pendconn_from_px()
79 return (s && (s->nbpend || (p->nbpend && srv_is_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy21/haproxy-2.1.12/src/
H A Dqueue.c139 p->srv->nbpend--; in __pendconn_unlink()
142 p->px->nbpend--; in __pendconn_unlink()
246 if (srv->nbpend) in pendconn_process_next_strm()
250 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
373 srv->nbpend++; in pendconn_add()
374 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
375 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
380 px->nbpend++; in pendconn_add()
381 if (px->nbpend > px->be_counters.nbpend_max) in pendconn_add()
382 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
/dports/net/haproxy19/haproxy-1.9.16/src/
H A Dqueue.c139 p->srv->nbpend--; in __pendconn_unlink()
142 p->px->nbpend--; in __pendconn_unlink()
246 if (srv->nbpend) in pendconn_process_next_strm()
250 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
372 srv->nbpend++; in pendconn_add()
373 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
374 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
379 px->nbpend++; in pendconn_add()
380 if (px->nbpend > px->be_counters.nbpend_max) in pendconn_add()
381 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
/dports/net/nuster/nuster-5.0.4.21/src/
H A Dqueue.c139 p->srv->nbpend--; in __pendconn_unlink()
142 p->px->nbpend--; in __pendconn_unlink()
246 if (srv->nbpend) in pendconn_process_next_strm()
250 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
373 srv->nbpend++; in pendconn_add()
374 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
375 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
380 px->nbpend++; in pendconn_add()
381 if (px->nbpend > px->be_counters.nbpend_max) in pendconn_add()
382 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
/dports/net/haproxy20/haproxy-2.0.26/src/
H A Dqueue.c139 p->srv->nbpend--; in __pendconn_unlink()
142 p->px->nbpend--; in __pendconn_unlink()
246 if (srv->nbpend) in pendconn_process_next_strm()
250 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
376 srv->nbpend++; in pendconn_add()
377 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
378 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
383 px->nbpend++; in pendconn_add()
384 if (px->nbpend > px->be_counters.nbpend_max) in pendconn_add()
385 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
/dports/net/haproxy22/haproxy-2.2.19/src/
H A Dqueue.c137 p->srv->nbpend--; in __pendconn_unlink()
140 p->px->nbpend--; in __pendconn_unlink()
244 if (srv->nbpend) in pendconn_process_next_strm()
248 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
374 srv->nbpend++; in pendconn_add()
375 if (srv->nbpend > srv->counters.nbpend_max) in pendconn_add()
376 srv->counters.nbpend_max = srv->nbpend; in pendconn_add()
381 px->nbpend++; in pendconn_add()
382 if (px->nbpend > px->be_counters.nbpend_max) in pendconn_add()
383 px->be_counters.nbpend_max = px->nbpend; in pendconn_add()
/dports/net/haproxy/haproxy-2.4.10/src/
H A Dqueue.c197 _HA_ATOMIC_DEC(&p->srv->nbpend); in pendconn_unlink()
210 _HA_ATOMIC_DEC(&p->px->nbpend); in pendconn_unlink()
273 if (srv->nbpend) in pendconn_process_next_strm()
277 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
313 _HA_ATOMIC_DEC(&px->nbpend); in pendconn_process_next_strm()
320 _HA_ATOMIC_DEC(&srv->nbpend); in pendconn_process_next_strm()
407 new_max = _HA_ATOMIC_ADD_FETCH(&srv->nbpend, 1); in pendconn_add()
423 new_max = _HA_ATOMIC_ADD_FETCH(&px->nbpend, 1); in pendconn_add()
472 _HA_ATOMIC_SUB(&s->nbpend, xferred); in pendconn_redistribute()
515 _HA_ATOMIC_SUB(&s->proxy->nbpend, xferred); in pendconn_grab_from_px()
H A Dlb_fwlc.c60 unsigned int inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_queue_srv()
75 unsigned int inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_srv_reposition()
92 inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_srv_reposition()
354 if (!s->maxconn || s->served + s->nbpend < srv_dynamic_maxconn(s) + s->maxqueue) { in fwlc_get_next_server()
/dports/net/haproxy23/haproxy-2.3.16/src/
H A Dqueue.c196 _HA_ATOMIC_SUB(&p->srv->nbpend, 1); in pendconn_unlink()
209 _HA_ATOMIC_SUB(&p->px->nbpend, 1); in pendconn_unlink()
272 if (srv->nbpend) in pendconn_process_next_strm()
276 if (srv_currently_usable(rsrv) && px->nbpend && in pendconn_process_next_strm()
312 _HA_ATOMIC_SUB(&px->nbpend, 1); in pendconn_process_next_strm()
319 _HA_ATOMIC_SUB(&srv->nbpend, 1); in pendconn_process_next_strm()
406 new_max = _HA_ATOMIC_ADD(&srv->nbpend, 1); in pendconn_add()
422 new_max = _HA_ATOMIC_ADD(&px->nbpend, 1); in pendconn_add()
471 _HA_ATOMIC_SUB(&s->nbpend, xferred); in pendconn_redistribute()
514 _HA_ATOMIC_SUB(&s->proxy->nbpend, xferred); in pendconn_grab_from_px()
H A Dlb_fwlc.c60 unsigned int inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_queue_srv()
75 unsigned int inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_srv_reposition()
92 inflight = _HA_ATOMIC_LOAD(&s->served) + _HA_ATOMIC_LOAD(&s->nbpend); in fwlc_srv_reposition()
354 if (!s->maxconn || s->served + s->nbpend < srv_dynamic_maxconn(s) + s->maxqueue) { in fwlc_get_next_server()
/dports/multimedia/mjpegtools/mjpegtools-2.1.0/lavtools/
H A Daudiolib.c661 int nbdone, nbque, ndiff, nbpend, nbset, maxdiff; in do_audio() local
1013 nbpend = count.blocks; in do_audio()
1015 nbpend = 1; in do_audio()
1017 while(nbpend) in do_audio()
1037 nbpend += count.blocks; in do_audio()
1040 shmemptr->status[NBUF(nbdone)] = (nbpend >= info.fragstotal) ? -1 : 1; in do_audio()
1045 nbpend--; in do_audio()
1054 nbpend = count.blocks; in do_audio()
1056 while(nbpend) in do_audio()
1065 nbpend--; in do_audio()
/dports/net/haproxy18/haproxy-1.8.30/include/proto/
H A Dqueue.h58 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy21/haproxy-2.1.12/include/proto/
H A Dqueue.h88 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy20/haproxy-2.0.26/include/proto/
H A Dqueue.h88 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy22/haproxy-2.2.19/include/haproxy/
H A Dqueue.h84 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy23/haproxy-2.3.16/include/haproxy/
H A Dqueue.h90 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy/haproxy-2.4.10/include/haproxy/
H A Dqueue.h90 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy19/haproxy-1.9.16/include/proto/
H A Dqueue.h88 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/nuster/nuster-5.0.4.21/include/proto/
H A Dqueue.h88 return (s && (s->nbpend || (p->nbpend && srv_currently_usable(s))) && in may_dequeue_tasks()
/dports/net/haproxy17/haproxy-1.7.14/include/types/
H A Dserver.h192 int nbpend; /* number of pending connections */ member
/dports/net/haproxy18/haproxy-1.8.30/include/types/
H A Dserver.h206 int nbpend; /* number of pending connections */ member
/dports/net/haproxy21/haproxy-2.1.12/include/types/
H A Dserver.h215 int nbpend; /* number of pending connections */ member
/dports/net/haproxy20/haproxy-2.0.26/include/types/
H A Dserver.h215 int nbpend; /* number of pending connections */ member

123456