138 static void	tcp_connect (netmsg_t msg);
140 static void	tcp6_connect (netmsg_t msg);
200 tcp_usr_attach(netmsg_t msg)  in tcp_usr_attach()  argument
202 	struct socket *so = msg->base.nm_so;  in tcp_usr_attach()
203 	struct pru_attach_info *ai = msg->attach.nm_ai;  in tcp_usr_attach()
222 	lwkt_replymsg(&msg->lmsg, error);  in tcp_usr_attach()
233 tcp_usr_detach(netmsg_t msg)  in tcp_usr_detach()  argument
235 	struct socket *so = msg->base.nm_so;  in tcp_usr_detach()
255 	lwkt_replymsg(&msg->lmsg, error);  in tcp_usr_detach()
283 			lwkt_replymsg(&msg->lmsg, error);	\
290 tcp_sosetport(struct lwkt_msg *msg, lwkt_port_t port)  in tcp_sosetport()  argument
292 	sosetport(((struct netmsg_base *)msg)->nm_so, port);  in tcp_sosetport()
299 tcp_usr_bind(netmsg_t msg)  in tcp_usr_bind()  argument
301 	struct socket *so = msg->bind.base.nm_so;  in tcp_usr_bind()
302 	struct sockaddr *nam = msg->bind.nm_nam;  in tcp_usr_bind()
303 	struct thread *td = msg->bind.nm_td;  in tcp_usr_bind()
355 		lwkt_msg_t lmsg = &msg->bind.base.lmsg;  in tcp_usr_bind()
357 		KASSERT((msg->bind.nm_flags & PRUB_RELINK) == 0,  in tcp_usr_bind()
361 		msg->bind.nm_flags |= PRUB_RELINK;  in tcp_usr_bind()
373 	if (msg->bind.nm_flags & PRUB_RELINK) {  in tcp_usr_bind()
374 		msg->bind.nm_flags &= ~PRUB_RELINK;  in tcp_usr_bind()
390 tcp6_usr_bind(netmsg_t msg)  in tcp6_usr_bind()  argument
392 	struct socket *so = msg->bind.base.nm_so;  in tcp6_usr_bind()
393 	struct sockaddr *nam = msg->bind.nm_nam;  in tcp6_usr_bind()
394 	struct thread *td = msg->bind.nm_td;  in tcp6_usr_bind()
425 in_pcbinswildcardhash_handler(netmsg_t msg)  in in_pcbinswildcardhash_handler()  argument
427 	struct netmsg_inswildcard *nm = (struct netmsg_inswildcard *)msg;  in in_pcbinswildcardhash_handler()
443 tcp_usr_listen(netmsg_t msg)  in tcp_usr_listen()  argument
445 	struct socket *so = msg->listen.base.nm_so;  in tcp_usr_listen()
446 	struct thread *td = msg->listen.nm_td;  in tcp_usr_listen()
456 		lwkt_msg_t lmsg = &msg->listen.base.lmsg;  in tcp_usr_listen()
458 		KASSERT((msg->listen.nm_flags & PRUL_RELINK) == 0,  in tcp_usr_listen()
462 		msg->listen.nm_flags |= PRUL_RELINK;  in tcp_usr_listen()
474 	if (msg->listen.nm_flags & PRUL_RELINK) {  in tcp_usr_listen()
475 		msg->listen.nm_flags &= ~PRUL_RELINK;  in tcp_usr_listen()
520 tcp6_usr_listen(netmsg_t msg)  in tcp6_usr_listen()  argument
522 	struct socket *so = msg->listen.base.nm_so;  in tcp6_usr_listen()
523 	struct thread *td = msg->listen.nm_td;  in tcp6_usr_listen()
580 tcp_usr_connect(netmsg_t msg)  in tcp_usr_connect()  argument
582 	struct socket *so = msg->connect.base.nm_so;  in tcp_usr_connect()
583 	struct sockaddr *nam = msg->connect.nm_nam;  in tcp_usr_connect()
584 	struct thread *td = msg->connect.nm_td;  in tcp_usr_connect()
603 	tcp_connect(msg);  in tcp_usr_connect()
607 	if (msg->connect.nm_m) {  in tcp_usr_connect()
608 		m_freem(msg->connect.nm_m);  in tcp_usr_connect()
609 		msg->connect.nm_m = NULL;  in tcp_usr_connect()
611 	if (msg->connect.nm_flags & PRUC_HELDTD)  in tcp_usr_connect()
613 	if (error && (msg->connect.nm_flags & PRUC_ASYNC)) {  in tcp_usr_connect()
617 	lwkt_replymsg(&msg->lmsg, error);  in tcp_usr_connect()
623 tcp6_usr_connect(netmsg_t msg)  in tcp6_usr_connect()  argument
625 	struct socket *so = msg->connect.base.nm_so;  in tcp6_usr_connect()
626 	struct sockaddr *nam = msg->connect.nm_nam;  in tcp6_usr_connect()
627 	struct thread *td = msg->connect.nm_td;  in tcp6_usr_connect()
659 	tcp6_connect(msg);  in tcp6_usr_connect()
663 	if (msg->connect.nm_m) {  in tcp6_usr_connect()
664 		m_freem(msg->connect.nm_m);  in tcp6_usr_connect()
665 		msg->connect.nm_m = NULL;  in tcp6_usr_connect()
667 	lwkt_replymsg(&msg->lmsg, error);  in tcp6_usr_connect()
684 tcp_usr_disconnect(netmsg_t msg)  in tcp_usr_disconnect()  argument
686 	struct socket *so = msg->disconnect.base.nm_so;  in tcp_usr_disconnect()
702 tcp_usr_accept(netmsg_t msg)  in tcp_usr_accept()  argument
704 	struct socket *so = msg->accept.base.nm_so;  in tcp_usr_accept()
705 	struct sockaddr **nam = msg->accept.nm_nam;  in tcp_usr_accept()
729 tcp6_usr_accept(netmsg_t msg)  in tcp6_usr_accept()  argument
731 	struct socket *so = msg->accept.base.nm_so;  in tcp6_usr_accept()
732 	struct sockaddr **nam = msg->accept.nm_nam;  in tcp6_usr_accept()
759 tcp_usr_shutdown(netmsg_t msg)  in tcp_usr_shutdown()  argument
761 	struct socket *so = msg->shutdown.base.nm_so;  in tcp_usr_shutdown()
778 tcp_usr_rcvd(netmsg_t msg)  in tcp_usr_rcvd()  argument
780 	struct socket *so = msg->rcvd.base.nm_so;  in tcp_usr_rcvd()
787 	if (msg->rcvd.nm_pru_flags & PRUR_ASYNC) {  in tcp_usr_rcvd()
804 tcp_usr_send(netmsg_t msg)  in tcp_usr_send()  argument
806 	struct socket *so = msg->send.base.nm_so;  in tcp_usr_send()
807 	int flags = msg->send.nm_flags;  in tcp_usr_send()
808 	struct mbuf *m = msg->send.nm_m;  in tcp_usr_send()
814 	KKASSERT(msg->send.nm_control == NULL);  in tcp_usr_send()
815 	KKASSERT(msg->send.nm_addr == NULL);  in tcp_usr_send()
901 tcp_usr_abort(netmsg_t msg)  in tcp_usr_abort()  argument
903 	struct socket *so = msg->abort.base.nm_so;  in tcp_usr_abort()
917 tcp_usr_rcvoob(netmsg_t msg)  in tcp_usr_rcvoob()  argument
919 	struct socket *so = msg->rcvoob.base.nm_so;  in tcp_usr_rcvoob()
920 	struct mbuf *m = msg->rcvoob.nm_m;  in tcp_usr_rcvoob()
921 	int flags = msg->rcvoob.nm_flags;  in tcp_usr_rcvoob()
1128 tcp_connect(netmsg_t msg)  in tcp_connect()  argument
1130 	struct socket *so = msg->connect.base.nm_so;  in tcp_connect()
1131 	struct sockaddr *nam = msg->connect.nm_nam;  in tcp_connect()
1132 	struct thread *td = msg->connect.nm_td;  in tcp_connect()
1146 	if (msg->connect.nm_flags & PRUC_RECONNECT) {  in tcp_connect()
1147 		msg->connect.nm_flags &= ~PRUC_RECONNECT;  in tcp_connect()
1170 		msg->connect.nm_flags |= PRUC_HASLADDR;  in tcp_connect()
1188 	if ((msg->connect.nm_flags & PRUC_HASLADDR) == 0) {  in tcp_connect()
1221 		lwkt_msg_t lmsg = &msg->connect.base.lmsg;  in tcp_connect()
1236 		msg->connect.nm_flags |= PRUC_RECONNECT;  in tcp_connect()
1237 		msg->connect.base.nm_dispatch = tcp_connect;  in tcp_connect()
1283 	} else if (msg->connect.nm_flags & PRUC_HELDTD) {  in tcp_connect()
1288 		msg->connect.nm_flags &= ~PRUC_HELDTD;  in tcp_connect()
1290 	error = tcp_connect_oncpu(tp, msg->connect.nm_sndflags,  in tcp_connect()
1291 				  msg->connect.nm_m, sin, if_sin, hash);  in tcp_connect()
1292 	msg->connect.nm_m = NULL;  in tcp_connect()
1294 	if (msg->connect.nm_m) {  in tcp_connect()
1295 		m_freem(msg->connect.nm_m);  in tcp_connect()
1296 		msg->connect.nm_m = NULL;  in tcp_connect()
1298 	if (msg->connect.nm_flags & PRUC_HELDTD)  in tcp_connect()
1300 	if (error && (msg->connect.nm_flags & PRUC_ASYNC)) {  in tcp_connect()
1304 	lwkt_replymsg(&msg->connect.base.lmsg, error);  in tcp_connect()
1311 tcp6_connect(netmsg_t msg)  in tcp6_connect()  argument
1314 	struct socket *so = msg->connect.base.nm_so;  in tcp6_connect()
1315 	struct sockaddr *nam = msg->connect.nm_nam;  in tcp6_connect()
1316 	struct thread *td = msg->connect.nm_td;  in tcp6_connect()
1328 	if (msg->connect.nm_flags & PRUC_RECONNECT) {  in tcp6_connect()
1329 		msg->connect.nm_flags &= ~PRUC_RECONNECT;  in tcp6_connect()
1355 		lwkt_msg_t lmsg = &msg->connect.base.lmsg;  in tcp6_connect()
1365 		msg->connect.nm_flags |= PRUC_RECONNECT;  in tcp6_connect()
1366 		msg->connect.base.nm_dispatch = tcp6_connect;  in tcp6_connect()
1376 	error = tcp6_connect_oncpu(tp, msg->connect.nm_sndflags,  in tcp6_connect()
1377 				   &msg->connect.nm_m, sin6, addr6);  in tcp6_connect()
1380 	if (msg->connect.nm_m) {  in tcp6_connect()
1381 		m_freem(msg->connect.nm_m);  in tcp6_connect()
1382 		msg->connect.nm_m = NULL;  in tcp6_connect()
1384 	lwkt_replymsg(&msg->connect.base.lmsg, error);  in tcp6_connect()
1469 tcp_ctloutput(netmsg_t msg)  in tcp_ctloutput()  argument
1471 	struct socket *so = msg->base.nm_so;  in tcp_ctloutput()
1472 	struct sockopt *sopt = msg->ctloutput.nm_sopt;  in tcp_ctloutput()
1478 	if (msg->ctloutput.nm_flags & PRCO_HELDTD)  in tcp_ctloutput()
1532 			ip6_ctloutput_dispatch(msg);  in tcp_ctloutput()
1535 		ip_ctloutput(msg);  in tcp_ctloutput()
1706 	lwkt_replymsg(&msg->lmsg, error);  in tcp_ctloutput()
1721 	struct netmsg_tcp_ctloutput *msg;  in tcp_ctloutmsg()  local
1739 	msg = kmalloc(sizeof(*msg), M_LWKTMSG, M_WAITOK | M_NULLOK);  in tcp_ctloutmsg()
1740 	if (msg == NULL) {  in tcp_ctloutmsg()
1746 	msg->sopt = *sopt;  in tcp_ctloutmsg()
1749 	error = sooptcopyin(sopt, &msg->sopt_val,  in tcp_ctloutmsg()
1750 	    sizeof(msg->sopt_val), sizeof(msg->sopt_val));  in tcp_ctloutmsg()
1752 		kfree(msg, M_LWKTMSG);  in tcp_ctloutmsg()
1755 	msg->sopt.sopt_val = &msg->sopt_val;  in tcp_ctloutmsg()
1758 	if (msg->sopt.sopt_td != NULL) {  in tcp_ctloutmsg()
1760 		lwkt_hold(msg->sopt.sopt_td);  in tcp_ctloutmsg()
1763 	msg->ctloutput.nm_flags = flags;  in tcp_ctloutmsg()
1764 	msg->ctloutput.nm_sopt = &msg->sopt;  in tcp_ctloutmsg()
1766 	return &msg->ctloutput;  in tcp_ctloutmsg()