health.go RawHistoryFolder

1package dgram
2
3import (
4	"time"
5
6	"github.com/bnema/vev/internal/ports"
7)
8
9// healthTracker separates authenticated path contact from useful stream
10// progress. Transport.mu protects every field.
11type healthTracker struct {
12	lastPacket   time.Time
13	lastRecord   time.Time
14	lastProgress time.Time
15	pendingSince time.Time
16	generation   uint64
17}
18
19func newHealthTracker(now time.Time) healthTracker {
20	return healthTracker{lastPacket: now, lastRecord: now, lastProgress: now}
21}
22
23func (h *healthTracker) authenticatedPacket(now time.Time) {
24	h.lastPacket = now
25	h.generation++
26}
27
28func (h *healthTracker) completeRecord(now time.Time) {
29	h.lastRecord = now
30	h.generation++
31}
32
33func (h *healthTracker) ackProgress(now time.Time) {
34	h.lastProgress = now
35	h.generation++
36}
37
38func (h *healthTracker) pendingStarted(now time.Time) {
39	h.pendingSince = now
40	h.generation++
41}
42
43func (h *healthTracker) pendingCleared() {
44	h.pendingSince = time.Time{}
45	h.generation++
46}
47
48func (h healthTracker) decide(now time.Time, hasPending bool, degradedAfter, probeAfter, offlineAfter, deadAfter time.Duration) (ports.LinkState, bool, bool) {
49	packetAge := now.Sub(h.lastPacket)
50	switch {
51	case deadAfter > 0 && packetAge >= deadAfter:
52		return ports.LinkStateDead, false, true
53	case offlineAfter > 0 && packetAge >= offlineAfter:
54		return ports.LinkStateOffline, false, false
55	case probeAfter > 0 && packetAge >= probeAfter:
56		return ports.LinkStateProbing, true, false
57	}
58
59	qualityAt := h.lastRecord
60	if h.lastProgress.After(qualityAt) {
61		qualityAt = h.lastProgress
62	}
63	qualityAge := now.Sub(qualityAt)
64	if hasPending && probeAfter > 0 {
65		pendingBaseline := h.pendingSince
66		if pendingBaseline.IsZero() || h.lastProgress.After(pendingBaseline) {
67			pendingBaseline = h.lastProgress
68		}
69		if now.Sub(pendingBaseline) >= probeAfter {
70			return ports.LinkStateProbing, true, false
71		}
72	}
73	if degradedAfter > 0 && qualityAge >= degradedAfter {
74		return ports.LinkStateDegraded, false, false
75	}
76	return ports.LinkStateConnected, false, false
77}