Fix race condition to sessions map in K8S proxy (#15238)

This commit is contained in:
Joel
2022-08-11 23:11:13 +00:00
committed by GitHub
parent 941f0fc97e
commit 92883f4a65
+4
View File
@@ -838,7 +838,9 @@ func (f *Forwarder) join(ctx *authContext, w http.ResponseWriter, req *http.Requ
return nil, trace.Wrap(err)
}
f.mu.Lock()
session := f.sessions[sessionID]
f.mu.Unlock()
if session == nil {
return nil, trace.NotFound("session %v not found", sessionID)
}
@@ -1232,7 +1234,9 @@ func (f *Forwarder) exec(ctx *authContext, w http.ResponseWriter, req *http.Requ
}
<-party.closeC
f.mu.Lock()
delete(f.sessions, session.id)
f.mu.Unlock()
return nil, nil
}