75 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,  in rds_tcp_xmit()  argument
78 	struct rds_conn_path *cp = rm->m_inc.i_conn_path;  in rds_tcp_xmit()
90 		rm->m_ack_seq = tc->t_last_sent_nxt +  in rds_tcp_xmit()
92 				be32_to_cpu(rm->m_inc.i_hdr.h_len) - 1;  in rds_tcp_xmit()
94 		set_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags);  in rds_tcp_xmit()
95 		tc->t_last_expected_una = rm->m_ack_seq + 1;  in rds_tcp_xmit()
97 		if (test_bit(RDS_MSG_RETRANSMITTED, &rm->m_flags))  in rds_tcp_xmit()
98 			rm->m_inc.i_hdr.h_flags |= RDS_FLAG_RETRANSMITTED;  in rds_tcp_xmit()
101 			 rm, rds_tcp_write_seq(tc),  in rds_tcp_xmit()
102 			 (unsigned long long)rm->m_ack_seq);  in rds_tcp_xmit()
110 				      (void *)&rm->m_inc.i_hdr + hdr_off,  in rds_tcp_xmit()
111 				      sizeof(rm->m_inc.i_hdr) - hdr_off);  in rds_tcp_xmit()
119 	more = rm->data.op_nents > 1 ? (MSG_MORE | MSG_SENDPAGE_NOTLAST) : 0;  in rds_tcp_xmit()
120 	while (sg < rm->data.op_nents) {  in rds_tcp_xmit()
124 						sg_page(&rm->data.op_sg[sg]),  in rds_tcp_xmit()
125 						rm->data.op_sg[sg].offset + off,  in rds_tcp_xmit()
126 						rm->data.op_sg[sg].length - off,  in rds_tcp_xmit()
128 		rdsdebug("tcp sendpage %p:%u:%u ret %d\n", (void *)sg_page(&rm->data.op_sg[sg]),  in rds_tcp_xmit()
129 			 rm->data.op_sg[sg].offset + off, rm->data.op_sg[sg].length - off,  in rds_tcp_xmit()
136 		if (off == rm->data.op_sg[sg].length) {  in rds_tcp_xmit()
140 		if (sg == rm->data.op_nents - 1)  in rds_tcp_xmit()
176 static int rds_tcp_is_acked(struct rds_message *rm, uint64_t ack)  in rds_tcp_is_acked()  argument
178 	if (!test_bit(RDS_MSG_HAS_ACK_SEQ, &rm->m_flags))  in rds_tcp_is_acked()
180 	return (__s32)((u32)rm->m_ack_seq - (u32)ack) < 0;  in rds_tcp_is_acked()