Lines Matching refs:sockets
112 SocketEntry *sockets = NULL;
982 if (sockets[i].type == AUTH_UNUSED) {
983 sockets[i].fd = fd;
984 buffer_init(&sockets[i].input);
985 buffer_init(&sockets[i].output);
986 buffer_init(&sockets[i].request);
987 sockets[i].type = type;
992 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]));
994 sockets[i].type = AUTH_UNUSED;
996 sockets[old_alloc].fd = fd;
997 buffer_init(&sockets[old_alloc].input);
998 buffer_init(&sockets[old_alloc].output);
999 buffer_init(&sockets[old_alloc].request);
1000 sockets[old_alloc].type = type;
1012 switch (sockets[i].type) {
1015 n = MAX(n, sockets[i].fd);
1020 fatal("Unknown socket type %d", sockets[i].type);
1042 switch (sockets[i].type) {
1045 FD_SET(sockets[i].fd, *fdrp);
1046 if (buffer_len(&sockets[i].output) > 0)
1047 FD_SET(sockets[i].fd, *fdwp);
1079 switch (sockets[i].type) {
1083 if (FD_ISSET(sockets[i].fd, readset)) {
1085 sock = accept(sockets[i].fd,
1109 if (buffer_len(&sockets[i].output) > 0 &&
1110 FD_ISSET(sockets[i].fd, writeset)) {
1111 len = write(sockets[i].fd,
1112 buffer_ptr(&sockets[i].output),
1113 buffer_len(&sockets[i].output));
1119 close_socket(&sockets[i]);
1122 buffer_consume(&sockets[i].output, len);
1124 if (FD_ISSET(sockets[i].fd, readset)) {
1125 len = read(sockets[i].fd, buf, sizeof(buf));
1131 close_socket(&sockets[i]);
1134 buffer_append(&sockets[i].input, buf, len);
1135 process_message(&sockets[i]);
1139 fatal("Unknown type %d", sockets[i].type);
1373 fprintf(stderr, "no sockets\n");