Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

etcdserver/*: rollback default settings

Browse Source
This commit is contained in:
Viacheslav Biriukov 2019-01-07 14:27:19 +00:00 committed by Joe Betz
parent 5435e7686a
commit 91efa67cb1
No known key found for this signature in database
GPG Key ID: 4930C680B6E0DDB8
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
etcdserver/server.go
View File

@ -67,14 +67,14 @@ import (
) )
const ( const (
DefaultSnapshotCount = 10 DefaultSnapshotCount = 100000
// DefaultSnapshotCatchUpEntries is the number of entries for a slow follower // DefaultSnapshotCatchUpEntries is the number of entries for a slow follower
// to catch-up after compacting the raft storage entries. // to catch-up after compacting the raft storage entries.
// We expect the follower has a millisecond level latency with the leader. // We expect the follower has a millisecond level latency with the leader.
// The max throughput is around 10K. Keep a 5K entries is enough for helping // The max throughput is around 10K. Keep a 5K entries is enough for helping
// follower to catch up. // follower to catch up.
DefaultSnapshotCatchUpEntries uint64 = 10 DefaultSnapshotCatchUpEntries uint64 = 5000
StoreClusterPrefix = "/0" StoreClusterPrefix = "/0"
StoreKeysPrefix = "/1" StoreKeysPrefix = "/1"
@ -416,11 +416,6 @@ func NewServer(cfg ServerConfig) (srv *EtcdServer, err error) {
} }
// Find a snapshot to start/restart a raft node // Find a snapshot to start/restart a raft node
var (
snapshot *raftpb.Snapshot
err error
)
for i := uint64(0); ; i++ { for i := uint64(0); ; i++ {
snapshot, err = ss.LoadIndex(i) snapshot, err = ss.LoadIndex(i)
if err != nil && err != snap.ErrNoSnapshot { if err != nil && err != snap.ErrNoSnapshot {