increase log verbosity to check CI errors

Author: danielfoehrKn

.github/workflows/e2e.yaml

@@ -96,6 +96,8 @@ jobs:
         docker tag gcr.io/k8s-staging-kas-network-proxy/proxy-agent:master gcr.io/k8s-staging-kas-network-proxy/proxy-agent-amd64:master
     - name: Run e2e tests
       run: make test-e2e-ci
+
+
   e2e:
     name: e2e
     runs-on: ubuntu-24.04
@@ -217,6 +219,8 @@ jobs:
         /usr/local/bin/kubectl wait --timeout=1m --for=condition=ready pods test
         /usr/local/bin/kubectl get pods -A -owide
         /usr/local/bin/kubectl wait --timeout=1m --for=condition=ready pods --namespace=kube-system -l k8s-app=konnectivity-agent
+        /usr/local/bin/kubectl get pods -A -owide
+        sleep 10
         /usr/local/bin/kubectl logs test
         
 

pkg/agent/client.go

@@ -568,6 +568,7 @@ func (a *Client) Serve() {
 	}
 }
 
+// TODO: e2e test failure: No "Received data from agent" in server, only ACKS are received
 func (a *Client) remoteToProxy(connID int64, eConn *endpointConn) {
 	defer func() {
 		if panicInfo := recover(); panicInfo != nil {
@@ -585,7 +586,7 @@ func (a *Client) remoteToProxy(connID int64, eConn *endpointConn) {
 
 	for {
 		n, err := eConn.conn.Read(buf[:])
-		klog.V(5).InfoS("received data from remote", "bytes", n, "connectionID", connID)
+		klog.V(4).InfoS("received data from remote", "bytes", n, "connectionID", connID)
 
 		if err == io.EOF {
 			klog.V(2).InfoS("remote connection EOF", "connectionID", connID)
@@ -615,6 +616,7 @@ func (a *Client) remoteToProxy(connID int64, eConn *endpointConn) {
 		if err := a.Send(resp); err != nil {
 			klog.ErrorS(err, "could not send DATA", "connectionID", connID)
 		}
+		klog.V(4).InfoS("send data to server successfully", "bytes", n, "connectionID", connID)
 	}
 }
 
@@ -654,11 +656,11 @@ func (a *Client) proxyToRemote(connID int64, eConn *endpointConn) {
 		resp.Payload = &client.Packet_DataAck{DataAck: &client.DataAck{
 			ConnectID: connID,
 		}}
-		klog.V(4).InfoS("DANIEL: send DATA_ACK", "connectionID", connID)
+		klog.V(4).InfoS("send DATA_ACK", "connectionID", connID)
 		if err := a.Send(resp); err != nil {
 			klog.ErrorS(err, "stream send ack failure")
 		}
-		klog.V(4).InfoS("DANIEL: send DATA_ACK SUCCESSFULLY", "connectionID", connID)
+		klog.V(4).InfoS("send DATA_ACK SUCCESSFULLY", "connectionID", connID)
 
 		pos := 0
 		for {

pkg/server/server.go

@@ -982,7 +982,7 @@ func (s *ProxyServer) serveRecvBackend(backend *Backend, agentID string, recvCh
 
 		case client.PacketType_DATA:
 			resp := pkt.GetData()
-			klog.V(5).InfoS("Received data from agent", "bytes", len(resp.Data), "agentID", agentID, "connectionID", resp.ConnectID)
+			klog.V(4).InfoS("Received data from agent", "bytes", len(resp.Data), "agentID", agentID, "connectionID", resp.ConnectID)
 			if resp.ConnectID == 0 {
 				klog.ErrorS(nil, "Received packet missing ConnectID from agent", "packetType", "DATA")
 				continue