Lines Matching refs:sockets

116 SocketEntry *sockets = NULL;  variable
704 e = &sockets[socknum]; in process_message()
806 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
807 sockets[i].fd = fd; in new_socket()
808 if ((sockets[i].input = sshbuf_new()) == NULL) in new_socket()
810 if ((sockets[i].output = sshbuf_new()) == NULL) in new_socket()
812 if ((sockets[i].request = sshbuf_new()) == NULL) in new_socket()
814 sockets[i].type = type; in new_socket()
819 sockets = xreallocarray(sockets, new_alloc, sizeof(sockets[0])); in new_socket()
821 sockets[i].type = AUTH_UNUSED; in new_socket()
823 sockets[old_alloc].fd = fd; in new_socket()
824 if ((sockets[old_alloc].input = sshbuf_new()) == NULL) in new_socket()
826 if ((sockets[old_alloc].output = sshbuf_new()) == NULL) in new_socket()
828 if ((sockets[old_alloc].request = sshbuf_new()) == NULL) in new_socket()
830 sockets[old_alloc].type = type; in new_socket()
843 fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen); in handle_socket_read()
870 if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) { in handle_conn_read()
875 __func__, socknum, sockets[socknum].fd, in handle_conn_read()
880 if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0) in handle_conn_read()
893 if (sshbuf_len(sockets[socknum].output) == 0) in handle_conn_write()
895 if ((len = write(sockets[socknum].fd, in handle_conn_write()
896 sshbuf_ptr(sockets[socknum].output), in handle_conn_write()
897 sshbuf_len(sockets[socknum].output))) <= 0) { in handle_conn_write()
902 __func__, socknum, sockets[socknum].fd, in handle_conn_write()
907 if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0) in handle_conn_write()
923 if (sockets[socknum].type != AUTH_SOCKET && in after_poll()
924 sockets[socknum].type != AUTH_CONNECTION) in after_poll()
926 if (pfd[i].fd == sockets[socknum].fd) in after_poll()
934 switch (sockets[socknum].type) { in after_poll()
956 close_socket(&sockets[socknum]); in after_poll()
976 switch (sockets[i].type) { in prepare_poll()
984 fatal("Unknown socket type %d", sockets[i].type); in prepare_poll()
995 switch (sockets[i].type) { in prepare_poll()
1002 pfd[j].fd = sockets[i].fd; in prepare_poll()
1008 pfd[j].fd = sockets[i].fd; in prepare_poll()
1012 if (sshbuf_len(sockets[i].output) > 0) in prepare_poll()