File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 11use std:: io:: { self , Write } ;
22use std:: pin:: Pin ;
33use std:: sync:: Arc ;
4+ use std:: time:: Instant ;
45
56use futures:: { SinkExt , StreamExt } ;
67#[ cfg( any( feature = "_ring" , feature = "_aws-lc-rs" ) ) ]
@@ -340,7 +341,7 @@ async fn peek_for_sslrequest<ST>(
340341 loop {
341342 let mut buf = [ 0u8 ; 8 ] ;
342343 let n = socket. get_ref ( ) . peek ( & mut buf) . await ?;
343- println ! ( "Reading n {}" , n) ;
344+ println ! ( "Reading n {} {:?} " , n, Instant :: now ( ) ) ;
344345 println ! ( "Reading buf {:?}" , & buf) ;
345346 std:: io:: stdout ( ) . flush ( ) . unwrap ( ) ;
346347
@@ -444,7 +445,7 @@ where
444445 socket. next ( ) . await
445446 } ;
446447
447- println ! ( "{:?}" , msg) ;
448+ println ! ( "{:?} {:?} " , msg, Instant :: now ( ) ) ;
448449 if let Some ( Ok ( msg) ) = msg {
449450 let is_extended_query = match socket. state ( ) {
450451 PgWireConnectionState :: CopyInProgress ( is_extended_query) => is_extended_query,
You can’t perform that action at this time.
0 commit comments