10 #define FUSE_USE_VERSION 30
12 #include <fuse_config.h>
13 #include <fuse_lowlevel.h>
27 #include <linux/limits.h>
31 #define FILE_NAME "write_me"
44 #define OPTION(t, p) \
45 { t, offsetof(struct options, p), 1 }
46 static const struct fuse_opt option_spec[] = {
47 OPTION(
"writeback_cache", writeback),
48 OPTION(
"--data-size=%d", data_size),
49 OPTION(
"--delay_ms=%d", delay_ms),
54 pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
55 pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
56 static int write_start, write_done;
62 if(options.writeback) {
68 static int tfs_stat(
fuse_ino_t ino,
struct stat *stbuf) {
71 stbuf->st_mode = S_IFDIR | 0755;
75 else if (ino == FILE_INO) {
76 stbuf->st_mode = S_IFREG | 0222;
90 memset(&e, 0,
sizeof(e));
94 else if (strcmp(name, FILE_NAME) == 0)
99 if (tfs_stat(e.ino, &e.attr) != 0)
114 memset(&stbuf, 0,
sizeof(stbuf));
115 if (tfs_stat(ino, &stbuf) != 0)
126 assert(ino == FILE_INO);
128 fi->
noflush = !options.writeback && options.delay_ms &&
129 (fi->
flags & O_ACCMODE) == O_RDONLY;
136 (void) fi; (void) buf; (void) off;
139 assert(ino == FILE_INO);
140 expected = options.data_size;
141 if(options.writeback)
145 fprintf(stderr,
"ERROR: Expected %zd bytes, got %zd\n!",
151 if (options.delay_ms) {
152 pthread_mutex_lock(&lock);
154 pthread_cond_signal(&cond);
155 pthread_mutex_unlock(&lock);
157 usleep(options.delay_ms * 1000);
159 pthread_mutex_lock(&lock);
161 pthread_cond_signal(&cond);
162 pthread_mutex_unlock(&lock);
170 .lookup = tfs_lookup,
171 .getattr = tfs_getattr,
176 static void* close_rofd(
void *data) {
177 int rofd = (int)(
long) data;
180 pthread_mutex_lock(&lock);
181 while (!write_start && !write_done)
182 pthread_cond_wait(&cond, &lock);
183 pthread_mutex_unlock(&lock);
186 printf(
"rofd closed. write_start: %d write_done: %d\n", write_start, write_done);
190 fprintf(stderr,
"ERROR: close(rofd) blocked on write!\n");
195 static void* run_fs(
void *data) {
196 struct fuse_session *se = (
struct fuse_session*) data;
201 static void test_fs(
char *mountpoint) {
202 char fname[PATH_MAX];
204 size_t dsize = options.data_size;
206 pthread_t rofd_thread;
210 assert((fd = open(
"/dev/urandom", O_RDONLY)) != -1);
211 assert(read(fd, buf, dsize) == dsize);
214 assert(snprintf(fname, PATH_MAX,
"%s/" FILE_NAME,
216 fd = open(fname, O_WRONLY);
222 if (options.delay_ms) {
224 rofd = open(fname, O_RDONLY);
225 assert(pthread_create(&rofd_thread, NULL, close_rofd, (
void *)(
long)rofd) == 0);
227 usleep(options.delay_ms * 1000);
230 assert(write(fd, buf, dsize) == dsize);
231 assert(write(fd, buf, dsize) == dsize);
235 if (options.delay_ms) {
236 printf(
"rwfd closed. write_start: %d write_done: %d\n", write_start, write_done);
237 assert(pthread_join(rofd_thread, NULL) == 0);
241 int main(
int argc,
char *argv[]) {
243 struct fuse_session *se;
248 assert(fuse_parse_cmdline(&args, &fuse_opts) == 0);
253 sizeof(tfs_oper), NULL);
260 assert(pthread_create(&fs_thread, NULL, run_fs, (
void *)se) == 0);
263 test_fs(fuse_opts.mountpoint);
264 free(fuse_opts.mountpoint);
269 assert(pthread_join(fs_thread, NULL) == 0);
271 assert(got_write == 1);
275 printf(
"Test completed successfully.\n");
int fuse_set_signal_handlers(struct fuse_session *se)
#define FUSE_CAP_WRITEBACK_CACHE
void fuse_remove_signal_handlers(struct fuse_session *se)
void fuse_session_destroy(struct fuse_session *se)
int fuse_reply_open(fuse_req_t req, const struct fuse_file_info *fi)
void fuse_session_exit(struct fuse_session *se)
int fuse_reply_err(fuse_req_t req, int err)
struct fuse_req * fuse_req_t
int fuse_session_loop(struct fuse_session *se)
int fuse_reply_entry(fuse_req_t req, const struct fuse_entry_param *e)
void fuse_session_unmount(struct fuse_session *se)
struct fuse_session * fuse_session_new(struct fuse_args *args, const struct fuse_lowlevel_ops *op, size_t op_size, void *userdata)
int fuse_reply_write(fuse_req_t req, size_t count)
int fuse_session_mount(struct fuse_session *se, const char *mountpoint)
int fuse_reply_attr(fuse_req_t req, const struct stat *attr, double attr_timeout)
int fuse_opt_add_arg(struct fuse_args *args, const char *arg)
void fuse_opt_free_args(struct fuse_args *args)
int fuse_opt_parse(struct fuse_args *args, void *data, const struct fuse_opt opts[], fuse_opt_proc_t proc)
#define FUSE_ARGS_INIT(argc, argv)
void(* init)(void *userdata, struct fuse_conn_info *conn)