allocators.cpp

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
#include <felspar/coro/eager.hpp>
#include <felspar/io.hpp>
#include <felspar/memory/fixed-pool.pmr.hpp>
#include <felspar/test.hpp>


using namespace std::literals;


namespace {


    auto const suite = felspar::testsuite("allocators");


    struct counting_allocator : public felspar::pmr::memory_resource {
        felspar::pmr::memory_resource *backing_allocator =
                felspar::pmr::new_delete_resource();
        std::size_t allocations{}, deallocations{};

      private:
        void *do_allocate(std::size_t bytes, std::size_t alignment) override {
            ++allocations;
            return backing_allocator->allocate(bytes, alignment);
        }

        void do_deallocate(
                void *p, std::size_t bytes, std::size_t alignment) override {
            backing_allocator->deallocate(p, bytes, alignment);
            ++deallocations;
        }

        bool do_is_equal(memory_resource const &other) const noexcept override {
            return this == &other;
        }
    };


    felspar::io::warden::task<void> sleeper(felspar::io::warden &ward) {
        co_await ward.sleep(20ms);
    }


    auto const task = suite.test("task", []() {
        felspar::io::poll_warden ward;
        ward.run(
                +[](felspar::io::warden &ward)
                        -> felspar::io::warden::task<void> {
                    felspar::test::injected check;

                    counting_allocator count;
                    felspar::io::allocator allocator{ward, count};

                    felspar::io::warden::eager<> coro;
                    coro.post(sleeper, std::ref(allocator));
                    check(count.allocations) == 1u;
                    check(count.deallocations) == 0u;

                    co_await std::move(coro).release();
                    check(count.allocations) == 1u;
                    check(count.deallocations) == 1u;
                });
    });


}