Lines Matching defs:sockets
92 SocketEntry *sockets = NULL;
893 if (sockets[i].type == AUTH_UNUSED) {
894 sockets[i].fd = fd;
895 buffer_init(&sockets[i].input);
896 buffer_init(&sockets[i].output);
897 buffer_init(&sockets[i].request);
898 sockets[i].type = type;
903 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]));
905 sockets[i].type = AUTH_UNUSED;
907 sockets[old_alloc].fd = fd;
908 buffer_init(&sockets[old_alloc].input);
909 buffer_init(&sockets[old_alloc].output);
910 buffer_init(&sockets[old_alloc].request);
911 sockets[old_alloc].type = type;
923 switch (sockets[i].type) {
926 n = MAX(n, sockets[i].fd);
931 fatal("Unknown socket type %d", sockets[i].type);
953 switch (sockets[i].type) {
956 FD_SET(sockets[i].fd, *fdrp);
957 if (buffer_len(&sockets[i].output) > 0)
958 FD_SET(sockets[i].fd, *fdwp);
990 switch (sockets[i].type) {
994 if (FD_ISSET(sockets[i].fd, readset)) {
996 sock = accept(sockets[i].fd,
1020 if (buffer_len(&sockets[i].output) > 0 &&
1021 FD_ISSET(sockets[i].fd, writeset)) {
1022 len = write(sockets[i].fd,
1023 buffer_ptr(&sockets[i].output),
1024 buffer_len(&sockets[i].output));
1029 close_socket(&sockets[i]);
1032 buffer_consume(&sockets[i].output, len);
1034 if (FD_ISSET(sockets[i].fd, readset)) {
1035 len = read(sockets[i].fd, buf, sizeof(buf));
1040 close_socket(&sockets[i]);
1043 buffer_append(&sockets[i].input, buf, len);
1044 process_message(&sockets[i]);
1048 fatal("Unknown type %d", sockets[i].type);