fix: dead loop bug

hengyoush · hengyoush · commit eb3958576b09 · 2025-02-16T19:16:55.000+08:00
fix: dead loop bug
diff --git a/agent/conn/processor.go b/agent/conn/processor.go
@@ -339,6 +339,8 @@ func (p *Processor) processOldFirstPacketEvents(recordChannel chan RecordWithCon
 		if now.Sub(event.timestamp) > 100*time.Millisecond {
 			p.processFirstPacketEvent(event.event, recordChannel)
 			p.tempFirstPacketEvents.Read()
+		} else {
+			break
 		}
 	}
 }
@@ -464,7 +466,6 @@ func (p *Processor) processSyscallEvent(event *bpf.SyscallEventData, recordChann
 	conn := p.connManager.LookupConnection4ByTimestamp(tgidFd, event.SyscallEvent.GetEndTs())
 
 	timeCheck := conn != nil && conn.timeBoundCheck(event.SyscallEvent.GetEndTs())
-
 	if conn == nil {
 		if common.BPFEventLog.Level >= logrus.DebugLevel {
 			common.BPFEventLog.Debugf("[syscall][no conn][ts=%d][tgid=%d fd=%d][len=%d] %s", event.SyscallEvent.Ke.Ts, tgidFd>>32, uint32(tgidFd), event.SyscallEvent.BufSize, string(event.Buf))

Original file line number	Diff line number	Diff line change
`@@ -339,6 +339,8 @@ func (p *Processor) processOldFirstPacketEvents(recordChannel chan RecordWithCon`
`339`	`339`	`if now.Sub(event.timestamp) > 100*time.Millisecond {`
`340`	`340`	`p.processFirstPacketEvent(event.event, recordChannel)`
`341`	`341`	`p.tempFirstPacketEvents.Read()`
	`342`	`+ } else {`
	`343`	`+ break`
`342`	`344`	`}`
`343`	`345`	`}`
`344`	`346`	`}`
`@@ -464,7 +466,6 @@ func (p Processor) processSyscallEvent(event bpf.SyscallEventData, recordChann`
`464`	`466`	`conn := p.connManager.LookupConnection4ByTimestamp(tgidFd, event.SyscallEvent.GetEndTs())`
`465`	`467`
`466`	`468`	`timeCheck := conn != nil && conn.timeBoundCheck(event.SyscallEvent.GetEndTs())`
`467`		`-`
`468`	`469`	`if conn == nil {`
`469`	`470`	`if common.BPFEventLog.Level >= logrus.DebugLevel {`
`470`	`471`	`common.BPFEventLog.Debugf("[syscall][no conn][ts=%d][tgid=%d fd=%d][len=%d] %s", event.SyscallEvent.Ke.Ts, tgidFd>>32, uint32(tgidFd), event.SyscallEvent.BufSize, string(event.Buf))`