Lines Matching refs:peer
27 struct rxrpc_connection *rxrpc_find_service_conn_rcu(struct rxrpc_peer *peer, in rxrpc_find_service_conn_rcu() argument
44 read_seqbegin_or_lock(&peer->service_conn_lock, &seq); in rxrpc_find_service_conn_rcu()
46 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
58 } while (need_seqretry(&peer->service_conn_lock, seq)); in rxrpc_find_service_conn_rcu()
60 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
69 static void rxrpc_publish_service_conn(struct rxrpc_peer *peer, in rxrpc_publish_service_conn() argument
76 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
78 pp = &peer->service_conns.rb_node; in rxrpc_publish_service_conn()
94 rb_insert_color(&conn->service_node, &peer->service_conns); in rxrpc_publish_service_conn()
97 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
104 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
116 &peer->service_conns); in rxrpc_publish_service_conn()
186 rxrpc_publish_service_conn(conn->params.peer, conn); in rxrpc_new_incoming_connection()
197 struct rxrpc_peer *peer = conn->params.peer; in rxrpc_unpublish_service_conn() local
199 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_unpublish_service_conn()
201 rb_erase(&conn->service_node, &peer->service_conns); in rxrpc_unpublish_service_conn()
202 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_unpublish_service_conn()