* [Qemu-devel] [PATCH] spice: connection events.
@ 2010-11-02 13:29 Gerd Hoffmann
2010-11-16 14:06 ` Anthony Liguori
0 siblings, 1 reply; 2+ messages in thread
From: Gerd Hoffmann @ 2010-11-02 13:29 UTC (permalink / raw)
To: qemu-devel; +Cc: Gerd Hoffmann
This patch adds support for connection events to spice. The events are
quite simliar to the vnc events. Unlike vnc spice uses multiple tcp
channels though. qemu will report every single tcp connection (aka
spice channel). If you want track spice sessions only you can filter
for the main channel (channel-type == 1).
Signed-off-by: Gerd Hoffmann <kraxel@redhat.com>
---
monitor.c | 9 +++++++
monitor.h | 3 ++
ui/spice-core.c | 63 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
3 files changed, 75 insertions(+), 0 deletions(-)
diff --git a/monitor.c b/monitor.c
index 61607c5..23f3b73 100644
--- a/monitor.c
+++ b/monitor.c
@@ -458,6 +458,15 @@ void monitor_protocol_event(MonitorEvent event, QObject *data)
case QEVENT_WATCHDOG:
event_name = "WATCHDOG";
break;
+ case QEVENT_SPICE_CONNECTED:
+ event_name = "SPICE_CONNECTED";
+ break;
+ case QEVENT_SPICE_INITIALIZED:
+ event_name = "SPICE_INITIALIZED";
+ break;
+ case QEVENT_SPICE_DISCONNECTED:
+ event_name = "SPICE_DISCONNECTED";
+ break;
default:
abort();
break;
diff --git a/monitor.h b/monitor.h
index 2d36bba..4f2d328 100644
--- a/monitor.h
+++ b/monitor.h
@@ -32,6 +32,9 @@ typedef enum MonitorEvent {
QEVENT_BLOCK_IO_ERROR,
QEVENT_RTC_CHANGE,
QEVENT_WATCHDOG,
+ QEVENT_SPICE_CONNECTED,
+ QEVENT_SPICE_INITIALIZED,
+ QEVENT_SPICE_DISCONNECTED,
QEVENT_MAX,
} MonitorEvent;
diff --git a/ui/spice-core.c b/ui/spice-core.c
index b7fa031..a9f6d8f 100644
--- a/ui/spice-core.c
+++ b/ui/spice-core.c
@@ -18,16 +18,24 @@
#include <spice.h>
#include <spice-experimental.h>
+#include <netdb.h>
+
#include "qemu-common.h"
#include "qemu-spice.h"
#include "qemu-timer.h"
#include "qemu-queue.h"
#include "qemu-x509.h"
+#include "qemu_socket.h"
+#include "qint.h"
+#include "qbool.h"
+#include "qstring.h"
+#include "qjson.h"
#include "monitor.h"
/* core bits */
static SpiceServer *spice_server;
+static const char *auth = "spice";
int using_spice = 0;
struct SpiceTimer {
@@ -121,6 +129,56 @@ static void watch_remove(SpiceWatch *watch)
qemu_free(watch);
}
+#if SPICE_INTERFACE_CORE_MINOR >= 3
+static void channel_event(int event, SpiceChannelEventInfo *info)
+{
+ static const int qevent[] = {
+ [ SPICE_CHANNEL_EVENT_CONNECTED ] = QEVENT_SPICE_CONNECTED,
+ [ SPICE_CHANNEL_EVENT_INITIALIZED ] = QEVENT_SPICE_INITIALIZED,
+ [ SPICE_CHANNEL_EVENT_DISCONNECTED ] = QEVENT_SPICE_DISCONNECTED,
+ };
+ char lhost[NI_MAXHOST], lport[NI_MAXSERV];
+ char phost[NI_MAXHOST], pport[NI_MAXSERV];
+ QDict *server, *client;
+ QObject *data;
+
+ getnameinfo(&info->laddr, info->llen,
+ lhost, sizeof(lhost), lport, sizeof(lport),
+ NI_NUMERICHOST | NI_NUMERICSERV);
+ getnameinfo(&info->paddr, info->plen,
+ phost, sizeof(phost), pport, sizeof(pport),
+ NI_NUMERICHOST | NI_NUMERICSERV);
+#if 0
+ fprintf(stderr, "%s: ev %d, flg %d, id %x, %d:%d, %s:%s <-> %s:%s\n",
+ __FUNCTION__, event, info->flags, info->connection_id,
+ info->type, info->id, lhost, lport, phost, pport);
+#endif
+
+ server = qdict_new();
+ qdict_put(server, "host", qstring_from_str(lhost));
+ qdict_put(server, "port", qstring_from_str(lport));
+ qdict_put(server, "family", qstring_from_str(inet_strfamily(info->laddr.sa_family)));
+ if (event != SPICE_CHANNEL_EVENT_CONNECTED) {
+ int tls = info->flags & SPICE_CHANNEL_EVENT_FLAG_TLS;
+ qdict_put(server, "auth", qstring_from_str(auth));
+ qdict_put(server, "connection-id", qint_from_int(info->connection_id));
+ qdict_put(server, "channel-type", qint_from_int(info->type));
+ qdict_put(server, "channel-id", qint_from_int(info->id));
+ qdict_put(server, "tls", qbool_from_int(tls));
+ }
+
+ client = qdict_new();
+ qdict_put(client, "host", qstring_from_str(phost));
+ qdict_put(client, "port", qstring_from_str(pport));
+ qdict_put(client, "family", qstring_from_str(inet_strfamily(info->paddr.sa_family)));
+
+ data = qobject_from_jsonf("{ 'client': %p, 'server': %p }",
+ QOBJECT(client), QOBJECT(server));
+ monitor_protocol_event(qevent[event], data);
+ qobject_decref(data);
+}
+#endif
+
static SpiceCoreInterface core_interface = {
.base.type = SPICE_INTERFACE_CORE,
.base.description = "qemu core services",
@@ -135,6 +193,10 @@ static SpiceCoreInterface core_interface = {
.watch_add = watch_add,
.watch_update_mask = watch_update_mask,
.watch_remove = watch_remove,
+
+#if SPICE_INTERFACE_CORE_MINOR >= 3
+ .channel_event = channel_event,
+#endif
};
/* config string parsing */
@@ -316,6 +378,7 @@ void qemu_spice_init(void)
spice_server_set_ticket(spice_server, password, 0, 0, 0);
}
if (qemu_opt_get_bool(opts, "disable-ticketing", 0)) {
+ auth = "none";
spice_server_set_noauth(spice_server);
}
--
1.7.1
^ permalink raw reply related [flat|nested] 2+ messages in thread
* Re: [Qemu-devel] [PATCH] spice: connection events.
2010-11-02 13:29 [Qemu-devel] [PATCH] spice: connection events Gerd Hoffmann
@ 2010-11-16 14:06 ` Anthony Liguori
0 siblings, 0 replies; 2+ messages in thread
From: Anthony Liguori @ 2010-11-16 14:06 UTC (permalink / raw)
To: Gerd Hoffmann; +Cc: qemu-devel
On 11/02/2010 08:29 AM, Gerd Hoffmann wrote:
> This patch adds support for connection events to spice. The events are
> quite simliar to the vnc events. Unlike vnc spice uses multiple tcp
> channels though. qemu will report every single tcp connection (aka
> spice channel). If you want track spice sessions only you can filter
> for the main channel (channel-type == 1).
>
> Signed-off-by: Gerd Hoffmann<kraxel@redhat.com>
> ---
> monitor.c | 9 +++++++
> monitor.h | 3 ++
> ui/spice-core.c | 63 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
> 3 files changed, 75 insertions(+), 0 deletions(-)
>
> diff --git a/monitor.c b/monitor.c
> index 61607c5..23f3b73 100644
> --- a/monitor.c
> +++ b/monitor.c
> @@ -458,6 +458,15 @@ void monitor_protocol_event(MonitorEvent event, QObject *data)
> case QEVENT_WATCHDOG:
> event_name = "WATCHDOG";
> break;
> + case QEVENT_SPICE_CONNECTED:
> + event_name = "SPICE_CONNECTED";
> + break;
> + case QEVENT_SPICE_INITIALIZED:
> + event_name = "SPICE_INITIALIZED";
> + break;
> + case QEVENT_SPICE_DISCONNECTED:
> + event_name = "SPICE_DISCONNECTED";
> + break;
> default:
> abort();
> break;
> diff --git a/monitor.h b/monitor.h
> index 2d36bba..4f2d328 100644
> --- a/monitor.h
> +++ b/monitor.h
> @@ -32,6 +32,9 @@ typedef enum MonitorEvent {
> QEVENT_BLOCK_IO_ERROR,
> QEVENT_RTC_CHANGE,
> QEVENT_WATCHDOG,
> + QEVENT_SPICE_CONNECTED,
> + QEVENT_SPICE_INITIALIZED,
> + QEVENT_SPICE_DISCONNECTED,
> QEVENT_MAX,
> } MonitorEvent;
>
> diff --git a/ui/spice-core.c b/ui/spice-core.c
> index b7fa031..a9f6d8f 100644
> --- a/ui/spice-core.c
> +++ b/ui/spice-core.c
> @@ -18,16 +18,24 @@
> #include<spice.h>
> #include<spice-experimental.h>
>
> +#include<netdb.h>
> +
> #include "qemu-common.h"
> #include "qemu-spice.h"
> #include "qemu-timer.h"
> #include "qemu-queue.h"
> #include "qemu-x509.h"
> +#include "qemu_socket.h"
> +#include "qint.h"
> +#include "qbool.h"
> +#include "qstring.h"
> +#include "qjson.h"
> #include "monitor.h"
>
> /* core bits */
>
> static SpiceServer *spice_server;
> +static const char *auth = "spice";
> int using_spice = 0;
>
> struct SpiceTimer {
> @@ -121,6 +129,56 @@ static void watch_remove(SpiceWatch *watch)
> qemu_free(watch);
> }
>
> +#if SPICE_INTERFACE_CORE_MINOR>= 3
> +static void channel_event(int event, SpiceChannelEventInfo *info)
> +{
> + static const int qevent[] = {
> + [ SPICE_CHANNEL_EVENT_CONNECTED ] = QEVENT_SPICE_CONNECTED,
> + [ SPICE_CHANNEL_EVENT_INITIALIZED ] = QEVENT_SPICE_INITIALIZED,
> + [ SPICE_CHANNEL_EVENT_DISCONNECTED ] = QEVENT_SPICE_DISCONNECTED,
> + };
> + char lhost[NI_MAXHOST], lport[NI_MAXSERV];
> + char phost[NI_MAXHOST], pport[NI_MAXSERV];
> + QDict *server, *client;
> + QObject *data;
> +
> + getnameinfo(&info->laddr, info->llen,
> + lhost, sizeof(lhost), lport, sizeof(lport),
> + NI_NUMERICHOST | NI_NUMERICSERV);
> + getnameinfo(&info->paddr, info->plen,
> + phost, sizeof(phost), pport, sizeof(pport),
> + NI_NUMERICHOST | NI_NUMERICSERV);
> +#if 0
> + fprintf(stderr, "%s: ev %d, flg %d, id %x, %d:%d, %s:%s<-> %s:%s\n",
> + __FUNCTION__, event, info->flags, info->connection_id,
> + info->type, info->id, lhost, lport, phost, pport);
> +#endif
>
A DPRINTF would be nicer but otherwise, Reviewed-by: Anthony Liguori
<aliguori@us.ibm.com>
Regards,
Anthony Liguori
> +
> + server = qdict_new();
> + qdict_put(server, "host", qstring_from_str(lhost));
> + qdict_put(server, "port", qstring_from_str(lport));
> + qdict_put(server, "family", qstring_from_str(inet_strfamily(info->laddr.sa_family)));
> + if (event != SPICE_CHANNEL_EVENT_CONNECTED) {
> + int tls = info->flags& SPICE_CHANNEL_EVENT_FLAG_TLS;
> + qdict_put(server, "auth", qstring_from_str(auth));
> + qdict_put(server, "connection-id", qint_from_int(info->connection_id));
> + qdict_put(server, "channel-type", qint_from_int(info->type));
> + qdict_put(server, "channel-id", qint_from_int(info->id));
> + qdict_put(server, "tls", qbool_from_int(tls));
> + }
> +
> + client = qdict_new();
> + qdict_put(client, "host", qstring_from_str(phost));
> + qdict_put(client, "port", qstring_from_str(pport));
> + qdict_put(client, "family", qstring_from_str(inet_strfamily(info->paddr.sa_family)));
> +
> + data = qobject_from_jsonf("{ 'client': %p, 'server': %p }",
> + QOBJECT(client), QOBJECT(server));
> + monitor_protocol_event(qevent[event], data);
> + qobject_decref(data);
> +}
> +#endif
> +
> static SpiceCoreInterface core_interface = {
> .base.type = SPICE_INTERFACE_CORE,
> .base.description = "qemu core services",
> @@ -135,6 +193,10 @@ static SpiceCoreInterface core_interface = {
> .watch_add = watch_add,
> .watch_update_mask = watch_update_mask,
> .watch_remove = watch_remove,
> +
> +#if SPICE_INTERFACE_CORE_MINOR>= 3
> + .channel_event = channel_event,
> +#endif
> };
>
> /* config string parsing */
> @@ -316,6 +378,7 @@ void qemu_spice_init(void)
> spice_server_set_ticket(spice_server, password, 0, 0, 0);
> }
> if (qemu_opt_get_bool(opts, "disable-ticketing", 0)) {
> + auth = "none";
> spice_server_set_noauth(spice_server);
> }
>
>
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2010-11-16 14:06 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2010-11-02 13:29 [Qemu-devel] [PATCH] spice: connection events Gerd Hoffmann
2010-11-16 14:06 ` Anthony Liguori
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).