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
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
|
/*
Copyright (c) 2006, 2007, 2008 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 __READ_AHEAD_H
#define __READ_AHEAD_H
#ifndef _CONFIG_H
#define _CONFIG_H
#include "config.h"
#endif
#include "glusterfs.h"
#include "logging.h"
#include "dict.h"
#include "xlator.h"
#include "common-utils.h"
struct ra_conf;
struct ra_local;
struct ra_page;
struct ra_file;
struct ra_waitq;
struct ra_waitq {
struct ra_waitq *next;
void *data;
};
struct ra_fill {
struct ra_fill *next;
struct ra_fill *prev;
off_t offset;
size_t size;
struct iovec *vector;
int32_t count;
dict_t *refs;
};
struct ra_local {
mode_t mode;
struct ra_fill fill;
off_t offset;
size_t size;
int32_t op_ret;
int32_t op_errno;
off_t pending_offset;
size_t pending_size;
fd_t *fd;
int32_t wait_count;
pthread_mutex_t local_lock;
};
struct ra_page {
struct ra_page *next;
struct ra_page *prev;
struct ra_file *file;
char dirty;
char ready;
struct iovec *vector;
int32_t count;
off_t offset;
size_t size;
struct ra_waitq *waitq;
dict_t *ref;
};
struct ra_file {
struct ra_file *next;
struct ra_file *prev;
struct ra_conf *conf;
fd_t *fd;
int disabled;
size_t expected;
struct ra_page pages;
off_t offset;
size_t size;
int32_t refcount;
pthread_mutex_t file_lock;
struct stat stbuf;
uint64_t page_size;
uint32_t page_count;
};
struct ra_conf {
uint64_t page_size;
uint32_t page_count;
void *cache_block;
struct ra_file files;
gf_boolean_t force_atime_update;
pthread_mutex_t conf_lock;
};
typedef struct ra_conf ra_conf_t;
typedef struct ra_local ra_local_t;
typedef struct ra_page ra_page_t;
typedef struct ra_file ra_file_t;
typedef struct ra_waitq ra_waitq_t;
typedef struct ra_fill ra_fill_t;
ra_page_t *
ra_page_get (ra_file_t *file,
off_t offset);
ra_page_t *
ra_page_create (ra_file_t *file,
off_t offset);
void
ra_page_fault (ra_file_t *file,
call_frame_t *frame,
off_t offset);
void
ra_wait_on_page (ra_page_t *page,
call_frame_t *frame);
ra_waitq_t *
ra_page_wakeup (ra_page_t *page);
void
ra_page_flush (ra_page_t *page);
ra_waitq_t *
ra_page_error (ra_page_t *page,
int32_t op_ret,
int32_t op_errno);
void
ra_page_purge (ra_page_t *page);
void
ra_frame_return (call_frame_t *frame);
void
ra_frame_fill (ra_page_t *page,
call_frame_t *frame);
void
ra_file_destroy (ra_file_t *file);
static inline void
ra_file_lock (ra_file_t *file)
{
pthread_mutex_lock (&file->file_lock);
}
static inline void
ra_file_unlock (ra_file_t *file)
{
pthread_mutex_unlock (&file->file_lock);
}
static inline void
ra_conf_lock (ra_conf_t *conf)
{
pthread_mutex_lock (&conf->conf_lock);
}
static inline void
ra_conf_unlock (ra_conf_t *conf)
{
pthread_mutex_unlock (&conf->conf_lock);
}
static inline void
ra_local_lock (ra_local_t *local)
{
pthread_mutex_lock (&local->local_lock);
}
static inline void
ra_local_unlock (ra_local_t *local)
{
pthread_mutex_unlock (&local->local_lock);
}
#endif /* __READ_AHEAD_H */
|
