Skip to content

Commit

Permalink
Merge #39046
Browse files Browse the repository at this point in the history
39046: vendor: bump go.etcd.io/etcd r=nvanbenschoten a=tbg

This picks up Joint Consensus, see:

etcd-io/etcd#10914

Release note: None

Co-authored-by: Tobias Schottdorf <tobias.schottdorf@gmail.com>
  • Loading branch information
craig[bot] and tbg committed Jul 25, 2019
2 parents ff04012 + ae2eafd commit 8124d48
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions Gopkg.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion pkg/storage/replica_raft.go
Original file line number Diff line number Diff line change
Expand Up @@ -1265,7 +1265,7 @@ func (r *Replica) withRaftGroupLocked(
r.mu.state.RaftAppliedIndex,
r.store.cfg,
&raftLogger{ctx: ctx},
), nil)
))
if err != nil {
return err
}
Expand Down
4 changes: 2 additions & 2 deletions pkg/storage/replica_raftstorage.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ func (r *replicaRaftStorage) InitialState() (raftpb.HardState, raftpb.ConfState,
}
var cs raftpb.ConfState
for _, rep := range r.mu.state.Desc.Replicas().Voters() {
cs.Nodes = append(cs.Nodes, uint64(rep.ReplicaID))
cs.Voters = append(cs.Voters, uint64(rep.ReplicaID))
}
for _, rep := range r.mu.state.Desc.Replicas().Learners() {
cs.Learners = append(cs.Learners, uint64(rep.ReplicaID))
Expand Down Expand Up @@ -540,7 +540,7 @@ func snapshot(
// Synthesize our raftpb.ConfState from desc.
var cs raftpb.ConfState
for _, rep := range desc.Replicas().Voters() {
cs.Nodes = append(cs.Nodes, uint64(rep.ReplicaID))
cs.Voters = append(cs.Voters, uint64(rep.ReplicaID))
}
for _, rep := range desc.Replicas().Learners() {
cs.Learners = append(cs.Learners, uint64(rep.ReplicaID))
Expand Down
2 changes: 1 addition & 1 deletion pkg/storage/store_snapshot_preemptive.go
Original file line number Diff line number Diff line change
Expand Up @@ -303,7 +303,7 @@ func (s *Store) processPreemptiveSnapshotRequest(
appliedIndex,
r.store.cfg,
&raftLogger{ctx: ctx},
), nil)
))
if err != nil {
return roachpb.NewError(err)
}
Expand Down

0 comments on commit 8124d48

Please sign in to comment.