From 0d6503c03f468d4df569009ea7c39ac0d8b4a0c5 Mon Sep 17 00:00:00 2001 From: Owen Date: Thu, 4 Jun 2026 14:47:49 -0700 Subject: [PATCH] Add comment --- olm/olm.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/olm/olm.go b/olm/olm.go index 07d144f..b6dc330 100644 --- a/olm/olm.go +++ b/olm/olm.go @@ -68,10 +68,10 @@ type Olm struct { stopRegister func() updateRegister func(newData any) - stopPeerSends map[string]func() - stopPeerInits map[string]func() + stopPeerSends map[string]func() + stopPeerInits map[string]func() jitPendingSites map[int]string // siteId -> chainId for in-flight JIT requests - peerSendMu sync.Mutex + peerSendMu sync.Mutex // WaitGroup to track tunnel lifecycle tunnelWg sync.WaitGroup @@ -188,10 +188,10 @@ func Init(ctx context.Context, config OlmConfig) (*Olm, error) { apiServer.SetAgent(config.Agent) newOlm := &Olm{ - logFile: logFile, - olmCtx: ctx, - apiServer: apiServer, - olmConfig: config, + logFile: logFile, + olmCtx: ctx, + apiServer: apiServer, + olmConfig: config, stopPeerSends: make(map[string]func()), stopPeerInits: make(map[string]func()), jitPendingSites: make(map[int]string), @@ -467,7 +467,7 @@ func (o *Olm) StartTunnel(config TunnelConfig) { "userToken": userToken, "fingerprint": o.fingerprint, "postures": o.postures, - }, 2*time.Second, 20) + }, 2*time.Second, 20) // after 18 tries on the server side we send the error so dont change this without changing that // Invoke onRegistered callback if configured if o.olmConfig.OnRegistered != nil {