blob: d24a02487e135ccb9c0cfe488c2e13c574331961 (
plain)
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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#ifndef _CEPH_CLIENT_DELEGATION_H
#define _CEPH_CLIENT_DELEGATION_H
#include "common/Clock.h"
#include "common/Timer.h"
#include "include/cephfs/ceph_ll_client.h"
/* Commands for manipulating delegation state */
#ifndef CEPH_DELEGATION_NONE
# define CEPH_DELEGATION_NONE 0
# define CEPH_DELEGATION_RD 1
# define CEPH_DELEGATION_WR 2
#endif
/* Converts CEPH_DELEGATION_* to cap mask */
int ceph_deleg_caps_for_type(unsigned type);
/*
* A delegation is a container for holding caps on behalf of a client that
* wants to be able to rely on them until recalled.
*/
class Delegation {
public:
Delegation(Fh *_fh, unsigned _type, ceph_deleg_cb_t _cb, void *_priv);
~Delegation();
Fh *get_fh() { return fh; }
unsigned get_type() { return type; }
bool is_recalled() { return !recall_time.is_zero(); }
void reinit(unsigned _type, ceph_deleg_cb_t _recall_cb, void *_priv);
void recall(bool skip_read);
private:
// Filehandle against which it was acquired
Fh *fh;
// opaque token that will be passed to the callback
void *priv;
// CEPH_DELEGATION_* type
unsigned type;
// callback into application to recall delegation
ceph_deleg_cb_t recall_cb;
// time of first recall
utime_t recall_time;
// timer for unreturned delegations
Context *timeout_event;
void arm_timeout();
void disarm_timeout();
};
#endif /* _CEPH_CLIENT_DELEGATION_H */
|
