Yicheng Qin
|
d5ceb26408
|
rafthttp: only batch good MsgAppResp
A MsgAppResp with Reject set should be sent back to the leader as soon
as possible instead of batching.
|
2014-11-25 17:53:26 -08:00 |
|
Yicheng Qin
|
61ce494386
|
rafthttp: limit the buffer for every read correctly
|
2014-11-24 17:39:39 -08:00 |
|
Yicheng Qin
|
1e797c1e38
|
rafthttp: limit the data size read from connection each time
|
2014-11-24 13:54:45 -08:00 |
|
Yicheng Qin
|
3e55834c38
|
*: set read/write timeout for raft transport and listener
|
2014-11-24 13:46:44 -08:00 |
|
Yicheng Qin
|
400e573013
|
rafthttp: log start and stop of streaming
|
2014-11-24 13:35:46 -08:00 |
|
Xiang Li
|
91bfead9e9
|
rafthttp: add batcher
After we enable streaming, there will be a large amount of msgAppResp due to high
rate msgApp. We should batch msgAppResp in a meanful way.
|
2014-11-23 12:05:42 -08:00 |
|
Xiang Li
|
264a63be80
|
rafthttp: fix import
|
2014-11-20 18:05:45 -08:00 |
|
Brian Waldon
|
c0fb1c8a00
|
Merge pull request #1755 from bcwaldon/golang.org-deps
Switch to golang.org/x/net/context
|
2014-11-20 16:26:14 -08:00 |
|
Yicheng Qin
|
9d53b94546
|
rafthttp: add streaming server and client
|
2014-11-20 11:34:50 -08:00 |
|
Brian Waldon
|
9a728a127a
|
dep: bump golang.org/x/net/context
Move from code.google.com/p/go.net/context to
golang.org/x/net/context before bumping to latest.
|
2014-11-20 10:19:12 -08:00 |
|
Yicheng Qin
|
1a72143ecb
|
rafthttp: send takes raft message instead of bytes
This gives streaming mechanism the chance to assemble and disassemble
raft messages.
|
2014-11-17 22:39:53 -08:00 |
|
Yicheng Qin
|
04d416291a
|
*: add rafthttp pkg into test list
|
2014-11-17 16:45:54 -08:00 |
|
Yicheng Qin
|
f24e214ee5
|
rafthttp: move server stats in raftHandler to etcdserver
|
2014-11-17 16:02:20 -08:00 |
|
Yicheng Qin
|
5dc5f8145c
|
*: etcdhttp.raftHandler -> rafthttp.RaftHandler
|
2014-11-17 15:52:24 -08:00 |
|
Yicheng Qin
|
84fbf7aab5
|
*: etcdserver.sender -> rafthttp.Sender
|
2014-11-17 15:35:10 -08:00 |
|