blob: 851db0222c276f28b673ce9002c174953f111cc7 (
plain) (
blame)
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
67
68
69
70
71
72
73
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "buffer_free_list.h"
#include "free_list.h"
#include <cassert>
namespace vespalib::datastore {
void
BufferFreeList::attach()
{
assert(_free_list != nullptr);
_free_list->attach(*this);
}
void
BufferFreeList::detach()
{
assert(_free_list != nullptr);
_free_list->detach(*this);
}
BufferFreeList::BufferFreeList(std::atomic<EntryCount>& dead_entries)
: _dead_entries(dead_entries),
_free_list(),
_free_refs()
{
}
BufferFreeList::~BufferFreeList()
{
assert(_free_list == nullptr);
assert(_free_refs.empty());
}
void
BufferFreeList::enable(FreeList& free_list)
{
assert(_free_list == nullptr);
assert(_free_refs.empty());
_free_list = &free_list;
}
void
BufferFreeList::disable()
{
if (!empty()) {
detach();
EntryRefArray().swap(_free_refs);
}
_free_list = nullptr;
}
void
BufferFreeList::push_entry(EntryRef ref) {
if (empty()) {
attach();
}
_free_refs.push_back(ref);
}
EntryRef
BufferFreeList::pop_entry() {
EntryRef ret = _free_refs.back();
_free_refs.pop_back();
if (empty()) {
detach();
}
_dead_entries.store(_dead_entries.load(std::memory_order_relaxed) - 1, std::memory_order_relaxed);
return ret;
}
}
|
