Closed
Description
Hi, I believe I have finally managed to track down the issue that was haunting me for some time.
Publisher gets several NAKs per second and exact same amount of Invalid Packets. Subscriber is unable to advance with stream processing.
Publisher log buffer excerpt:
======================================================================
Sun Jun 19 22:23:15 CEST 2016 Inspection dump for publisher.buf
======================================================================
Time of last SM: Sun Jun 19 22:19:42 CEST 2016
Initial term id: 21875911
Active index: 0
Term length: 16777216
MTU length: 4096
default Data Header{frame_length=0 version=0 flags=11000000 type=1 frame_length=0 term_offset=0 session_id=-549905289 stream_id=1 term_id=21875911 reserved_value=0}
Index 0 Term Meta Data status=CLEAN termOffset=10040736 termId=21883759
Index 1 Term Meta Data status=CLEAN termOffset=16777984 termId=21883757
Index 2 Term Meta Data status=CLEAN termOffset=16778560 termId=21883758
...
Index 2 Term Data
....
Data Header{frame_length=1011 version=0 flags=11000000 type=1 frame_length=1011 term_offset=16775040 session_id=-549905289 stream_id=1 term_id=21883758 reserved_value=0}
Data Header{frame_length=1108 version=0 flags=11000000 type=1 frame_length=1108 term_offset=16776064 session_id=-549905289 stream_id=1 term_id=21883758 reserved_value=0}
Data Header{frame_length=32 version=0 flags=11000000 type=0 frame_length=32 term_offset=16777184 session_id=-549905289 stream_id=1 term_id=21883758 reserved_value=0}
Subscriber log buffer excerpt:
======================================================================
Sun Jun 19 22:23:00 CEST 2016 Inspection dump for subscriber.buf
======================================================================
Time of last SM: Thu Jan 01 01:00:00 CET 1970
Initial term id: 21875911
Active index: 0
Term length: 16777216
MTU length: 4096
default Data Header{frame_length=0 version=0 flags=11000000 type=1 frame_length=0 term_offset=0 session_id=-549905289 stream_id=1 term_id=21875911 reserved_value=0}
Index 0 Term Meta Data status=CLEAN termOffset=0 termId=0
Index 1 Term Meta Data status=CLEAN termOffset=0 termId=0
Index 2 Term Meta Data status=CLEAN termOffset=0 termId=0
...
Index 2 Term Data
...
Data Header{frame_length=1011 version=0 flags=11000000 type=1 frame_length=1011 term_offset=16775040 session_id=-549905289 stream_id=1 term_id=21883758 reserved_value=0}
Data Header{frame_length=1108 version=0 flags=11000000 type=1 frame_length=1108 term_offset=16776064 session_id=-549905289 stream_id=1 term_id=21883758 reserved_value=0}
Data Header{frame_length=0 version=0 flags=00000000 type=0 frame_length=0 term_offset=0 session_id=0 stream_id=0 term_id=0 reserved_value=0}
The last log buffer fragment to retransmit is the padding fragment. At the same time
final boolean isInvalid = termOffset >= (capacity - DataHeaderFlyweight.HEADER_LENGTH);
in io.aeron.driver.RetransmitHandler .
Metadata
Metadata
Assignees
Labels
No labels