Lines Matching refs:sockets
137 SocketEntry *sockets = NULL; variable
1641 e = &sockets[socknum]; in process_message()
1748 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
1749 sockets[i].fd = fd; in new_socket()
1750 if ((sockets[i].input = sshbuf_new()) == NULL || in new_socket()
1751 (sockets[i].output = sshbuf_new()) == NULL || in new_socket()
1752 (sockets[i].request = sshbuf_new()) == NULL) in new_socket()
1754 sockets[i].type = type; in new_socket()
1759 sockets = xrecallocarray(sockets, old_alloc, new_alloc, in new_socket()
1760 sizeof(sockets[0])); in new_socket()
1762 sockets[i].type = AUTH_UNUSED; in new_socket()
1764 sockets[old_alloc].fd = fd; in new_socket()
1765 if ((sockets[old_alloc].input = sshbuf_new()) == NULL || in new_socket()
1766 (sockets[old_alloc].output = sshbuf_new()) == NULL || in new_socket()
1767 (sockets[old_alloc].request = sshbuf_new()) == NULL) in new_socket()
1769 sockets[old_alloc].type = type; in new_socket()
1782 fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen); in handle_socket_read()
1809 if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) { in handle_conn_read()
1814 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_read()
1818 if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0) in handle_conn_read()
1836 if (sshbuf_len(sockets[socknum].output) == 0) in handle_conn_write()
1838 if ((len = write(sockets[socknum].fd, in handle_conn_write()
1839 sshbuf_ptr(sockets[socknum].output), in handle_conn_write()
1840 sshbuf_len(sockets[socknum].output))) <= 0) { in handle_conn_write()
1845 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_write()
1849 if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0) in handle_conn_write()
1865 if (sockets[socknum].type != AUTH_SOCKET && in after_poll()
1866 sockets[socknum].type != AUTH_CONNECTION) in after_poll()
1868 if (pfd[i].fd == sockets[socknum].fd) in after_poll()
1876 switch (sockets[socknum].type) { in after_poll()
1897 close_socket(&sockets[socknum]); in after_poll()
1918 switch (sockets[i].type) { in prepare_poll()
1926 fatal("Unknown socket type %d", sockets[i].type); in prepare_poll()
1937 switch (sockets[i].type) { in prepare_poll()
1944 pfd[j].fd = sockets[i].fd; in prepare_poll()
1950 pfd[j].fd = sockets[i].fd; in prepare_poll()
1956 if ((r = sshbuf_check_reserve(sockets[i].input, in prepare_poll()
1958 (r = sshbuf_check_reserve(sockets[i].output, in prepare_poll()
1963 if (sshbuf_len(sockets[i].output) > 0) in prepare_poll()