Skip to content
Snippets Groups Projects
Commit 7aaeb18f authored by ztelur's avatar ztelur
Browse files

add lock when destroy

parent 0b2945d2
No related branches found
No related tags found
No related merge requests found
......@@ -105,6 +105,8 @@ func (gp *GrpcProtocol) Destroy() {
gp.BaseProtocol.Destroy()
gp.serverLock.Lock()
defer gp.serverLock.Unlock()
for key, server := range gp.serverMap {
delete(gp.serverMap, key)
server.Stop()
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment