Merge pull request #582 from unistack-org/memory2

memory transport: use write mutex lock when close
2019-07-12 10:29:46 +01:00 · 2019-07-12 10:29:46 +01:00 · 3ccb900bca
commit 3ccb900bca
parent 5157241c88 a72e1185da
1 changed files with 2 additions and 2 deletions
--- a/transport/memory/memory.go
+++ b/transport/memory/memory.go
@ -84,8 +84,8 @@ func (ms *memorySocket) Send(m *transport.Message) error {
 }

 func (ms *memorySocket) Close() error {
-	ms.RLock()
-	defer ms.RUnlock()
+	ms.Lock()
+	defer ms.Unlock()
 	select {
 	case <-ms.exit:
 		return nil