Skip to content

Commit ef892e3

Browse files
committed
delete the mutex for session
1 parent 21882fa commit ef892e3

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

server/sse.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -344,10 +344,7 @@ func (s *SSEServer) handleMessage(w http.ResponseWriter, r *http.Request) {
344344
s.writeJSONRPCError(w, nil, mcp.INVALID_PARAMS, "Missing sessionId")
345345
return
346346
}
347-
348-
s.mu.RLock()
349347
sessionI, ok := s.sessions.Load(sessionID)
350-
s.mu.RUnlock()
351348
if !ok {
352349
s.writeJSONRPCError(w, nil, mcp.INVALID_PARAMS, "Invalid session ID")
353350
return

0 commit comments

Comments
 (0)