 Yicheng Qin
|
fb4b0b5cf0
rafthttp: support to init term when adding peer
|
пре 9 година |
|
Yicheng Qin
|
7ff1fa36f2
rafthttp: always init streamReader before return from newPeer
|
пре 9 година |
|
Yicheng Qin
|
0de0e4b77c
rafthttp: pretty print message drop info
|
пре 9 година |
|
Yicheng Qin
|
1dbe72bb74
rafthttp: pretty print connection error
|
пре 9 година |
|
Yicheng Qin
|
f1e995b070
rafthttp: use leveled logger
|
пре 9 година |
 Xiang Li
|
28878e34ff
Merge pull request #2903 from xiang90/chord_rafthttp
|
пре 9 година |
|
Yicheng Qin
|
c371d8c65c
rafthttp: version enforcement on rafthttp messages
|
пре 9 година |
 Xiang Li
|
a7a4233f0b
rafhttp: clean up logging messages
|
пре 9 година |
|
Yicheng Qin
|
19fc1a7137
rafthttp: update streamReader term in time
|
пре 9 година |
|
Yicheng Qin
|
1c1cccd236
rafthttp: stop etcd if it is found removed when stream dial
|
пре 9 година |
|
Yicheng Qin
|
0d88e0d111
rafthttp: introduce msgappv2 stream format
|
пре 9 година |
|
Yicheng Qin
|
d9cb77aad5
rafthttp: report snapshot failure when dropping MsgSnap
|
пре 9 година |
|
Yicheng Qin
|
e41cbeda5d
rafthttp: drop messages in channel when disconnection
|
пре 9 година |
|
Yicheng Qin
|
a230003255
rafthttp: report unreachable when dropping messages
|
пре 9 година |
|
Xiang Li
|
b1ff6ddd88
Merge pull request #2446 from xiang90/apply-routine
|
пре 9 година |
|
Xiang Li
|
d015610da5
etcdserver: separate apply and raft routine
|
пре 9 година |
|
Yicheng Qin
|
51397a6423
rafthttp: use go-routine for MsgProp processing
|
пре 9 година |
|
Yicheng Qin
|
933ab1e4f7
rafthttp: peer.newURLc -> peer.newURLsC
|
пре 9 година |
|
Yicheng Qin
|
0fe9861197
rafthttp: support multiple peer urls
|
пре 9 година |
|
Xiang Li
|
cb105c626c
rafthttp: kill connection timeout TODO
|
пре 9 година |
|
Xiang Li
|
115b045505
rafthttp: add comment for timeout
|
пре 9 година |
|
Xiang Li
|
88bde91716
rafhttp: refactor func peer.pick in peer.go
|
пре 9 година |
|
Yicheng Qin
|
399e3cdf81
rafthttp: add stream http tests
|
пре 9 година |
|
Yicheng Qin
|
78aa251ab2
rafthttp: only use pipeline to send MsgSnap
|
пре 9 година |
|
Yicheng Qin
|
9b986fb4c1
rafthttp: report unreachable status of the peer
|
пре 9 година |
|
Yicheng Qin
|
1c5a507761
rafthttp: refactor peer and add general stream
|
пре 9 година |
|
Yicheng Qin
|
2c94e2d771
*: make dial timeout configurable
|
пре 9 година |
|
Yicheng Qin
|
55cd03ff4b
rafthttp: add run loop for peer
|
пре 9 година |
|
Yicheng Qin
|
d8a9e11e22
rafthttp: extract pipeline from peer
|
пре 9 година |
 Brandon Philips
|
a4c4027dc7
rafthttp: becomes -> became in log line
|
пре 9 година |
