Changeset 60250 in vbox for trunk/src/VBox/Frontends/VirtualBox

Timestamp:

Mar 29, 2016 7:23:26 PM (9 years ago)

Author:

vboxsync

Message:

FE/Qt: ​​​bugref:8308: Implementing passive event handler (part 01): Initial implementation, not used for now.

Location:

trunk/src/VBox/Frontends/VirtualBox

Files:

• Makefile.kmk (modified) (2 diffs)
• src/globals/UIMainEventListener.cpp (modified) (6 diffs)
• src/globals/UIMainEventListener.h (modified) (6 diffs)

trunk/src/VBox/Frontends/VirtualBox/Makefile.kmk

@@ -532 +532 @@
         src/globals/UIActionPool.cpp \
         src/globals/UIDesktopWidgetWatchdog.cpp \
+    src/globals/UIMainEventListener.cpp \
         src/globals/UIThreadPool.cpp \
         src/medium/UIMediumEnumerator.cpp \
@@ -542 +543 @@
         src/runtime/UIStatusBarEditorWindow.cpp \
         src/selector/UIActionPoolSelector.cpp \
-        src/selector/UIVirtualBoxEventHandler.cpp \
+    src/selector/UIVirtualBoxEventHandler.cpp \
         src/selector/UIVMDesktop.cpp \
         src/settings/machine/UIMachineSettingsStorage.cpp \

trunk/src/VBox/Frontends/VirtualBox/src/globals/UIMainEventListener.cpp

@@ -5 +5 @@
 
 /*
- * Copyright (C) 2010-2015 Oracle Corporation
+ * Copyright (C) 2010-2016 Oracle Corporation
  *
  * This file is part of VirtualBox Open Source Edition (OSE), as
@@ -20 +20 @@
 #else  /* !VBOX_WITH_PRECOMPILED_HEADERS */
 
+/* Qt includes: */
+# include <QThread>
+
 /* GUI includes: */
 # include "UIMainEventListener.h"
@@ -27 +30 @@
 # include "COMEnums.h"
 # include "CEvent.h"
+# include "CEventSource.h"
+# include "CEventListener.h"
 # include "CVBoxSVCAvailabilityChangedEvent.h"
 # include "CVirtualBoxErrorInfo.h"
@@ -54 +59 @@
 #endif /* !VBOX_WITH_PRECOMPILED_HEADERS */
 
+
+/** Private QThread extension allowing to listen for Main events in separate thread.
+  * This thread listens for a Main events infinitely unless creator calls for #setShutdown. */
+class UIMainEventListeningThread : public QThread
+{
+    Q_OBJECT;
+
+public:
+
+    /** Constructs Main events listener thread redirecting events from @a source to @a listener. */
+    UIMainEventListeningThread(const CEventSource &source, const CEventListener &listener);
+    /** Destructs Main events listener thread. */
+    ~UIMainEventListeningThread();
+
+protected:
+
+    /** Contains the thread excution body. */
+    virtual void run() /* override */;
+
+    /** Returns whether the thread asked to shutdown prematurely. */
+    bool isShutdown() const;
+    /** Defines whether the thread asked to @a fShutdown prematurely. */
+    void setShutdown(bool fShutdown);
+
+private:
+
+    /** Holds the Main event source reference. */
+    CEventSource m_source;
+    /** Holds the Main event listener reference. */
+    CEventListener m_listener;
+
+    /** Holds the mutex instance which protects thread access. */
+    mutable QMutex m_mutex;
+    /** Holds whether the thread asked to shutdown prematurely. */
+    bool m_fShutdown;
+};
+
+
+/*********************************************************************************************************************************
+*   Class UIMainEventListeningThread implementation.                                                                             *
+*********************************************************************************************************************************/
+
+UIMainEventListeningThread::UIMainEventListeningThread(const CEventSource &source, const CEventListener &listener)
+    : m_source(source)
+    , m_listener(listener)
+    , m_fShutdown(false)
+{
+}
+
+UIMainEventListeningThread::~UIMainEventListeningThread()
+{
+    /* Make a request to shutdown: */
+    setShutdown(true);
+
+    /* And wait 30 seconds for run() to finish: */
+    wait(30000);
+}
+
+void UIMainEventListeningThread::run()
+{
+    /* Initialize COM: */
+    COMBase::InitializeCOM(false);
+
+    /* Copy source wrapper to this thread: */
+    CEventSource source = m_source;
+    /* Copy listener wrapper to this thread: */
+    CEventListener listener = m_listener;
+
+    /* While we are not in shutdown: */
+    while (!isShutdown())
+    {
+        /* Fetch the event from the queue: */
+        CEvent event = source.GetEvent(listener, 50);
+        if (!event.isNull())
+        {
+            /* Process the event and tell the listener: */
+            listener.HandleEvent(event);
+            if (event.GetWaitable())
+                source.EventProcessed(listener, event);
+        }
+    }
+
+    /* Cleanup COM: */
+    COMBase::CleanupCOM();
+}
+
+bool UIMainEventListeningThread::isShutdown() const
+{
+    m_mutex.lock();
+    bool fShutdown = m_fShutdown;
+    m_mutex.unlock();
+    return fShutdown;
+}
+
+void UIMainEventListeningThread::setShutdown(bool fShutdown)
+{
+    m_mutex.lock();
+    m_fShutdown = fShutdown;
+    m_mutex.unlock();
+}
+
+
+/*********************************************************************************************************************************
+*   Class UIMainEventListener implementation.                                                                                    *
+*********************************************************************************************************************************/
+
 UIMainEventListener::UIMainEventListener()
 {
@@ -67 +178 @@
 }
 
+void UIMainEventListener::registerSource(const CEventSource &source, const CEventListener &listener)
+{
+    /* Create thread for passed source: */
+    m_threads << new UIMainEventListeningThread(source, listener);
+    /* And start it: */
+    m_threads.last()->start();
+}
+
+void UIMainEventListener::unregisterSources()
+{
+    /* Wipe out the threads: */
+    qDeleteAll(m_threads);
+}
+
 STDMETHODIMP UIMainEventListener::HandleEvent(VBoxEventType_T /* type */, IEvent *pEvent)
 {
@@ -283 +408 @@
 }
 
+#include "UIMainEventListener.moc"
+

trunk/src/VBox/Frontends/VirtualBox/src/globals/UIMainEventListener.h

@@ -5 +5 @@
 
 /*
- * Copyright (C) 2010-2015 Oracle Corporation
+ * Copyright (C) 2010-2016 Oracle Corporation
  *
  * This file is part of VirtualBox Open Source Edition (OSE), as
@@ -21 +21 @@
 /* Qt includes: */
 #include <QObject>
+#include <QList>
 
 /* COM includes: */
@@ -31 +32 @@
 /* Other VBox includes: */
 #include <VBox/com/listeners.h>
+
+/* Forward declarations: */
+class UIMainEventListeningThread;
+class CEventListener;
+class CEventSource;
 
 
@@ -116 +122 @@
 public:
 
-    /** Constructor. */
+    /** Constructs main event listener. */
     UIMainEventListener();
 
@@ -124 +130 @@
     void uninit() {}
 
+    /** Registers event @a source for passive event @a listener. */
+    void registerSource(const CEventSource &source, const CEventListener &listener);
+    /** Unregisters event sources. */
+    void unregisterSources();
+
     /** Main event handler routine. */
     STDMETHOD(HandleEvent)(VBoxEventType_T enmType, IEvent *pEvent);
+
+    /** Holds the list of threads handling passive event listening. */
+    QList<UIMainEventListeningThread*> m_threads;
 };
 
@@ -132 +146 @@
 
 #endif /* !___UIMainEventListener_h___ */
+