Xiang Li
cb105c626c
rafthttp: kill connection timeout TODO
2015-03-03 09:49:01 -08:00
Xiang Li
115b045505
rafthttp: add comment for timeout
2015-03-02 16:52:19 -08:00
Xiang Li
88bde91716
rafhttp: refactor func peer.pick in peer.go
2015-03-02 15:17:14 -08:00
Yicheng Qin
399e3cdf81
rafthttp: add stream http tests
2015-03-02 13:24:50 -08:00
Yicheng Qin
78aa251ab2
rafthttp: only use pipeline to send MsgSnap
...
The size of MsgSnap may be very big, e.g., 1G.
If its size is big and general streaming is used to send it, it may block
the following messages for several ten seconds, which interrupts the
heartbeat heavily.
Only use pipeline to send MsgSnap.
2015-03-02 09:35:54 -08:00
Yicheng Qin
9b986fb4c1
rafthttp: report unreachable status of the peer
...
When it failed to send message to the remote peer, it reports unreachable
to raft.
2015-03-01 16:48:26 -08:00
Yicheng Qin
1c5a507761
rafthttp: refactor peer and add general stream
2015-02-28 11:35:16 -08:00
Yicheng Qin
2c94e2d771
*: make dial timeout configurable
...
Dial timeout is set shorter because
1. etcd is supposed to work in good environment, and the new value is long
enough
2. shorter dial timeout makes dial fail faster, which is good for
performance
2015-02-28 11:18:59 -08:00
Yicheng Qin
55cd03ff4b
rafthttp: add run loop for peer
2015-02-28 11:18:59 -08:00
Yicheng Qin
d8a9e11e22
rafthttp: extract pipeline from peer
2015-02-28 11:06:11 -08:00
Brandon Philips
a4c4027dc7
rafthttp: becomes -> became in log line
...
Simple grammar fix.
2015-02-04 21:28:23 -08:00
Jonathan Boulle
f1ed69e883
*: switch to line comments for copyright
...
Build tags are not compatible with block comments.
Also adds copyright header to a few places it was missing.
2015-01-26 09:53:30 -08:00
Xiang Li
0c55cfb21e
Merge pull request #2036 from xiang90/trtr
...
refactor rafthttp
2015-01-05 14:08:51 -08:00
Xiang Li
4938e6bff5
rafthttp: a stopped peer does not accept any methods
2015-01-03 20:02:43 -08:00
Xiang Li
15be030aaa
etcdserver: collect error from errorc
2015-01-02 20:13:46 -08:00
Xiang Li
fe53ffd74d
rafthttp: streamserver -> streamwriter
2014-12-31 21:11:24 -08:00
Yicheng Qin
2292da15d6
rafthttp: fix stream.open call
2014-12-31 10:02:45 -08:00
Xiang Li
2193b70fb3
rafthttp: add stream
2014-12-30 13:45:11 -08:00
Yicheng Qin
5bb8eeb5cf
rafthttp: transport cleanup
2014-12-29 11:21:40 -08:00
