OpenE2K/qemu-e2k
13
4
Fork 0
Code Issues 4 Pull Requests Projects 2 Releases Activity

virtiofsd: Add main virtio loop

Browse Source 
Processes incoming requests on the vhost-user fd.

Signed-off-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
Signed-off-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
This commit is contained in:
Dr. David Alan Gilbert 2018-06-12 16:31:24 +01:00
parent f6f3573c6f
commit 204d8ae57b
1 changed files with 39 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
tools/virtiofsd/fuse_virtio.c
View File

@ -11,12 +11,14 @@
* See the file COPYING.LIB * See the file COPYING.LIB
*/ */
#include "fuse_virtio.h"
#include "fuse_i.h" #include "fuse_i.h"
#include "standard-headers/linux/fuse.h" #include "standard-headers/linux/fuse.h"
#include "fuse_misc.h" #include "fuse_misc.h"
#include "fuse_opt.h" #include "fuse_opt.h"
#include "fuse_virtio.h"
#include <assert.h>
#include <errno.h>
#include <stdint.h> #include <stdint.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
@ -80,15 +82,49 @@ static const VuDevIface fv_iface = {
.queue_is_processed_in_order = fv_queue_order, .queue_is_processed_in_order = fv_queue_order,
}; };
/*
* Main loop; this mostly deals with events on the vhost-user
* socket itself, and not actual fuse data.
*/
int virtio_loop(struct fuse_session *se) int virtio_loop(struct fuse_session *se)
{ {
fuse_log(FUSE_LOG_INFO, "%s: Entry\n", __func__); fuse_log(FUSE_LOG_INFO, "%s: Entry\n", __func__);
while (1) { while (!fuse_session_exited(se)) {
/* TODO: Add stuffing */ struct pollfd pf[1];
pf[0].fd = se->vu_socketfd;
pf[0].events = POLLIN;
pf[0].revents = 0;
fuse_log(FUSE_LOG_DEBUG, "%s: Waiting for VU event\n", __func__);
int poll_res = ppoll(pf, 1, NULL, NULL);
if (poll_res == -1) {
if (errno == EINTR) {
fuse_log(FUSE_LOG_INFO, "%s: ppoll interrupted, going around\n",
__func__);
continue;
}
fuse_log(FUSE_LOG_ERR, "virtio_loop ppoll: %m\n");
break;
}
assert(poll_res == 1);
if (pf[0].revents & (POLLERR | POLLHUP | POLLNVAL)) {
fuse_log(FUSE_LOG_ERR, "%s: Unexpected poll revents %x\n", __func__,
pf[0].revents);
break;
}
assert(pf[0].revents & POLLIN);
fuse_log(FUSE_LOG_DEBUG, "%s: Got VU event\n", __func__);
if (!vu_dispatch(&se->virtio_dev->dev)) {
fuse_log(FUSE_LOG_ERR, "%s: vu_dispatch failed\n", __func__);
break;
}
} }
fuse_log(FUSE_LOG_INFO, "%s: Exit\n", __func__); fuse_log(FUSE_LOG_INFO, "%s: Exit\n", __func__);
return 0;
} }
int virtio_session_mount(struct fuse_session *se) int virtio_session_mount(struct fuse_session *se)