Skip to content

Replace maxsize=1 streams in *Pools with LatestValueCache #912

Description

@shsms

What happened?

There are a number of maxsize=1 receivers in the battery pool, and when we don't consume from them for 0.1-0.2s, their messages get dropped, leading to confusing logs.

What did you expect instead?

No logs like Broadcast receiver [raw-component-data-1019:daeca7a3-33a5-4ecb-9932-04d51c17da26] is full. Oldest message was dropped. coming from the status tracking code.

This can be achieved by replacing the maxsize=1 receivers with LatestValueCache

Affected version(s)

No response

Affected part(s)

Data pipeline (part:data-pipeline)

Extra information

No response

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    part:data-pipelineAffects the data pipelinepriority:highAddress this as soon as possibletype:bugSomething isn't working

    Type

    No type

    Fields

    Priority

    None yet

    Projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions