| /netbsd/src/external/ibm-public/postfix/dist/src/oqmgr/ |
| D | qmgr.h | 35 typedef struct QMGR_TRANSPORT QMGR_TRANSPORT; typedef 100 QMGR_TRANSPORT *next; 101 QMGR_TRANSPORT *prev; 154 struct QMGR_TRANSPORT { struct 175 typedef void (*QMGR_TRANSPORT_ALLOC_NOTIFY) (QMGR_TRANSPORT *, VSTREAM *); argument 176 extern QMGR_TRANSPORT *qmgr_transport_select(void); 177 extern void qmgr_transport_alloc(QMGR_TRANSPORT *, QMGR_TRANSPORT_ALLOC_NOTIFY); 178 extern void qmgr_transport_throttle(QMGR_TRANSPORT *, DSN *); 179 extern void qmgr_transport_unthrottle(QMGR_TRANSPORT *); 180 extern QMGR_TRANSPORT *qmgr_transport_create(const char *); [all …]
|
| D | qmgr_transport.c | 118 QMGR_TRANSPORT *transport; /* transport context */ 180 qmgr_transport_unthrottle((QMGR_TRANSPORT *) context); in qmgr_transport_unthrottle_wrapper() 185 void qmgr_transport_unthrottle(QMGR_TRANSPORT *transport) in qmgr_transport_unthrottle() 213 void qmgr_transport_throttle(QMGR_TRANSPORT *transport, DSN *dsn) in qmgr_transport_throttle() 300 QMGR_TRANSPORT *qmgr_transport_select(void) in qmgr_transport_select() 302 QMGR_TRANSPORT *xport; in qmgr_transport_select() 341 void qmgr_transport_alloc(QMGR_TRANSPORT *transport, QMGR_TRANSPORT_ALLOC_NOTIFY notify) in qmgr_transport_alloc() 412 QMGR_TRANSPORT *qmgr_transport_create(const char *name) in qmgr_transport_create() 414 QMGR_TRANSPORT *transport; in qmgr_transport_create() 418 transport = (QMGR_TRANSPORT *) mymalloc(sizeof(QMGR_TRANSPORT)); in qmgr_transport_create() [all …]
|
| D | qmgr_error.c | 67 QMGR_TRANSPORT *qmgr_error_transport(const char *service) in qmgr_error_transport() 69 QMGR_TRANSPORT *transport; in qmgr_error_transport() 89 QMGR_TRANSPORT *transport; in qmgr_error_queue()
|
| D | qmgr_queue.c | 203 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_unthrottle() 283 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_throttle() 355 QMGR_QUEUE *qmgr_queue_select(QMGR_TRANSPORT *transport) in qmgr_queue_select() 379 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_done() 409 QMGR_QUEUE *qmgr_queue_create(QMGR_TRANSPORT *transport, const char *name, in qmgr_queue_create() 441 QMGR_QUEUE *qmgr_queue_find(QMGR_TRANSPORT *transport, const char *name) in qmgr_queue_find()
|
| D | qmgr_enable.c | 64 QMGR_TRANSPORT *xport; in qmgr_enable_all() 79 void qmgr_enable_transport(QMGR_TRANSPORT *transport) in qmgr_enable_transport()
|
| D | qmgr_deliver.c | 237 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_abort() 250 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_update() 381 void qmgr_deliver(QMGR_TRANSPORT *transport, VSTREAM *stream) in qmgr_deliver()
|
| D | qmgr_entry.c | 219 QMGR_TRANSPORT *transport = queue->transport; in qmgr_entry_done() 352 QMGR_TRANSPORT *transport; in qmgr_entry_create()
|
| D | qmgr_defer.c | 85 void qmgr_defer_transport(QMGR_TRANSPORT *transport, DSN *dsn) in qmgr_defer_transport()
|
| D | qmgr_active.c | 601 QMGR_TRANSPORT *transport; in qmgr_active_drain()
|
| D | qmgr_message.c | 1015 QMGR_TRANSPORT *transport = 0; in qmgr_message_resolve()
|
| /netbsd/src/external/ibm-public/postfix/dist/src/qmgr/ |
| D | qmgr.h | 35 typedef struct QMGR_TRANSPORT QMGR_TRANSPORT; typedef 112 QMGR_TRANSPORT *next; 113 QMGR_TRANSPORT *prev; 171 struct QMGR_TRANSPORT { struct 216 typedef void (*QMGR_TRANSPORT_ALLOC_NOTIFY) (QMGR_TRANSPORT *, VSTREAM *); argument 217 extern QMGR_TRANSPORT *qmgr_transport_select(void); 218 extern void qmgr_transport_alloc(QMGR_TRANSPORT *, QMGR_TRANSPORT_ALLOC_NOTIFY); 219 extern void qmgr_transport_throttle(QMGR_TRANSPORT *, DSN *); 220 extern void qmgr_transport_unthrottle(QMGR_TRANSPORT *); 221 extern QMGR_TRANSPORT *qmgr_transport_create(const char *); [all …]
|
| D | qmgr_transport.c | 123 QMGR_TRANSPORT *transport; /* transport context */ 185 qmgr_transport_unthrottle((QMGR_TRANSPORT *) context); in qmgr_transport_unthrottle_wrapper() 190 void qmgr_transport_unthrottle(QMGR_TRANSPORT *transport) in qmgr_transport_unthrottle() 218 void qmgr_transport_throttle(QMGR_TRANSPORT *transport, DSN *dsn) in qmgr_transport_throttle() 305 QMGR_TRANSPORT *qmgr_transport_select(void) in qmgr_transport_select() 307 QMGR_TRANSPORT *xport; in qmgr_transport_select() 346 void qmgr_transport_alloc(QMGR_TRANSPORT *transport, QMGR_TRANSPORT_ALLOC_NOTIFY notify) in qmgr_transport_alloc() 417 QMGR_TRANSPORT *qmgr_transport_create(const char *name) in qmgr_transport_create() 419 QMGR_TRANSPORT *transport; in qmgr_transport_create() 423 transport = (QMGR_TRANSPORT *) mymalloc(sizeof(QMGR_TRANSPORT)); in qmgr_transport_create() [all …]
|
| D | qmgr_job.c | 102 static QMGR_JOB *qmgr_job_create(QMGR_MESSAGE *message, QMGR_TRANSPORT *transport) in qmgr_job_create() 133 QMGR_TRANSPORT *transport = job->transport; in qmgr_job_link() 234 static QMGR_JOB *qmgr_job_find(QMGR_MESSAGE *message, QMGR_TRANSPORT *transport) in qmgr_job_find() 248 QMGR_JOB *qmgr_job_obtain(QMGR_MESSAGE *message, QMGR_TRANSPORT *transport) in qmgr_job_obtain() 282 QMGR_TRANSPORT *transport = job->transport; in qmgr_job_move_limits() 344 QMGR_TRANSPORT *transport = job->transport; in qmgr_job_unlink() 418 QMGR_TRANSPORT *transport = job->transport; in qmgr_job_free() 488 QMGR_TRANSPORT *transport = current->transport; in qmgr_job_candidate() 577 QMGR_TRANSPORT *transport = current->transport; in qmgr_job_preempt() 693 QMGR_TRANSPORT *transport = job->transport; in qmgr_job_pop() [all …]
|
| D | qmgr_error.c | 67 QMGR_TRANSPORT *qmgr_error_transport(const char *service) in qmgr_error_transport() 69 QMGR_TRANSPORT *transport; in qmgr_error_transport() 89 QMGR_TRANSPORT *transport; in qmgr_error_queue()
|
| D | qmgr_queue.c | 220 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_unthrottle() 300 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_throttle() 375 QMGR_TRANSPORT *transport = queue->transport; in qmgr_queue_done() 405 QMGR_QUEUE *qmgr_queue_create(QMGR_TRANSPORT *transport, const char *name, in qmgr_queue_create() 438 QMGR_QUEUE *qmgr_queue_find(QMGR_TRANSPORT *transport, const char *name) in qmgr_queue_find()
|
| D | qmgr_enable.c | 64 QMGR_TRANSPORT *xport; in qmgr_enable_all() 79 void qmgr_enable_transport(QMGR_TRANSPORT *transport) in qmgr_enable_transport()
|
| D | qmgr_entry.c | 208 QMGR_TRANSPORT *dst_transport = dst_queue->transport; in qmgr_entry_move_todo() 258 QMGR_TRANSPORT *transport = job->transport; in qmgr_entry_done() 413 QMGR_TRANSPORT *transport; in qmgr_entry_create()
|
| D | qmgr_deliver.c | 242 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_abort() 255 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_update() 386 void qmgr_deliver(QMGR_TRANSPORT *transport, VSTREAM *stream) in qmgr_deliver()
|
| D | qmgr_defer.c | 90 void qmgr_defer_transport(QMGR_TRANSPORT *transport, DSN *dsn) in qmgr_defer_transport()
|
| D | qmgr_active.c | 601 QMGR_TRANSPORT *transport; in qmgr_active_drain()
|
| D | qmgr_message.c | 1072 QMGR_TRANSPORT *transport = 0; in qmgr_message_resolve()
|