484 	old_timeout = sockets[sock_id].in_timeout;  in tcp_drain_input()
485 	sockets[sock_id].in_timeout = timeout;  in tcp_drain_input()
491 	old_in_gram = sockets[sock_id].inq;  in tcp_drain_input()
492 	sockets[sock_id].inq = NULL;  in tcp_drain_input()
496 		if (sockets[sock_id].input[i] != NULL) {  in tcp_drain_input()
497 			if (sockets[sock_id].input[i](sock_id) < 0) {  in tcp_drain_input()
498 				sockets[sock_id].in_timeout = old_timeout;  in tcp_drain_input()
499 				if (sockets[sock_id].inq != NULL)  in tcp_drain_input()
500 					nuke_grams(&sockets[sock_id].inq);  in tcp_drain_input()
501 				sockets[sock_id].inq = old_in_gram;  in tcp_drain_input()
509 	while ((in_gram = sockets[sock_id].inq) != NULL) {  in tcp_drain_input()
516 			del_gram(&sockets[sock_id].inq, in_gram, B_TRUE);  in tcp_drain_input()
520 		del_gram(&sockets[sock_id].inq, in_gram, B_FALSE);  in tcp_drain_input()
523 		sockets[sock_id].in_timeout = old_timeout;  in tcp_drain_input()
531 		if (sockets[sock_id].pcb == NULL)  in tcp_drain_input()
535 	if (tcp == NULL || sockets[sock_id].pcb == NULL) {  in tcp_drain_input()
536 		if (sockets[sock_id].so_error != 0)  in tcp_drain_input()
544 	sockets[sock_id].in_timeout = old_timeout;  in tcp_drain_input()
545 	sockets[sock_id].inq = old_in_gram;  in tcp_drain_input()
569 	if ((tcp = sockets[sock_id].pcb) == NULL)  in tcp_input()
572 	while ((in_gram = sockets[sock_id].inq) != NULL) {  in tcp_input()
579 			del_gram(&sockets[sock_id].inq, in_gram, B_TRUE);  in tcp_input()
583 		del_gram(&sockets[sock_id].inq, in_gram, B_FALSE);  in tcp_input()
587 		if (sockets[sock_id].pcb == NULL)  in tcp_input()
597 			sockets[sock_id].so_state |= SS_CANTRCVMORE;  in tcp_input()
829 	if ((tcp = sockets[sock_id].pcb) == NULL) {  in tcp_shutdown()
843 		if (sockets[sock_id].pcb != NULL)  in tcp_shutdown()
865 			if (sockets[sock_id].pcb == NULL)  in tcp_shutdown()
886 	if ((tcp = sockets[sock_id].pcb) == NULL) {  in tcp_close()
902 		if (sockets[sock_id].pcb != NULL)  in tcp_close()
959 		if (sockets[sock_id].pcb == NULL)  in tcp_close()
979 					if (sockets[sock_id].pcb != NULL) {  in tcp_close()
990 			if (sockets[sock_id].pcb == NULL)  in tcp_close()
1013 	sockets[sock_id].pcb = NULL;  in tcp_close()
1023 	if ((tcp = (tcp_t *)(sockets[sock_id].pcb)) == NULL) {  in tcp_listen()
1059 	if ((listener = (tcp_t *)(sockets[sock_id].pcb)) == NULL ||  in tcp_accept()
1067 	if (sockets[sock_id].in_timeout > tcp_accept_timeout)  in tcp_accept()
1068 		timeout = prom_gettime() + sockets[sock_id].in_timeout;  in tcp_accept()
1100 	bkmem_free((caddr_t)(sockets[new_sock_id].pcb), sizeof (tcp_t));  in tcp_accept()
1107 	sockets[new_sock_id].pcb = eager;  in tcp_accept()
1146 		if (sockets[i].type != INETBOOT_STREAM ||  in tcp_bindi()
1147 		    ((tcp = (tcp_t *)sockets[i].pcb) == NULL) ||  in tcp_bindi()
1186 	if ((tcp = (tcp_t *)sockets[sock_id].pcb) == NULL) {  in tcp_bind()
1197 	requested_port = ntohs(sockets[sock_id].bind.sin_port);  in tcp_bind()
1200 	tcp->tcp_bound_source = sockets[sock_id].bind.sin_addr.s_addr;  in tcp_bind()
1213 	reuseaddr = sockets[sock_id].so_opt & SO_REUSEADDR;  in tcp_bind()
1223 	sockets[sock_id].bind.sin_port = tcp->tcp_lport;  in tcp_bind()
1238 		if (sockets[i].type != INETBOOT_STREAM)  in tcp_conn_check()
1241 		if ((tmp_tcp = (tcp_t *)sockets[i].pcb) == NULL)  in tcp_conn_check()
1269 	if ((tcp = (tcp_t *)(sockets[sock_id].pcb)) == NULL) {  in tcp_connect()
1276 	dstaddr = sockets[sock_id].remote.sin_addr.s_addr;  in tcp_connect()
1277 	dstport = sockets[sock_id].remote.sin_port;  in tcp_connect()
1308 		ipv4_getipaddr(&(sockets[sock_id].bind.sin_addr));  in tcp_connect()
1310 		if (ntohl(sockets[sock_id].bind.sin_addr.s_addr) ==  in tcp_connect()
1315 		tcp->tcp_bound_source = sockets[sock_id].bind.sin_addr.s_addr;  in tcp_connect()
1714 	timeout = sockets[sock_id].in_timeout;  in tcp_state_wait()
1716 		sockets[sock_id].in_timeout = tcp->tcp_rto;  in tcp_state_wait()
1720 	if (sockets[sock_id].inq == NULL) {  in tcp_state_wait()
1723 			if (sockets[sock_id].input[i] != NULL) {  in tcp_state_wait()
1724 				if (sockets[sock_id].input[i](sock_id) < 0) {  in tcp_state_wait()
1726 						sockets[sock_id].in_timeout =  in tcp_state_wait()
1735 	while ((in_gram = sockets[sock_id].inq) != NULL) {  in tcp_state_wait()
1746 			del_gram(&sockets[sock_id].inq, in_gram, B_TRUE);  in tcp_state_wait()
1750 		del_gram(&sockets[sock_id].inq, in_gram, B_FALSE);  in tcp_state_wait()
1760 		if (sockets[sock_id].pcb == NULL) {  in tcp_state_wait()
1766 	if (tcp == NULL || sockets[sock_id].pcb == NULL) {  in tcp_state_wait()
1769 		    "error %d\n", state, sockets[sock_id].so_error);  in tcp_state_wait()
1771 		if (sockets[sock_id].so_error != 0)  in tcp_state_wait()
1791 		sockets[sock_id].in_timeout = timeout;  in tcp_state_wait()
1835 		if (sockets[i].type == INETBOOT_STREAM &&  in tcp_lookup_ipv4()
1836 		    (tcp = (tcp_t *)sockets[i].pcb) != NULL) {  in tcp_lookup_ipv4()
1870 		if (sockets[i].type == INETBOOT_STREAM &&  in tcp_lookup_listener_ipv4()
1871 		    (tcp = (tcp_t *)sockets[i].pcb) != NULL) {  in tcp_lookup_listener_ipv4()
1927 		sockets[sock_id].pcb = NULL;  in tcp_clean_death()
1929 			sockets[sock_id].so_error = err;  in tcp_clean_death()
4092 	if (++tcp->tcp_rack_cnt == 2 || sockets[sock_id].inq == NULL) {  in tcp_rput_data()
4175 			if (sockets[sock_id].pcb == NULL)  in tcp_rput_data()
5218 	if ((sockets[sock_id].pcb == NULL) || (sockets[sock_id].pcb != tcp))  in tcp_time_wait_processing()
6747 	if (sockets[sock_id].so_rcvbuf <= 0)  in tcp_rcv_drain()
6776 	add_grams(&sockets[sock_id].inq, in_gram);  in tcp_rcv_drain()
6779 	sockets[sock_id].so_rcvbuf -= in_mp->b_wptr - in_mp->b_rptr;  in tcp_rcv_drain()
6786 	if (sockets[sock_id].so_rcvbuf > 0 &&  in tcp_rcv_drain()
6801 	if ((tcp = sockets[sock_id].pcb) == NULL)  in tcp_rcv_drain_sock()
6817 		sockets[sock_id].inq, tcp->tcp_rcv_list);  in tcp_drain_needed()
6819 	if ((sockets[sock_id].inq != NULL) ||  in tcp_drain_needed()
6831 	add_grams(&sockets[sock_id].inq, in_gram);  in tcp_drain_needed()