Lines Matching defs:peer
11 /* QMGR_ENTRY *qmgr_entry_create(peer, message)
12 /* QMGR_PEER *peer;
33 /* qmgr_entry_create() creates an entry for the named peer and message,
34 /* and appends the entry to the peer's list and its queue's todo list.
45 /* qmgr_entry_done() discards its peer structure when the peer
62 /* delivered. The entry is also removed from its peer list.
66 /* `todo' list. The entry is also prepended to its peer list again.
112 QMGR_ENTRY *qmgr_entry_select(QMGR_PEER *peer)
118 if ((entry = peer->entry_list.next) != 0) {
124 QMGR_LIST_UNLINK(peer->entry_list, QMGR_ENTRY *, entry, peer_peers);
125 peer->job->selected_entries++;
186 QMGR_PEER *peer = entry->peer;
190 * Move the entry back to the todo lists. In case of the peer list, put
199 QMGR_LIST_PREPEND(peer->entry_list, entry, peer_peers);
200 peer->job->selected_entries--;
211 QMGR_PEER *dst_peer, *src_peer = entry->peer;
256 QMGR_PEER *peer = entry->peer;
257 QMGR_JOB *sponsor, *job = peer->job;
269 QMGR_LIST_UNLINK(peer->entry_list, QMGR_ENTRY *, entry, peer_peers);
325 * When there are no more entries for this peer, discard the peer
328 peer->refcount--;
329 if (peer->refcount == 0)
330 qmgr_peer_free(peer);
362 QMGR_ENTRY *qmgr_entry_create(QMGR_PEER *peer, QMGR_MESSAGE *message)
365 QMGR_QUEUE *queue = peer->queue;
381 entry->peer = peer;
382 QMGR_LIST_APPEND(peer->entry_list, entry, peer_peers);
383 peer->refcount++;
387 peer->job->read_entries++;