aboutsummaryrefslogtreecommitdiffstats
path: root/p2p/message.go
diff options
context:
space:
mode:
authorFelix Lange <fjl@twurst.com>2015-02-13 21:44:00 +0800
committerFelix Lange <fjl@twurst.com>2015-02-13 21:44:00 +0800
commit5110f80bba13e3758ae1836a88afee123df81e3e (patch)
tree0648f72c5955b46179a8205f8e2d2fb7d4988ccb /p2p/message.go
parent170eb3ac684231dc2ddebc34e7006e0f2b5fc0c1 (diff)
downloaddexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar.gz
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar.bz2
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar.lz
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar.xz
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.tar.zst
dexon-5110f80bba13e3758ae1836a88afee123df81e3e.zip
p2p: improve read deadlines
There are now two deadlines, frameReadTimeout and payloadReadTimeout. The frame timeout is longer and allows for connections that are idle. The message timeout is still short and ensures that we don't get stuck in the middle of a message.
Diffstat (limited to 'p2p/message.go')
-rw-r--r--p2p/message.go28
1 files changed, 25 insertions, 3 deletions
diff --git a/p2p/message.go b/p2p/message.go
index dfc33f349..07916f7b3 100644
--- a/p2p/message.go
+++ b/p2p/message.go
@@ -18,6 +18,28 @@ import (
"github.com/ethereum/go-ethereum/rlp"
)
+// parameters for frameRW
+const (
+ // maximum time allowed for reading a message header.
+ // this is effectively the amount of time a connection can be idle.
+ frameReadTimeout = 1 * time.Minute
+
+ // maximum time allowed for reading the payload data of a message.
+ // this is shorter than (and distinct from) frameReadTimeout because
+ // the connection is not considered idle while a message is transferred.
+ // this also limits the payload size of messages to how much the connection
+ // can transfer within the timeout.
+ payloadReadTimeout = 5 * time.Second
+
+ // maximum amount of time allowed for writing a complete message.
+ msgWriteTimeout = 5 * time.Second
+
+ // messages smaller than this many bytes will be read at
+ // once before passing them to a protocol. this increases
+ // concurrency in the processing.
+ wholePayloadSize = 64 * 1024
+)
+
// Msg defines the structure of a p2p message.
//
// Note that a Msg can only be sent once since the Payload reader is
@@ -167,9 +189,7 @@ func makeListHeader(length uint32) []byte {
func (rw *frameRW) ReadMsg() (msg Msg, err error) {
<-rw.rsync // wait until bufconn is ours
- // this read timeout applies also to the payload.
- // TODO: proper read timeout
- rw.SetReadDeadline(time.Now().Add(msgReadTimeout))
+ rw.SetReadDeadline(time.Now().Add(frameReadTimeout))
// read magic and payload size
start := make([]byte, 8)
@@ -193,6 +213,8 @@ func (rw *frameRW) ReadMsg() (msg Msg, err error) {
}
msg.Size = size - posr.p
+ rw.SetReadDeadline(time.Now().Add(payloadReadTimeout))
+
if msg.Size <= wholePayloadSize {
// msg is small, read all of it and move on to the next message.
pbuf := make([]byte, msg.Size)