HomeSoftware Heritage

journalprocessor: Fix freeze on empty offset ranges.

Description

journalprocessor: Fix freeze on empty offset ranges.

The state is only updated after consuming messages; so if there is no
message at all, JournalClientOffsetRanges never notices there is no
message to wait for.

Details

Provenance
vlorentzAuthored on Jul 27 2021, 3:16 PM
vlorentzPushed on Jul 27 2021, 5:33 PM
Differential Revision
D6028: journalprocessor: Fix freeze on empty offset ranges.
Parents
rDDATASETd7ff3f5632ef: Fix confusing variable names
Branches
Unknown
Tags
Unknown