Lines Matching refs:conn
183 void rds_cong_add_conn(struct rds_connection *conn) in rds_cong_add_conn() argument
187 rdsdebug("conn %p now on map %p\n", conn, conn->c_lcong); in rds_cong_add_conn()
189 list_add_tail(&conn->c_map_item, &conn->c_lcong->m_conn_list); in rds_cong_add_conn()
193 void rds_cong_remove_conn(struct rds_connection *conn) in rds_cong_remove_conn() argument
197 rdsdebug("removing conn %p from map %p\n", conn, conn->c_lcong); in rds_cong_remove_conn()
199 list_del_init(&conn->c_map_item); in rds_cong_remove_conn()
203 int rds_cong_get_maps(struct rds_connection *conn) in rds_cong_get_maps() argument
205 conn->c_lcong = rds_cong_from_addr(conn->c_laddr); in rds_cong_get_maps()
206 conn->c_fcong = rds_cong_from_addr(conn->c_faddr); in rds_cong_get_maps()
208 if (!(conn->c_lcong && conn->c_fcong)) in rds_cong_get_maps()
216 struct rds_connection *conn; in rds_cong_queue_updates() local
221 list_for_each_entry(conn, &map->m_conn_list, c_map_item) { in rds_cong_queue_updates()
222 if (!test_and_set_bit(0, &conn->c_map_queued)) { in rds_cong_queue_updates()
224 rds_send_xmit(conn); in rds_cong_queue_updates()
396 struct rds_message *rds_cong_update_alloc(struct rds_connection *conn) in rds_cong_update_alloc() argument
398 struct rds_cong_map *map = conn->c_lcong; in rds_cong_update_alloc()