|
@@ -71,7 +71,7 @@ type raftNode struct {
|
|
|
httpdonec chan struct{} // signals http server shutdown complete
|
|
httpdonec chan struct{} // signals http server shutdown complete
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-var defaultSnapCount uint64 = 10000
|
|
|
|
|
|
|
+var defaultSnapshotCount uint64 = 10000
|
|
|
|
|
|
|
|
// newRaftNode initiates a raft instance and returns a committed log entry
|
|
// newRaftNode initiates a raft instance and returns a committed log entry
|
|
|
// channel and error channel. Proposals for log updates are sent over the
|
|
// channel and error channel. Proposals for log updates are sent over the
|
|
@@ -95,7 +95,7 @@ func newRaftNode(id int, peers []string, join bool, getSnapshot func() ([]byte,
|
|
|
waldir: fmt.Sprintf("raftexample-%d", id),
|
|
waldir: fmt.Sprintf("raftexample-%d", id),
|
|
|
snapdir: fmt.Sprintf("raftexample-%d-snap", id),
|
|
snapdir: fmt.Sprintf("raftexample-%d-snap", id),
|
|
|
getSnapshot: getSnapshot,
|
|
getSnapshot: getSnapshot,
|
|
|
- snapCount: defaultSnapCount,
|
|
|
|
|
|
|
+ snapCount: defaultSnapshotCount,
|
|
|
stopc: make(chan struct{}),
|
|
stopc: make(chan struct{}),
|
|
|
httpstopc: make(chan struct{}),
|
|
httpstopc: make(chan struct{}),
|
|
|
httpdonec: make(chan struct{}),
|
|
httpdonec: make(chan struct{}),
|
Gyuho Lee