diff mercurial/wireprotoframing.py @ 37656:e6870bca1f47

wireprotoframing: record when new stream is encountered Without this, we choke after receiving the 2nd frame in a stream. Not sure how we made it this far without finding this bug. Differential Revision: https://phab.mercurial-scm.org/D3334
author Gregory Szorc <gregory.szorc@gmail.com>
date Fri, 13 Apr 2018 12:49:47 -0700
parents b9502b5f2066
children 89a16704114c
line wrap: on
line diff
--- a/mercurial/wireprotoframing.py	Thu Apr 12 13:11:29 2018 -0700
+++ b/mercurial/wireprotoframing.py	Fri Apr 13 12:49:47 2018 -0700
@@ -1029,6 +1029,8 @@
                                  'without beginning of stream flag set'),
                 }
 
+            self._incomingstreams[frame.streamid] = stream(frame.streamid)
+
         if frame.streamflags & STREAM_FLAG_ENCODING_APPLIED:
             raise error.ProgrammingError('support for decoding stream '
                                          'payloads not yet implemneted')