blob: 68486ff1459ade8192b321a3c1a67be08975309b (
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
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) 2008-2009 Z RESEARCH, Inc. <http://www.zresearch.com>
This file is part of GlusterFS.
GlusterFS is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
by the Free Software Foundation; either version 3 of the License,
or (at your option) any later version.
GlusterFS is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef _GUTS_PARSE_H_
#define _GUTS_PARSE_H_
#include "glusterfs.h"
#include "glusterfs-guts.h"
#include "fuse_kernel.h"
#include <fuse/fuse_lowlevel.h>
#include "list.h"
#ifndef _FUSE_OPAQUE_
#define _FUSE_OPAQUE_
struct fuse_private {
int fd;
struct fuse *fuse;
struct fuse_session *se;
struct fuse_chan *ch;
char *mountpoint;
};
struct fuse_req {
struct fuse_ll *f;
uint64_t unique;
int ctr;
pthread_mutex_t lock;
struct fuse_ctx ctx;
struct fuse_chan *ch;
int interrupted;
union {
struct {
uint64_t unique;
} i;
struct {
fuse_interrupt_func_t func;
void *data;
} ni;
} u;
struct fuse_req *next;
struct fuse_req *prev;
};
struct fuse_ll {
int debug;
int allow_root;
struct fuse_lowlevel_ops op;
int got_init;
void *userdata;
uid_t owner;
struct fuse_conn_info conn;
struct fuse_req list;
struct fuse_req interrupts;
pthread_mutex_t lock;
int got_destroy;
};
#endif
#define REQ_BEGIN "GUTS_REQ_BEGIN:"
#define REQ_HEADER_FULL_LEN (strlen(REQ_BEGIN) + sizeof (struct fuse_in_header) + sizeof (int32_t))
#define REP_BEGIN "GUTS_REP_BEGIN:"
#define REP_HEADER_FULL_LEN (strlen(REP_BEGIN) + sizeof (struct fuse_req) + sizeof (int32_t))
#define REQ_HEADER_LEN (sizeof (struct fuse_in_header) + sizeof (int32_t))
#define REP_HEADER_LEN (sizeof (struct fuse_req) + sizeof (int32_t))
#define is_request(begin) (0==strcmp(begin, REQ_BEGIN)?1:0)
typedef void (*func_t)(struct fuse_in_header *, const void *);
typedef struct {
func_t func;
const char *name;
} guts_log_t;
typedef struct {
struct fuse_in_header header;
int32_t arg_len;
struct list_head list;
void *arg;
} guts_req_t;
typedef struct {
struct fuse_req req;
int32_t arg_len;
void *arg;
} guts_reply_t;
struct guts_replay_ctx {
int32_t tio_fd;
struct fuse_ll *guts_ll;
dict_t *replies;
dict_t *inodes;
dict_t *fds;
struct list_head requests;
dict_t *requests_dict;
};
typedef struct guts_replay_ctx guts_replay_ctx_t;
extern guts_log_t guts_log[];
int32_t
guts_tio_init (const char *);
void
guts_req_dump (struct fuse_in_header *,
const void *,
int32_t);
guts_req_t *
guts_read_entry (guts_replay_ctx_t *ctx);
void
guts_reply_dump (fuse_req_t,
const void *,
int32_t);
guts_reply_t *
guts_read_reply (guts_replay_ctx_t *ctx,
uint64_t unique);
#endif /* _GUTS_PARSE_H_ */
|
