Lines Matching defs:peer
28 void **param_tbl; /* one per registered peer */
29 /* one per registered peer; doesn't exist if !timeout */
80 int isrv_register_fd(isrv_state_t *state, int peer, int fd)
84 DPRINTF("register_fd(peer:%d,fd:%d)", peer, fd);
97 DPRINTF("register_fd: FD2PEER[%d] = %d", fd, peer);
99 FD2PEER[fd] = peer;
142 static void remove_peer(isrv_state_t *state, int peer)
147 DPRINTF("remove_peer(%d)", peer);
151 if (FD2PEER[fd] == peer) {
156 if (FD2PEER[fd] > peer)
164 movesize = (PEER_COUNT - peer) * sizeof(void*);
166 memcpy(&PARAM_TBL[peer], &PARAM_TBL[peer+1], movesize);
168 memcpy(&TIMEO_TBL[peer], &TIMEO_TBL[peer+1], movesize);
194 remove_peer(state, n); /* unsuccesful peer start */
202 int fd, peer;
235 peer = FD2PEER[fd];
236 if (peer < 0)
237 continue; /* peer is already gone */
238 if (peer == 0) {
243 if (h(fd, &PARAM_TBL[peer])) {
244 /* this peer is gone */
245 remove_peer(state, peer);
247 TIMEO_TBL[peer] = monotonic_sec();
254 int n, peer;
255 peer = PEER_COUNT-1;
256 /* peer 0 is not checked */
257 while (peer > 0) {
258 DPRINTF("peer %d: time diff %d", peer,
259 (int)(CURTIME - TIMEO_TBL[peer]));
260 if ((CURTIME - TIMEO_TBL[peer]) >= TIMEOUT) {
261 DPRINTF("peer %d: do_timeout()", peer);
262 n = do_timeout(&PARAM_TBL[peer]);
264 remove_peer(state, peer);
266 peer--;
284 /* register "peer" #0 - it will accept new connections */
286 isrv_register_fd(state, /*peer:*/ 0, listen_fd);