You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iggy.apache.org by hg...@apache.org on 2025/10/16 13:33:26 UTC

(iggy) branch io_uring_tpc_broadcast updated (ec6007d3a -> 96703d522)

This is an automated email from the ASF dual-hosted git repository.

hgruszecki pushed a change to branch io_uring_tpc_broadcast
in repository https://gitbox.apache.org/repos/asf/iggy.git


    from ec6007d3a feat(io_uring): implement broadcast mechanism error handling
     add 96703d522 process CreateTopic and CreateStream on shard0

No new revisions were added by this update.

Summary of changes:
 .../handlers/streams/create_stream_handler.rs      |  28 +---
 .../binary/handlers/topics/create_topic_handler.rs |  26 +---
 core/server/src/shard/builder.rs                   |   8 +-
 core/server/src/shard/mod.rs                       | 143 ++++++++++++++++++++-
 core/server/src/shard/system/streams.rs            |  83 +++++++++++-
 core/server/src/shard/system/topics.rs             | 129 +++++++++++++++----
 core/server/src/shard/transmission/frame.rs        |   5 +
 core/server/src/shard/transmission/message.rs      |  24 ++++
 core/server/src/slab/streams.rs                    |  11 +-
 core/server/src/slab/topics.rs                     |  21 +++
 core/server/src/streaming/topics/topic2.rs         |   8 ++
 11 files changed, 400 insertions(+), 86 deletions(-)