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/04/14 20:13:10 UTC
(iggy) branch zero-copy-no-batching-rebase-3 updated (b69bd16f -> c4a6ef0c)
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch zero-copy-no-batching-rebase-3
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b69bd16f again improve print
add c4a6ef0c refactor memory pool, add configs
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 99 ++++--
bench/src/args/examples.rs | 2 +-
configs/server.toml | 13 +-
integration/tests/streaming/common/test_setup.rs | 2 +
integration/tests/streaming/segment.rs | 9 +
.../handlers/messages/send_messages_handler.rs | 10 +-
server/src/channels/commands/print_sysinfo.rs | 6 +-
server/src/configs/defaults.rs | 19 +-
server/src/configs/system.rs | 7 +
server/src/configs/validators.rs | 27 +-
server/src/http/jwt/storage.rs | 6 +-
server/src/http/messages.rs | 8 +-
server/src/main.rs | 4 +-
server/src/streaming/partitions/messages.rs | 2 +
server/src/streaming/partitions/partition.rs | 3 +
server/src/streaming/partitions/segments.rs | 1 +
server/src/streaming/partitions/storage.rs | 1 +
.../src/streaming/segments/indexes/index_reader.rs | 36 +-
.../src/streaming/segments/indexes/indexes_mut.rs | 30 +-
.../streaming/segments/messages/messages_reader.rs | 31 +-
server/src/streaming/segments/segment.rs | 15 +-
.../streaming/segments/types/messages_batch_mut.rs | 28 +-
.../streaming/segments/types/messages_batch_set.rs | 12 -
server/src/streaming/streams/stream.rs | 6 +-
server/src/streaming/streams/topics.rs | 2 +
server/src/streaming/systems/messages.rs | 6 +-
server/src/streaming/systems/storage.rs | 9 +-
server/src/streaming/topics/consumer_groups.rs | 2 +
server/src/streaming/topics/messages.rs | 2 +
server/src/streaming/topics/topic.rs | 6 +-
server/src/streaming/utils/bytes_mut_pool.rs | 300 ----------------
server/src/streaming/utils/memory_pool.rs | 385 +++++++++++++++++++++
server/src/streaming/utils/mod.rs | 7 +-
server/src/streaming/utils/pooled_bytes_mut.rs | 93 +++++
34 files changed, 748 insertions(+), 441 deletions(-)
delete mode 100644 server/src/streaming/utils/bytes_mut_pool.rs
create mode 100644 server/src/streaming/utils/memory_pool.rs
create mode 100644 server/src/streaming/utils/pooled_bytes_mut.rs