mirror of
https://gitlab.com/libvirt/libvirt.git
synced 2024-12-26 03:21:44 +03:00
9cf2573c8a
* configure.in: Use PortableXDR if available.
* qemud/internal.h: Use "socketcompat.h".
* qemud/qemud.c: Use <signal.h>.
* src/sexpr.c: Use <stdlib.h> instead of <malloc.h>.
* src/socketcompat.h: Include <sys/un.h> for Mac OS X.
193 lines
4.2 KiB
C
193 lines
4.2 KiB
C
/*
|
|
* internal.h: daemon data structure definitions
|
|
*
|
|
* Copyright (C) 2006, 2007 Red Hat, Inc.
|
|
* Copyright (C) 2006 Daniel P. Berrange
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 of the License, or (at your option) any later version.
|
|
*
|
|
* This library 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
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
*
|
|
* Author: Daniel P. Berrange <berrange@redhat.com>
|
|
*/
|
|
|
|
|
|
#ifndef QEMUD_INTERNAL_H__
|
|
#define QEMUD_INTERNAL_H__
|
|
|
|
#include <config.h>
|
|
|
|
#include "../src/socketcompat.h"
|
|
|
|
#include <gnutls/gnutls.h>
|
|
#include <gnutls/x509.h>
|
|
#include "../src/gnutls_1_0_compat.h"
|
|
#if HAVE_SASL
|
|
#include <sasl/sasl.h>
|
|
#endif
|
|
|
|
#ifdef HAVE_POLKIT
|
|
#include <dbus/dbus.h>
|
|
#endif
|
|
|
|
#ifdef HAVE_SYS_SYSLIMITS_H
|
|
#include <sys/syslimits.h>
|
|
#endif
|
|
|
|
#include <rpc/types.h>
|
|
#include <rpc/xdr.h>
|
|
#include "remote_protocol.h"
|
|
|
|
#ifdef __GNUC__
|
|
#ifdef HAVE_ANSIDECL_H
|
|
#include <ansidecl.h>
|
|
#endif
|
|
#ifndef ATTRIBUTE_UNUSED
|
|
#define ATTRIBUTE_UNUSED __attribute__((__unused__))
|
|
#endif
|
|
#ifndef ATTRIBUTE_FORMAT
|
|
#define ATTRIBUTE_FORMAT(args...) __attribute__((__format__ (args)))
|
|
#endif
|
|
#else
|
|
#define ATTRIBUTE_UNUSED
|
|
#define ATTRIBUTE_FORMAT(...)
|
|
#endif
|
|
|
|
typedef enum {
|
|
QEMUD_ERR,
|
|
QEMUD_WARN,
|
|
QEMUD_INFO,
|
|
#ifdef ENABLE_DEBUG
|
|
QEMUD_DEBUG
|
|
#endif
|
|
} qemudLogPriority;
|
|
|
|
|
|
enum qemud_mode {
|
|
QEMUD_MODE_RX_HEADER,
|
|
QEMUD_MODE_RX_PAYLOAD,
|
|
QEMUD_MODE_TX_PACKET,
|
|
QEMUD_MODE_TLS_HANDSHAKE,
|
|
};
|
|
|
|
/* Whether we're passing reads & writes through a sasl SSF */
|
|
enum qemud_sasl_ssf {
|
|
QEMUD_SASL_SSF_NONE = 0,
|
|
QEMUD_SASL_SSF_READ = 1,
|
|
QEMUD_SASL_SSF_WRITE = 2,
|
|
};
|
|
|
|
enum qemud_sock_type {
|
|
QEMUD_SOCK_TYPE_UNIX = 0,
|
|
QEMUD_SOCK_TYPE_TCP = 1,
|
|
QEMUD_SOCK_TYPE_TLS = 2,
|
|
};
|
|
|
|
/* Stores the per-client connection state */
|
|
struct qemud_client {
|
|
int magic;
|
|
|
|
int fd;
|
|
int readonly;
|
|
enum qemud_mode mode;
|
|
|
|
struct sockaddr_storage addr;
|
|
socklen_t addrlen;
|
|
|
|
int type; /* qemud_sock_type */
|
|
gnutls_session_t tlssession;
|
|
int auth;
|
|
#if HAVE_SASL
|
|
sasl_conn_t *saslconn;
|
|
int saslSSF;
|
|
const char *saslDecoded;
|
|
unsigned int saslDecodedLength;
|
|
unsigned int saslDecodedOffset;
|
|
const char *saslEncoded;
|
|
unsigned int saslEncodedLength;
|
|
unsigned int saslEncodedOffset;
|
|
char *saslUsername;
|
|
#endif
|
|
|
|
unsigned int incomingSerial;
|
|
unsigned int outgoingSerial;
|
|
|
|
char buffer [REMOTE_MESSAGE_MAX];
|
|
unsigned int bufferLength;
|
|
unsigned int bufferOffset;
|
|
|
|
/* This is only valid if a remote open call has been made on this
|
|
* connection, otherwise it will be NULL. Also if remote close is
|
|
* called, it will be set back to NULL if that succeeds.
|
|
*/
|
|
virConnectPtr conn;
|
|
|
|
struct qemud_client *next;
|
|
};
|
|
|
|
#define QEMUD_CLIENT_MAGIC 0x7788aaee
|
|
|
|
|
|
struct qemud_socket {
|
|
int fd;
|
|
int readonly;
|
|
int type; /* qemud_sock_type */
|
|
int auth;
|
|
int port;
|
|
struct qemud_socket *next;
|
|
};
|
|
|
|
/* Main server state */
|
|
struct qemud_server {
|
|
int nsockets;
|
|
struct qemud_socket *sockets;
|
|
int nclients;
|
|
struct qemud_client *clients;
|
|
int sigread;
|
|
char logDir[PATH_MAX];
|
|
unsigned int shutdown : 1;
|
|
#ifdef HAVE_AVAHI
|
|
struct libvirtd_mdns *mdns;
|
|
#endif
|
|
#if HAVE_SASL
|
|
char **saslUsernameWhitelist;
|
|
#endif
|
|
#if HAVE_POLKIT
|
|
DBusConnection *sysbus;
|
|
#endif
|
|
};
|
|
|
|
void qemudLog(int priority, const char *fmt, ...)
|
|
ATTRIBUTE_FORMAT(printf,2,3);
|
|
|
|
#ifdef ENABLE_DEBUG
|
|
#define qemudDebug(...) qemudLog(QEMUD_DEBUG, __VA_ARGS__)
|
|
#else
|
|
#define qemudDebug(fmt, ...) do {} while(0)
|
|
#endif
|
|
|
|
void remoteDispatchClientRequest (struct qemud_server *server,
|
|
struct qemud_client *client);
|
|
|
|
|
|
#endif
|
|
|
|
/*
|
|
* Local variables:
|
|
* indent-tabs-mode: nil
|
|
* c-indent-level: 4
|
|
* c-basic-offset: 4
|
|
* tab-width: 4
|
|
* End:
|
|
*/
|