Home
last modified time | relevance | path

Searched refs:dest_concurrency_limit (Results 1 – 8 of 8) sorted by relevance

/netbsd-src/external/ibm-public/postfix/dist/src/oqmgr/
H A Dqmgr_transport.c426 transport->dest_concurrency_limit = in qmgr_transport_create()
443 transport->dest_concurrency_limit = 1; in qmgr_transport_create()
444 if (transport->dest_concurrency_limit != 0 in qmgr_transport_create()
445 && transport->dest_concurrency_limit < transport->init_dest_concurrency) in qmgr_transport_create()
446 transport->init_dest_concurrency = transport->dest_concurrency_limit; in qmgr_transport_create()
464 transport->name, transport->dest_concurrency_limit, in qmgr_transport_create()
H A Dqmgr_queue.c127 myname, queue->name, queue->transport->dest_concurrency_limit, \
258 if (transport->dest_concurrency_limit == 0 in qmgr_queue_unthrottle()
259 || transport->dest_concurrency_limit > queue->window) in qmgr_queue_unthrottle()
271 if (transport->dest_concurrency_limit > 0 in qmgr_queue_unthrottle()
272 && queue->window > transport->dest_concurrency_limit) in qmgr_queue_unthrottle()
273 queue->window = transport->dest_concurrency_limit; in qmgr_queue_unthrottle()
H A Dqmgr_entry.c364 if (transport->dest_concurrency_limit > 0 in qmgr_entry_create()
365 && transport->dest_concurrency_limit <= queue->busy_refcount + 1) in qmgr_entry_create()
368 transport->dest_concurrency_limit); in qmgr_entry_create()
H A Dqmgr.h158 int dest_concurrency_limit; /* concurrency per domain */ member
/netbsd-src/external/ibm-public/postfix/dist/src/qmgr/
H A Dqmgr_queue.c133 myname, queue->name, queue->transport->dest_concurrency_limit, \
275 if (transport->dest_concurrency_limit == 0 in qmgr_queue_unthrottle()
276 || transport->dest_concurrency_limit > queue->window) in qmgr_queue_unthrottle()
288 if (transport->dest_concurrency_limit > 0 in qmgr_queue_unthrottle()
289 && queue->window > transport->dest_concurrency_limit) in qmgr_queue_unthrottle()
290 queue->window = transport->dest_concurrency_limit; in qmgr_queue_unthrottle()
H A Dqmgr_transport.c431 transport->dest_concurrency_limit = in qmgr_transport_create()
448 transport->dest_concurrency_limit = 1; in qmgr_transport_create()
449 if (transport->dest_concurrency_limit != 0 in qmgr_transport_create()
450 && transport->dest_concurrency_limit < transport->init_dest_concurrency) in qmgr_transport_create()
451 transport->init_dest_concurrency = transport->dest_concurrency_limit; in qmgr_transport_create()
496 transport->name, transport->dest_concurrency_limit, in qmgr_transport_create()
H A Dqmgr_entry.c425 if (transport->dest_concurrency_limit > 0 in qmgr_entry_create()
426 && transport->dest_concurrency_limit <= queue->busy_refcount + 1) in qmgr_entry_create()
429 transport->dest_concurrency_limit); in qmgr_entry_create()
H A Dqmgr.h175 int dest_concurrency_limit; /* concurrency per domain */ member