Merge pull request #2624 from yichengq/fix-raft-storage

raft: lock storage when compact it
This commit is contained in:
Yicheng Qin 2015-04-03 13:51:06 -07:00
commit fa96e64b43

View File

@ -194,6 +194,8 @@ func (ms *MemoryStorage) CreateSnapshot(i uint64, cs *pb.ConfState, data []byte)
// It is the application's responsibility to not attempt to compact an index
// greater than raftLog.applied.
func (ms *MemoryStorage) Compact(compactIndex uint64) error {
ms.Lock()
defer ms.Unlock()
offset := ms.ents[0].Index
if compactIndex <= offset {
return ErrCompacted