From a72e1185da90086935a9cc86703eddb06257aa61 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Fri, 12 Jul 2019 12:11:08 +0300 Subject: [PATCH] memory transport: use write mutex lock when close Signed-off-by: Vasiliy Tolstov --- transport/memory/memory.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/memory/memory.go b/transport/memory/memory.go index 274e98c9..b1f4f071 100644 --- 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