Skip to content

Commit 1a6ae0c

Browse files
author
speruri
committed
Add detailed debug logging to tlvExtractorListener.Accept()
Log connection type and TLV extraction details to debug cache population Signed-off-by: speruri <surya.srikar.peruri@zalando.de>
1 parent 3b609ef commit 1a6ae0c

1 file changed

Lines changed: 13 additions & 1 deletion

File tree

proxylistener/proxylistener.go

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package proxylistener
22

33
import (
44
"fmt"
5+
"log"
56
"net"
67
"net/netip"
78
"sync"
@@ -103,15 +104,26 @@ func (tl *tlvExtractorListener) Accept() (net.Conn, error) {
103104
return conn, err
104105
}
105106

107+
log.Printf("[tlvExtractorListener] Accepted conn type: %T, RemoteAddr: %s, LocalAddr: %s", conn, conn.RemoteAddr(), conn.LocalAddr())
108+
106109
if pconn, ok := conn.(*proxyproto.Conn); ok {
110+
log.Printf("[tlvExtractorListener] Got proxyproto.Conn")
107111
if header := pconn.ProxyHeader(); header != nil {
112+
log.Printf("[tlvExtractorListener] Got ProxyHeader")
108113
tlvs, err := header.TLVs()
109-
if err == nil {
114+
if err != nil {
115+
log.Printf("[tlvExtractorListener] Error getting TLVs: %v", err)
116+
} else {
110117
ssl := hasTLVSSL(tlvs)
111118
key := conn.RemoteAddr().String() + "|" + conn.LocalAddr().String()
119+
log.Printf("[tlvExtractorListener] Storing SSL=%v for key=%s", ssl, key)
112120
proxySSLCache.Store(key, ssl)
113121
}
122+
} else {
123+
log.Printf("[tlvExtractorListener] ProxyHeader is nil")
114124
}
125+
} else {
126+
log.Printf("[tlvExtractorListener] Not a proxyproto.Conn: %T", conn)
115127
}
116128

117129
return &tlvCacheCleanupConn{conn: conn}, nil

0 commit comments

Comments
 (0)