Lines Matching defs:sockets
110 SocketEntry *sockets = NULL;
919 if (sockets[i].type == AUTH_UNUSED) {
920 sockets[i].fd = fd;
921 if ((sockets[i].input = sshbuf_new()) == NULL)
923 if ((sockets[i].output = sshbuf_new()) == NULL)
925 if ((sockets[i].request = sshbuf_new()) == NULL)
927 sockets[i].type = type;
932 sockets = xrealloc(sockets, new_alloc, sizeof(sockets[0]));
934 sockets[i].type = AUTH_UNUSED;
936 sockets[old_alloc].fd = fd;
937 if ((sockets[old_alloc].input = sshbuf_new()) == NULL)
939 if ((sockets[old_alloc].output = sshbuf_new()) == NULL)
941 if ((sockets[old_alloc].request = sshbuf_new()) == NULL)
943 sockets[old_alloc].type = type;
956 switch (sockets[i].type) {
959 n = MAX(n, sockets[i].fd);
964 fatal("Unknown socket type %d", sockets[i].type);
984 switch (sockets[i].type) {
987 FD_SET(sockets[i].fd, *fdrp);
988 if (sshbuf_len(sockets[i].output) > 0)
989 FD_SET(sockets[i].fd, *fdwp);
1021 switch (sockets[i].type) {
1025 if (FD_ISSET(sockets[i].fd, readset)) {
1027 sock = accept(sockets[i].fd,
1051 if (sshbuf_len(sockets[i].output) > 0 &&
1052 FD_ISSET(sockets[i].fd, writeset)) {
1053 len = write(sockets[i].fd,
1054 sshbuf_ptr(sockets[i].output),
1055 sshbuf_len(sockets[i].output));
1061 close_socket(&sockets[i]);
1064 if ((r = sshbuf_consume(sockets[i].output,
1069 if (FD_ISSET(sockets[i].fd, readset)) {
1070 len = read(sockets[i].fd, buf, sizeof(buf));
1076 close_socket(&sockets[i]);
1079 if ((r = sshbuf_put(sockets[i].input,
1084 process_message(&sockets[i]);
1088 fatal("Unknown type %d", sockets[i].type);
