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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
#include "sdsl/ram_fs.hpp"
#include "sdsl/util.hpp"
#include <cstdio>
#include <iostream>
#include <algorithm>
static int nifty_counter = 0;
sdsl::ram_fs::mss_type sdsl::ram_fs::m_map;
std::recursive_mutex sdsl::ram_fs::m_rlock;
sdsl::ram_fs_initializer::ram_fs_initializer()
{
if (0 == nifty_counter++) {
if (!ram_fs::m_map.empty()) {
throw std::logic_error("Static preinitialized object is not empty.");
}
}
}
sdsl::ram_fs_initializer::~ram_fs_initializer()
{
if (0 == --nifty_counter) {
// clean up
}
}
namespace sdsl
{
ram_fs::ram_fs() {}
void
ram_fs::store(const std::string& name, content_type data)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
if (!exists(name)) {
std::string cname = name;
m_map.insert(std::make_pair(std::move(cname), std::move(data)));
} else {
m_map[name] = std::move(data);
}
}
bool
ram_fs::exists(const std::string& name)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
return m_map.find(name) != m_map.end();
}
ram_fs::content_type&
ram_fs::content(const std::string& name)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
return m_map[name];
}
size_t
ram_fs::file_size(const std::string& name)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
if (exists(name)) {
return m_map[name].size();
} else {
return 0;
}
}
int
ram_fs::remove(const std::string& name)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
m_map.erase(name);
return 0;
}
int
ram_fs::rename(const std::string old_filename, const std::string new_filename)
{
std::lock_guard<std::recursive_mutex> lock(m_rlock);
m_map[new_filename] = std::move(m_map[old_filename]);
remove(old_filename);
return 0;
}
bool is_ram_file(const std::string& file)
{
if (file.size() > 0) {
if (file[0]=='@') {
return true;
}
}
return false;
}
std::string ram_file_name(const std::string& file)
{
if (is_ram_file(file)) {
return file;
} else {
return "@" + file;
}
}
std::string disk_file_name(const std::string& file)
{
if (!is_ram_file(file)) {
return file;
} else {
return file.substr(1);
}
}
int remove(const std::string& file)
{
if (is_ram_file(file)) {
return ram_fs::remove(file);
} else {
return std::remove(file.c_str());
}
}
int rename(const std::string& old_filename, const std::string& new_filename)
{
if (is_ram_file(old_filename)) {
if (!is_ram_file(new_filename)) { // error, if new file is not also RAM-file
return -1;
}
return ram_fs::rename(old_filename, new_filename);
} else {
return std::rename(old_filename.c_str(), new_filename.c_str());
}
}
} // end namespace sdsl
|
