Lines Matching refs:rm
80 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_tcp_xmit() argument
94 rm->m_ack_seq = tc->t_last_sent_nxt + in rds_tcp_xmit()
96 be32_to_cpu(rm->m_inc.i_hdr.h_len) - 1; in rds_tcp_xmit()
98 set_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags); in rds_tcp_xmit()
99 tc->t_last_expected_una = rm->m_ack_seq + 1; in rds_tcp_xmit()
102 rm, rds_tcp_snd_nxt(tc), in rds_tcp_xmit()
103 (unsigned long long)rm->m_ack_seq); in rds_tcp_xmit()
111 (void *)&rm->m_inc.i_hdr + hdr_off, in rds_tcp_xmit()
112 sizeof(rm->m_inc.i_hdr) - hdr_off); in rds_tcp_xmit()
120 more = rm->data.op_nents > 1 ? (MSG_MORE | MSG_SENDPAGE_NOTLAST) : 0; in rds_tcp_xmit()
121 while (sg < rm->data.op_nents) { in rds_tcp_xmit()
125 sg_page(&rm->data.op_sg[sg]), in rds_tcp_xmit()
126 rm->data.op_sg[sg].offset + off, in rds_tcp_xmit()
127 rm->data.op_sg[sg].length - off, in rds_tcp_xmit()
129 rdsdebug("tcp sendpage %p:%u:%u ret %d\n", (void *)sg_page(&rm->data.op_sg[sg]), in rds_tcp_xmit()
130 rm->data.op_sg[sg].offset + off, rm->data.op_sg[sg].length - off, in rds_tcp_xmit()
137 if (off == rm->data.op_sg[sg].length) { in rds_tcp_xmit()
141 if (sg == rm->data.op_nents - 1) in rds_tcp_xmit()
170 static int rds_tcp_is_acked(struct rds_message *rm, uint64_t ack) in rds_tcp_is_acked() argument
172 if (!test_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags)) in rds_tcp_is_acked()
174 return (__s32)((u32)rm->m_ack_seq - (u32)ack) < 0; in rds_tcp_is_acked()