Lines Matching refs:sockets
102 SocketEntry *sockets = NULL;
909 if (sockets[i].type == AUTH_UNUSED) {
910 sockets[i].fd = fd;
911 buffer_init(&sockets[i].input);
912 buffer_init(&sockets[i].output);
913 buffer_init(&sockets[i].request);
914 sockets[i].type = type;
919 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]));
921 sockets[i].type = AUTH_UNUSED;
923 sockets[old_alloc].fd = fd;
924 buffer_init(&sockets[old_alloc].input);
925 buffer_init(&sockets[old_alloc].output);
926 buffer_init(&sockets[old_alloc].request);
927 sockets[old_alloc].type = type;
939 switch (sockets[i].type) {
942 n = MAX(n, sockets[i].fd);
947 fatal("Unknown socket type %d", sockets[i].type);
969 switch (sockets[i].type) {
972 FD_SET(sockets[i].fd, *fdrp);
973 if (buffer_len(&sockets[i].output) > 0)
974 FD_SET(sockets[i].fd, *fdwp);
1006 switch (sockets[i].type) {
1010 if (FD_ISSET(sockets[i].fd, readset)) {
1012 sock = accept(sockets[i].fd,
1036 if (buffer_len(&sockets[i].output) > 0 &&
1037 FD_ISSET(sockets[i].fd, writeset)) {
1038 len = write(sockets[i].fd,
1039 buffer_ptr(&sockets[i].output),
1040 buffer_len(&sockets[i].output));
1046 close_socket(&sockets[i]);
1049 buffer_consume(&sockets[i].output, len);
1051 if (FD_ISSET(sockets[i].fd, readset)) {
1052 len = read(sockets[i].fd, buf, sizeof(buf));
1058 close_socket(&sockets[i]);
1061 buffer_append(&sockets[i].input, buf, len);
1062 process_message(&sockets[i]);
1066 fatal("Unknown type %d", sockets[i].type);
