File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -598,6 +598,7 @@ def buffer_updated(self, nbytes: int) -> None:
598
598
if self ._expecting_header :
599
599
try :
600
600
self ._body_size , self ._op_code = self .process_header ()
601
+ self ._request_id = None
601
602
except ProtocolError as exc :
602
603
self .connection_lost (exc )
603
604
return
@@ -626,8 +627,12 @@ def buffer_updated(self, nbytes: int) -> None:
626
627
self ._overflow_index ,
627
628
)
628
629
)
630
+ # If the current message has an overflow buffer, then the entire default buffer is full
631
+ if self ._overflow :
632
+ self ._start_index = self ._end_index
629
633
# Update the buffer's first written offset to reflect this message's size
630
- self ._start_index += self ._body_size
634
+ else :
635
+ self ._start_index += self ._body_size
631
636
self ._done_messages .append (result )
632
637
# If at least one header's worth of data remains after the current message, reprocess all leftover data
633
638
if self ._end_index - self ._start_index >= 16 :
You can’t perform that action at this time.
0 commit comments