fix: surround agentTokenToLogger with mutex

Fixes #15
coder · Feb 9, 2024 · d46083a · d46083a
1 parent b661fb8
commit d46083a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/logger.go b/logger.go
@@ -300,7 +300,9 @@ func (p *podEventLogger) init() error {
 // If a logger already exists for the token, it's returned. Otherwise a new
 // logger is created and returned.
 func (p *podEventLogger) sendLog(resourceName, token string, log agentsdk.StartupLog) {
+	p.mutex.Lock()
 	logger, ok := p.agentTokenToLogger[token]
+	p.mutex.Unlock()
 	if !ok {
 		client := agentsdk.New(p.coderURL)
 		client.SetSessionToken(token)