/* include readable_conn1 */ #include "icmpd.h" int readable_conn(int i) { int unixfd, recvfd; char c; ssize_t n; socklen_t len; union { char buf[MAXSOCKADDR]; struct sockaddr sock; } un; unixfd = client[i].connfd; recvfd = -1; if ( (n = Read_fd(unixfd, &c, 1, &recvfd)) == 0) { err_msg("client %d terminated, recvfd = %d", i, recvfd); goto clientdone; /* client probably terminated */ } /* 4data from client; should be descriptor */ if (recvfd < 0) { err_msg("read_fd did not return descriptor"); goto clienterr; } /* end readable_conn1 */ /* include readable_conn2 */ len = sizeof(un.buf); if (getsockname(recvfd, (SA *) un.buf, &len) < 0) { err_ret("getsockname error"); goto clienterr; } client[i].family = un.sock.sa_family; if ( (client[i].lport = sock_get_port(&un.sock, len)) == 0) { client[i].lport = sock_bind_wild(recvfd, client[i].family); if (client[i].lport <= 0) { err_ret("error binding ephemeral port"); goto clienterr; } } Write(unixfd, "1", 1); /* tell client all OK */ FD_SET(unixfd, &allset); if (unixfd > maxfd) maxfd = unixfd; if (i > maxi) maxi = i; Close(recvfd); /* all done with client's UDP socket */ return(--nready); clienterr: Write(unixfd, "0", 1); /* tell client error occurred */ clientdone: Close(unixfd); if (recvfd >= 0) Close(recvfd); FD_CLR(unixfd, &allset); client[i].connfd = -1; return(--nready); } /* end readable_conn2 */