unit-map.cpp
2.23 KB
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
74
75
76
77
78
79
80
81
//===-- runtime/unit-map.cpp ------------------------------------*- C++ -*-===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//
#include "unit-map.h"
namespace Fortran::runtime::io {
ExternalFileUnit *UnitMap::LookUpForClose(int n) {
CriticalSection critical{lock_};
Chain *previous{nullptr};
int hash{Hash(n)};
for (Chain *p{bucket_[hash].get()}; p; previous = p, p = p->next.get()) {
if (p->unit.unitNumber() == n) {
if (previous) {
previous->next.swap(p->next);
} else {
bucket_[hash].swap(p->next);
}
// p->next.get() == p at this point; the next swap pushes p on closing_
closing_.swap(p->next);
return &p->unit;
}
}
return nullptr;
}
void UnitMap::DestroyClosed(ExternalFileUnit &unit) {
Chain *p{nullptr};
{
CriticalSection critical{lock_};
Chain *previous{nullptr};
for (p = closing_.get(); p; previous = p, p = p->next.get()) {
if (&p->unit == &unit) {
if (previous) {
previous->next.swap(p->next);
} else {
closing_.swap(p->next);
}
break;
}
}
}
if (p) {
p->unit.~ExternalFileUnit();
FreeMemory(p);
}
}
void UnitMap::CloseAll(IoErrorHandler &handler) {
CriticalSection critical{lock_};
for (int j{0}; j < buckets_; ++j) {
while (Chain * p{bucket_[j].get()}) {
bucket_[j].swap(p->next); // pops p from head of list
p->unit.CloseUnit(CloseStatus::Keep, handler);
p->unit.~ExternalFileUnit();
FreeMemory(p);
}
}
}
void UnitMap::FlushAll(IoErrorHandler &handler) {
CriticalSection critical{lock_};
for (int j{0}; j < buckets_; ++j) {
for (Chain *p{bucket_[j].get()}; p; p = p->next.get()) {
p->unit.Flush(handler);
}
}
}
ExternalFileUnit &UnitMap::Create(int n, const Terminator &terminator) {
Chain &chain{*New<Chain>{terminator}(n).release()};
chain.next.reset(&chain);
bucket_[Hash(n)].swap(chain.next); // pushes new node as list head
return chain.unit;
}
} // namespace Fortran::runtime::io