Delayed ProcessManager.pidToProcessInfo cleanup

Uses ProcessedUntil mechanism to guarantee that process metadata
is not discarded before all relevant trace events have been
processed.

processmanager/manager.go

@@ -360,6 +360,9 @@ func (pm *ProcessManager) ProcessedUntil(traceCaptureKTime times.KTime) {
 		if pidExitKTime > traceCaptureKTime {
 			continue
 		}
+
+		delete(pm.pidToProcessInfo, pid)
+
 		for _, instance := range pm.interpreters[pid] {
 			if err := instance.Detach(pm.ebpf, pid); err != nil {
 				log.Errorf("Failed to handle interpreted process exit for PID %d: %v",

processmanager/processinfo.go

@@ -512,20 +512,19 @@ func (pm *ProcessManager) synchronizeMappings(pr process.Process,
 // fast enough and this particular pid is reused again by the system.
 // NOTE: Exported only for tracer.
 func (pm *ProcessManager) ProcessPIDExit(pid libpf.PID) {
+	exitKTime := times.GetKTime()
+
 	log.Debugf("- PID: %v", pid)
 	defer pm.ebpf.RemoveReportedPID(pid)
 
 	pm.mu.Lock()
 	defer pm.mu.Unlock()
 
-	exitKTime := times.GetKTime()
-	if pm.interpreterTracerEnabled {
-		if len(pm.interpreters[pid]) > 0 {
-			pm.exitEvents[pid] = exitKTime
-		}
-	}
-
 	info, ok := pm.pidToProcessInfo[pid]
+	if ok || (pm.interpreterTracerEnabled &&
+		len(pm.interpreters[pid]) > 0) {
+		pm.exitEvents[pid] = exitKTime
+	}
 	if !ok {
 		log.Debugf("Skip process exit handling for unknown PID %d", pid)
 		return
@@ -545,7 +544,6 @@ func (pm *ProcessManager) ProcessPIDExit(pid libpf.PID) {
 				address, pid, err)
 		}
 	}
-	delete(pm.pidToProcessInfo, pid)
 }
 
 func (pm *ProcessManager) SynchronizeProcess(pr process.Process) {