@@ -339,26 +339,16 @@ async fn main() -> anyhow::Result<()> {
339339 }
340340 result = listener. accept( ) => {
341341 match result {
342- Ok ( ( socket, addr) ) => {
343- info!( "PGWire: Accepted connection from {}" , addr) ;
342+ Ok ( ( socket, _addr) ) => {
344343 let handler_factory = HandlerFactory ( pg_service. clone( ) ) ;
345344 tokio:: spawn( async move {
346- debug!( "PGWire: Received connection from {}, preparing to process" , addr) ;
347- debug!( "PGWire: Starting to process socket for {}" , addr) ;
348- match pgwire:: tokio:: process_socket( socket, None , handler_factory) . await {
349- Ok ( _) => {
350- info!( "PGWire: Connection from {} processed successfully" , addr) ;
351- debug!( "PGWire: Socket processing completed for {}" , addr) ;
352- }
353- Err ( e) => {
354- error!( "PGWire: Error processing connection from {}: {:?}" , addr, e) ;
355- debug!( "PGWire: Failed socket details: {:?}" , e) ;
356- }
345+ if let Err ( e) = pgwire:: tokio:: process_socket( socket, None , handler_factory) . await {
346+ error!( "Error processing PGWire socket: {:?}" , e) ;
357347 }
358348 } ) ;
359349 }
360350 Err ( e) => {
361- error!( "PGWire: Error accepting connection: {:?}" , e) ;
351+ error!( "Error accepting connection: {:?}" , e) ;
362352 }
363353 }
364354 }
0 commit comments