/dports/net/haproxy17/haproxy-1.7.14/src/ |
H A D | queue.c | 159 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 D | queue.c | 75 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 D | queue.h | 53 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 D | queue.c | 139 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 D | queue.c | 139 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 D | queue.c | 139 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 D | queue.c | 139 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 D | queue.c | 137 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 D | queue.c | 197 _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 D | lb_fwlc.c | 60 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 D | queue.c | 196 _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 D | lb_fwlc.c | 60 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 D | audiolib.c | 661 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 D | queue.h | 58 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 D | queue.h | 88 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 D | queue.h | 88 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 D | queue.h | 84 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 D | queue.h | 90 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 D | queue.h | 90 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 D | queue.h | 88 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 D | queue.h | 88 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 D | server.h | 192 int nbpend; /* number of pending connections */ member
|
/dports/net/haproxy18/haproxy-1.8.30/include/types/ |
H A D | server.h | 206 int nbpend; /* number of pending connections */ member
|
/dports/net/haproxy21/haproxy-2.1.12/include/types/ |
H A D | server.h | 215 int nbpend; /* number of pending connections */ member
|
/dports/net/haproxy20/haproxy-2.0.26/include/types/ |
H A D | server.h | 215 int nbpend; /* number of pending connections */ member
|