Lines Matching refs:sockets
137 SocketEntry *sockets = NULL; variable
1803 e = &sockets[socknum]; in process_message()
1906 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
1907 sockets[i].fd = fd; in new_socket()
1908 if ((sockets[i].input = sshbuf_new()) == NULL || in new_socket()
1909 (sockets[i].output = sshbuf_new()) == NULL || in new_socket()
1910 (sockets[i].request = sshbuf_new()) == NULL) in new_socket()
1912 sockets[i].type = type; in new_socket()
1917 sockets = xrecallocarray(sockets, old_alloc, new_alloc, in new_socket()
1918 sizeof(sockets[0])); in new_socket()
1920 sockets[i].type = AUTH_UNUSED; in new_socket()
1922 sockets[old_alloc].fd = fd; in new_socket()
1923 if ((sockets[old_alloc].input = sshbuf_new()) == NULL || in new_socket()
1924 (sockets[old_alloc].output = sshbuf_new()) == NULL || in new_socket()
1925 (sockets[old_alloc].request = sshbuf_new()) == NULL) in new_socket()
1927 sockets[old_alloc].type = type; in new_socket()
1940 fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen); in handle_socket_read()
1967 if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) { in handle_conn_read()
1972 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_read()
1976 if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0) in handle_conn_read()
1994 if (sshbuf_len(sockets[socknum].output) == 0) in handle_conn_write()
1996 if ((len = write(sockets[socknum].fd, in handle_conn_write()
1997 sshbuf_ptr(sockets[socknum].output), in handle_conn_write()
1998 sshbuf_len(sockets[socknum].output))) <= 0) { in handle_conn_write()
2003 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_write()
2007 if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0) in handle_conn_write()
2023 if (sockets[socknum].type != AUTH_SOCKET && in after_poll()
2024 sockets[socknum].type != AUTH_CONNECTION) in after_poll()
2026 if (pfd[i].fd == sockets[socknum].fd) in after_poll()
2034 switch (sockets[socknum].type) { in after_poll()
2055 close_socket(&sockets[socknum]); in after_poll()
2076 switch (sockets[i].type) { in prepare_poll()
2084 fatal("Unknown socket type %d", sockets[i].type); in prepare_poll()
2095 switch (sockets[i].type) { in prepare_poll()
2102 pfd[j].fd = sockets[i].fd; in prepare_poll()
2108 pfd[j].fd = sockets[i].fd; in prepare_poll()
2114 if ((r = sshbuf_check_reserve(sockets[i].input, in prepare_poll()
2116 (r = sshbuf_check_reserve(sockets[i].output, in prepare_poll()
2121 if (sshbuf_len(sockets[i].output) > 0) in prepare_poll()