From 406b79887d8682c25a27d3bafea6e42114b73d6f Mon Sep 17 00:00:00 2001
From: Dmitriy Ryajov <dryajov@gmail.com>
Date: Wed, 11 Mar 2020 09:12:08 -0600
Subject: [PATCH] add jitter tolerance to mplex

---
 libp2p/muxers/mplex/coder.nim | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/libp2p/muxers/mplex/coder.nim b/libp2p/muxers/mplex/coder.nim
index 5c9c8c726..14a23ee1f 100644
--- a/libp2p/muxers/mplex/coder.nim
+++ b/libp2p/muxers/mplex/coder.nim
@@ -57,8 +57,9 @@ proc readMsg*(conn: Connection): Future[Msg] {.async, gcsafe.} =
 
   var data: seq[byte] = newSeq[byte](dataLenVarint.int)
   if dataLenVarint.int > 0:
-    await conn.readExactly(addr data[0], dataLenVarint.int)
-    trace "read data", len = data.len
+    while data.len < dataLenVarint.int:
+      data &= await conn.read(dataLenVarint.int - data.len)
+      trace "read data", data = data
 
   let header = headerVarint
   result = (header shr 3, MessageType(header and 0x7), data)