diff --git a/contrib/raftexample/kvstore.go b/contrib/raftexample/kvstore.go index f780acc59..b56dcb31a 100644 --- a/contrib/raftexample/kvstore.go +++ b/contrib/raftexample/kvstore.go @@ -95,8 +95,8 @@ func (s *kvstore) readCommits(commitC <-chan *string, errorC <-chan error) { } func (s *kvstore) getSnapshot() ([]byte, error) { - s.mu.Lock() - defer s.mu.Unlock() + s.mu.RLock() + defer s.mu.RUnlock() return json.Marshal(s.kvStore) }