File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -290,18 +290,18 @@ impl FrameHandler for CommonFrameHandler {
290290 ( PathPrefix :: Event , & DNSTAP_VALUE_PATHS . raw_data ) ,
291291 BASE64_STANDARD . encode ( & frame) ,
292292 ) ;
293- } else { match DnstapParser :: parse (
293+ } else if let Err ( err ) = DnstapParser :: parse (
294294 & mut log_event,
295295 frame,
296296 DnsParserOptions {
297297 lowercase_hostnames : self . lowercase_hostnames ,
298298 } ,
299- ) { Err ( err ) => {
299+ ) {
300300 emit ! ( DnstapParseError {
301301 error: format!( "Dnstap protobuf decode error {err:?}." )
302302 } ) ;
303303 return None ;
304- } _ => { } } }
304+ }
305305
306306 if self . log_namespace == LogNamespace :: Vector {
307307 // The timestamp is inserted by the parser which caters for the Legacy namespace.
Original file line number Diff line number Diff line change @@ -674,11 +674,11 @@ async fn handle_tcp_frame<T>(
674674 frame_handler. max_frame_handling_tasks ( ) ,
675675 )
676676 . await ;
677- } else { match frame_handler. handle_event ( received_from, frame) { Some ( event ) => {
677+ } else if let Some ( event ) = frame_handler. handle_event ( received_from, frame) {
678678 if let Err ( e) = event_sink. send_event ( event) . await {
679679 error ! ( "Error sending event: {e:?}." ) ;
680680 }
681- } _ => { } } }
681+ }
682682}
683683
684684/**
You can’t perform that action at this time.
0 commit comments