cxgbe/iw_cxgbe/cm.c

63 #define TOEPCB(so)  ((struct toepcb *)(so_sototcpcb((so))->t_toe))
115 static int c4iw_so_upcall(struct socket *so, void *arg, int waitflag);
162 		if (epc->so)
178 	struct socket *so = ep->com.so;
179 	struct inpcb *inp = sotoinpcb(so);
188 		log(LOG_ERR, "%s: connection not offloaded (so %p, ep %p)\n",
189 		    __func__, so, ep);
192 	toep = TOEPCB(so);
226 	struct socket *so = epc->so;
229 	CTR4(KTR_IW_CXGBE, "%s: so %p, ep %p, state %s", __func__, epc, so,
232 	SOCK_LOCK(so);
233 	soupcall_clear(so, SO_RCV);
234 	SOCK_UNLOCK(so);
237                 rc = soclose(so);
239                 rc = soshutdown(so, SHUT_WR | SHUT_RD);
240 	epc->so = NULL;
249 	CTR4(KTR_IW_CXGBE, "%s: so %p, ep %p, state %s", __func__, epc->so, epc,
252 	return (soshutdown(epc->so, SHUT_WR));
262 	CTR4(KTR_IW_CXGBE, "%s ep %p so %p state %s", __func__, ep, ep->com.so,
275 	rc = sosetopt(ep->com.so, &sopt);
289 	CTR4(KTR_IW_CXGBE, "%s:ppcB ep %p so %p state %s", __func__, ep,
290 	    ep->com.so, states[ep->com.state]);
411 	CTR5(KTR_IW_CXGBE, "%s:pceB ep %p so %p so->so_error %u state %s",
412 	    __func__, ep, ep->com.so, ep->com.so->so_error,
466 			    __func__, ep->com.so->so_error);
491 	CTR4(KTR_IW_CXGBE, "%s:pccB ep %p so %p state %s", __func__, ep,
492 	    ep->com.so, states[ep->com.state]);
562 	struct socket *so = epc->so;
565 	SOCK_LOCK(so);
566 	soupcall_set(so, SO_RCV, c4iw_so_upcall, epc);
567 	so->so_state |= SS_NBIO;
568 	SOCK_UNLOCK(so);
575 	rc = sosetopt(so, &sopt);
577 		log(LOG_ERR, "%s: can't set TCP_NODELAY on so %p (%d)\n",
578 		    __func__, so, rc);
587 	CTR5(KTR_IW_CXGBE, "%s: so %p, ep %p, state %s, sb_cc %d", __func__,
588 	    ep->com.so, ep, states[ep->com.state], ep->com.so->so_rcv.sb_cc);
595 		in_getsockaddr(ep->com.so, (struct sockaddr **)&local);
596 		in_getpeeraddr(ep->com.so, (struct sockaddr **)&remote);
604 		if (ep->com.so->so_rcv.sb_cc)
606 			    "ep %p, state %d, so %p, so_state 0x%x, sb_cc %u\n",
607 			    __func__, ep, state_read(&ep->com), ep->com.so,
608 			    ep->com.so->so_state, ep->com.so->so_rcv.sb_cc);
617 	if ((ep->com.so->so_state & SS_ISCONNECTED) && !ep->com.so->so_error)
620 		connect_reply_upcall(ep, -ep->com.so->so_error);
631 	struct socket *so;
634 	so = TAILQ_FIRST(&head->so_comp);
635 	if (!so) {
639 	TAILQ_REMOVE(&head->so_comp, so, so_list);
641 	SOCK_LOCK(so);
642 	so->so_qstate &= ~SQ_COMP;
643 	so->so_head = NULL;
644 	soref(so);
645 	soupcall_set(so, SO_RCV, c4iw_so_upcall, child_ep);
646 	so->so_state |= SS_NBIO;
647 	SOCK_UNLOCK(so);
649 	soaccept(so, (struct sockaddr **)remote);
651 	return (so);
663 		CTR3(KTR_IW_CXGBE, "%s: parent so %p, parent ep %p, ENOMEM",
664 		    __func__, parent_ep->com.so, parent_ep);
669 	child_so = dequeue_socket(parent_ep->com.so, &remote, child_ep);
672 		    "%s: parent so %p, parent ep %p, child ep %p, dequeue err",
673 		    __func__, parent_ep->com.so, parent_ep, child_ep);
681 	    "%s: parent so %p, parent ep %p, child so %p, child ep %p",
682 	     __func__, parent_ep->com.so, parent_ep, child_so, child_ep);
687 	child_ep->com.so = child_so;
704 c4iw_so_upcall(struct socket *so, void *arg, int waitflag)
711 	    "%s: so %p, so_state 0x%x, ep %p, ep_state %s, tqe_prev %p",
712 	    __func__, so, so->so_state, ep, states[ep->com.state],
715 	if (ep && ep->com.so && !ep->com.entry.tqe_prev) {
716 		KASSERT(ep->com.so == so, ("%s: XXX review.", __func__));
730 	struct socket *so = ep->com.so;
732 	CTR6(KTR_IW_CXGBE, "process_socket_event: so %p, so_state 0x%x, "
733 	    "so_err %d, sb_state 0x%x, ep %p, ep_state %s", so, so->so_state,
734 	    so->so_error, so->so_rcv.sb_state, ep, states[state]);
747 	if (so->so_error) {
753 	if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) && state < CLOSING) {
759 	if (so->so_state & SS_ISDISCONNECTED) {
931 	KASSERT(!epc->so, ("%s warning ep->so %p \n", __func__, epc->so));
944 	KASSERT(!epc->so, ("%s ep->so %p", __func__, epc->so));
1032 	err = sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT, ep->com.thread);
1110 	err = sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT, ep->com.thread);
1203 	err = sosend(ep->com.so, NULL, NULL, m, NULL, MSG_DONTWAIT,
1351 	event.so = ep->com.so;
1430 	err = soreceive(ep->com.so, NULL, &uio, &top, NULL, &flags);
1445 	if (ep->com.so->so_rcv.sb_mb) {
1448 		printf("%s data after soreceive called! so %p sb_mb %p top %p\n",
1449 		       __func__, ep->com.so, ep->com.so->so_rcv.sb_mb, top);
1640 	 * FW_RI_INIT_P2PTYPE_DISABLED in mpa attributes so that RTR is not
1653 	//ep->ofld_txq = TOEPCB(ep->com.so)->ofld_txq;
1745 	rc = soreceive(ep->com.so, NULL, &uio, NULL, NULL, &flags);
1754 	KASSERT(uio.uio_offset > 0, ("%s: sorecieve on so %p read no data",
1755 	    __func__, ep->com.so));
1891 		err = soshutdown(ep->com.so, 3);
1982 	//ep->ofld_txq = TOEPCB(ep->com.so)->ofld_txq;
2087 	ep->com.so = cm_id->so;
2127 	err = soconnect(ep->com.so, (struct sockaddr *)&ep->com.remote_addr,
2156 	struct socket *so = cm_id->so;
2160 	    cm_id, so, ep, so->so_pcb);
2175 	ep->com.so = so;
2178 	rc = solisten(so, ep->backlog, ep->com.thread);
2202 	CTR4(KTR_IW_CXGBE, "%s: cm_id %p, so %p, inp %p", __func__, cm_id,
2203 	    cm_id->so, cm_id->so->so_pcb);
2394 	struct socket *so = inp_inpcbtosocket(toep->inp);
2395 	struct c4iw_ep *ep = so->so_rcv.sb_upcallarg;