408 	int sock_id;  in shutdown()  local
412 	if ((sock_id = so_check_fd(s, &errno)) == -1)  in shutdown()
416 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in shutdown()
421 	if (!(sockets[sock_id].so_state & SS_ISCONNECTED)) {  in shutdown()
428 		sockets[sock_id].so_state |= SS_CANTRCVMORE;  in shutdown()
431 		sockets[sock_id].so_state |= SS_CANTSENDMORE;  in shutdown()
434 		sockets[sock_id].so_state |= (SS_CANTRCVMORE | SS_CANTSENDMORE);  in shutdown()
441 	switch (sockets[sock_id].so_state &  in shutdown()
446 			if (sockets[sock_id].close[i] != NULL) {  in shutdown()
447 				(void) sockets[sock_id].close[i](sock_id);  in shutdown()
450 		nuke_grams(&sockets[sock_id].inq);  in shutdown()
453 		nuke_grams(&sockets[sock_id].inq);  in shutdown()
457 		if (tcp_shutdown(sock_id) < 0)  in shutdown()
474 	int sock_id, i;  in socket_close()  local
477 	if ((sock_id = so_check_fd(s, &errno)) == -1)  in socket_close()
482 		if (sockets[sock_id].close[i] != NULL) {  in socket_close()
492 			(void) sockets[sock_id].close[i](sock_id);  in socket_close()
501 	nuke_grams(&sockets[sock_id].inq);  in socket_close()
503 	bzero((caddr_t)&sockets[sock_id], sizeof (struct inetboot_socket));  in socket_close()
504 	sockets[sock_id].type = INETBOOT_UNUSED;  in socket_close()
552 bind_check(int sock_id, const struct sockaddr *addr)  in bind_check()  argument
558 	if (! (sockets[sock_id].so_opt & SO_REUSEADDR)) {  in bind_check()
561 			    sockets[k].proto == sockets[sock_id].proto &&  in bind_check()
634 quickbind(int sock_id)  in quickbind()  argument
649 		if (bind_check(sock_id, (struct sockaddr *)&addr) == 0)  in quickbind()
656 		bcopy((caddr_t)&addr, (caddr_t)&sockets[sock_id].bind,  in quickbind()
658 		sockets[sock_id].bound = B_TRUE;  in quickbind()
661 		    inet_ntoa(sockets[sock_id].bind.sin_addr),  in quickbind()
662 		    ntohs(sockets[sock_id].bind.sin_port));  in quickbind()
673 	int sock_id;  in listen()  local
676 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in listen()
679 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in listen()
683 	if (sockets[sock_id].so_error != 0) {  in listen()
684 		errno = sockets[sock_id].so_error;  in listen()
687 	return (tcp_listen(sock_id, backlog));  in listen()
693 	int sock_id;  in accept()  local
697 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in accept()
700 	if (sockets[sock_id].type != INETBOOT_STREAM) {  in accept()
704 	if (sockets[sock_id].so_error != 0) {  in accept()
705 		errno = sockets[sock_id].so_error;  in accept()
708 	if ((new_sd = tcp_accept(sock_id, addr, addr_len)) == -1)  in accept()
710 	sock_id = so_check_fd(new_sd, &errno);  in accept()
711 	sockets[sock_id].so_state |= SS_ISCONNECTED;  in accept()
718 	int sock_id;  in connect()  local
722 	if ((sock_id = so_check_fd(fd, &errno)) == -1)  in connect()
725 	so_type = sockets[sock_id].type;  in connect()
737 	if (sockets[sock_id].so_state & SS_ISCONNECTED) {  in connect()
742 	if (sockets[sock_id].so_error != 0) {  in connect()
743 		errno = sockets[sock_id].so_error;  in connect()
748 	if (!sockets[sock_id].bound) {  in connect()
751 			if (tcp_bind(sock_id) < 0)  in connect()
754 			if (quickbind(sock_id) < 0) {  in connect()
761 	bcopy((caddr_t)addr, &sockets[sock_id].remote,  in connect()
764 	if (sockets[sock_id].type == INETBOOT_STREAM) {  in connect()
766 		if (tcp_connect(sock_id) == 0)  in connect()
767 			sockets[sock_id].so_state |= SS_ISCONNECTED;  in connect()
769 			if (sockets[sock_id].so_error != 0)  in connect()
770 				errno = sockets[sock_id].so_error;  in connect()
774 		sockets[sock_id].so_state |= SS_ISCONNECTED;  in connect()
796 	int			sock_id, i;  in recvfrom()  local
805 	if ((sock_id = so_check_fd(s, &errno)) == -1) {  in recvfrom()
810 	if (sockets[sock_id].type == INETBOOT_STREAM &&  in recvfrom()
811 	    !(sockets[sock_id].so_state & SS_ISCONNECTED)) {  in recvfrom()
827 	if (sockets[sock_id].inq == NULL) {  in recvfrom()
830 			if (sockets[sock_id].input[i] != NULL) {  in recvfrom()
831 				if (sockets[sock_id].input[i](sock_id) < 0) {  in recvfrom()
832 					if (sockets[sock_id].so_error != 0) {  in recvfrom()
834 						    sockets[sock_id].so_error;  in recvfrom()
842 	so_type = sockets[sock_id].type;  in recvfrom()
845 	while ((icp = sockets[sock_id].inq) != NULL) {  in recvfrom()
853 			del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
867 		if (sockets[sock_id].so_state & SS_CANTRCVMORE) {  in recvfrom()
868 			if (sockets[sock_id].so_error != 0) {  in recvfrom()
869 				errno = sockets[sock_id].so_error;  in recvfrom()
888 			bcopy(&(sockets[sock_id].remote), from, MIN(*fromlen,  in recvfrom()
910 			del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
911 			tcp_rcv_drain_sock(sock_id);  in recvfrom()
929 				del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
935 				while ((icp = sockets[sock_id].inq) != NULL) {  in recvfrom()
938 					del_gram(&sockets[sock_id].inq, icp,  in recvfrom()
947 		sockets[sock_id].so_rcvbuf += (int32_t)bytes;  in recvfrom()
956 		del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
966 		del_gram(&sockets[sock_id].inq, icp, B_TRUE);  in recvfrom()
971 	printf("recvfrom(%d): data: (0x%x,%d)\n", sock_id,  in recvfrom()
995 	int sock_id;  in sendto()  local
1000 	if ((sock_id = so_check_fd(s, &errno)) == -1) {  in sendto()
1007 	so_type = sockets[sock_id].type;  in sendto()
1012 	if (sockets[sock_id].so_error != 0) {  in sendto()
1013 		errno = sockets[sock_id].so_error;  in sendto()
1024 		if (!(sockets[sock_id].so_state & SS_ISCONNECTED) &&  in sendto()
1029 		bytes = dgram_sendto(sock_id, msg, len, flags, to, tolen);  in sendto()
1032 		if (!((sockets[sock_id].so_state & SS_ISCONNECTED) ||  in sendto()
1033 		    (sockets[sock_id].so_state & SS_ISCONNECTING))) {  in sendto()
1037 		if (sockets[sock_id].so_state & SS_CANTSENDMORE) {  in sendto()
1041 		bytes = stream_sendto(sock_id, msg, len, flags);  in sendto()