Lines Matching refs:sockets

137 SocketEntry *sockets = NULL;  variable
1826 e = &sockets[socknum]; in process_message()
1933 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
1934 sockets[i].fd = fd; in new_socket()
1935 if ((sockets[i].input = sshbuf_new()) == NULL || in new_socket()
1936 (sockets[i].output = sshbuf_new()) == NULL || in new_socket()
1937 (sockets[i].request = sshbuf_new()) == NULL) in new_socket()
1939 sockets[i].type = type; in new_socket()
1944 sockets = xrecallocarray(sockets, old_alloc, new_alloc, in new_socket()
1945 sizeof(sockets[0])); in new_socket()
1947 sockets[i].type = AUTH_UNUSED; in new_socket()
1949 sockets[old_alloc].fd = fd; in new_socket()
1950 if ((sockets[old_alloc].input = sshbuf_new()) == NULL || in new_socket()
1951 (sockets[old_alloc].output = sshbuf_new()) == NULL || in new_socket()
1952 (sockets[old_alloc].request = sshbuf_new()) == NULL) in new_socket()
1954 sockets[old_alloc].type = type; in new_socket()
1967 fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen); in handle_socket_read()
1994 if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) { in handle_conn_read()
1999 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_read()
2003 if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0) in handle_conn_read()
2021 if (sshbuf_len(sockets[socknum].output) == 0) in handle_conn_write()
2023 if ((len = write(sockets[socknum].fd, in handle_conn_write()
2024 sshbuf_ptr(sockets[socknum].output), in handle_conn_write()
2025 sshbuf_len(sockets[socknum].output))) <= 0) { in handle_conn_write()
2030 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_write()
2034 if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0) in handle_conn_write()
2050 if (sockets[socknum].type != AUTH_SOCKET && in after_poll()
2051 sockets[socknum].type != AUTH_CONNECTION) in after_poll()
2053 if (pfd[i].fd == sockets[socknum].fd) in after_poll()
2061 switch (sockets[socknum].type) { in after_poll()
2082 close_socket(&sockets[socknum]); in after_poll()
2103 switch (sockets[i].type) { in prepare_poll()
2111 fatal("Unknown socket type %d", sockets[i].type); in prepare_poll()
2122 switch (sockets[i].type) { in prepare_poll()
2129 pfd[j].fd = sockets[i].fd; in prepare_poll()
2135 pfd[j].fd = sockets[i].fd; in prepare_poll()
2141 if ((r = sshbuf_check_reserve(sockets[i].input, in prepare_poll()
2143 (r = sshbuf_check_reserve(sockets[i].output, in prepare_poll()
2148 if (sshbuf_len(sockets[i].output) > 0) in prepare_poll()