2008-10-23 13:18:18 +00:00
|
|
|
#include <config.h>
|
2008-10-24 13:10:30 +00:00
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
#include <stdio.h>
|
2008-11-19 15:25:24 +00:00
|
|
|
#include <stdlib.h>
|
2008-10-23 13:18:18 +00:00
|
|
|
#include <string.h>
|
2008-11-19 15:25:24 +00:00
|
|
|
#include <signal.h>
|
2012-07-13 09:05:17 +00:00
|
|
|
#include <inttypes.h>
|
2008-10-24 13:10:30 +00:00
|
|
|
|
2011-03-23 14:30:30 +00:00
|
|
|
#include <libvirt/libvirt.h>
|
|
|
|
#include <libvirt/virterror.h>
|
2008-10-23 13:18:18 +00:00
|
|
|
|
2011-05-11 19:24:50 +00:00
|
|
|
#define VIR_DEBUG(fmt) printf("%s:%d: " fmt "\n", __func__, __LINE__)
|
2014-08-22 12:59:28 +00:00
|
|
|
#define STREQ(a, b) (strcmp(a, b) == 0)
|
2008-10-23 13:18:18 +00:00
|
|
|
|
2011-03-23 14:30:30 +00:00
|
|
|
#ifndef ATTRIBUTE_UNUSED
|
|
|
|
# define ATTRIBUTE_UNUSED __attribute__((__unused__))
|
|
|
|
#endif
|
2008-10-23 13:18:18 +00:00
|
|
|
|
2012-07-19 14:59:59 +00:00
|
|
|
int run = 1;
|
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
/* Prototypes */
|
|
|
|
const char *eventToString(int event);
|
|
|
|
int myEventAddHandleFunc (int fd, int event,
|
2008-11-19 16:24:01 +00:00
|
|
|
virEventHandleCallback cb,
|
|
|
|
void *opaque,
|
|
|
|
virFreeCallback ff);
|
2008-11-19 16:19:36 +00:00
|
|
|
void myEventUpdateHandleFunc(int watch, int event);
|
|
|
|
int myEventRemoveHandleFunc(int watch);
|
2008-10-23 13:18:18 +00:00
|
|
|
|
2008-11-19 16:24:01 +00:00
|
|
|
int myEventAddTimeoutFunc(int timeout,
|
|
|
|
virEventTimeoutCallback cb,
|
|
|
|
void *opaque,
|
|
|
|
virFreeCallback ff);
|
2008-10-23 13:18:18 +00:00
|
|
|
void myEventUpdateTimeoutFunc(int timer, int timout);
|
|
|
|
int myEventRemoveTimeoutFunc(int timer);
|
|
|
|
|
|
|
|
int myEventHandleTypeToPollEvent(virEventHandleType events);
|
|
|
|
virEventHandleType myPollEventToEventHandleType(int events);
|
|
|
|
|
|
|
|
void usage(const char *pname);
|
|
|
|
|
|
|
|
/* Callback functions */
|
|
|
|
|
2012-07-19 14:59:59 +00:00
|
|
|
|
|
|
|
static void connectClose(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
int reason,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
switch (reason) {
|
|
|
|
case VIR_CONNECT_CLOSE_REASON_ERROR:
|
|
|
|
fprintf(stderr, "Connection closed due to I/O error\n");
|
|
|
|
break;
|
|
|
|
case VIR_CONNECT_CLOSE_REASON_EOF:
|
|
|
|
fprintf(stderr, "Connection closed due to end of file\n");
|
|
|
|
break;
|
|
|
|
case VIR_CONNECT_CLOSE_REASON_KEEPALIVE:
|
|
|
|
fprintf(stderr, "Connection closed due to keepalive timeout\n");
|
|
|
|
break;
|
|
|
|
case VIR_CONNECT_CLOSE_REASON_CLIENT:
|
|
|
|
fprintf(stderr, "Connection closed due to client request\n");
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
fprintf(stderr, "Connection closed due to unknown reason\n");
|
|
|
|
break;
|
|
|
|
};
|
|
|
|
run = 0;
|
|
|
|
}
|
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
const char *eventToString(int event) {
|
2008-11-17 16:43:00 +00:00
|
|
|
const char *ret = "";
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventType) event) {
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_DEFINED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Defined";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_UNDEFINED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Undefined";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STARTED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Started";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Suspended";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_RESUMED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Resumed";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Stopped";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
2011-12-05 12:59:13 +00:00
|
|
|
case VIR_DOMAIN_EVENT_SHUTDOWN:
|
|
|
|
ret = "Shutdown";
|
|
|
|
break;
|
2012-09-06 15:00:43 +00:00
|
|
|
case VIR_DOMAIN_EVENT_PMSUSPENDED:
|
|
|
|
ret = "PMSuspended";
|
|
|
|
break;
|
2013-06-07 10:23:31 +00:00
|
|
|
case VIR_DOMAIN_EVENT_CRASHED:
|
|
|
|
ret = "Crashed";
|
|
|
|
break;
|
2008-11-17 16:43:00 +00:00
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static const char *eventDetailToString(int event, int detail) {
|
|
|
|
const char *ret = "";
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventType) event) {
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_DEFINED:
|
|
|
|
if (detail == VIR_DOMAIN_EVENT_DEFINED_ADDED)
|
|
|
|
ret = "Added";
|
|
|
|
else if (detail == VIR_DOMAIN_EVENT_DEFINED_UPDATED)
|
|
|
|
ret = "Updated";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_UNDEFINED:
|
|
|
|
if (detail == VIR_DOMAIN_EVENT_UNDEFINED_REMOVED)
|
|
|
|
ret = "Removed";
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STARTED:
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventStartedDetailType) detail) {
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STARTED_BOOTED:
|
|
|
|
ret = "Booted";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STARTED_MIGRATED:
|
|
|
|
ret = "Migrated";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STARTED_RESTORED:
|
|
|
|
ret = "Restored";
|
|
|
|
break;
|
2011-08-05 22:05:50 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STARTED_FROM_SNAPSHOT:
|
|
|
|
ret = "Snapshot";
|
|
|
|
break;
|
2012-03-14 15:26:55 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STARTED_WAKEUP:
|
|
|
|
ret = "Event wakeup";
|
|
|
|
break;
|
2008-11-17 16:43:00 +00:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED:
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventSuspendedDetailType) detail) {
|
2011-08-05 22:05:50 +00:00
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_PAUSED:
|
2009-05-25 09:44:10 +00:00
|
|
|
ret = "Paused";
|
2011-08-05 22:05:50 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_MIGRATED:
|
2008-11-17 16:43:00 +00:00
|
|
|
ret = "Migrated";
|
2011-08-05 22:05:50 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_IOERROR:
|
|
|
|
ret = "I/O Error";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_WATCHDOG:
|
|
|
|
ret = "Watchdog";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_RESTORED:
|
|
|
|
ret = "Restored";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_FROM_SNAPSHOT:
|
|
|
|
ret = "Snapshot";
|
|
|
|
break;
|
2012-11-06 17:39:18 +00:00
|
|
|
case VIR_DOMAIN_EVENT_SUSPENDED_API_ERROR:
|
|
|
|
ret = "API error";
|
|
|
|
break;
|
2011-08-05 22:05:50 +00:00
|
|
|
}
|
2008-11-17 16:43:00 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_RESUMED:
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventResumedDetailType) detail) {
|
2011-08-05 22:05:50 +00:00
|
|
|
case VIR_DOMAIN_EVENT_RESUMED_UNPAUSED:
|
2008-11-17 16:43:00 +00:00
|
|
|
ret = "Unpaused";
|
2011-08-05 22:05:50 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_RESUMED_MIGRATED:
|
2008-11-17 16:43:00 +00:00
|
|
|
ret = "Migrated";
|
2011-08-05 22:05:50 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_RESUMED_FROM_SNAPSHOT:
|
|
|
|
ret = "Snapshot";
|
|
|
|
break;
|
|
|
|
}
|
2008-11-17 16:43:00 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED:
|
2011-12-05 12:59:13 +00:00
|
|
|
switch ((virDomainEventStoppedDetailType) detail) {
|
2008-11-17 16:43:00 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_SHUTDOWN:
|
|
|
|
ret = "Shutdown";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_DESTROYED:
|
|
|
|
ret = "Destroyed";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_CRASHED:
|
|
|
|
ret = "Crashed";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_MIGRATED:
|
|
|
|
ret = "Migrated";
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_SAVED:
|
2012-08-08 14:17:31 +00:00
|
|
|
ret = "Saved";
|
2008-11-17 16:43:00 +00:00
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_FAILED:
|
|
|
|
ret = "Failed";
|
|
|
|
break;
|
2011-08-05 22:05:50 +00:00
|
|
|
case VIR_DOMAIN_EVENT_STOPPED_FROM_SNAPSHOT:
|
|
|
|
ret = "Snapshot";
|
|
|
|
break;
|
2008-11-17 16:43:00 +00:00
|
|
|
}
|
2008-10-23 13:18:18 +00:00
|
|
|
break;
|
2011-12-05 12:59:13 +00:00
|
|
|
case VIR_DOMAIN_EVENT_SHUTDOWN:
|
|
|
|
switch ((virDomainEventShutdownDetailType) detail) {
|
|
|
|
case VIR_DOMAIN_EVENT_SHUTDOWN_FINISHED:
|
|
|
|
ret = "Finished";
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
break;
|
2012-09-06 15:00:43 +00:00
|
|
|
case VIR_DOMAIN_EVENT_PMSUSPENDED:
|
|
|
|
switch ((virDomainEventPMSuspendedDetailType) detail) {
|
|
|
|
case VIR_DOMAIN_EVENT_PMSUSPENDED_MEMORY:
|
|
|
|
ret = "Memory";
|
|
|
|
break;
|
2012-10-12 19:13:39 +00:00
|
|
|
case VIR_DOMAIN_EVENT_PMSUSPENDED_DISK:
|
|
|
|
ret = "Disk";
|
|
|
|
break;
|
2012-09-06 15:00:43 +00:00
|
|
|
}
|
|
|
|
break;
|
2013-06-07 10:23:31 +00:00
|
|
|
case VIR_DOMAIN_EVENT_CRASHED:
|
|
|
|
switch ((virDomainEventCrashedDetailType) detail) {
|
|
|
|
case VIR_DOMAIN_EVENT_CRASHED_PANICKED:
|
|
|
|
ret = "Panicked";
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
break;
|
2008-10-23 13:18:18 +00:00
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2013-12-11 14:23:24 +00:00
|
|
|
static const char *
|
|
|
|
networkEventToString(int event)
|
|
|
|
{
|
|
|
|
const char *ret = "";
|
|
|
|
switch ((virNetworkEventLifecycleType) event) {
|
|
|
|
case VIR_NETWORK_EVENT_DEFINED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Defined";
|
2013-12-11 14:23:24 +00:00
|
|
|
break;
|
|
|
|
case VIR_NETWORK_EVENT_UNDEFINED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Undefined";
|
2013-12-11 14:23:24 +00:00
|
|
|
break;
|
|
|
|
case VIR_NETWORK_EVENT_STARTED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Started";
|
2013-12-11 14:23:24 +00:00
|
|
|
break;
|
|
|
|
case VIR_NETWORK_EVENT_STOPPED:
|
2014-01-20 11:27:29 +00:00
|
|
|
ret = "Stopped";
|
2013-12-11 14:23:24 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2010-03-18 17:47:02 +00:00
|
|
|
static int myDomainEventCallback1(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int event,
|
|
|
|
int detail,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
2008-10-23 13:18:18 +00:00
|
|
|
{
|
2008-12-18 12:25:11 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) %s %s\n", __func__, virDomainGetName(dom),
|
2008-11-17 16:43:00 +00:00
|
|
|
virDomainGetID(dom), eventToString(event),
|
|
|
|
eventDetailToString(event, detail));
|
2008-10-23 13:18:18 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-03-18 17:47:02 +00:00
|
|
|
static int myDomainEventCallback2(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int event,
|
|
|
|
int detail,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
2008-10-23 13:18:18 +00:00
|
|
|
{
|
2008-12-18 12:25:11 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) %s %s\n", __func__, virDomainGetName(dom),
|
2008-11-17 16:43:00 +00:00
|
|
|
virDomainGetID(dom), eventToString(event),
|
|
|
|
eventDetailToString(event, detail));
|
2008-10-23 13:18:18 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-03-18 15:25:38 +00:00
|
|
|
static int myDomainEventRebootCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) rebooted\n", __func__, virDomainGetName(dom),
|
|
|
|
virDomainGetID(dom));
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2010-03-18 18:28:15 +00:00
|
|
|
static int myDomainEventRTCChangeCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
long long offset,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
2013-07-29 18:53:36 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) rtc change %" PRIdMAX "\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom),
|
|
|
|
(intmax_t)offset);
|
2010-03-18 18:28:15 +00:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2012-07-13 09:05:17 +00:00
|
|
|
static int myDomainEventBalloonChangeCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
unsigned long long actual,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) balloon change %" PRIuMAX "KB\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom), (uintmax_t)actual);
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
Add support for an explicit watchdog event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_WATCHDOG
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_WATCHDOG_NONE = 0,
VIR_DOMAIN_EVENT_WATCHDOG_PAUSE,
VIR_DOMAIN_EVENT_WATCHDOG_RESET,
VIR_DOMAIN_EVENT_WATCHDOG_POWEROFF,
VIR_DOMAIN_EVENT_WATCHDOG_SHUTDOWN,
VIR_DOMAIN_EVENT_WATCHDOG_DEBUG,
} virDomainEventWatchdogAction;
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventWatchdogCallback)(virConnectPtr conn,
virDomainPtr dom,
int action,
void *opaque);
* daemon/remote.c: Dispatch watchdog events to client
* examples/domain-events/events-c/event-test.c: Watch for
watchdog events
* include/libvirt/libvirt.h.in: Define new watchdg event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle watchdog events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for watchdogs and emit a libvirt watchdog event
* src/remote/remote_driver.c: Receive and dispatch watchdog
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
watchdog events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for WATCHDOG event
from QEMU monitor
2010-03-18 19:07:48 +00:00
|
|
|
static int myDomainEventWatchdogCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int action,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) watchdog action=%d\n", __func__, virDomainGetName(dom),
|
|
|
|
virDomainGetID(dom), action);
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
Add support for an explicit IO error event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_IO_ERROR
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_IO_ERROR_NONE = 0,
VIR_DOMAIN_EVENT_IO_ERROR_PAUSE,
VIR_DOMAIN_EVENT_IO_ERROR_REPORT,
} virDomainEventIOErrorAction;
In addition it has the source path of the disk that had the
error and its unique device alias. It does not include the
target device name (/dev/sda), since this would preclude
triggering IO errors from other file backed devices (eg
serial ports connected to a file)
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventIOErrorCallback)(virConnectPtr conn,
virDomainPtr dom,
const char *srcPath,
const char *devAlias,
int action,
void *opaque);
This is currently wired up to the QEMU block IO error events
* daemon/remote.c: Dispatch IO error events to client
* examples/domain-events/events-c/event-test.c: Watch for
IO error events
* include/libvirt/libvirt.h.in: Define new IO error event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle IO error events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for block IO errors and emit a libvirt IO error event
* src/remote/remote_driver.c: Receive and dispatch IO error
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
IO error events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for BLOCK_IO_ERROR event
from QEMU monitor
2010-03-18 19:37:44 +00:00
|
|
|
static int myDomainEventIOErrorCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
const char *srcPath,
|
|
|
|
const char *devAlias,
|
|
|
|
int action,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) io error path=%s alias=%s action=%d\n", __func__, virDomainGetName(dom),
|
|
|
|
virDomainGetID(dom), srcPath, devAlias, action);
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
static int myDomainEventGraphicsCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int phase,
|
|
|
|
virDomainEventGraphicsAddressPtr local,
|
|
|
|
virDomainEventGraphicsAddressPtr remote,
|
|
|
|
const char *authScheme,
|
|
|
|
virDomainEventGraphicsSubjectPtr subject,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
Convert 'int i' to 'size_t i' in examples/ files
Convert the type of loop iterators named 'i', 'j', k',
'ii', 'jj', 'kk', to be 'size_t' instead of 'int' or
'unsigned int', also santizing 'ii', 'jj', 'kk' to use
the normal 'i', 'j', 'k' naming
Signed-off-by: Daniel P. Berrange <berrange@redhat.com>
2013-07-08 14:09:33 +00:00
|
|
|
size_t i;
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) graphics ", __func__, virDomainGetName(dom),
|
|
|
|
virDomainGetID(dom));
|
|
|
|
|
|
|
|
switch (phase) {
|
|
|
|
case VIR_DOMAIN_EVENT_GRAPHICS_CONNECT:
|
|
|
|
printf("connected ");
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE:
|
|
|
|
printf("initialized ");
|
|
|
|
break;
|
|
|
|
case VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT:
|
|
|
|
printf("disconnected ");
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
printf("local: family=%d node=%s service=%s ",
|
|
|
|
local->family, local->node, local->service);
|
|
|
|
printf("remote: family=%d node=%s service=%s ",
|
|
|
|
remote->family, remote->node, remote->service);
|
|
|
|
|
|
|
|
printf("auth: %s ", authScheme);
|
2013-05-21 08:04:26 +00:00
|
|
|
for (i = 0; i < subject->nidentity; i++) {
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
printf(" identity: %s=%s",
|
|
|
|
subject->identities[i].type,
|
|
|
|
subject->identities[i].name);
|
|
|
|
}
|
|
|
|
printf("\n");
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2011-05-29 12:21:53 +00:00
|
|
|
static int myDomainEventControlErrorCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) control error\n", __func__, virDomainGetName(dom),
|
|
|
|
virDomainGetID(dom));
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2011-10-18 14:15:42 +00:00
|
|
|
const char *diskChangeReasonStrings[] = {
|
|
|
|
"startupPolicy", /* 0 */
|
|
|
|
/* add new reason here */
|
|
|
|
};
|
|
|
|
static int myDomainEventDiskChangeCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
const char *oldSrcPath,
|
|
|
|
const char *newSrcPath,
|
|
|
|
const char *devAlias,
|
|
|
|
int reason,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) disk change oldSrcPath: %s newSrcPath: %s devAlias: %s reason: %s\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom),
|
|
|
|
oldSrcPath, newSrcPath, devAlias, diskChangeReasonStrings[reason]);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2012-03-23 13:44:50 +00:00
|
|
|
const char *trayChangeReasonStrings[] = {
|
|
|
|
"open",
|
|
|
|
"close",
|
|
|
|
};
|
|
|
|
|
|
|
|
static int myDomainEventTrayChangeCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
const char *devAlias,
|
|
|
|
int reason,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) removable disk's tray change devAlias: %s reason: %s\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom),
|
|
|
|
devAlias, trayChangeReasonStrings[reason]);
|
|
|
|
return 0;
|
|
|
|
}
|
2011-10-18 14:15:42 +00:00
|
|
|
|
2012-03-23 14:43:14 +00:00
|
|
|
static int myDomainEventPMWakeupCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int reason ATTRIBUTE_UNUSED,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
2012-09-06 14:56:08 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) system pmwakeup\n",
|
2012-03-23 14:43:14 +00:00
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom));
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2012-03-23 14:50:36 +00:00
|
|
|
static int myDomainEventPMSuspendCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int reason ATTRIBUTE_UNUSED,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
2012-09-06 14:56:08 +00:00
|
|
|
printf("%s EVENT: Domain %s(%d) system pmsuspend\n",
|
2012-03-23 14:50:36 +00:00
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom));
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2012-10-12 19:13:39 +00:00
|
|
|
static int myDomainEventPMSuspendDiskCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
int reason ATTRIBUTE_UNUSED,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) system pmsuspend-disk\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom));
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2013-06-19 13:28:00 +00:00
|
|
|
static int
|
|
|
|
myDomainEventDeviceRemovedCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virDomainPtr dom,
|
|
|
|
const char *devAlias,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Domain %s(%d) device removed: %s\n",
|
|
|
|
__func__, virDomainGetName(dom), virDomainGetID(dom), devAlias);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2013-12-11 14:23:24 +00:00
|
|
|
static int myNetworkEventCallback(virConnectPtr conn ATTRIBUTE_UNUSED,
|
|
|
|
virNetworkPtr dom,
|
|
|
|
int event,
|
|
|
|
int detail,
|
|
|
|
void *opaque ATTRIBUTE_UNUSED)
|
|
|
|
{
|
|
|
|
printf("%s EVENT: Network %s %s %d\n", __func__, virNetworkGetName(dom),
|
|
|
|
networkEventToString(event), detail);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2008-11-19 15:25:24 +00:00
|
|
|
static void myFreeFunc(void *opaque)
|
|
|
|
{
|
|
|
|
char *str = opaque;
|
2008-12-18 12:25:11 +00:00
|
|
|
printf("%s: Freeing [%s]\n", __func__, str);
|
2008-11-19 15:25:24 +00:00
|
|
|
free(str);
|
|
|
|
}
|
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
|
|
|
|
/* main test functions */
|
|
|
|
|
|
|
|
void usage(const char *pname)
|
|
|
|
{
|
|
|
|
printf("%s uri\n", pname);
|
|
|
|
}
|
|
|
|
|
2008-11-19 15:25:24 +00:00
|
|
|
|
|
|
|
static void stop(int sig)
|
|
|
|
{
|
|
|
|
printf("Exiting on signal %d\n", sig);
|
|
|
|
run = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
int main(int argc, char **argv)
|
|
|
|
{
|
2009-05-25 09:44:10 +00:00
|
|
|
int callback1ret = -1;
|
|
|
|
int callback2ret = -1;
|
2010-03-18 15:25:38 +00:00
|
|
|
int callback3ret = -1;
|
2010-03-18 18:28:15 +00:00
|
|
|
int callback4ret = -1;
|
Add support for an explicit watchdog event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_WATCHDOG
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_WATCHDOG_NONE = 0,
VIR_DOMAIN_EVENT_WATCHDOG_PAUSE,
VIR_DOMAIN_EVENT_WATCHDOG_RESET,
VIR_DOMAIN_EVENT_WATCHDOG_POWEROFF,
VIR_DOMAIN_EVENT_WATCHDOG_SHUTDOWN,
VIR_DOMAIN_EVENT_WATCHDOG_DEBUG,
} virDomainEventWatchdogAction;
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventWatchdogCallback)(virConnectPtr conn,
virDomainPtr dom,
int action,
void *opaque);
* daemon/remote.c: Dispatch watchdog events to client
* examples/domain-events/events-c/event-test.c: Watch for
watchdog events
* include/libvirt/libvirt.h.in: Define new watchdg event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle watchdog events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for watchdogs and emit a libvirt watchdog event
* src/remote/remote_driver.c: Receive and dispatch watchdog
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
watchdog events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for WATCHDOG event
from QEMU monitor
2010-03-18 19:07:48 +00:00
|
|
|
int callback5ret = -1;
|
Add support for an explicit IO error event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_IO_ERROR
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_IO_ERROR_NONE = 0,
VIR_DOMAIN_EVENT_IO_ERROR_PAUSE,
VIR_DOMAIN_EVENT_IO_ERROR_REPORT,
} virDomainEventIOErrorAction;
In addition it has the source path of the disk that had the
error and its unique device alias. It does not include the
target device name (/dev/sda), since this would preclude
triggering IO errors from other file backed devices (eg
serial ports connected to a file)
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventIOErrorCallback)(virConnectPtr conn,
virDomainPtr dom,
const char *srcPath,
const char *devAlias,
int action,
void *opaque);
This is currently wired up to the QEMU block IO error events
* daemon/remote.c: Dispatch IO error events to client
* examples/domain-events/events-c/event-test.c: Watch for
IO error events
* include/libvirt/libvirt.h.in: Define new IO error event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle IO error events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for block IO errors and emit a libvirt IO error event
* src/remote/remote_driver.c: Receive and dispatch IO error
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
IO error events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for BLOCK_IO_ERROR event
from QEMU monitor
2010-03-18 19:37:44 +00:00
|
|
|
int callback6ret = -1;
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
int callback7ret = -1;
|
2011-05-29 12:21:53 +00:00
|
|
|
int callback8ret = -1;
|
2011-10-18 14:15:42 +00:00
|
|
|
int callback9ret = -1;
|
2012-03-23 13:44:50 +00:00
|
|
|
int callback10ret = -1;
|
2012-03-23 14:43:14 +00:00
|
|
|
int callback11ret = -1;
|
2012-03-23 14:50:36 +00:00
|
|
|
int callback12ret = -1;
|
2012-07-13 09:05:17 +00:00
|
|
|
int callback13ret = -1;
|
2012-10-12 19:13:39 +00:00
|
|
|
int callback14ret = -1;
|
2013-06-19 13:28:00 +00:00
|
|
|
int callback15ret = -1;
|
2013-12-11 14:23:24 +00:00
|
|
|
int callback16ret = -1;
|
2010-04-25 10:50:23 +00:00
|
|
|
struct sigaction action_stop;
|
2010-03-18 17:47:02 +00:00
|
|
|
|
2012-03-29 09:52:04 +00:00
|
|
|
memset(&action_stop, 0, sizeof(action_stop));
|
2010-04-25 10:50:23 +00:00
|
|
|
|
|
|
|
action_stop.sa_handler = stop;
|
2008-10-23 13:18:18 +00:00
|
|
|
|
2011-03-23 14:30:30 +00:00
|
|
|
if (argc > 1 && STREQ(argv[1], "--help")) {
|
2008-10-23 13:18:18 +00:00
|
|
|
usage(argv[0]);
|
|
|
|
return -1;
|
2013-05-09 21:17:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
if (virInitialize() < 0) {
|
|
|
|
fprintf(stderr, "Failed to initialize libvirt");
|
|
|
|
return -1;
|
2008-10-23 13:18:18 +00:00
|
|
|
}
|
2008-11-19 15:25:24 +00:00
|
|
|
|
2013-05-09 21:17:44 +00:00
|
|
|
if (virEventRegisterDefaultImpl() < 0) {
|
|
|
|
virErrorPtr err = virGetLastError();
|
|
|
|
fprintf(stderr, "Failed to register event implementation: %s\n",
|
|
|
|
err && err->message ? err->message: "Unknown error");
|
|
|
|
return -1;
|
|
|
|
}
|
2008-10-23 13:18:18 +00:00
|
|
|
|
|
|
|
virConnectPtr dconn = NULL;
|
2011-11-22 11:09:13 +00:00
|
|
|
dconn = virConnectOpenAuth(argc > 1 ? argv[1] : NULL,
|
|
|
|
virConnectAuthPtrDefault,
|
|
|
|
VIR_CONNECT_RO);
|
2008-10-23 13:18:18 +00:00
|
|
|
if (!dconn) {
|
|
|
|
printf("error opening\n");
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
2012-07-19 14:59:59 +00:00
|
|
|
virConnectRegisterCloseCallback(dconn,
|
|
|
|
connectClose, NULL, NULL);
|
|
|
|
|
2008-11-19 15:25:24 +00:00
|
|
|
sigaction(SIGTERM, &action_stop, NULL);
|
|
|
|
sigaction(SIGINT, &action_stop, NULL);
|
|
|
|
|
2013-12-11 14:23:24 +00:00
|
|
|
VIR_DEBUG("Registering event cbs");
|
2008-10-23 13:18:18 +00:00
|
|
|
|
|
|
|
/* Add 2 callbacks to prove this works with more than just one */
|
2009-05-25 09:44:10 +00:00
|
|
|
callback1ret = virConnectDomainEventRegister(dconn, myDomainEventCallback1,
|
|
|
|
strdup("callback 1"), myFreeFunc);
|
2010-03-18 17:47:02 +00:00
|
|
|
callback2ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_LIFECYCLE,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventCallback2),
|
|
|
|
strdup("callback 2"), myFreeFunc);
|
2010-03-18 15:25:38 +00:00
|
|
|
callback3ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_REBOOT,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventRebootCallback),
|
|
|
|
strdup("callback reboot"), myFreeFunc);
|
2010-03-18 18:28:15 +00:00
|
|
|
callback4ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_RTC_CHANGE,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventRTCChangeCallback),
|
|
|
|
strdup("callback rtcchange"), myFreeFunc);
|
Add support for an explicit watchdog event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_WATCHDOG
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_WATCHDOG_NONE = 0,
VIR_DOMAIN_EVENT_WATCHDOG_PAUSE,
VIR_DOMAIN_EVENT_WATCHDOG_RESET,
VIR_DOMAIN_EVENT_WATCHDOG_POWEROFF,
VIR_DOMAIN_EVENT_WATCHDOG_SHUTDOWN,
VIR_DOMAIN_EVENT_WATCHDOG_DEBUG,
} virDomainEventWatchdogAction;
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventWatchdogCallback)(virConnectPtr conn,
virDomainPtr dom,
int action,
void *opaque);
* daemon/remote.c: Dispatch watchdog events to client
* examples/domain-events/events-c/event-test.c: Watch for
watchdog events
* include/libvirt/libvirt.h.in: Define new watchdg event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle watchdog events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for watchdogs and emit a libvirt watchdog event
* src/remote/remote_driver.c: Receive and dispatch watchdog
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
watchdog events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for WATCHDOG event
from QEMU monitor
2010-03-18 19:07:48 +00:00
|
|
|
callback5ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_WATCHDOG,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventWatchdogCallback),
|
|
|
|
strdup("callback watchdog"), myFreeFunc);
|
Add support for an explicit IO error event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_IO_ERROR
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_IO_ERROR_NONE = 0,
VIR_DOMAIN_EVENT_IO_ERROR_PAUSE,
VIR_DOMAIN_EVENT_IO_ERROR_REPORT,
} virDomainEventIOErrorAction;
In addition it has the source path of the disk that had the
error and its unique device alias. It does not include the
target device name (/dev/sda), since this would preclude
triggering IO errors from other file backed devices (eg
serial ports connected to a file)
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventIOErrorCallback)(virConnectPtr conn,
virDomainPtr dom,
const char *srcPath,
const char *devAlias,
int action,
void *opaque);
This is currently wired up to the QEMU block IO error events
* daemon/remote.c: Dispatch IO error events to client
* examples/domain-events/events-c/event-test.c: Watch for
IO error events
* include/libvirt/libvirt.h.in: Define new IO error event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle IO error events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for block IO errors and emit a libvirt IO error event
* src/remote/remote_driver.c: Receive and dispatch IO error
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
IO error events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for BLOCK_IO_ERROR event
from QEMU monitor
2010-03-18 19:37:44 +00:00
|
|
|
callback6ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_IO_ERROR,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventIOErrorCallback),
|
|
|
|
strdup("callback io error"), myFreeFunc);
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
callback7ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_GRAPHICS,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventGraphicsCallback),
|
|
|
|
strdup("callback graphics"), myFreeFunc);
|
2011-05-29 12:21:53 +00:00
|
|
|
callback8ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_CONTROL_ERROR,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventControlErrorCallback),
|
|
|
|
strdup("callback control error"), myFreeFunc);
|
2011-10-18 14:15:42 +00:00
|
|
|
callback9ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_DISK_CHANGE,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventDiskChangeCallback),
|
|
|
|
strdup("disk change"), myFreeFunc);
|
2012-03-23 13:44:50 +00:00
|
|
|
callback10ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_TRAY_CHANGE,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventTrayChangeCallback),
|
|
|
|
strdup("tray change"), myFreeFunc);
|
2012-03-23 14:43:14 +00:00
|
|
|
callback11ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_PMWAKEUP,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventPMWakeupCallback),
|
|
|
|
strdup("pmwakeup"), myFreeFunc);
|
2012-03-23 14:50:36 +00:00
|
|
|
callback12ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_PMSUSPEND,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventPMSuspendCallback),
|
|
|
|
strdup("pmsuspend"), myFreeFunc);
|
2012-07-13 09:05:17 +00:00
|
|
|
callback13ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_BALLOON_CHANGE,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventBalloonChangeCallback),
|
|
|
|
strdup("callback balloonchange"), myFreeFunc);
|
2012-10-12 19:13:39 +00:00
|
|
|
callback14ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_PMSUSPEND_DISK,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventPMSuspendDiskCallback),
|
|
|
|
strdup("pmsuspend-disk"), myFreeFunc);
|
2013-06-19 13:28:00 +00:00
|
|
|
callback15ret = virConnectDomainEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_DOMAIN_EVENT_ID_DEVICE_REMOVED,
|
|
|
|
VIR_DOMAIN_EVENT_CALLBACK(myDomainEventDeviceRemovedCallback),
|
|
|
|
strdup("device removed"), myFreeFunc);
|
2013-12-11 14:23:24 +00:00
|
|
|
callback16ret = virConnectNetworkEventRegisterAny(dconn,
|
|
|
|
NULL,
|
|
|
|
VIR_NETWORK_EVENT_ID_LIFECYCLE,
|
|
|
|
VIR_NETWORK_EVENT_CALLBACK(myNetworkEventCallback),
|
|
|
|
strdup("net callback"), myFreeFunc);
|
2013-06-19 13:28:00 +00:00
|
|
|
|
2010-03-18 17:47:02 +00:00
|
|
|
if ((callback1ret != -1) &&
|
2010-03-18 15:25:38 +00:00
|
|
|
(callback2ret != -1) &&
|
2010-03-18 18:28:15 +00:00
|
|
|
(callback3ret != -1) &&
|
Add support for an explicit watchdog event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_WATCHDOG
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_WATCHDOG_NONE = 0,
VIR_DOMAIN_EVENT_WATCHDOG_PAUSE,
VIR_DOMAIN_EVENT_WATCHDOG_RESET,
VIR_DOMAIN_EVENT_WATCHDOG_POWEROFF,
VIR_DOMAIN_EVENT_WATCHDOG_SHUTDOWN,
VIR_DOMAIN_EVENT_WATCHDOG_DEBUG,
} virDomainEventWatchdogAction;
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventWatchdogCallback)(virConnectPtr conn,
virDomainPtr dom,
int action,
void *opaque);
* daemon/remote.c: Dispatch watchdog events to client
* examples/domain-events/events-c/event-test.c: Watch for
watchdog events
* include/libvirt/libvirt.h.in: Define new watchdg event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle watchdog events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for watchdogs and emit a libvirt watchdog event
* src/remote/remote_driver.c: Receive and dispatch watchdog
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
watchdog events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for WATCHDOG event
from QEMU monitor
2010-03-18 19:07:48 +00:00
|
|
|
(callback4ret != -1) &&
|
Add support for an explicit IO error event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_IO_ERROR
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_IO_ERROR_NONE = 0,
VIR_DOMAIN_EVENT_IO_ERROR_PAUSE,
VIR_DOMAIN_EVENT_IO_ERROR_REPORT,
} virDomainEventIOErrorAction;
In addition it has the source path of the disk that had the
error and its unique device alias. It does not include the
target device name (/dev/sda), since this would preclude
triggering IO errors from other file backed devices (eg
serial ports connected to a file)
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventIOErrorCallback)(virConnectPtr conn,
virDomainPtr dom,
const char *srcPath,
const char *devAlias,
int action,
void *opaque);
This is currently wired up to the QEMU block IO error events
* daemon/remote.c: Dispatch IO error events to client
* examples/domain-events/events-c/event-test.c: Watch for
IO error events
* include/libvirt/libvirt.h.in: Define new IO error event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle IO error events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for block IO errors and emit a libvirt IO error event
* src/remote/remote_driver.c: Receive and dispatch IO error
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
IO error events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for BLOCK_IO_ERROR event
from QEMU monitor
2010-03-18 19:37:44 +00:00
|
|
|
(callback5ret != -1) &&
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
(callback6ret != -1) &&
|
2011-10-18 14:15:42 +00:00
|
|
|
(callback7ret != -1) &&
|
2012-03-23 13:44:50 +00:00
|
|
|
(callback9ret != -1) &&
|
2012-03-23 14:43:14 +00:00
|
|
|
(callback10ret != -1) &&
|
2012-03-23 14:50:36 +00:00
|
|
|
(callback11ret != -1) &&
|
2012-07-13 09:05:17 +00:00
|
|
|
(callback12ret != -1) &&
|
2012-10-12 19:13:39 +00:00
|
|
|
(callback13ret != -1) &&
|
2013-06-19 13:28:00 +00:00
|
|
|
(callback14ret != -1) &&
|
2013-12-11 14:23:24 +00:00
|
|
|
(callback15ret != -1) &&
|
|
|
|
(callback16ret != -1)) {
|
2011-09-16 09:04:22 +00:00
|
|
|
if (virConnectSetKeepAlive(dconn, 5, 3) < 0) {
|
|
|
|
virErrorPtr err = virGetLastError();
|
|
|
|
fprintf(stderr, "Failed to start keepalive protocol: %s\n",
|
|
|
|
err && err->message ? err->message : "Unknown error");
|
|
|
|
run = 0;
|
|
|
|
}
|
|
|
|
|
2012-07-19 14:59:59 +00:00
|
|
|
while (run) {
|
2011-03-23 14:30:30 +00:00
|
|
|
if (virEventRunDefaultImpl() < 0) {
|
|
|
|
virErrorPtr err = virGetLastError();
|
|
|
|
fprintf(stderr, "Failed to run event loop: %s\n",
|
|
|
|
err && err->message ? err->message : "Unknown error");
|
2009-05-25 09:44:10 +00:00
|
|
|
}
|
2008-10-23 13:18:18 +00:00
|
|
|
}
|
|
|
|
|
2011-05-09 09:24:09 +00:00
|
|
|
VIR_DEBUG("Deregistering event handlers");
|
2009-05-25 09:44:10 +00:00
|
|
|
virConnectDomainEventDeregister(dconn, myDomainEventCallback1);
|
2010-03-18 17:47:02 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback2ret);
|
2010-03-18 15:25:38 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback3ret);
|
2010-03-18 18:28:15 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback4ret);
|
Add support for an explicit watchdog event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_WATCHDOG
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_WATCHDOG_NONE = 0,
VIR_DOMAIN_EVENT_WATCHDOG_PAUSE,
VIR_DOMAIN_EVENT_WATCHDOG_RESET,
VIR_DOMAIN_EVENT_WATCHDOG_POWEROFF,
VIR_DOMAIN_EVENT_WATCHDOG_SHUTDOWN,
VIR_DOMAIN_EVENT_WATCHDOG_DEBUG,
} virDomainEventWatchdogAction;
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventWatchdogCallback)(virConnectPtr conn,
virDomainPtr dom,
int action,
void *opaque);
* daemon/remote.c: Dispatch watchdog events to client
* examples/domain-events/events-c/event-test.c: Watch for
watchdog events
* include/libvirt/libvirt.h.in: Define new watchdg event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle watchdog events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for watchdogs and emit a libvirt watchdog event
* src/remote/remote_driver.c: Receive and dispatch watchdog
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
watchdog events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for WATCHDOG event
from QEMU monitor
2010-03-18 19:07:48 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback5ret);
|
Add support for an explicit IO error event
This introduces a new event type
VIR_DOMAIN_EVENT_ID_IO_ERROR
This event includes the action that is about to be taken
as a result of the watchdog triggering
typedef enum {
VIR_DOMAIN_EVENT_IO_ERROR_NONE = 0,
VIR_DOMAIN_EVENT_IO_ERROR_PAUSE,
VIR_DOMAIN_EVENT_IO_ERROR_REPORT,
} virDomainEventIOErrorAction;
In addition it has the source path of the disk that had the
error and its unique device alias. It does not include the
target device name (/dev/sda), since this would preclude
triggering IO errors from other file backed devices (eg
serial ports connected to a file)
Thus there is a new callback definition for this event type
typedef void (*virConnectDomainEventIOErrorCallback)(virConnectPtr conn,
virDomainPtr dom,
const char *srcPath,
const char *devAlias,
int action,
void *opaque);
This is currently wired up to the QEMU block IO error events
* daemon/remote.c: Dispatch IO error events to client
* examples/domain-events/events-c/event-test.c: Watch for
IO error events
* include/libvirt/libvirt.h.in: Define new IO error event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle IO error events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for block IO errors and emit a libvirt IO error event
* src/remote/remote_driver.c: Receive and dispatch IO error
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
IO error events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for BLOCK_IO_ERROR event
from QEMU monitor
2010-03-18 19:37:44 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback6ret);
|
Add domain events for graphics network clients
This introduces a new event type
VIR_DOMAIN_EVENT_ID_GRAPHICS
The same event can be emitted in 3 scenarios
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_CONNECT = 0,
VIR_DOMAIN_EVENT_GRAPHICS_INITIALIZE,
VIR_DOMAIN_EVENT_GRAPHICS_DISCONNECT,
} virDomainEventGraphicsPhase;
Connect/disconnect are triggered at socket accept/close.
The initialize phase is immediately after the protocol
setup and authentication has completed. ie when the
client is authorized and about to start interacting with
the graphical desktop
This event comes with *a lot* of potential information
- IP address, port & address family of client
- IP address, port & address family of server
- Authentication scheme (arbitrary string)
- Authenticated subject identity. A subject may have
multiple identities with some authentication schemes.
For example, vencrypt+sasl results in a x509dname
and saslUsername identities.
This results in a very complicated callback :-(
typedef enum {
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV4,
VIR_DOMAIN_EVENT_GRAPHICS_ADDRESS_IPV6,
} virDomainEventGraphicsAddressType;
struct _virDomainEventGraphicsAddress {
int family;
const char *node;
const char *service;
};
typedef struct _virDomainEventGraphicsAddress virDomainEventGraphicsAddress;
typedef virDomainEventGraphicsAddress *virDomainEventGraphicsAddressPtr;
struct _virDomainEventGraphicsSubject {
int nidentity;
struct {
const char *type;
const char *name;
} *identities;
};
typedef struct _virDomainEventGraphicsSubject virDomainEventGraphicsSubject;
typedef virDomainEventGraphicsSubject *virDomainEventGraphicsSubjectPtr;
typedef void (*virConnectDomainEventGraphicsCallback)(virConnectPtr conn,
virDomainPtr dom,
int phase,
virDomainEventGraphicsAddressPtr local,
virDomainEventGraphicsAddressPtr remote,
const char *authScheme,
virDomainEventGraphicsSubjectPtr subject,
void *opaque);
The wire protocol is similarly complex
struct remote_domain_event_graphics_address {
int family;
remote_nonnull_string node;
remote_nonnull_string service;
};
const REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX = 20;
struct remote_domain_event_graphics_identity {
remote_nonnull_string type;
remote_nonnull_string name;
};
struct remote_domain_event_graphics_msg {
remote_nonnull_domain dom;
int phase;
remote_domain_event_graphics_address local;
remote_domain_event_graphics_address remote;
remote_nonnull_string authScheme;
remote_domain_event_graphics_identity subject<REMOTE_DOMAIN_EVENT_GRAPHICS_IDENTITY_MAX>;
};
This is currently implemented in QEMU for the VNC graphics
protocol, but designed to be usable with SPICE graphics in
the future too.
* daemon/remote.c: Dispatch graphics events to client
* examples/domain-events/events-c/event-test.c: Watch for
graphics events
* include/libvirt/libvirt.h.in: Define new graphics event ID
and callback signature
* src/conf/domain_event.c, src/conf/domain_event.h,
src/libvirt_private.syms: Extend API to handle graphics events
* src/qemu/qemu_driver.c: Connect to the QEMU monitor event
for VNC events and emit a libvirt graphics event
* src/remote/remote_driver.c: Receive and dispatch graphics
events to application
* src/remote/remote_protocol.x: Wire protocol definition for
graphics events
* src/qemu/qemu_monitor.c, src/qemu/qemu_monitor.h,
src/qemu/qemu_monitor_json.c: Watch for VNC_CONNECTED,
VNC_INITIALIZED & VNC_DISCONNETED events from QEMU monitor
2010-03-19 13:27:45 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback7ret);
|
2011-10-18 14:15:42 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback9ret);
|
2012-03-23 13:44:50 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback10ret);
|
2012-03-23 14:43:14 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback11ret);
|
2012-03-23 14:50:36 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback12ret);
|
2012-07-13 09:05:17 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback13ret);
|
2013-06-19 13:28:00 +00:00
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback14ret);
|
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback15ret);
|
2013-12-11 14:23:24 +00:00
|
|
|
virConnectNetworkEventDeregisterAny(dconn, callback16ret);
|
2011-05-29 12:21:53 +00:00
|
|
|
if (callback8ret != -1)
|
|
|
|
virConnectDomainEventDeregisterAny(dconn, callback8ret);
|
2008-10-23 13:18:18 +00:00
|
|
|
}
|
|
|
|
|
2013-12-13 16:07:52 +00:00
|
|
|
virConnectUnregisterCloseCallback(dconn, connectClose);
|
|
|
|
|
2011-05-09 09:24:09 +00:00
|
|
|
VIR_DEBUG("Closing connection");
|
2011-03-23 14:30:30 +00:00
|
|
|
if (dconn && virConnectClose(dconn) < 0) {
|
2008-10-23 13:18:18 +00:00
|
|
|
printf("error closing\n");
|
|
|
|
}
|
2008-11-19 15:25:24 +00:00
|
|
|
|
2008-10-23 13:18:18 +00:00
|
|
|
printf("done\n");
|
|
|
|
return 0;
|
|
|
|
}
|