Revert "Properly use already specified MaxReadWriteTime as timeout"

This reverts commit 8f5dd75e7f.
This commit is contained in:
Giovanni Petrantoni 2020-02-12 17:29:04 +09:00 committed by Dmitriy Ryajov
parent ea0d167285
commit 11bd55308f
1 changed files with 3 additions and 1 deletions

View File

@ -23,6 +23,8 @@ import ../muxer,
logScope:
topic = "Mplex"
const HandleTimeout = 30.seconds
type
Mplex* = ref object of Muxer
remote*: Table[uint, LPChannel]
@ -69,7 +71,7 @@ method handle*(m: Mplex) {.async, gcsafe.} =
while not m.connection.closed:
trace "waiting for data"
let
res = await one(m.connection.readMsg(), messageTimeout(MaxReadWriteTime))
res = await one(m.connection.readMsg(), messageTimeout(HandleTimeout))
msg = res.read()
if msg.isNone:
trace "connection EOF"