ulp/iw_cxgb/iw_cxgb_cm.c

150 static int iwch_so_upcall(struct socket *so, void *arg, int waitflag);
195 	struct socket *so = ep->com.so;
196 	struct inpcb *inp = sotoinpcb(so);
293 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, epc, epc->so, states[epc->state]);
294 	SOCK_LOCK(epc->so);
295 	soupcall_clear(epc->so, SO_RCV);
296 	SOCK_UNLOCK(epc->so);
298 		soclose(epc->so);
300 		soshutdown(epc->so, SHUT_WR|SHUT_RD);
301 	epc->so = NULL;
307 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, epc, epc->so, states[epc->state]);
308 	soshutdown(epc->so, SHUT_WR);
318 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
329 	err = sosetopt(ep->com.so, &sopt);
362 	err = sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT, ep->com.thread);
401 	err = sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT, ep->com.thread);
413 	CTR4(KTR_IW_CXGB, "%s ep %p so %p plen %d", __FUNCTION__, ep, ep->com.so, plen);
435 	return sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT,
444 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
460 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
474 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
489 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
508 	CTR5(KTR_IW_CXGB, "%s ep %p so %p state %s status %d", __FUNCTION__, ep, ep->com.so, states[ep->com.state], status);
536 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
544 	event.so = ep->com.so;
559 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
581 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
594 	err = soreceive(ep->com.so, NULL, &uio, &top, NULL, &flags);
604 	if (ep->com.so->so_rcv.sb_mb) {
605 		printf("%s data after soreceive called! so %p sb_mb %p top %p\n",
606 			__FUNCTION__, ep->com.so, ep->com.so->so_rcv.sb_mb, top);
740 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
753 	err = soreceive(ep->com.so, NULL, &uio, &top, NULL, &flags);
881 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
996 			ep->com.so->so_error);
1018 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1077 	struct socket *so = toep->tp_inp->inp_socket;
1078 	struct iwch_ep *ep = so->so_rcv.sb_upcallarg;
1105 	struct socket *so = toep->tp_inp->inp_socket;
1106 	struct iwch_ep *ep = so->so_rcv.sb_upcallarg;
1134 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1171 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1182 		err = soshutdown(ep->com.so, 3);
1198 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1267 	SOCK_LOCK(epc->so);
1268 	soupcall_set(epc->so, SO_RCV, iwch_so_upcall, epc);
1269 	epc->so->so_state |= SS_NBIO;
1270 	SOCK_UNLOCK(epc->so);
1277 	err = sosetopt(epc->so, &sopt);
1333 	ep->com.so = cm_id->so;
1365 	err = soconnect(ep->com.so, (struct sockaddr *)&ep->com.remote_addr,
1395 	ep->com.so = cm_id->so;
1422 	PANIC_IF(!ep->com.so);
1424 	CTR5(KTR_IW_CXGB, "%s ep %p so %p state %s, abrupt %d", __FUNCTION__, ep,
1425 	     ep->com.so, states[ep->com.state], abrupt);
1478 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1492 		in_getsockaddr(ep->com.so, (struct sockaddr **)&local);
1493 		in_getpeeraddr(ep->com.so, (struct sockaddr **)&remote);
1504 		if (ep->com.so->so_rcv.sb_cc)
1506 			       " ep %p state %d so %p so_state %x so_rcv.sb_cc %u so_rcv.sb_mb %p\n",
1507 			       __FUNCTION__, ep, state_read(&ep->com), ep->com.so, ep->com.so->so_state,
1508 			       ep->com.so->so_rcv.sb_cc, ep->com.so->so_rcv.sb_mb);
1517 	CTR4(KTR_IW_CXGB, "%s ep %p so %p state %s", __FUNCTION__, ep, ep->com.so, states[ep->com.state]);
1518 	if ((ep->com.so->so_state & SS_ISCONNECTED) && !ep->com.so->so_error) {
1521 		connect_reply_upcall(ep, -ep->com.so->so_error);
1536 	CTR3(KTR_IW_CXGB, "%s parent ep %p so %p", __FUNCTION__, parent_ep, parent_ep->com.so);
1565 	child_ep->com.so = child_so;
1582 iwch_so_upcall(struct socket *so, void *arg, int waitflag)
1586 	CTR6(KTR_IW_CXGB, "%s so %p so state %x ep %p ep state(%d)=%s", __FUNCTION__, so, so->so_state, ep, ep->com.state, states[ep->com.state]);
1588 	if (ep && ep->com.so && !ep->com.entry.tqe_prev) {
1601 	struct socket *so = ep->com.so;
1603 	CTR6(KTR_IW_CXGB, "%s so %p so state %x ep %p ep state(%d)=%s", __FUNCTION__, so, so->so_state, ep, ep->com.state, states[ep->com.state]);
1618 	if (so->so_error) {
1624 	if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) && state < CLOSING) {
1630 	if (so->so_state & (SS_ISDISCONNECTED)) {
1652 		if (epc->so)