Lines Matching +defs:entry +defs:list
5 /* deliver one per-site queue entry to that site
28 /* of a suitable queue entry. The \fIfp\fR argument specifies a
129 static int qmgr_deliver_send_request(QMGR_ENTRY *entry, VSTREAM *stream)
131 RECIPIENT_LIST list = entry->rcpt_list;
133 QMGR_MESSAGE *message = entry->message;
149 message->sender, list.info);
154 | entry->queue->dflags
163 ATTR_TYPE_STR, MAIL_ATTR_NEXTHOP, entry->queue->nexthop,
182 ATTR_TYPE_INT, MAIL_ATTR_RCPT_COUNT, list.len,
186 for (recipient = list.info; recipient < list.info + list.len; recipient++)
191 msg_warn("write to process (%s): %m", entry->queue->transport->name);
195 msg_info("qmgr_deliver: site `%s'", entry->queue->name);
204 QMGR_ENTRY *entry = (QMGR_ENTRY *) context;
205 QMGR_QUEUE *queue = entry->queue;
207 QMGR_MESSAGE *message = entry->message;
217 QMGR_ENTRY *entry = (QMGR_ENTRY *) context;
218 QMGR_QUEUE *queue = entry->queue;
220 QMGR_MESSAGE *message = entry->message;
225 * Release the delivery agent from a "hot" queue entry.
227 #define QMGR_DELIVER_RELEASE_AGENT(entry) do { \
228 event_disable_readwrite(vstream_fileno(entry->stream)); \
229 (void) vstream_fclose(entry->stream); \
230 entry->stream = 0; \
249 status = qmgr_deliver_final_reply(entry->stream, dsb);
258 * entry.
282 * recipient of this queue entry, release the delivery process and
283 * move the entry back to the todo queue. Let qmgr_defer_transport()
287 * the entry becomes a dangling pointer.
289 QMGR_DELIVER_RELEASE_AGENT(entry);
290 qmgr_entry_unselect(queue, entry);
300 * (the todo list); stay away from queue entries that have been selected
301 * (the busy list), or we would have dangling pointers. The queue itself
302 * won't go away before we dispose of the current queue entry.
327 * itself won't go away before we dispose of the current queue entry.
335 * Release the delivery process, and give some other queue entry a chance
339 QMGR_DELIVER_RELEASE_AGENT(entry);
340 qmgr_entry_done(entry, QMGR_QUEUE_BUSY);
343 /* qmgr_deliver - deliver one per-site queue entry */
348 QMGR_ENTRY *entry;
377 * Find a suitable queue entry. Things may have changed since this
378 * transport was allocated. If no suitable entry is found,
384 || (entry = qmgr_entry_select(queue)) == 0) {
395 if (qmgr_deliver_send_request(entry, stream) < 0) {
396 qmgr_entry_unselect(queue, entry);
409 /* warning: entry and queue may be dangling pointers here */
418 entry->stream = stream;
420 qmgr_deliver_update, (char *) entry);
425 event_request_timer(qmgr_deliver_abort, (char *) entry, var_daemon_timeout);