diff --git a/seastar b/seastar index 70aecca3e0..ac02df7eac 160000 --- a/seastar +++ b/seastar @@ -1 +1 @@ -Subproject commit 70aecca3e0790a597a582ab1af97b623b8e0b61f +Subproject commit ac02df7eac81527b362bdb0350a62da973e5657b diff --git a/tests/commitlog_test.cc b/tests/commitlog_test.cc index 0f0ff046bb..7ba3fd2bd5 100644 --- a/tests/commitlog_test.cc +++ b/tests/commitlog_test.cc @@ -513,7 +513,7 @@ SEASTAR_TEST_CASE(test_commitlog_counters) { }); } -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR SEASTAR_TEST_CASE(test_allocation_failure){ return cl_test([](commitlog& log) { diff --git a/tests/continuous_data_consumer_test.cc b/tests/continuous_data_consumer_test.cc index 99ab94fa37..305c83b8c5 100644 --- a/tests/continuous_data_consumer_test.cc +++ b/tests/continuous_data_consumer_test.cc @@ -98,7 +98,7 @@ SEASTAR_THREAD_TEST_CASE(test_read_unsigned_vint) { static std::random_device rd; static std::mt19937 rng(rd()); auto nr_tests = -#ifdef DEBUG +#ifdef SEASTAR_DEBUG 10 #else 1000 diff --git a/tests/dynamic_bitset_test.cc b/tests/dynamic_bitset_test.cc index 34c858789a..ce042358b3 100644 --- a/tests/dynamic_bitset_test.cc +++ b/tests/dynamic_bitset_test.cc @@ -138,7 +138,7 @@ static void test_random_ops(size_t size, std::random_device& rd ) { return bv[i]; }; size_t limit = size * 100; -#ifdef DEBUG +#ifdef SEASTAR_DEBUG limit = std::min(limit, 20000); #endif for (size_t i = 0; i != limit; ++i) { diff --git a/tests/logalloc_test.cc b/tests/logalloc_test.cc index ce1beaaa50..abc95ef6cd 100644 --- a/tests/logalloc_test.cc +++ b/tests/logalloc_test.cc @@ -306,7 +306,7 @@ SEASTAR_TEST_CASE(test_merging) { }); } -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR SEASTAR_TEST_CASE(test_region_lock) { return seastar::async([] { region reg; @@ -1094,7 +1094,7 @@ SEASTAR_TEST_CASE(test_region_groups_basic_throttling_active_reclaim_no_double_r // Reproduces issue #2021 SEASTAR_TEST_CASE(test_no_crash_when_a_lot_of_requests_released_which_change_region_group_size) { return seastar::async([] { -#ifndef DEFAULT_ALLOCATOR // Because we need memory::stats().free_memory(); +#ifndef SEASTAR_DEFAULT_ALLOCATOR // Because we need memory::stats().free_memory(); logging::logger_registry().set_logger_level("lsa", seastar::log_level::debug); auto free_space = memory::stats().free_memory(); @@ -1242,7 +1242,7 @@ SEASTAR_TEST_CASE(test_zone_reclaiming_preserves_free_size) { } // No point in testing contiguous memory allocation in debug mode -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR SEASTAR_THREAD_TEST_CASE(test_can_reclaim_contiguous_memory_with_mixed_allocations) { prime_segment_pool(); // if previous test cases muddied the pool diff --git a/tests/row_cache_test.cc b/tests/row_cache_test.cc index 4ccd4ee49c..cb3121930c 100644 --- a/tests/row_cache_test.cc +++ b/tests/row_cache_test.cc @@ -936,7 +936,7 @@ SEASTAR_TEST_CASE(test_update) { }); } -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR SEASTAR_TEST_CASE(test_update_failure) { return seastar::async([] { auto s = make_schema(); diff --git a/transport/server.cc b/transport/server.cc index 80d592adf2..f886215e20 100644 --- a/transport/server.cc +++ b/transport/server.cc @@ -1617,7 +1617,7 @@ std::vector cql_server::response::compress_lz4(const std::vector& bo output[1] = (input_len >> 16) & 0xFF; output[2] = (input_len >> 8) & 0xFF; output[3] = input_len & 0xFF; -#ifdef HAVE_LZ4_COMPRESS_DEFAULT +#ifdef SEASTAR_HAVE_LZ4_COMPRESS_DEFAULT auto ret = LZ4_compress_default(input, output + 4, input_len, LZ4_compressBound(input_len)); #else auto ret = LZ4_compress(input, output + 4, input_len); diff --git a/utils/logalloc.cc b/utils/logalloc.cc index f406858666..5d475e3517 100644 --- a/utils/logalloc.cc +++ b/utils/logalloc.cc @@ -325,7 +325,7 @@ struct segment { void record_free(size_type size); occupancy_stats occupancy() const; -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR static void* operator new(size_t size) = delete; static void* operator new(size_t, void* ptr) noexcept { return ptr; } static void operator delete(void* ptr) = delete; @@ -371,7 +371,7 @@ struct segment_descriptor : public log_heap_hook; -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR // Segment pool implementation for the seastar allocator. // Stores segment descriptors in a vector which is indexed using most significant @@ -1481,7 +1481,7 @@ public: inline void region_group_binomial_group_sanity_check(const region_group::region_heap& bh) { -#ifdef DEBUG +#ifdef SEASTAR_DEBUG bool failed = false; size_t last = std::numeric_limits::max(); for (auto b = bh.ordered_begin(); b != bh.ordered_end(); b++) { @@ -1862,7 +1862,7 @@ size_t tracker::impl::compact_and_evict_locked(size_t memory_to_release) { return mem_released; } -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR bool segment_pool::migrate_segment(segment* src, segment* dst) { @@ -2077,7 +2077,7 @@ allocating_section::guard::~guard() { shard_segment_pool.set_emergency_reserve_max(_prev); } -#ifndef DEFAULT_ALLOCATOR +#ifndef SEASTAR_DEFAULT_ALLOCATOR void allocating_section::reserve() { shard_segment_pool.set_emergency_reserve_max(std::max(_lsa_reserve, _minimum_lsa_emergency_reserve));