409 	int sock_id;  in shutdown()  local
413 	if ((sock_id = so_check_fd(s, &errno)) == -1)  in shutdown()
417 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in shutdown()
422 	if (!(sockets[sock_id].so_state & SS_ISCONNECTED)) {  in shutdown()
429 		sockets[sock_id].so_state |= SS_CANTRCVMORE;  in shutdown()
432 		sockets[sock_id].so_state |= SS_CANTSENDMORE;  in shutdown()
435 		sockets[sock_id].so_state |= (SS_CANTRCVMORE | SS_CANTSENDMORE);  in shutdown()
442 	switch (sockets[sock_id].so_state &  in shutdown()
447 			if (sockets[sock_id].close[i] != NULL) {  in shutdown()
448 				(void) sockets[sock_id].close[i](sock_id);  in shutdown()
451 		nuke_grams(&sockets[sock_id].inq);  in shutdown()
454 		nuke_grams(&sockets[sock_id].inq);  in shutdown()
458 		if (tcp_shutdown(sock_id) < 0)  in shutdown()
475 	int sock_id, i;  in socket_close()  local
478 	if ((sock_id = so_check_fd(s, &errno)) == -1)  in socket_close()
483 		if (sockets[sock_id].close[i] != NULL) {  in socket_close()
493 			(void) sockets[sock_id].close[i](sock_id);  in socket_close()
502 	nuke_grams(&sockets[sock_id].inq);  in socket_close()
504 	bzero((caddr_t)&sockets[sock_id], sizeof (struct inetboot_socket));  in socket_close()
505 	sockets[sock_id].type = INETBOOT_UNUSED;  in socket_close()
553 bind_check(int sock_id, const struct sockaddr *addr)  in bind_check()  argument
559 	if (! (sockets[sock_id].so_opt & SO_REUSEADDR)) {  in bind_check()
562 			    sockets[k].proto == sockets[sock_id].proto &&  in bind_check()
635 quickbind(int sock_id)  in quickbind()  argument
650 		if (bind_check(sock_id, (struct sockaddr *)&addr) == 0)  in quickbind()
657 		bcopy((caddr_t)&addr, (caddr_t)&sockets[sock_id].bind,  in quickbind()
659 		sockets[sock_id].bound = B_TRUE;  in quickbind()
662 		    inet_ntoa(sockets[sock_id].bind.sin_addr),  in quickbind()
663 		    ntohs(sockets[sock_id].bind.sin_port));  in quickbind()
674 	int sock_id;  in listen()  local
677 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in listen()
680 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in listen()
684 	if (sockets[sock_id].so_error != 0) {  in listen()
685 		errno = sockets[sock_id].so_error;  in listen()
688 	return (tcp_listen(sock_id, backlog));  in listen()
694 	int sock_id;  in accept()  local
698 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in accept()
701 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in accept()
705 	if (sockets[sock_id].so_error != 0) {  in accept()
706 		errno = sockets[sock_id].so_error;  in accept()
709 	if ((new_sd = tcp_accept(sock_id, addr, addr_len)) == -1)  in accept()
711 	sock_id = so_check_fd(new_sd, &errno);  in accept()
712 	sockets[sock_id].so_state |= SS_ISCONNECTED;  in accept()
719 	int sock_id;  in connect()  local
723 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in connect()
726 	so_type = sockets[sock_id].type;  in connect()
738 	if (sockets[sock_id].so_state & SS_ISCONNECTED) {  in connect()
743 	if (sockets[sock_id].so_error != 0) {  in connect()
744 		errno = sockets[sock_id].so_error;  in connect()
749 	if (!sockets[sock_id].bound) {  in connect()
752 			if (tcp_bind(sock_id) < 0)  in connect()
755 			if (quickbind(sock_id) < 0) {  in connect()
762 	bcopy((caddr_t)addr, &sockets[sock_id].remote,  in connect()
765 	if (sockets[sock_id].type == INETBOOT_STREAM) {  in connect()
767 		if (tcp_connect(sock_id) == 0)  in connect()
768 			sockets[sock_id].so_state |= SS_ISCONNECTED;  in connect()
770 			if (sockets[sock_id].so_error != 0)  in connect()
771 				errno = sockets[sock_id].so_error;  in connect()
775 		sockets[sock_id].so_state |= SS_ISCONNECTED;  in connect()
797 	int			sock_id, i;  in recvfrom()  local
806 	if ((sock_id = so_check_fd(s, &errno)) == -1) {  in recvfrom()
811 	if (sockets[sock_id].type == INETBOOT_STREAM &&  in recvfrom()
812 	    !(sockets[sock_id].so_state & SS_ISCONNECTED)) {  in recvfrom()
828 	if (sockets[sock_id].inq == NULL) {  in recvfrom()
831 			if (sockets[sock_id].input[i] != NULL) {  in recvfrom()
832 				if (sockets[sock_id].input[i](sock_id) < 0) {  in recvfrom()
833 					if (sockets[sock_id].so_error != 0) {  in recvfrom()
835 						    sockets[sock_id].so_error;  in recvfrom()
843 	so_type = sockets[sock_id].type;  in recvfrom()
846 	while ((icp = sockets[sock_id].inq) != NULL) {  in recvfrom()
854 			del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
868 		if (sockets[sock_id].so_state & SS_CANTRCVMORE) {  in recvfrom()
869 			if (sockets[sock_id].so_error != 0) {  in recvfrom()
870 				errno = sockets[sock_id].so_error;  in recvfrom()
889 			bcopy(&(sockets[sock_id].remote), from, MIN(*fromlen,  in recvfrom()
911 			del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
912 			tcp_rcv_drain_sock(sock_id);  in recvfrom()
930 				del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
936 				while ((icp = sockets[sock_id].inq) != NULL) {  in recvfrom()
939 					del_gram(&sockets[sock_id].inq, icp,  in recvfrom()
948 		sockets[sock_id].so_rcvbuf += (int32_t)bytes;  in recvfrom()
957 		del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
967 		del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
972 	printf("recvfrom(%d): data: (0x%x,%d)\n", sock_id,  in recvfrom()
996 	int sock_id;  in sendto()  local
1001 	if ((sock_id = so_check_fd(s, &errno)) == -1) {  in sendto()
1008 	so_type = sockets[sock_id].type;  in sendto()
1013 	if (sockets[sock_id].so_error != 0) {  in sendto()
1014 		errno = sockets[sock_id].so_error;  in sendto()
1025 		if (!(sockets[sock_id].so_state & SS_ISCONNECTED) &&  in sendto()
1030 		bytes = dgram_sendto(sock_id, msg, len, flags, to, tolen);  in sendto()
1033 		if (!((sockets[sock_id].so_state & SS_ISCONNECTED) ||  in sendto()
1034 		    (sockets[sock_id].so_state & SS_ISCONNECTING))) {  in sendto()
1038 		if (sockets[sock_id].so_state & SS_CANTSENDMORE) {  in sendto()
1042 		bytes = stream_sendto(sock_id, msg, len, flags);  in sendto()