MCPcopy Index your code
hub / github.com/wavetermdev/waveterm / updateTelemetryCountsLoop

Function updateTelemetryCountsLoop

cmd/server/main-server.go:274–288  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

272}
273
274func updateTelemetryCountsLoop() {
275 defer func() {
276 panichandler.PanicHandler("updateTelemetryCountsLoop", recover())
277 }()
278 var nextSend int64
279 var lastCounts telemetrydata.TEventProps
280 time.Sleep(TelemetryInitialCountsWait)
281 for {
282 if time.Now().Unix() > nextSend {
283 nextSend = time.Now().Add(TelemetryCountsInterval).Unix()
284 lastCounts = updateTelemetryCounts(lastCounts)
285 }
286 time.Sleep(TelemetryTick)
287 }
288}
289
290func beforeSendActivityUpdate(ctx context.Context) {
291 activity := wshrpc.ActivityUpdate{}

Callers 1

mainFunction · 0.85

Calls 2

PanicHandlerFunction · 0.92
updateTelemetryCountsFunction · 0.85

Tested by

no test coverage detected