@@ -429,7 +429,7 @@ func (s *ProxyServer) serveRecvFrontend(stream client.ProxyService_ProxyServer,
429
429
Payload : & client.Packet_DialResponse {DialResponse : & client.DialResponse {Error : err .Error ()}},
430
430
}
431
431
if err := stream .Send (resp ); err != nil {
432
- klog .V (5 ).Infoln ("Failed to send DIAL_RSP for no backend" , "error" , err , "serverID" , s .serverID )
432
+ klog .V (5 ).InfoS ("Failed to send DIAL_RSP for no backend" , "error" , err , "serverID" , s .serverID )
433
433
}
434
434
// The Dial is failing; no reason to keep this goroutine.
435
435
return
@@ -462,15 +462,15 @@ func (s *ProxyServer) serveRecvFrontend(stream client.ProxyService_ProxyServer,
462
462
// TODO: retry with other backends connecting to this agent.
463
463
klog .ErrorS (err , "CLOSE_REQ to Backend failed" , "serverID" , s .serverID , "connectionID" , connID )
464
464
} else {
465
- klog .V (5 ).Infoln ("CLOSE_REQ sent to backend" , "serverID" , s .serverID , "connectionID" , connID )
465
+ klog .V (5 ).InfoS ("CLOSE_REQ sent to backend" , "serverID" , s .serverID , "connectionID" , connID )
466
466
}
467
467
468
468
case client .PacketType_DIAL_CLS :
469
469
random := pkt .GetCloseDial ().Random
470
470
klog .V (5 ).InfoS ("Received DIAL_CLOSE" , "serverID" , s .serverID , "dialID" , random )
471
471
// Currently not worrying about backend as we do not have an established connection,
472
472
s .PendingDial .Remove (random )
473
- klog .V (5 ).Infoln ("Removing pending dial request" , "serverID" , s .serverID , "dialID" , random )
473
+ klog .V (5 ).InfoS ("Removing pending dial request" , "serverID" , s .serverID , "dialID" , random )
474
474
475
475
case client .PacketType_DATA :
476
476
connID := pkt .GetData ().ConnectID
@@ -717,7 +717,7 @@ func (s *ProxyServer) serveRecvBackend(backend Backend, stream agent.AgentServic
717
717
klog .V (5 ).InfoS ("Received DIAL_RSP" , "dialID" , resp .Random , "agentID" , agentID , "connectionID" , resp .ConnectID )
718
718
719
719
if frontend , ok := s .PendingDial .Get (resp .Random ); ! ok {
720
- klog .V (2 ).Infoln ("DIAL_RSP not recognized; dropped" , "dialID" , resp .Random , "agentID" , agentID , "connectionID" , resp .ConnectID )
720
+ klog .V (2 ).InfoS ("DIAL_RSP not recognized; dropped" , "dialID" , resp .Random , "agentID" , agentID , "connectionID" , resp .ConnectID )
721
721
} else {
722
722
dialErr := false
723
723
if resp .Error != "" {
@@ -768,7 +768,7 @@ func (s *ProxyServer) serveRecvBackend(backend Backend, stream agent.AgentServic
768
768
// Normal when frontend closes it.
769
769
klog .ErrorS (err , "CLOSE_RSP send to client stream error" , "serverID" , s .serverID , "agentID" , agentID , "connectionID" , resp .ConnectID )
770
770
} else {
771
- klog .V (5 ).Infoln ("CLOSE_RSP sent to frontend" , "connectionID" , resp .ConnectID )
771
+ klog .V (5 ).InfoS ("CLOSE_RSP sent to frontend" , "connectionID" , resp .ConnectID )
772
772
}
773
773
s .removeFrontend (agentID , resp .ConnectID )
774
774
klog .V (5 ).InfoS ("Close streaming" , "agentID" , agentID , "connectionID" , resp .ConnectID )
0 commit comments