Lines Matching refs:rs
266 struct rds_sock *rs; in rds_cong_map_updated() local
269 list_for_each_entry(rs, &rds_cong_monitor, rs_cong_list) { in rds_cong_map_updated()
270 spin_lock(&rs->rs_lock); in rds_cong_map_updated()
271 rs->rs_cong_notify |= (rs->rs_cong_mask & portmask); in rds_cong_map_updated()
272 rs->rs_cong_mask &= ~portmask; in rds_cong_map_updated()
273 spin_unlock(&rs->rs_lock); in rds_cong_map_updated()
274 if (rs->rs_cong_notify) in rds_cong_map_updated()
275 rds_wake_sk_sleep(rs); in rds_cong_map_updated()
338 void rds_cong_add_socket(struct rds_sock *rs) in rds_cong_add_socket() argument
343 if (list_empty(&rs->rs_cong_list)) in rds_cong_add_socket()
344 list_add(&rs->rs_cong_list, &rds_cong_monitor); in rds_cong_add_socket()
348 void rds_cong_remove_socket(struct rds_sock *rs) in rds_cong_remove_socket() argument
354 list_del_init(&rs->rs_cong_list); in rds_cong_remove_socket()
359 map = rds_cong_tree_walk(&rs->rs_bound_addr, NULL); in rds_cong_remove_socket()
362 if (map && rds_cong_test_bit(map, rs->rs_bound_port)) { in rds_cong_remove_socket()
363 rds_cong_clear_bit(map, rs->rs_bound_port); in rds_cong_remove_socket()
369 struct rds_sock *rs) in rds_cong_wait() argument
374 if (rs && rs->rs_cong_monitor) { in rds_cong_wait()
379 spin_lock_irqsave(&rs->rs_lock, flags); in rds_cong_wait()
380 rs->rs_cong_mask |= RDS_CONG_MONITOR_MASK(ntohs(port)); in rds_cong_wait()
381 spin_unlock_irqrestore(&rs->rs_lock, flags); in rds_cong_wait()