Skip to content

Make etl::Publisher stoppableΒ #2833

@kuznetsss

Description

@kuznetsss

Issue Description

etl::LedgerPublisher has this loop:

while (not state_.get().isStopping) {

But the flag isStopping is not set anywhere so it is always false.
Also the method publish() is called with maxAttempts = std::nullopt:

publisher_->publish(seq, {});

So if LedgerPublisher couldn't fetch range or range is older it will stuck in an infinite loop.

Probably we should add method stop() to LedgerPublisher and call it in ETLService::stop().

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    Status

    πŸ“‹ Backlog

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions