a1ea553fe1
The latter is recommended in seastar, and the former was left as
compatibility alias. Latest seastar explicitly marks it as deprecated so
once the submodule is updated, compilation logs will explode.
Most of the patch is generated with
for f in $(git grep -l '\<distributed<[A-Za-z0-9:_]*>') ; do sed -e 's/\<distributed<\([A-Za-z0-9:_]*\)>/sharded<\1>/g' -i $f; done
for f in $(git grep -l distributed.hh); do sed -e 's/distributed.hh/sharded.hh/' -i $f ; done
and a small manual change in test/perf/perf.hh
Signed-off-by: Pavel Emelyanov <xemul@scylladb.com>
Closes scylladb/scylladb#26136
82 lines
2.8 KiB
C++
82 lines
2.8 KiB
C++
/*
|
|
* Copyright (C) 2015-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#include <seastar/core/sharded.hh>
|
|
#include <seastar/core/app-template.hh>
|
|
#include <seastar/core/sstring.hh>
|
|
#include <seastar/core/thread.hh>
|
|
#include <seastar/util/defer.hh>
|
|
|
|
#include "utils/managed_bytes.hh"
|
|
#include "utils/logalloc.hh"
|
|
#include "utils/log.hh"
|
|
|
|
void print_stats() {
|
|
std::cout << "free " << memory::stats().free_memory()
|
|
<< " used " << logalloc::shard_tracker().occupancy().used_space()
|
|
<< " total " << logalloc::shard_tracker().occupancy().total_space()
|
|
<< std::endl;
|
|
}
|
|
|
|
int main(int argc, char** argv) {
|
|
namespace bpo = boost::program_options;
|
|
app_template app;
|
|
app.add_options()
|
|
("size", bpo::value<unsigned>()->default_value(1024), "size of allocated object")
|
|
("batch", bpo::value<unsigned>()->default_value(1024), "number of allocated objects between deferring points")
|
|
("count", bpo::value<unsigned>()->default_value(1024*200), "number of objects to allocate before exiting");
|
|
|
|
logging::logger_registry().set_all_loggers_level(logging::log_level::debug);
|
|
|
|
return app.run(argc, argv, [&app] {
|
|
auto obj_size = app.configuration()["size"].as<unsigned>();
|
|
auto obj_count = app.configuration()["count"].as<unsigned>();
|
|
auto objects_in_batch = app.configuration()["batch"].as<unsigned>();
|
|
|
|
return seastar::async([obj_size, obj_count, objects_in_batch] {
|
|
chunked_fifo<managed_bytes> refs;
|
|
logalloc::region r;
|
|
|
|
with_allocator(r.allocator(), [&] {
|
|
auto clear_refs = defer([&refs] { refs.clear(); });
|
|
|
|
r.make_evictable([&] {
|
|
return with_allocator(r.allocator(), [&] {
|
|
if (refs.empty()) {
|
|
return memory::reclaiming_result::reclaimed_nothing;
|
|
}
|
|
refs.pop_front();
|
|
return memory::reclaiming_result::reclaimed_something;
|
|
});
|
|
});
|
|
|
|
uint64_t counter = 0;
|
|
logalloc::allocating_section alloc_sect;
|
|
alloc_sect.set_lsa_reserve(0);
|
|
alloc_sect.set_std_reserve(0);
|
|
|
|
while (counter < obj_count) {
|
|
alloc_sect(r, [&] {
|
|
auto obj = managed_bytes(managed_bytes::initialized_later(), obj_size);
|
|
logalloc::reclaim_lock l(r);
|
|
refs.push_back(std::move(obj));
|
|
});
|
|
|
|
++counter;
|
|
|
|
if (counter % objects_in_batch == 0) {
|
|
print_stats();
|
|
seastar::thread::yield();
|
|
}
|
|
}
|
|
});
|
|
return 0;
|
|
});
|
|
});
|
|
}
|