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
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
#pragma once
#include "file_table.h"
#include "logger.h"
#include "myutils.h"
#include <fuse.h>
#define OPT_TRACE_WITH_PATH TRACE_LOG("%s path=%s", __func__, path)
#define OPT_TRACE_WITH_PATH_OFF_LEN(off, len) \
TRACE_LOG("%s path=%s offset=%lld length=%zu", \
__func__, \
path, \
static_cast<long long>(off), \
static_cast<size_t>(len))
#define OPT_TRACE_WITH_TWO_PATHS(path1, path2) \
TRACE_LOG("%s %s=%s %s=%s", __func__, #path1, path1, #path2, path2)
#define OPT_CATCH_WITH_PATH \
catch (const std::exception& e) \
{ \
auto ebase = dynamic_cast<const ExceptionBase*>(&e); \
auto code = ebase ? ebase->error_number() : EPERM; \
ERROR_LOG("%s path=%s encounters exception %s (code=%d): %s", \
__func__, \
path, \
get_type_name(e).get(), \
code, \
e.what()); \
return -code; \
}
#define OPT_CATCH_WITH_PATH_OFF_LEN(off, len) \
catch (const std::exception& e) \
{ \
auto ebase = dynamic_cast<const ExceptionBase*>(&e); \
auto code = ebase ? ebase->error_number() : EPERM; \
ERROR_LOG("%s path=%s offset=%lld length=%zu encounters exception %s (code=%d): %s", \
__func__, \
path, \
static_cast<long long>(off), \
static_cast<size_t>(len), \
get_type_name(e).get(), \
code, \
e.what()); \
return -code; \
}
#define OPT_CATCH_WITH_TWO_PATHS(path1, path2) \
catch (const std::exception& e) \
{ \
auto ebase = dynamic_cast<const ExceptionBase*>(&e); \
auto code = ebase ? ebase->error_number() : EPERM; \
ERROR_LOG("%s %s=%s %s=%s encounters exception %s (code=%d): %s", \
__func__, \
#path1, \
path1, \
#path2, \
path2, \
get_type_name(e).get(), \
code, \
e.what()); \
return -code; \
}
namespace securefs
{
class FileStream;
namespace operations
{
extern const char* LOCK_FILENAME;
struct MountOptions
{
optional<int> version;
std::shared_ptr<const OSService> root;
CryptoPP::AlignedSecByteBlock master_key;
optional<uint32_t> flags;
optional<unsigned> block_size;
optional<unsigned> iv_size;
MountOptions();
~MountOptions();
};
struct FileSystemContext
{
private:
static key_type from_cryptopp_key(const CryptoPP::AlignedSecByteBlock& key)
{
if (key.size() != KEY_LENGTH)
throwInvalidArgumentException("Invalid key length");
key_type result;
memcpy(result.data(), key.data(), key.size());
return result;
}
public:
FileTable table;
std::shared_ptr<const OSService> root;
id_type root_id;
unsigned block_size;
optional<fuse_uid_t> uid_override;
optional<fuse_gid_t> gid_override;
uint32_t flags;
explicit FileSystemContext(const MountOptions& opt);
~FileSystemContext();
};
void init_fuse_operations(struct fuse_operations* opt, bool xattr);
int statfs(const char*, struct fuse_statvfs*);
void* init(struct fuse_conn_info*);
void destroy(void* ptr);
int getattr(const char*, struct fuse_stat*);
int opendir(const char*, struct fuse_file_info*);
int releasedir(const char*, struct fuse_file_info*);
int readdir(const char*, void*, fuse_fill_dir_t, fuse_off_t, struct fuse_file_info*);
int create(const char*, fuse_mode_t, struct fuse_file_info*);
int open(const char*, struct fuse_file_info*);
int release(const char*, struct fuse_file_info*);
int read(const char*, char*, size_t, fuse_off_t, struct fuse_file_info*);
int write(const char*, const char*, size_t, fuse_off_t, struct fuse_file_info*);
int flush(const char*, struct fuse_file_info*);
int truncate(const char*, fuse_off_t);
int ftruncate(const char*, fuse_off_t, struct fuse_file_info*);
int unlink(const char*);
int mkdir(const char*, fuse_mode_t);
int rmdir(const char*);
int chmod(const char*, fuse_mode_t);
int chown(const char* path, fuse_uid_t uid, fuse_gid_t gid);
int symlink(const char* to, const char* from);
int readlink(const char* path, char* buf, size_t size);
int rename(const char*, const char*);
int link(const char*, const char*);
int fsync(const char* path, int isdatasync, struct fuse_file_info* fi);
int fsyncdir(const char* path, int isdatasync, struct fuse_file_info* fi);
int utimens(const char* path, const struct fuse_timespec ts[2]);
#ifdef __APPLE__
int listxattr(const char* path, char* list, size_t size);
int getxattr(const char* path, const char* name, char* value, size_t size, uint32_t position);
int setxattr(const char* path,
const char* name,
const char* value,
size_t size,
int flags,
uint32_t position);
int removexattr(const char* path, const char* name);
#endif
} // namespace operations
} // namespace securefs
|
