@@ -31,10 +31,9 @@ pub async fn handle_error(
3131 log_error ( error, client_socket_addr, server_socket_addr, opt_transaction_id, request_id) ;
3232
3333 trigger_udp_error_event (
34- error. clone ( ) ,
34+ error,
3535 client_socket_addr,
3636 server_service_binding,
37- opt_transaction_id,
3837 opt_udp_server_stats_event_sender,
3938 req_kind,
4039 )
@@ -51,7 +50,6 @@ fn log_error(
5150 client_socket_addr : SocketAddr ,
5251 server_socket_addr : SocketAddr ,
5352 opt_transaction_id : Option < TransactionId > ,
54-
5553 request_id : Uuid ,
5654) {
5755 match opt_transaction_id {
@@ -66,25 +64,19 @@ fn log_error(
6664}
6765
6866async fn trigger_udp_error_event (
69- error : Error ,
67+ error : & Error ,
7068 client_socket_addr : SocketAddr ,
7169 server_service_binding : ServiceBinding ,
72- opt_transaction_id : Option < TransactionId > ,
73-
7470 opt_udp_server_stats_event_sender : & crate :: event:: sender:: Sender ,
7571 req_kind : Option < UdpRequestKind > ,
7672) {
77- if opt_transaction_id. is_some ( ) {
78- // code-review: why we trigger an event only if transaction_id is present?
79-
80- if let Some ( udp_server_stats_event_sender) = opt_udp_server_stats_event_sender. as_deref ( ) {
81- udp_server_stats_event_sender
82- . send ( Event :: UdpError {
83- context : ConnectionContext :: new ( client_socket_addr, server_service_binding) ,
84- kind : req_kind,
85- error : error. clone ( ) . into ( ) ,
86- } )
87- . await ;
88- }
73+ if let Some ( udp_server_stats_event_sender) = opt_udp_server_stats_event_sender. as_deref ( ) {
74+ udp_server_stats_event_sender
75+ . send ( Event :: UdpError {
76+ context : ConnectionContext :: new ( client_socket_addr, server_service_binding) ,
77+ kind : req_kind,
78+ error : error. clone ( ) . into ( ) ,
79+ } )
80+ . await ;
8981 }
9082}
0 commit comments