fix protocol analyzer not added to the connection issue

apache · Nov 19, 2024 · 2bd4208 · 2bd4208
1 parent 656265f
commit 2bd4208
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/accesslog/collector/protocols/queue.go b/pkg/accesslog/collector/protocols/queue.go
@@ -133,7 +133,7 @@ func newPartitionConnection(protocolMgr *ProtocolManager, conID, randomID uint64
 }
 
 func (p *PartitionConnection) appendProtocolIfNeed(protocolMgr *ProtocolManager, conID, randomID uint64, protocol enums.ConnectionProtocol) {
-	if _, exist := protocolMgr.protocols[protocol]; !exist {
+	if _, exist := p.protocol[protocol]; !exist {
 		analyzer := protocolMgr.GetProtocol(protocol)
 		p.protocol[protocol] = true
 		p.protocolAnalyzer[protocol] = analyzer