ulp/tom/cxgb_cpl_io.c

350 make_tx_data_wr(struct socket *so, struct tx_data_wr *req, int len,
353 	struct tcpcb *tp = so_sototcpcb(so);
358 	snd = so_sockbuf_snd(so);
424 t3_push_frames(struct socket *so, int req_completion)
426 	struct tcpcb *tp = so_sototcpcb(so);
440 	snd = so_sockbuf_snd(so);
451 			    so, curthread))
500 			make_tx_data_wr(so, wr, bytes, sndptr);
529 			make_tx_data_wr(so, wr, bytes, sndptr);
591 	struct socket *so = inp->inp_socket;
592 	struct sockbuf *so_rcv = &so->so_rcv;
636 	struct socket *so = inp_inpcbtosocket(inp);
648 	t3_push_frames(so, 1);
657 	struct socket *so = inp->inp_socket;
659 	t3_push_frames(so, 1);
734 select_rcv_wnd(struct socket *so)
738 	SOCKBUF_LOCK_ASSERT(&so->so_rcv);
740 	wnd = sbspace(&so->so_rcv);
767 offload_socket(struct socket *so, struct toepcb *toep)
771 	struct inpcb *inp = sotoinpcb(so);
777 	SOCKBUF_LOCK(&so->so_snd);
778 	so_sockbuf_snd(so)->sb_flags |= SB_NOCOALESCE;
779 	SOCKBUF_UNLOCK(&so->so_snd);
780 	SOCKBUF_LOCK(&so->so_rcv);
781 	so_sockbuf_rcv(so)->sb_flags |= SB_NOCOALESCE;
782 	SOCKBUF_UNLOCK(&so->so_rcv);
802 undo_offload_socket(struct socket *so)
804 	struct inpcb *inp = sotoinpcb(so);
812 	so_sockbuf_snd(so)->sb_flags &= ~SB_NOCOALESCE;
813 	so_sockbuf_rcv(so)->sb_flags &= ~SB_NOCOALESCE;
834 calc_opt0h(struct socket *so, int mtu_idx, int rscale, struct l2t_entry *e)
839 	if (so != NULL) {
840 		struct inpcb *inp = sotoinpcb(so);
843 		    so_options_get(so) & SO_KEEPALIVE;
856 calc_opt0l(struct socket *so, int rcv_bufsize)
863 	if (so != NULL)		/* optional because noone cares about IP TOS */
864 		opt0l |= V_TOS(INP_TOS(sotoinpcb(so)));
949 t3_connect(struct toedev *tod, struct socket *so,
957 	struct inpcb *inp = sotoinpcb(so);
990 	SOCKBUF_LOCK(&so->so_rcv);
992 	toep->tp_rx_credits = min(select_rcv_wnd(so) >> 10, M_RCV_BUFSIZ);
993 	SOCKBUF_UNLOCK(&so->so_rcv);
995 	offload_socket(so, toep);
1014 	cpl->opt0h = calc_opt0h(so, mtu_idx, rscale, e);
1015 	cpl->opt0l = calc_opt0l(so, toep->tp_rx_credits);
1025 	undo_offload_socket(so);
1057 	struct socket *so = inp->inp_socket;
1075 	sbflush(so_sockbuf_snd(so));
1116 	struct socket *so;
1164 	so  = inp->inp_socket;
1165 	so_rcv = &so->so_rcv;
1194 		if (!sbreserve_locked(so_rcv, newsize, so, NULL))
1202 	sorwakeup_locked(so);
1222 	struct socket *so;
1234 	so = inp_inpcbtosocket(inp);
1236 	socantrcvmore(so);
1285 	struct socket *so;
1297 	so = inp_inpcbtosocket(inp);
1318 		if (so->so_rcv.sb_state & SBS_CANTRCVMORE)
1319 			soisdisconnected(so);
1477 	struct socket *so;
1495 	so = inp->inp_socket;
1519 		so_error_set(so, abort_status_to_errno(tp, req->status));
1568 make_established(struct socket *so, uint32_t cpl_iss, uint32_t cpl_irs,
1571 	struct inpcb *inp = sotoinpcb(so);
1596 	 * in rx_credits so that they can be handed over with the next credit
1599 	SOCKBUF_LOCK(&so->so_rcv);
1600 	bufsize = select_rcv_wnd(so);
1601 	SOCKBUF_UNLOCK(&so->so_rcv);
1611 	soisconnected(so);
1633 		 * be touching are common to all so any message type will do.
1657 	struct socket *so;
1683 	so = inp->inp_socket;
1684 	make_established(so, req->snd_isn, req->rcv_isn, req->tcp_opt);
1709 	struct socket *so;
1719 	so = inp->inp_socket;
1763 	snd = so_sockbuf_snd(so);
1767 		so_sowwakeup_locked(so);
1771 		t3_push_frames(so, 0);