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
|
#include <errno.h>
#include <set>
#include <unistd.h>
#include <limits.h>
#include "comms.h"
#include "msgtypes.h"
#include "daemon.h"
#include "misc.h"
extern std::map<int, int> files;
handler(AccessRequest)
{
TypedPayload<AccessRequest::Reply> * r = new TypedPayload<AccessRequest::Reply>();
r->data.value = access(req->data.path.c_str(), req->data.access);
s.Send(r);
}
handler(GetAttrRequest)
{
TypedPayload<GetAttrRequest::Reply> * r = new TypedPayload<GetAttrRequest::Reply>();
errno = 0;
r->data.res = stat(req->data.path.c_str(), &r->data.val);
r->data.res = errno;
s.Send(r);
}
handler(FgetAttrRequest)
{
TypedPayload<FgetAttrRequest::Reply> * r = new TypedPayload<FgetAttrRequest::Reply>();
errno = 0;
if (files.find(req->data.handle) != files.end()) {
fstat(files[req->data.handle], &r->data.val);
r->data.res = errno;
}
else {
r->data.res = EBADF;
}
s.Send(r);
}
handler(SymlinkRequest)
{
TypedPayload<SymlinkRequest::Reply> * r = new TypedPayload<SymlinkRequest::Reply>();
errno = 0;
if (symlink(req->data.path1.c_str(), req->data.path2.c_str()) != 0) {
r->data.value = errno;
}
else {
r->data.value = 0;
s.replicatedRequest = true;
}
s.Send(r);
}
handler(LinkRequest)
{
TypedPayload<LinkRequest::Reply> * r = new TypedPayload<LinkRequest::Reply>();
errno = 0;
if (link(req->data.path1.c_str(), req->data.path2.c_str()) != 0) {
r->data.value = errno;
}
else {
r->data.value = 0;
s.replicatedRequest = true;
}
s.Send(r);
}
handler(RenameRequest)
{
TypedPayload<RenameRequest::Reply> * r = new TypedPayload<RenameRequest::Reply>();
errno = 0;
if (rename(req->data.path1.c_str(), req->data.path2.c_str()) != 0) {
r->data.value = errno;
}
else {
r->data.value = 0;
s.replicatedRequest = true;
}
s.Send(r);
}
handler(ReadlinkRequest)
{
TypedPayload<ReadlinkRequest::Reply> * r = new TypedPayload<ReadlinkRequest::Reply>();
errno = 0;
char buf[PATH_MAX];
ssize_t rc = readlink(req->data.path.c_str(), buf, PATH_MAX);
if (rc == -1) {
r->data.error = errno;
}
else {
buf[rc] = '\0';
r->data.path = buf;
r->data.error = 0;
}
s.Send(r);
}
handler(ChmodRequest)
{
TypedPayload<ChmodRequest::Reply> * r = new TypedPayload<ChmodRequest::Reply>();
errno = 0;
if (chmod(req->data.path.c_str(), req->data.mode) != 0) {
r->data.value = errno;
}
else {
r->data.value = 0;
s.replicatedRequest = true;
}
s.Send(r);
}
handler(ChownRequest)
{
TypedPayload<ChownRequest::Reply> * r = new TypedPayload<ChownRequest::Reply>();
errno = 0;
if (chown(req->data.path.c_str(), req->data.user, req->data.group) != 0) {
r->data.value = errno;
}
else {
r->data.value = 0;
s.replicatedRequest = true;
}
s.Send(r);
}
|