Lines Matching defs:conn
43 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn,
48 inc->i_conn = conn;
132 static void rds_conn_peer_gen_update(struct rds_connection *conn,
139 WARN_ON(conn->c_trans->t_type != RDS_TRANS_TCP);
141 if (conn->c_peer_gen_num != 0 &&
142 peer_gen_num != conn->c_peer_gen_num) {
146 cp = &conn->c_path[i];
158 conn->c_peer_gen_num = peer_gen_num;
199 struct rds_connection *conn)
217 conn->c_npaths = min_t(int, RDS_MPATH_WORKERS,
229 conn->c_npaths = max_t(int, conn->c_npaths, 1);
230 conn->c_ping_triggered = 0;
231 rds_conn_peer_gen_update(conn, new_peer_gen_num);
252 static void rds_start_mprds(struct rds_connection *conn)
257 if (conn->c_npaths > 1 &&
258 rds_addr_cmp(&conn->c_laddr, &conn->c_faddr) < 0) {
259 for (i = 0; i < conn->c_npaths; i++) {
260 cp = &conn->c_path[i];
268 * rx and conn reset on this specific conn.
271 * down a connection at a time. This lets us reassemble in the conn
273 * flows to tear down partial reassembly progress on conn failure and
279 * conn. This lets loopback, who only has one conn for both directions,
280 * tell us which roles the addrs in the conn are playing for this message.
282 void rds_recv_incoming(struct rds_connection *conn, struct in6_addr *saddr,
291 inc->i_conn = conn;
293 if (conn->c_trans->t_mp_capable)
296 cp = &conn->c_path[0];
298 rdsdebug("conn %p next %llu inc %p seq %llu len %u sport %u dport %u "
299 "flags 0x%x rx_jiffies %lu\n", conn,
311 * sequence number as they're queued in a sending conn. They
314 * under normal operation. They can also drop back in the conn
316 * new instance of a conn. We drop those, otherwise we have
324 * from the sending conn until all their frags are sent.
362 rs = rds_find_bound(daddr, inc->i_hdr.h_dport, conn->c_bound_if);