Lines Matching defs:sockets

127 SocketEntry *sockets = NULL;
1806 	e = &sockets[socknum];
1909 		if (sockets[i].type == AUTH_UNUSED) {
1910 			sockets[i].fd = fd;
1911 			if ((sockets[i].input = sshbuf_new()) == NULL ||
1912 			    (sockets[i].output = sshbuf_new()) == NULL ||
1913 			    (sockets[i].request = sshbuf_new()) == NULL)
1915 			sockets[i].type = type;
1920 	sockets = xrecallocarray(sockets, old_alloc, new_alloc,
1921 	    sizeof(sockets[0]));
1923 		sockets[i].type = AUTH_UNUSED;
1925 	sockets[old_alloc].fd = fd;
1926 	if ((sockets[old_alloc].input = sshbuf_new()) == NULL ||
1927 	    (sockets[old_alloc].output = sshbuf_new()) == NULL ||
1928 	    (sockets[old_alloc].request = sshbuf_new()) == NULL)
1930 	sockets[old_alloc].type = type;
1943 	fd = accept(sockets[socknum].fd, (struct sockaddr *)&sunaddr, &slen);
1970 	if ((len = read(sockets[socknum].fd, buf, sizeof(buf))) <= 0) {
1975 			    socknum, sockets[socknum].fd, strerror(errno));
1979 	if ((r = sshbuf_put(sockets[socknum].input, buf, len)) != 0)
1997 	if (sshbuf_len(sockets[socknum].output) == 0)
1999 	if ((len = write(sockets[socknum].fd,
2000 	    sshbuf_ptr(sockets[socknum].output),
2001 	    sshbuf_len(sockets[socknum].output))) <= 0) {
2006 			    socknum, sockets[socknum].fd, strerror(errno));
2010 	if ((r = sshbuf_consume(sockets[socknum].output, len)) != 0)
2024 		/* Find sockets entry */
2026 			if (sockets[socknum].type != AUTH_SOCKET &&
2027 			    sockets[socknum].type != AUTH_CONNECTION)
2029 			if (pfd[i].fd == sockets[socknum].fd)
2037 		switch (sockets[socknum].type) {
2058 				close_socket(&sockets[socknum]);
2077 	/* Count active sockets */
2079 		switch (sockets[i].type) {
2087 			fatal("Unknown socket type %d", sockets[i].type);
2098 		switch (sockets[i].type) {
2105 			pfd[j].fd = sockets[i].fd;
2111 			pfd[j].fd = sockets[i].fd;
2117 			if ((r = sshbuf_check_reserve(sockets[i].input,
2119 			    (r = sshbuf_check_reserve(sockets[i].output,
2124 			if (sshbuf_len(sockets[i].output) > 0)