From ba99f037fbffd18af0077862beae9cb271122dfa Mon Sep 17 00:00:00 2001 From: Milos Gajdos Date: Fri, 23 Aug 2019 15:07:08 +0100 Subject: [PATCH] Lock started flag when changing it. --- server/grpc/grpc.go | 2 ++ server/rpc_server.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/server/grpc/grpc.go b/server/grpc/grpc.go index 86025a9d..4dcd6d73 100644 --- a/server/grpc/grpc.go +++ b/server/grpc/grpc.go @@ -815,7 +815,9 @@ func (g *grpcServer) Stop() error { var err error select { case err = <-ch: + g.Lock() g.started = false + g.Unlock() } return err diff --git a/server/rpc_server.go b/server/rpc_server.go index 4b825a8b..c02b893a 100644 --- a/server/rpc_server.go +++ b/server/rpc_server.go @@ -739,7 +739,9 @@ func (s *rpcServer) Stop() error { var err error select { case err = <-ch: + s.Lock() s.started = false + s.Unlock() } return err