Method runLoop

pkg/wshrpc/wshremote/processviewer.go:183–220

(firstReadyCh chan struct{})

}

func (s *procCacheState) runLoop(firstReadyCh chan struct{}) {
	firstDone := false
	defer func() {
		if panichandler.PanicHandler("procCache.runLoop", recover()) == nil {
			return
		}
		s.lock.Lock()
		defer s.lock.Unlock()
		s.running = false
		if !firstDone {
			close(firstReadyCh)
			s.ready = nil
		}
	}()

	numCPU := max(runtime.NumCPU(), 1)

	for {
		iterStart := time.Now()

		s.lastCPUEpoch++
		result := s.collectSnapshot(numCPU)

		// Remove stale entries (pids that weren't seen this epoch).
		for pid, sample := range s.lastCPUSamples {
			if sample.Epoch < s.lastCPUEpoch {
				delete(s.lastCPUSamples, pid)
			}
		}

		if s.updateCacheAndCheckIdle(result, &firstDone, firstReadyCh) {
			return
		}

		elapsed := time.Since(iterStart)
		time.Sleep(max(ProcCacheMinSleep, ProcCachePollInterval-elapsed))
	}
}

// lookupUID resolves a uid to a username, using the per-run cache to avoid
// repeated syscalls for the same uid.