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

Merge pull request #9558 from gyuho/propose

Browse Source 
etcdserver: handle raft Propose error in v2 applier
This commit is contained in:
Gyuho Lee 2018-04-10 16:49:33 -07:00 committed by GitHub
commit e9aa8fbcc3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
etcdserver/v2_server.go
View File

@ -101,7 +101,12 @@ func (a *reqV2HandlerEtcdServer) processRaftRequest(ctx context.Context, r *Requ
ch := a.s.w.Register(r.ID)
start := time.Now()
a.s.r.Propose(ctx, data)
err = a.s.r.Propose(ctx, data)
if err != nil {
proposalsFailed.Inc()
a.s.w.Trigger(r.ID, nil)
return Response{}, err
}
proposalsPending.Inc()
defer proposalsPending.Dec()