b24d546bd0
rafthttp: increase sender buffer size
...
The buffer size is set big enough to buffer all messages generated in
one second as a follower in good path.
2014-12-07 22:35:50 -08:00
88e2fab572
Merge pull request #1859 from xiang90/pause_test
...
*: add pauseMember test
2014-12-04 15:11:59 -08:00
3de2ab2c04
*: typofixes
...
https://github.com/vlajos/misspell_fixer
2014-12-04 22:51:19 +00:00
151f043414
*: add pauseMember test
2014-12-04 14:22:43 -08:00
416b799ecf
Merge pull request #1788 from yichengq/233
...
rafthttp: increase the size of streaming buffer
2014-11-26 15:22:28 -08:00
00ce0702b9
rafthttp: increase the size of streaming buffer
...
Streaming buffer is used for:
1. hand over data to io goroutine in non-blocking way
2. hold pressure for temprorary network delay
3. be able to wait on I/O instead of data coming under high throughput
The old 1024 value is too small and is very likely to be full and
break the streaming when suffering temprorary network delay.
2014-11-26 14:46:52 -08:00
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
61ce494386
rafthttp: limit the buffer for every read correctly
2014-11-24 17:39:39 -08:00
1e797c1e38
rafthttp: limit the data size read from connection each time
2014-11-24 13:54:45 -08:00
3e55834c38
*: set read/write timeout for raft transport and listener
2014-11-24 13:46:44 -08:00
400e573013
rafthttp: log start and stop of streaming
2014-11-24 13:35:46 -08:00
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
264a63be80
rafthttp: fix import
2014-11-20 18:05:45 -08:00
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
9d53b94546
rafthttp: add streaming server and client
2014-11-20 11:34:50 -08:00
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
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
04d416291a
*: add rafthttp pkg into test list
2014-11-17 16:45:54 -08:00
f24e214ee5
rafthttp: move server stats in raftHandler to etcdserver
2014-11-17 16:02:20 -08:00
5dc5f8145c
*: etcdhttp.raftHandler -> rafthttp.RaftHandler
2014-11-17 15:52:24 -08:00
84fbf7aab5
*: etcdserver.sender -> rafthttp.Sender
2014-11-17 15:35:10 -08:00
