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
|
/*
Copyright (c) 2008-2012 Red Hat, Inc. <http://www.redhat.com>
This file is part of GlusterFS.
This file is licensed to you under your choice of the GNU Lesser
General Public License, version 3 or any later version (LGPLv3 or
later), or the GNU General Public License, version 2 (GPLv2), in all
cases as published by the Free Software Foundation.
*/
#ifndef _LIBXLATOR_H
#define _LIBXLATOR_H
#include "xlator.h"
#include "logging.h"
#include "defaults.h"
#include "common-utils.h"
#include "compat.h"
#include "compat-errno.h"
#define MARKER_XATTR_PREFIX "trusted.glusterfs"
#define XTIME "xtime"
#define VOLUME_MARK "volume-mark"
#define GF_XATTR_MARKER_KEY MARKER_XATTR_PREFIX "." VOLUME_MARK
#define UUID_SIZE 36
#define MARKER_UUID_TYPE 1
#define MARKER_XTIME_TYPE 2
typedef int32_t (*xlator_specf_unwind_t)(call_frame_t *frame, int op_ret,
int op_errno, dict_t *dict,
dict_t *xdata);
struct volume_mark {
uint8_t major;
uint8_t minor;
uint8_t uuid[16];
uint8_t retval;
uint32_t sec;
uint32_t usec;
} __attribute__((__packed__));
/*
* The enumerated type here
* is used to index two kind
* of integer arrays:
* - gauges
* - counters
* A counter is used internally,
* in getxattr callbacks, to count
* the results, categorized as
* the enum names suggest. So values
* in the counter are always non-negative.
* Gauges are part of the API.
* The caller passes one to the
* top-level aggregator function,
* cluster_getmarkerattr(). The gauge
* defines an evaluation policy for the
* counter. That is, at the
* end of the aggregation process
* the gauge is matched against the
* counter, and the policy
* represented by the gauge decides
* whether to return with success or failure,
* and in latter case, what particular failure
* case (errno).
* The rules are the following: for some index i,
* - if gauge[i] == 0, no requirement is set
* against counter[i];
* - if gauge[i] > 0, counter[i] >= gauge[i]
* is required;
* - if gauge[i] < 0, counter[i] < |gauge[i]|
* is required.
* If the requirement is not met, then i is mapped
* to the respective errno (MCNT_ENOENT -> ENOENT),
* or in lack of that, EINVAL.
* Cf. evaluate_marker_results() and marker_idx_errno_map[]
* in libxlator.c
* We provide two default gauges, one intended for xtime
* aggregation, other for volume mark aggregation. The
* policies they represent agree with the hard-coded
* one prior to gauges. Cf. marker_xtime_default_gauge
* and marker_uuid_default_gauge in libxlator.c
*/
typedef enum {
MCNT_FOUND,
MCNT_NOTFOUND,
MCNT_ENODATA,
MCNT_ENOTCONN,
MCNT_ENOENT,
MCNT_EOTHER,
MCNT_MAX
} marker_result_idx_t;
extern int marker_xtime_default_gauge[];
extern int marker_uuid_default_gauge[];
struct marker_str {
struct volume_mark *volmark;
data_t *data;
uint32_t host_timebuf[2];
uint32_t net_timebuf[2];
int32_t call_count;
int gauge[MCNT_MAX];
int count[MCNT_MAX];
xlator_specf_unwind_t xl_specf_unwind;
void *xl_local;
char *vol_uuid;
uint8_t retval;
};
typedef struct marker_str xl_marker_local_t;
int32_t
cluster_markerxtime_cbk(call_frame_t *frame, void *cookie, xlator_t *this,
int op_ret, int op_errno, dict_t *dict, dict_t *xdata);
int32_t
cluster_markeruuid_cbk(call_frame_t *frame, void *cookie, xlator_t *this,
int op_ret, int op_errno, dict_t *dict, dict_t *xdata);
int
cluster_handle_marker_getxattr(call_frame_t *frame, loc_t *loc,
const char *name, char *vol_uuid,
xlator_specf_unwind_t unwind,
int (*populate_args)(call_frame_t *frame,
int type, int *gauge,
xlator_t **subvols));
int
match_uuid_local(const char *name, char *uuid);
int
gf_get_min_stime(xlator_t *this, dict_t *dst, char *key, data_t *value);
int
gf_get_max_stime(xlator_t *this, dict_t *dst, char *key, data_t *value);
#endif /* !_LIBXLATOR_H */
|
