net/rds/recv.c

44 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn,
49 	inc->i_conn = conn;
133 static void rds_conn_peer_gen_update(struct rds_connection *conn,
140 	WARN_ON(conn->c_trans->t_type != RDS_TRANS_TCP);
142 		if (conn->c_peer_gen_num != 0 &&
143 		    peer_gen_num != conn->c_peer_gen_num) {
147 				cp = &conn->c_path[i];
159 		conn->c_peer_gen_num = peer_gen_num;
200 				struct rds_connection *conn)
218 			conn->c_npaths = min_t(int, RDS_MPATH_WORKERS,
230 	conn->c_npaths = max_t(int, conn->c_npaths, 1);
231 	conn->c_ping_triggered = 0;
232 	rds_conn_peer_gen_update(conn, new_peer_gen_num);
253 static void rds_start_mprds(struct rds_connection *conn)
258 	if (conn->c_npaths > 1 &&
259 	    rds_addr_cmp(&conn->c_laddr, &conn->c_faddr) < 0) {
260 		for (i = 0; i < conn->c_npaths; i++) {
261 			cp = &conn->c_path[i];
269  * rx and conn reset on this specific conn.
272  * down a connection at a time.  This lets us reassemble in the conn
274  * flows to tear down partial reassembly progress on conn failure and
280  * conn.  This lets loopback, who only has one conn for both directions,
281  * tell us which roles the addrs in the conn are playing for this message.
283 void rds_recv_incoming(struct rds_connection *conn, struct in6_addr *saddr,
292 	inc->i_conn = conn;
294 	if (conn->c_trans->t_mp_capable)
297 		cp = &conn->c_path[0];
299 	rdsdebug("conn %p next %llu inc %p seq %llu len %u sport %u dport %u "
300 		 "flags 0x%x rx_jiffies %lu\n", conn,
312 	 * sequence number as they're queued in a sending conn.  They
315 	 * under normal operation.  They can also drop back in the conn
317 	 * new instance of a conn.  We drop those, otherwise we have
325 	 * from the sending conn until all their frags are sent.
363 	rs = rds_find_bound(daddr, inc->i_hdr.h_dport, conn->c_bound_if);