Newer
Older
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
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
//
// Created by evie on 4/18/17.
//
#ifndef LFS_FS_DATA_H
#define LFS_FS_DATA_H
#include "../../main.hpp"
#include <map>
class FsData {
private:
FsData() {}
// Caching
std::unordered_map<std::string, std::string> hashmap_;
std::hash<std::string> hashf_;
// inodes
// fuse_ino_t inode_count_;
// Later the blocksize will likely be coupled to the chunks to allow individually big chunk sizes.
blksize_t blocksize_;
//logger
std::shared_ptr<spdlog::logger> spdlogger_;
// paths
std::string rootdir_;
std::string inode_path_;
std::string dentry_path_;
std::string chunk_path_;
std::string mgmt_path_;
// hosts_
std::map<uint64_t, std::string> hosts_;
uint64_t host_id_; // my host number
size_t host_size_;
std::string rpc_port_;
// rocksdb
std::shared_ptr<rocksdb::DB> rdb_;
std::shared_ptr<rocksdb::DB> rdb_crt_; // additional db instance (currently not used)
std::shared_ptr<rocksdb::OptimisticTransactionDB> txn_rdb_;
rocksdb::Options rdb_options_;
rocksdb::OptimisticTransactionOptions txn_rdb_options_; // needed for snapshots
rocksdb::WriteOptions rdb_write_options_;
std::string rdb_path_;
public:
// mutex has a deleted method to assign an existing mutex. As such it cannot use getter or setters
std::mutex inode_mutex;
static FsData* getInstance() {
static FsData instance;
return &instance;
}
FsData(FsData const&) = delete;
void operator=(FsData const&) = delete;
// getter/setter
const std::unordered_map<std::string, std::string>& hashmap() const;
void hashmap(const std::unordered_map<std::string, std::string>& hashmap_);
const std::hash<std::string>& hashf() const;
void hashf(const std::hash<std::string>& hashf_);
// fuse_ino_t inode_count() const;
//
// void inode_count(fuse_ino_t inode_count);
blksize_t blocksize() const;
void blocksize(blksize_t blocksize_);
const std::shared_ptr<spdlog::logger>& spdlogger() const;
void spdlogger(const std::shared_ptr<spdlog::logger>& spdlogger_);
const std::string& rootdir() const;
void rootdir(const std::string& rootdir_);
const std::string& inode_path() const;
void inode_path(const std::string& inode_path_);
const std::string& dentry_path() const;
void dentry_path(const std::string& dentry_path_);
const std::string& chunk_path() const;
void chunk_path(const std::string& chunk_path_);
const std::string& mgmt_path() const;
void mgmt_path(const std::string& mgmt_path_);
const std::shared_ptr<rocksdb::DB>& rdb() const;
void rdb(const std::shared_ptr<rocksdb::DB>& rdb);
const rocksdb::Options& rdb_options() const;
void rdb_options(const rocksdb::Options& rdb_options);
const std::string& rdb_path() const;
void rdb_path(const std::string& rdb_path);
const std::shared_ptr<rocksdb::OptimisticTransactionDB>& txn_rdb() const;
void txn_rdb(const std::shared_ptr<rocksdb::OptimisticTransactionDB>& tx_rdb);
const std::shared_ptr<rocksdb::DB>& rdb_crt() const;
void rdb_crt(const std::shared_ptr<rocksdb::DB>& rdb_crt);
const rocksdb::OptimisticTransactionOptions& txn_rdb_options() const;
void txn_rdb_options(const rocksdb::OptimisticTransactionOptions& tx_rdb_options);
const rocksdb::WriteOptions& rdb_write_options() const;
void rdb_write_options(const rocksdb::WriteOptions& rdb_write_options);
const std::map<uint64_t, std::string>& hosts() const;
void hosts(const std::map<uint64_t, std::string>& hosts);
const uint64_t& host_id() const;
void host_id(const uint64_t& host_id);
size_t host_size() const;
void host_size(size_t host_size);
std::string rpc_port() const;
void rpc_port(std::string rpc_port);
// Utility member functions
// fuse_ino_t raise_inode_count(fuse_ino_t count);
bool is_local_op(size_t recipient);
};
#endif //LFS_FS_DATA_H