Lines Matching full:mb
66 sdp_post_send(struct sdp_sock *ssk, struct mbuf *mb) in sdp_post_send() argument
80 SDPSTATS_HIST(send_size, mb->len); in sdp_post_send()
83 m_freem(mb); in sdp_post_send()
88 h = mtod(mb, struct sdp_bsdh *); in sdp_post_send()
90 ssk->tx_bytes += mb->m_pkthdr.len; in sdp_post_send()
94 struct tx_srcavail_state *tx_sa = TX_SRCAVAIL_STATE(mb); in sdp_post_send()
99 m_freem(mb); in sdp_post_send()
102 TX_SRCAVAIL_STATE(mb)->mseq = mseq; in sdp_post_send()
106 if (unlikely(mb->m_flags & M_URG)) in sdp_post_send()
111 mb->m_flags |= M_RDONLY; /* Don't allow compression once sent. */ in sdp_post_send()
113 h->len = htonl(mb->m_pkthdr.len); in sdp_post_send()
117 sdp_prf1(ssk->socket, mb, "TX: %s bufs: %d mseq:%ld ack:%d", in sdp_post_send()
121 SDP_DUMP_PACKET(ssk->socket, "TX", mb, h); in sdp_post_send()
124 tx_req->mb = mb; in sdp_post_send()
127 for (i = 0; mb != NULL; i++, mb = mb->m_next, sge++) { in sdp_post_send()
128 addr = ib_dma_map_single(dev, mb->m_data, mb->m_len, in sdp_post_send()
135 sge->length = mb->m_len; in sdp_post_send()
144 if (unlikely(tx_req->mb->m_flags & M_URG)) in sdp_post_send()
155 m_freem(tx_req->mb); in sdp_post_send()
171 struct mbuf *mb = NULL; in sdp_send_completion() local
182 mb = tx_req->mb; in sdp_send_completion()
187 if (BZCOPY_STATE(mb)) in sdp_send_completion()
188 BZCOPY_STATE(mb)->busy--; in sdp_send_completion()
194 return mb; in sdp_send_completion()
200 struct mbuf *mb = NULL; in sdp_handle_send_comp() local
205 sdp_prf(ssk->socket, mb, "Send completion with error. " in sdp_handle_send_comp()
213 mb = sdp_send_completion(ssk, wc->wr_id); in sdp_handle_send_comp()
214 if (unlikely(!mb)) in sdp_handle_send_comp()
217 h = mtod(mb, struct sdp_bsdh *); in sdp_handle_send_comp()
218 sdp_prf1(ssk->socket, mb, "tx completion. mseq:%d", ntohl(h->mseq)); in sdp_handle_send_comp()
220 mb, mb->m_pkthdr.len, ntohl(h->mseq)); in sdp_handle_send_comp()
221 m_freem(mb); in sdp_handle_send_comp()
381 struct mbuf *mb; in sdp_tx_ring_purge() local
382 mb = sdp_send_completion(ssk, ring_tail(ssk->tx_ring)); in sdp_tx_ring_purge()
383 if (!mb) in sdp_tx_ring_purge()
385 m_freem(mb); in sdp_tx_ring_purge()