Lines Matching refs:sockets
121 SocketEntry *sockets = NULL; variable
996 e = &sockets[socknum]; in process_message()
1100 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
1101 sockets[i].fd = fd; in new_socket()
1102 if ((sockets[i].input = sshbuf_new()) == NULL || in new_socket()
1103 (sockets[i].output = sshbuf_new()) == NULL || in new_socket()
1104 (sockets[i].request = sshbuf_new()) == NULL) in new_socket()
1106 sockets[i].type = type; in new_socket()
1111 sockets = xrecallocarray(sockets, old_alloc, new_alloc, in new_socket()
1112 sizeof(sockets[0])); in new_socket()
1114 sockets[i].type = AUTH_UNUSED; in new_socket()
1116 sockets[old_alloc].fd = fd; in new_socket()
1117 if ((sockets[old_alloc].input = sshbuf_new()) == NULL || in new_socket()
1118 (sockets[old_alloc].output = sshbuf_new()) == NULL || in new_socket()
1119 (sockets[old_alloc].request = sshbuf_new()) == NULL) in new_socket()
1121 sockets[old_alloc].type = type; in new_socket()
1134 fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen); in handle_socket_read()
1161 if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) { in handle_conn_read()
1166 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_read()
1170 if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0) in handle_conn_read()
1188 if (sshbuf_len(sockets[socknum].output) == 0) in handle_conn_write()
1190 if ((len = write(sockets[socknum].fd, in handle_conn_write()
1191 sshbuf_ptr(sockets[socknum].output), in handle_conn_write()
1192 sshbuf_len(sockets[socknum].output))) <= 0) { in handle_conn_write()
1197 socknum, sockets[socknum].fd, strerror(errno)); in handle_conn_write()
1201 if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0) in handle_conn_write()
1217 if (sockets[socknum].type != AUTH_SOCKET && in after_poll()
1218 sockets[socknum].type != AUTH_CONNECTION) in after_poll()
1220 if (pfd[i].fd == sockets[socknum].fd) in after_poll()
1228 switch (sockets[socknum].type) { in after_poll()
1250 close_socket(&sockets[socknum]); in after_poll()
1271 switch (sockets[i].type) { in prepare_poll()
1279 fatal("Unknown socket type %d", sockets[i].type); in prepare_poll()
1290 switch (sockets[i].type) { in prepare_poll()
1297 pfd[j].fd = sockets[i].fd; in prepare_poll()
1303 pfd[j].fd = sockets[i].fd; in prepare_poll()
1309 if ((r = sshbuf_check_reserve(sockets[i].input, in prepare_poll()
1311 (r = sshbuf_check_reserve(sockets[i].output, in prepare_poll()
1316 if (sshbuf_len(sockets[i].output) > 0) in prepare_poll()