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
|
/*
Copyright (c) 2010-2013 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 _SERVER_HELPERS_H
#define _SERVER_HELPERS_H
#include "server.h"
#include <glusterfs/defaults.h>
#define CALL_STATE(frame) ((server_state_t *)frame->root->state)
#define XPRT_FROM_FRAME(frame) ((rpc_transport_t *)CALL_STATE(frame)->xprt)
#define SERVER_CONF(frame) \
((server_conf_t *)XPRT_FROM_FRAME(frame)->this->private)
#define XPRT_FROM_XLATOR(this) ((((server_conf_t *)this->private))->listen)
#define INODE_LRU_LIMIT(this) \
(((server_conf_t *)(this->private))->config.inode_lru_limit)
#define IS_ROOT_INODE(inode) (inode == inode->table->root)
#define IS_NOT_ROOT(pathlen) ((pathlen > 2) ? 1 : 0)
void
free_state(server_state_t *state);
void
server_loc_wipe(loc_t *loc);
void
server_print_request(call_frame_t *frame);
call_frame_t *
get_frame_from_request(rpcsvc_request_t *req);
int
server_connection_cleanup(xlator_t *this, struct _client *client, int32_t flags,
gf_boolean_t *fd_exist);
int
server_build_config(xlator_t *this, server_conf_t *conf);
int
serialize_rsp_dirent(gf_dirent_t *entries, gfs3_readdir_rsp *rsp);
int
serialize_rsp_direntp(gf_dirent_t *entries, gfs3_readdirp_rsp *rsp);
int
readdirp_rsp_cleanup(gfs3_readdirp_rsp *rsp);
int
readdir_rsp_cleanup(gfs3_readdir_rsp *rsp);
int
readdirp_rsp_cleanup_v2(gfx_readdirp_rsp *rsp);
int
readdir_rsp_cleanup_v2(gfx_readdir_rsp *rsp);
int
auth_set_username_passwd(dict_t *input_params, dict_t *config_params,
struct _client *client);
server_ctx_t *
server_ctx_get(client_t *client, xlator_t *xlator);
int
server_process_event_upcall(xlator_t *this, void *data);
inode_t *
server_inode_new(inode_table_t *itable, uuid_t gfid);
int
serialize_rsp_locklist(lock_migration_info_t *locklist,
gfs3_getactivelk_rsp *rsp);
int
serialize_rsp_locklist_v2(lock_migration_info_t *locklist,
gfx_getactivelk_rsp *rsp);
int
getactivelkinfo_rsp_cleanup(gfs3_getactivelk_rsp *rsp);
int
getactivelkinfo_rsp_cleanup_v2(gfx_getactivelk_rsp *rsp);
int
server_populate_compound_response(xlator_t *this, gfs3_compound_rsp *rsp,
call_frame_t *frame,
compound_args_cbk_t *args_cbk, int index);
int
server_get_compound_resolve(server_state_t *state, gfs3_compound_req *req);
int
server_populate_compound_request(gfs3_compound_req *req, call_frame_t *frame,
default_args_t *this_args, int index);
void
server_compound_rsp_cleanup(gfs3_compound_rsp *rsp, compound_args_cbk_t *args);
void
server_compound_req_cleanup(gfs3_compound_req *req, int len);
int
unserialize_req_locklist(gfs3_setactivelk_req *req, lock_migration_info_t *lmi);
int
unserialize_req_locklist_v2(gfx_setactivelk_req *req,
lock_migration_info_t *lmi);
int
serialize_rsp_dirent(gf_dirent_t *entries, gfs3_readdir_rsp *rsp);
int
serialize_rsp_direntp(gf_dirent_t *entries, gfs3_readdirp_rsp *rsp);
int
serialize_rsp_dirent_v2(gf_dirent_t *entries, gfx_readdir_rsp *rsp);
int
serialize_rsp_direntp_v2(gf_dirent_t *entries, gfx_readdirp_rsp *rsp);
int
server_populate_compound_response_v2(xlator_t *this, gfx_compound_rsp *rsp,
call_frame_t *frame,
compound_args_cbk_t *args_cbk, int index);
int
server_get_compound_resolve_v2(server_state_t *state, gfx_compound_req *req);
int
server_populate_compound_request_v2(gfx_compound_req *req, call_frame_t *frame,
default_args_t *this_args, int index);
void
server_compound_rsp_cleanup_v2(gfx_compound_rsp *rsp,
compound_args_cbk_t *args);
void
server_compound_req_cleanup_v2(gfx_compound_req *req, int len);
#endif /* !_SERVER_HELPERS_H */
|
