Lines Matching defs:fd
669 state->fd = INVALID_SOCKET;
711 int fd, e;
716 fd = socket(ai->ai_family, ai->ai_socktype, 0);
717 if (fd == INVALID_SOCKET) {
723 if (fd >= FD_SETSIZE) {
724 closesocket(fd);
726 dprint("socket: fd %d too high\n", fd);
730 set_cloexec_fd(fd);
736 if (ioctlsocket(fd, FIONBIO, (const void *) &one))
738 if (setsockopt(fd, SOL_SOCKET, SO_LINGER, &lopt, sizeof(lopt)))
743 dprint(" fd %d; connecting to %A...\n", fd, ai);
744 e = connect(fd, ai->ai_addr, ai->ai_addrlen);
752 state->fd = fd;
755 (void) closesocket(fd);
768 state->fd = fd;
784 (void) closesocket(fd);
786 state->fd = INVALID_SOCKET;
804 dprint("sending %d bytes on fd %d\n", SG_LEN(sg), state->fd);
805 ret = send(state->fd, SG_BUF(sg), SG_LEN(sg), 0);
808 (void) closesocket(state->fd);
809 state->fd = INVALID_SOCKET;
814 k5_trace_message_send(state->fd, SG_BUF(sg), SG_LEN(sg));
822 if (getsockname(state->fd, (struct sockaddr *)&ss, &sslen) == 0) {
833 FD_SET(state->fd, &selstate->rfds);
835 FD_SET(state->fd, &selstate->wfds);
836 FD_SET(state->fd, &selstate->xfds);
837 if (selstate->max <= state->fd)
838 selstate->max = state->fd + 1;
882 dprint("sending %d bytes on fd %d\n", SG_LEN(sg), conn->fd);
883 ret = send(conn->fd, SG_BUF(sg), SG_LEN(sg), 0);
894 k5_trace_message_send(conn->fd, SG_BUF(sg), SG_LEN(sg));
904 shutdown(conn->fd, SHUTDOWN_BOTH);
905 FD_CLR(conn->fd, &selstate->rfds);
906 FD_CLR(conn->fd, &selstate->wfds);
907 FD_CLR(conn->fd, &selstate->xfds);
909 dprint("abandoning connection %d: %m\n", conn->fd, err);
910 /* Fix up max fd for next select call. */
911 if (selstate->max == 1 + conn->fd) {
924 get_so_error(int fd)
931 e = getsockopt(fd, SOL_SOCKET, SO_ERROR, &sockerr, &sockerrlen);
935 dprint("getsockopt(SO_ERROR) on fd failed: %m\n", e);
964 closesocket(conn->fd);
965 conn->fd = INVALID_SOCKET;
971 e = get_so_error(conn->fd);
973 dprint("socket error on exception fd: %m", e);
975 dprint("no socket error info available on exception fd");
988 e = get_so_error(conn->fd);
990 dprint("socket error on write fd: %m", e);
1006 dprint("trying to writev %d (%d bytes) to fd %d\n",
1010 conn->fd);
1011 nwritten = SOCKET_WRITEV(conn->fd, conn->x.out.sgp,
1035 k5_trace_message_send(conn->fd, SG_BUF(&conn->x.out.sgbuf[1]),
1040 FD_CLR(conn->fd, &selstate->wfds);
1044 dprint("switching fd %d to READING\n", conn->fd);
1065 dprint("reading %d bytes of data from fd %d\n",
1066 (int) conn->x.in.n_left, conn->fd);
1067 nread = SOCKET_READ(conn->fd, conn->x.in.pos, conn->x.in.n_left);
1078 k5_trace_message_recv(conn->fd, conn->x.in.buf, nread);
1084 nread = SOCKET_READ(conn->fd,
1094 dprint("received length on fd %d is %d\n", conn->fd, (int)len);
1130 nread = recv(conn->fd, conn->x.in.buf, conn->x.in.bufsize, 0);
1137 k5_trace_message_recv(conn->fd, conn->x.in.buf, nread);
1173 if (conns[i].fd == INVALID_SOCKET)
1176 if (FD_ISSET(conns[i].fd, &seltemp->rfds))
1178 if (FD_ISSET(conns[i].fd, &seltemp->wfds))
1180 if (FD_ISSET(conns[i].fd, &seltemp->xfds))
1185 dprint("handling flags '%s%s%s' on fd %d (%A) in state %s\n",
1189 conns[i].fd, conns[i].addr,
1205 dprint("fd service routine says we're done\n");
1287 conns[i].fd = INVALID_SOCKET;
1379 (void) getsockname(conns[winning_conn].fd, localaddr, localaddrlen);
1382 (void) getpeername(conns[winning_conn].fd, remoteaddr, remoteaddrlen);
1386 if (conns[i].fd != INVALID_SOCKET)
1387 closesocket(conns[i].fd);