Skip to content

Conversation

@lhoguin
Copy link
Contributor

@lhoguin lhoguin commented Oct 21, 2025

No description provided.

%% @todo This can be heavily simplified: if the message falls into delta,
%% add it there. Otherwise just add it to q3 in the correct position.
%% @todo I think if the message falls within Q3 we must add it back there,
%% otherwise there's nothing to do? Except update stats.
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

todo

St#vqstate{?UP(len, ram_msg_count, +1),
?UP(bytes, +msg_size(MS)), ?UP(unacked_bytes, -msg_size(MS))}.

%% TODO!!!
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

todo

sets:union(MOD, Confirmed) })
end).

%% @todo Having to call run_backing_queue is probably reducing performance...
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

todo

%% queue implementation itself.
-export([pre_publish/7, flush_pre_publish_cache/2,
sync/1, needs_sync/1, flush/1,
%% @todo TODO
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

todo

We avoid an extra unnecessary message to the queue.
And drop all terminology from antique CQ. Some terminology
remains in the backing_queue_SUITE, to be addressed later.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants