Explorar o código

Merge pull request #863 from nullaus/fix-data-race-schema

Fix data race between event processing and session when concurrent go…
Chris Bannister %!s(int64=8) %!d(string=hai) anos
pai
achega
da3fa061b7
Modificáronse 1 ficheiros con 3 adicións e 0 borrados
  1. 3 0
      events.go

+ 3 - 0
events.go

@@ -106,6 +106,9 @@ func (s *Session) handleEvent(framer *framer) {
 }
 }
 
 
 func (s *Session) handleSchemaEvent(frames []frame) {
 func (s *Session) handleSchemaEvent(frames []frame) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+
 	if s.schemaDescriber == nil {
 	if s.schemaDescriber == nil {
 		return
 		return
 	}
 	}