Lines Matching refs:sockets
104 SocketEntry *sockets = NULL;
825 if (sockets[i].type == AUTH_UNUSED) {
826 sockets[i].fd = fd;
827 buffer_init(&sockets[i].input);
828 buffer_init(&sockets[i].output);
829 buffer_init(&sockets[i].request);
830 sockets[i].type = type;
835 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]));
837 sockets[i].type = AUTH_UNUSED;
839 sockets[old_alloc].fd = fd;
840 buffer_init(&sockets[old_alloc].input);
841 buffer_init(&sockets[old_alloc].output);
842 buffer_init(&sockets[old_alloc].request);
843 sockets[old_alloc].type = type;
856 switch (sockets[i].type) {
859 n = MAX(n, sockets[i].fd);
864 fatal("Unknown socket type %d", sockets[i].type);
884 switch (sockets[i].type) {
887 FD_SET(sockets[i].fd, *fdrp);
888 if (buffer_len(&sockets[i].output) > 0)
889 FD_SET(sockets[i].fd, *fdwp);
921 switch (sockets[i].type) {
925 if (FD_ISSET(sockets[i].fd, readset)) {
927 sock = accept(sockets[i].fd,
951 if (buffer_len(&sockets[i].output) > 0 &&
952 FD_ISSET(sockets[i].fd, writeset)) {
953 len = write(sockets[i].fd,
954 buffer_ptr(&sockets[i].output),
955 buffer_len(&sockets[i].output));
961 close_socket(&sockets[i]);
964 buffer_consume(&sockets[i].output, len);
966 if (FD_ISSET(sockets[i].fd, readset)) {
967 len = read(sockets[i].fd, buf, sizeof(buf));
973 close_socket(&sockets[i]);
976 buffer_append(&sockets[i].input, buf, len);
977 process_message(&sockets[i]);
981 fatal("Unknown type %d", sockets[i].type);