Lines Matching defs:peer
9 /* QMGR_ENTRY *qmgr_entry_create(peer, message)
10 /* QMGR_PEER *peer;
31 /* qmgr_entry_create() creates an entry for the named peer and message,
32 /* and appends the entry to the peer's list and its queue's todo list.
43 /* qmgr_entry_done() discards its peer structure when the peer
60 /* delivered. The entry is also removed from its peer list.
64 /* `todo' list. The entry is also prepended to its peer list again.
110 QMGR_ENTRY *qmgr_entry_select(QMGR_PEER *peer)
116 if ((entry = peer->entry_list.next) != 0) {
122 QMGR_LIST_UNLINK(peer->entry_list, QMGR_ENTRY *, entry, peer_peers);
123 peer->job->selected_entries++;
184 QMGR_PEER *peer = entry->peer;
188 * Move the entry back to the todo lists. In case of the peer list, put
197 QMGR_LIST_PREPEND(peer->entry_list, entry, peer_peers);
198 peer->job->selected_entries--;
209 QMGR_PEER *dst_peer, *src_peer = entry->peer;
254 QMGR_PEER *peer = entry->peer;
255 QMGR_JOB *sponsor, *job = peer->job;
267 QMGR_LIST_UNLINK(peer->entry_list, QMGR_ENTRY *, entry, peer_peers);
323 * When there are no more entries for this peer, discard the peer
326 peer->refcount--;
327 if (peer->refcount == 0)
328 qmgr_peer_free(peer);
360 QMGR_ENTRY *qmgr_entry_create(QMGR_PEER *peer, QMGR_MESSAGE *message)
363 QMGR_QUEUE *queue = peer->queue;
379 entry->peer = peer;
380 QMGR_LIST_APPEND(peer->entry_list, entry, peer_peers);
381 peer->refcount++;
385 peer->job->read_entries++;