-
Notifications
You must be signed in to change notification settings - Fork 6
/
Copy pathextent_client.h
47 lines (37 loc) · 1.07 KB
/
extent_client.h
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
// extent client interface.
#ifndef extent_client_h
#define extent_client_h
#include <string>
#include "extent_protocol.h"
#include "rpc.h"
#include "lock_client_cache.h"
class extent_client {
private:
rpcc *cl;
struct file {
std::string buf;
extent_protocol::attr attr;
bool dirty;
};
pthread_mutex_t lock;
std::map<extent_protocol::extentid_t, file> cache;
public:
extent_client(std::string dst);
extent_protocol::status get(extent_protocol::extentid_t eid,
std::string &buf);
extent_protocol::status getattr(extent_protocol::extentid_t eid,
extent_protocol::attr &a);
extent_protocol::status put(extent_protocol::extentid_t eid, std::string buf);
extent_protocol::status remove(extent_protocol::extentid_t eid);
extent_protocol::status flush(extent_protocol::extentid_t eid);
};
class my_lock_release_user : public lock_release_user {
private:
extent_client* ec;
public:
my_lock_release_user(extent_client* ec) : ec(ec) { }
void dorelease(lock_protocol::lockid_t eid) {
ec->flush(eid);
}
};
#endif