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

Timestamp:

Jan 31, 2024 11:13:23 AM (13 months ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

161387

Message:

FE/Qt: bugref:10501. Adding progress tasks for metric list and metric data inquiries.

File:

• trunk/src/VBox/Frontends/VirtualBox/src/activity/overview/UIVMActivityOverviewWidget.cpp (modified) (5 diffs)

trunk/src/VBox/Frontends/VirtualBox/src/activity/overview/UIVMActivityOverviewWidget.cpp

@@ -347 +347 @@
 
     void sltTimeout();
-
+    void sltMetricNameListingComplete(QVector<QString> metricNameList);
+    void sltMetricDataReceived(KMetricType enmMetricType,
+                               const QVector<QString> &data, const QVector<QString> &timeStamps);
 private:
+
+    void getMetricList();
     QTimer *m_pTimer;
     CCloudMachine m_comCloudMachine;
     KCloudMachineState m_enmMachineState;
+    QVector<KMetricType> m_availableMetricTypes;
 };
 
@@ -954 +959 @@
     , m_comCloudMachine(comCloudMachine)
 {
-    m_enmMachineState = comCloudMachine.GetState();
+    updateMachineState();
     m_pTimer = new QTimer(this);
     if (m_pTimer)
@@ -961 +966 @@
         m_pTimer->setInterval(60 * 1000);
     }
-    if (isRunning() && m_pTimer)
-    m_pTimer->start();
 }
 
@@ -1011 +1014 @@
 void UIActivityOverviewItemCloud::sltTimeout()
 {
+    int iDataSize = 1;
+    foreach (const KMetricType &enmMetricType, m_availableMetricTypes)
+    {
+        UIProgressTaskReadCloudMachineMetricData *pTask = new UIProgressTaskReadCloudMachineMetricData(this, m_comCloudMachine,
+                                                                                                       enmMetricType, iDataSize);
+        connect(pTask, &UIProgressTaskReadCloudMachineMetricData::sigMetricDataReceived,
+                this, &UIActivityOverviewItemCloud::sltMetricDataReceived);
+        pTask->start();
+    }
+}
+
+void UIActivityOverviewItemCloud::sltMetricDataReceived(KMetricType enmMetricType,
+                                                        const QVector<QString> &data, const QVector<QString> &timeStamps)
+{
+    Q_UNUSED(enmMetricType);
+    Q_UNUSED(data);
+    Q_UNUSED(timeStamps);
+    // if (!data.isEmpty())
+    //     printf("%d %lld %s\n", enmMetricType, data.size(), qPrintable(data[0]));
+    sender()->deleteLater();
 }
 
@@ -1021 +1044 @@
         return;
     m_enmMachineState = enmState;
+    if (isRunning())
+        getMetricList();
+    else
+    {
+        if (m_pTimer)
+            m_pTimer->stop();
+    }
+}
+
+void UIActivityOverviewItemCloud::getMetricList()
+{
+    if (!isRunning())
+        return;
+    UIProgressTaskReadCloudMachineMetricList *pReadListProgressTask =
+        new UIProgressTaskReadCloudMachineMetricList(this, m_comCloudMachine);
+    AssertPtrReturnVoid(pReadListProgressTask);
+    connect(pReadListProgressTask, &UIProgressTaskReadCloudMachineMetricList::sigMetricListReceived,
+            this, &UIActivityOverviewItemCloud::sltMetricNameListingComplete);
+    pReadListProgressTask->start();
+}
+
+void UIActivityOverviewItemCloud::sltMetricNameListingComplete(QVector<QString> metricNameList)
+{
+    AssertReturnVoid(m_pTimer);
+    m_availableMetricTypes.clear();
+    foreach (const QString &strName, metricNameList)
+        m_availableMetricTypes << gpConverter->fromInternalString<KMetricType>(strName);
+
+    if (!m_availableMetricTypes.isEmpty())
+    {
+        /* Dont wait 60 secs: */
+        sltTimeout();
+        m_pTimer->start();
+    }
+    else
+        m_pTimer->stop();
+
+    if (sender())
+        sender()->deleteLater();
+
 }