This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch server_perf_cut_extra_work
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b6107eca4 test(cluster): reproduce auto-commit group membership loss
add 596080d31 fix(cluster): preserve group membership during auto-commit
polls
No new revisions were added by this update.
Summary of changes:
core/binary_protocol/src/codes.rs | 6 +
core/binary_protocol/src/dispatch.rs | 6 +
.../src/requests/system/attach_consumer_session.rs | 84 +++++
core/binary_protocol/src/requests/system/mod.rs | 2 +
core/binary_protocol/src/responses/messages/mod.rs | 2 +
.../src/responses/messages/poll_routing.rs | 95 +++++
core/common/src/traits/binary_impls/messages.rs | 13 +-
core/common/src/traits/binary_transport.rs | 15 +
core/consensus/src/client_table.rs | 153 ++++++++
.../tests/cluster/partition_primary_routing.rs | 415 ++++++++++++++++++++-
.../tests/cluster/register_forwarding.rs | 2 +-
core/metadata/src/impls/metadata.rs | 34 ++
core/sdk/src/leader_aware.rs | 4 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/poll_routing.rs | 334 +++++++++++++++++
core/sdk/src/quic/quic_client.rs | 74 ++++
core/sdk/src/tcp/tcp_client.rs | 108 +++++-
core/sdk/src/websocket/websocket_client.rs | 69 ++++
core/server/src/dispatch/partition.rs | 62 ++-
core/server/src/dispatch/reads.rs | 210 ++++++++++-
core/server/src/dispatch/submit.rs | 17 +
core/server/src/responses.rs | 24 +-
core/server/src/session_manager.rs | 115 ++++++
core/shard/src/lib.rs | 13 +
core/shard/src/poll.rs | 54 ++-
core/shard/src/poll/completion.rs | 15 +-
core/shard/src/poll/completion_tests.rs | 105 +++++-
core/shard/src/poll/timeout_tests.rs | 4 +-
28 files changed, 1970 insertions(+), 66 deletions(-)
create mode 100644
core/binary_protocol/src/requests/system/attach_consumer_session.rs
create mode 100644 core/binary_protocol/src/responses/messages/poll_routing.rs
create mode 100644 core/sdk/src/poll_routing.rs
