blob: af852697bda5f4db53845ef4978759d318711f48 [file] [log] [blame]
Miklos Szeredia1482422005-08-14 23:00:27 +00001/*
2 FUSE: Filesystem in Userspace
Miklos Szeredi95da8602006-01-06 18:29:40 +00003 Copyright (C) 2001-2006 Miklos Szeredi <miklos@szeredi.hu>
Miklos Szeredia1482422005-08-14 23:00:27 +00004
5 This program can be distributed under the terms of the GNU LGPL.
6 See the file COPYING.LIB
7*/
8
9#include "fuse_lowlevel.h"
10
11#include <stdio.h>
12#include <stdlib.h>
Miklos Szeredi5d9ce362006-03-01 12:10:13 +000013#include <errno.h>
Miklos Szeredia1482422005-08-14 23:00:27 +000014
15int fuse_session_loop(struct fuse_session *se)
16{
17 int res = 0;
18 struct fuse_chan *ch = fuse_session_next_chan(se, NULL);
19 size_t bufsize = fuse_chan_bufsize(ch);
20 char *buf = (char *) malloc(bufsize);
21 if (!buf) {
22 fprintf(stderr, "fuse: failed to allocate read buffer\n");
23 return -1;
24 }
25
26 while (!fuse_session_exited(se)) {
Miklos Szeredi8d975f62006-03-17 15:56:05 +000027 struct fuse_chan *tmpch = ch;
28 res = fuse_chan_recv(&tmpch, buf, bufsize);
Miklos Szeredi5d9ce362006-03-01 12:10:13 +000029 if (res == -EINTR)
Miklos Szeredia1482422005-08-14 23:00:27 +000030 continue;
Miklos Szeredi5d9ce362006-03-01 12:10:13 +000031 if (res <= 0)
Miklos Szeredia1482422005-08-14 23:00:27 +000032 break;
Miklos Szeredi8d975f62006-03-17 15:56:05 +000033 fuse_session_process(se, buf, res, tmpch);
Miklos Szeredia1482422005-08-14 23:00:27 +000034 }
35
36 free(buf);
37 fuse_session_reset(se);
Miklos Szeredi5d9ce362006-03-01 12:10:13 +000038 return res < 0 ? -1 : 0;
Miklos Szeredia1482422005-08-14 23:00:27 +000039}