1*61c4878aSAndroid Build Coastguard Worker // Copyright 2024 The Pigweed Authors
2*61c4878aSAndroid Build Coastguard Worker //
3*61c4878aSAndroid Build Coastguard Worker // Licensed under the Apache License, Version 2.0 (the "License"); you may not
4*61c4878aSAndroid Build Coastguard Worker // use this file except in compliance with the License. You may obtain a copy of
5*61c4878aSAndroid Build Coastguard Worker // the License at
6*61c4878aSAndroid Build Coastguard Worker //
7*61c4878aSAndroid Build Coastguard Worker // https://www.apache.org/licenses/LICENSE-2.0
8*61c4878aSAndroid Build Coastguard Worker //
9*61c4878aSAndroid Build Coastguard Worker // Unless required by applicable law or agreed to in writing, software
10*61c4878aSAndroid Build Coastguard Worker // distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
11*61c4878aSAndroid Build Coastguard Worker // WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
12*61c4878aSAndroid Build Coastguard Worker // License for the specific language governing permissions and limitations under
13*61c4878aSAndroid Build Coastguard Worker // the License.
14*61c4878aSAndroid Build Coastguard Worker
15*61c4878aSAndroid Build Coastguard Worker #include "pw_multibuf/from_span.h"
16*61c4878aSAndroid Build Coastguard Worker
17*61c4878aSAndroid Build Coastguard Worker namespace pw::multibuf {
18*61c4878aSAndroid Build Coastguard Worker namespace {
19*61c4878aSAndroid Build Coastguard Worker
20*61c4878aSAndroid Build Coastguard Worker /// A simple ``ChunkRegionTracker`` that calls ``deleter`` for destruction.
21*61c4878aSAndroid Build Coastguard Worker class SpanTracker final : public ChunkRegionTracker {
22*61c4878aSAndroid Build Coastguard Worker private:
23*61c4878aSAndroid Build Coastguard Worker class PrivateConstructorType {};
24*61c4878aSAndroid Build Coastguard Worker static constexpr PrivateConstructorType kPrivateConstructor{};
25*61c4878aSAndroid Build Coastguard Worker
26*61c4878aSAndroid Build Coastguard Worker public:
New(Allocator & alloc,ByteSpan region,pw::Function<void (ByteSpan)> && deleter)27*61c4878aSAndroid Build Coastguard Worker static std::optional<OwnedChunk> New(Allocator& alloc,
28*61c4878aSAndroid Build Coastguard Worker ByteSpan region,
29*61c4878aSAndroid Build Coastguard Worker pw::Function<void(ByteSpan)>&& deleter) {
30*61c4878aSAndroid Build Coastguard Worker SpanTracker* tracker = alloc.New<SpanTracker>(
31*61c4878aSAndroid Build Coastguard Worker kPrivateConstructor, alloc, region, std::move(deleter));
32*61c4878aSAndroid Build Coastguard Worker if (tracker == nullptr) {
33*61c4878aSAndroid Build Coastguard Worker return std::nullopt;
34*61c4878aSAndroid Build Coastguard Worker }
35*61c4878aSAndroid Build Coastguard Worker std::optional<OwnedChunk> chunk = tracker->CreateFirstChunk();
36*61c4878aSAndroid Build Coastguard Worker if (!chunk.has_value()) {
37*61c4878aSAndroid Build Coastguard Worker // Delete without destroying the associated memory.
38*61c4878aSAndroid Build Coastguard Worker alloc.Delete(tracker);
39*61c4878aSAndroid Build Coastguard Worker return std::nullopt;
40*61c4878aSAndroid Build Coastguard Worker }
41*61c4878aSAndroid Build Coastguard Worker return chunk;
42*61c4878aSAndroid Build Coastguard Worker }
43*61c4878aSAndroid Build Coastguard Worker
SpanTracker(PrivateConstructorType,pw::Allocator & alloc,ByteSpan region,pw::Function<void (ByteSpan)> && deleter)44*61c4878aSAndroid Build Coastguard Worker SpanTracker(PrivateConstructorType,
45*61c4878aSAndroid Build Coastguard Worker pw::Allocator& alloc,
46*61c4878aSAndroid Build Coastguard Worker ByteSpan region,
47*61c4878aSAndroid Build Coastguard Worker pw::Function<void(ByteSpan)>&& deleter)
48*61c4878aSAndroid Build Coastguard Worker : alloc_(alloc), region_(region), deleter_(std::move(deleter)) {}
49*61c4878aSAndroid Build Coastguard Worker
50*61c4878aSAndroid Build Coastguard Worker ~SpanTracker() final = default;
51*61c4878aSAndroid Build Coastguard Worker
52*61c4878aSAndroid Build Coastguard Worker // SpanTracker is not copyable nor movable.
53*61c4878aSAndroid Build Coastguard Worker SpanTracker(const SpanTracker&) = delete;
54*61c4878aSAndroid Build Coastguard Worker SpanTracker& operator=(const SpanTracker&) = delete;
55*61c4878aSAndroid Build Coastguard Worker SpanTracker(SpanTracker&&) = delete;
56*61c4878aSAndroid Build Coastguard Worker SpanTracker& operator=(SpanTracker&&) = delete;
57*61c4878aSAndroid Build Coastguard Worker
58*61c4878aSAndroid Build Coastguard Worker private:
Destroy()59*61c4878aSAndroid Build Coastguard Worker void Destroy() final {
60*61c4878aSAndroid Build Coastguard Worker deleter_(region_);
61*61c4878aSAndroid Build Coastguard Worker alloc_.Delete(this);
62*61c4878aSAndroid Build Coastguard Worker }
63*61c4878aSAndroid Build Coastguard Worker
Region() const64*61c4878aSAndroid Build Coastguard Worker ByteSpan Region() const final { return region_; }
65*61c4878aSAndroid Build Coastguard Worker
AllocateChunkClass()66*61c4878aSAndroid Build Coastguard Worker void* AllocateChunkClass() final {
67*61c4878aSAndroid Build Coastguard Worker return alloc_.Allocate(allocator::Layout::Of<Chunk>());
68*61c4878aSAndroid Build Coastguard Worker }
69*61c4878aSAndroid Build Coastguard Worker
DeallocateChunkClass(void * ptr)70*61c4878aSAndroid Build Coastguard Worker void DeallocateChunkClass(void* ptr) final { return alloc_.Deallocate(ptr); }
71*61c4878aSAndroid Build Coastguard Worker
72*61c4878aSAndroid Build Coastguard Worker pw::Allocator& alloc_;
73*61c4878aSAndroid Build Coastguard Worker const ByteSpan region_;
74*61c4878aSAndroid Build Coastguard Worker pw::Function<void(ByteSpan)> deleter_;
75*61c4878aSAndroid Build Coastguard Worker };
76*61c4878aSAndroid Build Coastguard Worker
77*61c4878aSAndroid Build Coastguard Worker } // namespace
78*61c4878aSAndroid Build Coastguard Worker
FromSpan(pw::Allocator & metadata_allocator,ByteSpan region,pw::Function<void (ByteSpan)> && deleter)79*61c4878aSAndroid Build Coastguard Worker std::optional<MultiBuf> FromSpan(pw::Allocator& metadata_allocator,
80*61c4878aSAndroid Build Coastguard Worker ByteSpan region,
81*61c4878aSAndroid Build Coastguard Worker pw::Function<void(ByteSpan)>&& deleter) {
82*61c4878aSAndroid Build Coastguard Worker std::optional<OwnedChunk> chunk =
83*61c4878aSAndroid Build Coastguard Worker SpanTracker::New(metadata_allocator, region, std::move(deleter));
84*61c4878aSAndroid Build Coastguard Worker if (chunk == std::nullopt) {
85*61c4878aSAndroid Build Coastguard Worker return std::nullopt;
86*61c4878aSAndroid Build Coastguard Worker }
87*61c4878aSAndroid Build Coastguard Worker return MultiBuf::FromChunk(std::move(*chunk));
88*61c4878aSAndroid Build Coastguard Worker }
89*61c4878aSAndroid Build Coastguard Worker
90*61c4878aSAndroid Build Coastguard Worker } // namespace pw::multibuf
91