[libvirt] [PATCH 01/12] Introduce event loop support
Add initEventLoop() and processEvent() static methods to the Connect
class.
Signed-off-by: Claudio Bley <cbley(a)av-test.de>
---
src/main/java/org/libvirt/Connect.java | 36 ++++++++++++++++++++++++++++
src/main/java/org/libvirt/jna/Libvirt.java | 4 ++++
2 files changed, 40 insertions(+)
diff --git a/src/main/java/org/libvirt/Connect.java
b/src/main/java/org/libvirt/Connect.java
index b3e29be..8da83f3 100644
--- a/src/main/java/org/libvirt/Connect.java
+++ b/src/main/java/org/libvirt/Connect.java
@@ -342,6 +342,42 @@ public class Connect {
}
/**
+ * Registers a default event implementation based on the poll()
+ * system call.
+ * <p>
+ * Once registered, the application has to invoke
+ * {@link #processEvent} in a loop to process events.
+ * <p>
+ * Note: You must call this function before connecting to the
+ * hypervisor.
+ *
+ * @see #processEvent
+ */
+ public static void initEventLoop() throws LibvirtException {
+ if (libvirt.virEventRegisterDefaultImpl() == -1)
+ ErrorHandler.processError(libvirt);
+ }
+
+ /**
+ * Run one iteration of the event loop.
+ * <p>
+ * Applications will generally want to have a thread which invokes
+ * this method in an infinite loop:
+ * <pre>
+ * {@code while (true) connection.processEvent(); }
+ * </pre>
+ * <p>
+ * Failure to do so may result in connections being closed
+ * unexpectedly as a result of keepalive timeout.
+ *
+ * @see #initEventLoop()
+ */
+ public void processEvent() throws LibvirtException {
+ if (libvirt.virEventRunDefaultImpl() == -1)
+ ErrorHandler.processError(Libvirt.INSTANCE);
+ }
+
+ /**
* Finds a domain based on the hypervisor ID number.
*
* @param id
diff --git a/src/main/java/org/libvirt/jna/Libvirt.java
b/src/main/java/org/libvirt/jna/Libvirt.java
index 87979cd..b5e7503 100644
--- a/src/main/java/org/libvirt/jna/Libvirt.java
+++ b/src/main/java/org/libvirt/jna/Libvirt.java
@@ -176,6 +176,10 @@ public interface Libvirt extends Library {
void virResetLastError();
void virSetErrorFunc(Pointer userData, VirErrorCallback callback);
+ // Event loop functions.
+ int virEventRegisterDefaultImpl();
+ int virEventRunDefaultImpl();
+
// Domain functions
int virDomainAbortJob(DomainPointer virDomainPtr);
int virDomainAttachDevice(DomainPointer virDomainPtr, String deviceXML);
--
1.7.9.5