mirror of
https://github.com/xen-project/xen.git
synced 2026-10-28 02:01:24 +01:00
Juergen Gross
297a2587e6
Mount the 9pfs device in stubdom enabling it to use files. This has to happen in a worker thread in order to allow the main thread handling the required Xenstore accesses in parallel. Signed-off-by: Juergen Gross <jgross@suse.com> Reviewed-by: Jason Andryuk <jandryuk@gmail.com> Reviewed-by: Julien Grall <jgrall@amazon.com>
131 lines
2.7 KiB
C
131 lines
2.7 KiB
C
/*
|
|
Simple prototype Xen Store Daemon providing simple tree-like database.
|
|
Copyright (C) 2005 Rusty Russell IBM Corporation
|
|
|
|
This program 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 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program 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/>.
|
|
*/
|
|
#include <sys/types.h>
|
|
#include <sys/mman.h>
|
|
#include <syslog.h>
|
|
#include "talloc.h"
|
|
#include "core.h"
|
|
#include "utils.h"
|
|
#include <xen/grant_table.h>
|
|
#include <mini-os/lib.h>
|
|
#include <mini-os/9pfront.h>
|
|
#include <mini-os/sched.h>
|
|
#include <mini-os/xenbus.h>
|
|
#include <mini-os/xmalloc.h>
|
|
|
|
#define P9_STATE_PATH "device/9pfs/0/state"
|
|
|
|
static void *p9_device;
|
|
|
|
void finish_daemonize(void)
|
|
{
|
|
}
|
|
|
|
struct connection *add_socket_connection(int fd)
|
|
{
|
|
barf("socket based connection without sockets");
|
|
}
|
|
|
|
evtchn_port_t get_xenbus_evtchn(void)
|
|
{
|
|
return dom0_event;
|
|
}
|
|
|
|
void *xenbus_map(void)
|
|
{
|
|
return xengnttab_map_grant_ref(*xgt_handle, xenbus_master_domid(),
|
|
GNTTAB_RESERVED_XENSTORE, PROT_READ|PROT_WRITE);
|
|
}
|
|
|
|
void unmap_xenbus(void *interface)
|
|
{
|
|
xengnttab_unmap(*xgt_handle, interface, 1);
|
|
}
|
|
|
|
void early_init(bool live_update, bool dofork, const char *pidfile)
|
|
{
|
|
stub_domid = get_domid();
|
|
if (stub_domid == DOMID_INVALID)
|
|
barf("could not get own domid");
|
|
}
|
|
|
|
void late_init(bool live_update)
|
|
{
|
|
}
|
|
|
|
void set_special_fds(void)
|
|
{
|
|
}
|
|
|
|
void handle_special_fds(void)
|
|
{
|
|
}
|
|
|
|
int get_socket_fd(void)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
void set_socket_fd(int fd)
|
|
{
|
|
}
|
|
|
|
static void mount_thread(void *p)
|
|
{
|
|
xenbus_event_queue events = NULL;
|
|
char *err;
|
|
char *dummy;
|
|
|
|
err = xenbus_watch_path_token(XBT_NIL, P9_STATE_PATH, "9pfs", &events);
|
|
if (err) {
|
|
log("error \"%s\" when setting watch on \"%s\"\n", err,
|
|
P9_STATE_PATH);
|
|
free(err);
|
|
return;
|
|
}
|
|
|
|
for (;;) {
|
|
xenbus_wait_for_watch(&events);
|
|
|
|
/*
|
|
* We only care for existence of the state node.
|
|
* State changes are handled in init_9pfront().
|
|
*/
|
|
err = xenbus_read(XBT_NIL, P9_STATE_PATH, &dummy);
|
|
if (!err)
|
|
break;
|
|
free(err);
|
|
}
|
|
|
|
free(dummy);
|
|
|
|
err = xenbus_unwatch_path_token(XBT_NIL, P9_STATE_PATH, "9pfs");
|
|
if (err) {
|
|
log("error \"%s\" when unwatching \"%s\", leaking watch\n",
|
|
err, P9_STATE_PATH);
|
|
free(err);
|
|
}
|
|
|
|
p9_device = init_9pfront(0, XENSTORE_LIB_DIR);
|
|
}
|
|
|
|
void mount_9pfs(void)
|
|
{
|
|
create_thread("mount-9pfs", mount_thread, NULL);
|
|
}
|