Lines Matching defs:conn
12 static int rxrpc_input_packet_on_conn(struct rxrpc_connection *conn,
166 struct rxrpc_connection *conn;
273 conn = rxrpc_find_client_connection_rcu(local, &peer_srx, skb);
274 conn = rxrpc_get_connection_maybe(conn, rxrpc_conn_get_call_input);
276 if (!conn)
279 ret = rxrpc_input_packet_on_conn(conn, &peer_srx, skb);
280 rxrpc_put_connection(conn, rxrpc_conn_put_call_input);
296 conn = rxrpc_find_service_conn_rcu(peer, skb);
297 conn = rxrpc_get_connection_maybe(conn, rxrpc_conn_get_call_input);
298 if (conn) {
300 ret = rxrpc_input_packet_on_conn(conn, &peer_srx, skb);
301 rxrpc_put_connection(conn, rxrpc_conn_put_call_input);
316 static int rxrpc_input_packet_on_conn(struct rxrpc_connection *conn,
326 if (sp->hdr.securityIndex != conn->security_ix)
330 if (sp->hdr.serviceId != conn->service_id) {
333 if (!test_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags))
336 old_id = cmpxchg(&conn->service_id, conn->orig_service_id,
338 if (old_id != conn->orig_service_id &&
343 if (after(sp->hdr.serial, conn->hi_serial))
344 conn->hi_serial = sp->hdr.serial;
348 return rxrpc_input_conn_packet(conn, skb);
352 chan = &conn->channels[channel];
366 if (rxrpc_conn_is_service(conn) &&
378 rxrpc_conn_retransmit_call(conn, skb, channel);
401 return rxrpc_new_incoming_call(conn->local, conn->peer, conn,
415 struct rxrpc_connection *conn;
435 conn = list_first_entry_or_null(&local->conn_attend_q,
438 if (conn) {
440 list_del_init(&conn->attend_link);
443 rxrpc_input_conn_event(conn, NULL);
444 rxrpc_put_connection(conn, rxrpc_conn_put_poke);
485 rxrpc_input_conn_event(sp->conn, skb);
486 rxrpc_put_connection(sp->conn, rxrpc_conn_put_poke);