Lines Matching refs:sockets
79 SocketEntry *sockets = NULL; variable
698 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
699 sockets[i].fd = fd; in new_socket()
700 buffer_init(&sockets[i].input); in new_socket()
701 buffer_init(&sockets[i].output); in new_socket()
702 buffer_init(&sockets[i].request); in new_socket()
703 sockets[i].type = type; in new_socket()
708 sockets = xrealloc(sockets, new_alloc * sizeof(sockets[0])); in new_socket()
710 sockets[i].type = AUTH_UNUSED; in new_socket()
712 sockets[old_alloc].fd = fd; in new_socket()
713 buffer_init(&sockets[old_alloc].input); in new_socket()
714 buffer_init(&sockets[old_alloc].output); in new_socket()
715 buffer_init(&sockets[old_alloc].request); in new_socket()
716 sockets[old_alloc].type = type; in new_socket()
728 switch (sockets[i].type) { in prepare_select()
731 n = MAX(n, sockets[i].fd); in prepare_select()
736 fatal("Unknown socket type %d", sockets[i].type); in prepare_select()
758 switch (sockets[i].type) { in prepare_select()
761 FD_SET(sockets[i].fd, *fdrp); in prepare_select()
762 if (buffer_len(&sockets[i].output) > 0) in prepare_select()
763 FD_SET(sockets[i].fd, *fdwp); in prepare_select()
795 switch (sockets[i].type) { in after_select()
799 if (FD_ISSET(sockets[i].fd, readset)) { in after_select()
801 sock = accept(sockets[i].fd, in after_select()
825 if (buffer_len(&sockets[i].output) > 0 && in after_select()
826 FD_ISSET(sockets[i].fd, writeset)) { in after_select()
828 len = write(sockets[i].fd, in after_select()
829 buffer_ptr(&sockets[i].output), in after_select()
830 buffer_len(&sockets[i].output)); in after_select()
838 close_socket(&sockets[i]); in after_select()
841 buffer_consume(&sockets[i].output, len); in after_select()
843 if (FD_ISSET(sockets[i].fd, readset)) { in after_select()
845 len = read(sockets[i].fd, buf, sizeof(buf)); in after_select()
853 close_socket(&sockets[i]); in after_select()
856 buffer_append(&sockets[i].input, buf, len); in after_select()
857 process_message(&sockets[i]); in after_select()
861 fatal("Unknown type %d", sockets[i].type); in after_select()