9342647e0c
raft: fix read index request for #7331
2017-02-17 09:45:41 +08:00
b940e0d514
Merge pull request #7042 from petermattis/pmattis/resume-after-heartbeat-resp
...
raft: resume paused followers on receipt of MsgHeartbeatResp
2016-12-27 21:15:53 -08:00
e625400f1d
raft: resume paused followers on receipt of MsgHeartbeatResp
...
Previously, paused followers were resumed upon sending a MsgHearbeat.
Fixes #7037
2016-12-20 08:22:09 -05:00
f60a5d6025
raft: Export Progress.IsPaused
...
CockroachDB would like to use this method for monitoring.
2016-12-04 13:14:08 +08:00
4401d88546
raft: add node should reset the pendingConf state
...
After add node conf proposed twice with the same node id, the pending state is not reset because
the addNode returned without setting the pending state at the second
time and the pending state will always be true unless other conf changed. During this we
can not add any new node because the propose will be ignored since the
pending state is true.
2016-11-17 15:50:13 +08:00
2f34547d39
raft: Check promotable() in MsgTimeoutNow handling
...
If MsgTimeoutNow arrived after a node was removed, the node could start
and win an election, then panic in becomeLeader (see
cockroachdb/cockroach#8535 )
2016-11-07 20:02:21 +08:00
cb5c92f69b
raft: do not attach term to MsgReadIndex
...
Fix https://github.com/coreos/etcd/issues/6744 .
MsgReadIndex, as MsgProp, is to be forwarded to leader.
So we should treat it as local message.
2016-10-28 22:12:25 -07:00
22aa710c1f
raft: Improve comments and formatting for PreVote change
2016-10-24 22:29:33 +09:00
cf93a74aa8
raft: Refactor vote handling
...
Move all vote handling from the per-state step functions to the
top-level Step(). This wasn't necessary before because MsgVote would
cause us to become a follower, but MsgPreVote needs to be handled
without changing the node's current state.
2016-10-19 19:35:21 +08:00
73cae7abd0
raft: Implement the PreVote RPC described in thesis section 9.6
...
This prevents disruption when a node that has been partitioned
away rejoins the cluster.
Fixes #6522
2016-10-19 19:35:20 +08:00
cfe717e926
Merge pull request #6275 from xiang90/raft_l
...
raft: support safe readonly request
2016-09-13 01:36:04 -05:00
710b14ce56
raft: support safe readonly request
...
Implement raft readonly request described in raft thesis 6.4
along with the existing clock/lease based approach.
2016-09-12 15:13:52 +08:00
4a33aa3917
raft: use a singleton global rand
...
rand.NewSource creates a 4872 byte object. With a small number of raft
groups in a process this isn't a problem. With 10k raft groups we'd use
46MB for these random sources. The only usage is in
raft.resetRandomizedElectionTimeout which isn't performance critical.
Fixes #6347 .
2016-09-05 09:03:18 -04:00
a7a867c1e6
raft: Allow an election immediately after start with checkQuorum
...
Previously, the checkQuorum flag required an election timeout to
expire before a node could cast its first vote. This change permits
the node to cast a vote at any time when the leader is not known,
including immediately after startup.
2016-08-30 08:28:41 +08:00
f4141f0f51
raft: handle 'MsgTransferLeader' in follower
2016-08-10 16:24:29 -07:00
5f0c122496
raft: fix getting unapplied log entries
2016-08-08 10:44:02 -07:00
484f579905
raft: hide Campaign rules on applying all entries
2016-07-25 15:53:39 -07:00
1c5754f02d
raft: fix readindex
2016-07-19 15:00:58 -07:00
7432e9fbe9
Merge pull request #5809 from swingbach/master
...
raft: make leader transferring workable when quorum check is on
2016-07-12 09:46:18 -07:00
c36a40ca15
raft: introduce top-level context in message struct
2016-07-12 16:14:06 +08:00
6f3a40cb53
raft: set leader id in stepFollower
...
Follower has already set its leader ID from
previous append messages from the leader, but
to be consistent, this adds a line to set its
leader id from leader snapshot message.
2016-07-11 16:37:31 -07:00
0d9b6ba0ab
raft: fix a few problems
2016-07-11 14:59:53 +08:00
c396b6aaaa
raft: remove unnecessary type-cast, else-clause
2016-07-09 22:01:19 -07:00
e020b2a228
raft: make leader transferring workable when quorum check is on
2016-06-29 18:24:58 +08:00
5f1c763993
Merge pull request #5553 from swingbach/master
...
raft: implemented read-only query when quorum check is on
2016-06-28 12:47:43 -07:00
0faae33ace
raft: implemented read-only query when quorum check is on
2016-06-28 10:52:53 +08:00
33f7e7583b
raft: fix comment,method name to needSnapshotAbort
...
And 'maybeSnapshotAbort' does not 'unset'
the pendingSnapshot. 'resetState', which is called after this
metho, is the one that unsets pendingSnapshot. So this changes
the method name.
2016-06-24 07:54:10 -07:00
337ef64ed5
raft: implemented leader lease when quorum check is on
2016-06-02 06:17:27 +08:00
910781ef5b
raft: do not panic when removing all the nodes from cluster
2016-05-16 10:04:17 -07:00
4d2424210f
Merge pull request #5313 from xiang90/fix_raft_abort
...
raft: simplify leadership transfer
2016-05-13 09:26:01 -07:00
fe884f8209
raft: update LICENSE header
2016-05-12 20:49:15 -07:00
82a6de8b69
raft: simplify leadership transfer
2016-05-10 20:03:42 -07:00
9108af9046
*: clean up from go vet, misspell
2016-04-10 23:16:56 -07:00
4997ed36b4
Merge pull request #5011 from xiang90/r_c
...
raft: fix issues reported by golint
2016-04-08 11:46:12 -07:00
ac059eb8cb
raft: transfer leader feature
2016-04-08 16:56:32 +08:00
1b41ee9c99
raft: fix issues reported by golint
2016-04-07 22:14:56 -07:00
6e6d64fb9b
*: clean up unused vars, functions
...
With help from https://github.com/dominikh/go-unused .
IsNetTimeoutError seems useful, so moved to pkg/netutil.
2016-04-06 21:33:55 -07:00
68db18667a
raft: correct doc comment
2016-04-06 08:43:42 -04:00
5250784b09
raft: use rand.Intn instead of rand.Int and mod
...
This provides a better random distribution and is easier to read.
2016-04-06 08:43:42 -04:00
5d431b4782
raft: lower split vote rate
2016-04-01 12:11:03 -07:00
aedf2c5876
raft: Config: comment wrapping @ 80col
2016-03-01 09:54:58 +01:00
6c1b3a71db
raft: clarify Heartbeat/ElectionTick comments
...
Avoid other, ambiguous interpretations.
2016-03-01 09:52:14 +01:00
c5b51946eb
*: exported godoc fixups
2016-02-21 20:36:44 -08:00
20461ab11a
*: fix many typos
2016-01-31 21:42:39 -08:00
37290820de
Merge pull request #4293 from bdarnell/bcast-after-commit
...
raft: Always call bcastAppend after maybeCommit
2016-01-27 09:58:22 -08:00
6054748181
Merge pull request #4297 from ngaut/ngaut/raft-typo
...
raft: typo
2016-01-26 20:48:53 -08:00
751ab40f44
raft: typo
2016-01-27 12:35:14 +08:00
0771d713e6
raft: Always call bcastAppend after maybeCommit
2016-01-26 16:55:47 -05:00
22925a1d2f
raft: Remove redundant raft.Commit field.
...
Keeping this field in sync with `raft.raftLog.committed` was
error-prone, so instead we synthesize the `HardState` on demand.
Fixes #4278 .
2016-01-26 15:18:55 -05:00
46bb2582fe
raft: Call maybeCommit after removing a node.
...
removeNode reduces the required quorum size, so some pending entries may
be able to commit after it is applied.
Discovered in cockroachdb/cockroach#3642
2016-01-20 11:05:48 -04:00
