Code refactoring 14.2

DSView/pv/deviceagent.cpp

@@ -0,0 +1,204 @@
+/*
+ * This file is part of the DSView project.
+ * DSView is based on PulseView.
+ * 
+ * Copyright (C) 2022 DreamSourceLab <support@dreamsourcelab.com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
+ */
+
+#include "deviceagent.h"
+#include <assert.h>
+#include "log.h"
+
+DeviceAgent::DeviceAgent()
+{
+    _dev_handle = NULL;
+}
+
+void DeviceAgent::update()
+{
+    _dev_handle = NULL;
+    _dev_name = "";
+
+    ds_device_info info;
+
+    if (ds_get_actived_device_info(&info) == SR_OK)
+    {
+        _dev_handle = info.handle;
+        _dev_type = info.dev_type;
+        _dev_name = QString::fromLocal8Bit(info.name);
+    }
+}
+
+GVariant* DeviceAgent::get_config(const sr_channel *ch, const sr_channel_group *group, int key)
+{
+    assert(_dev_handle);
+
+    GVariant *data = NULL;
+    if (ds_set_actived_device_config(ch, group, key, data) != SR_OK)
+    {
+        dsv_err("%s", "Get device config error!");
+    }
+    return data;
+}
+
+bool DeviceAgent::set_config(sr_channel *ch, sr_channel_group *group, int key, GVariant *data)
+{
+    assert(_dev_handle);
+
+    if (ds_set_actived_device_config(ch, group, key, data) != SR_OK)
+    {   
+        dsv_err("%s", "Set device config error!");
+        return false;
+    }
+
+    config_changed();
+    return true;
+}
+
+GVariant* DeviceAgent::list_config(const sr_channel_group *group, int key)
+{
+    assert(_dev_handle);
+
+    GVariant *data = NULL;
+
+    if (ds_get_actived_device_config_list(group, key, &data) != SR_OK){
+        dsv_err("%s", "Get device config list error!");    
+    }
+
+    return data;
+}
+
+void DeviceAgent::enable_probe(const sr_channel *probe, bool enable = true)
+{
+    assert(_dev_handle);
+
+    if (ds_enable_device_channel(probe, enable) == SR_OK){
+        config_changed();
+    }
+}
+
+uint64_t DeviceAgent::get_sample_limit()
+{
+    assert(_dev_handle);
+
+    uint64_t v;
+    GVariant* gvar = NULL;
+
+    ds_get_actived_device_config(NULL, NULL, SR_CONF_LIMIT_SAMPLES, &gvar);
+
+	if (gvar != NULL) {
+        v = g_variant_get_uint64(gvar);
+		g_variant_unref(gvar);
+	}
+    else {
+		v = 0U;
+	}
+
+	return v;
+}
+
+uint64_t DeviceAgent::get_sample_rate()
+{
+    assert(_dev_handle);
+
+    uint64_t v;
+    GVariant* gvar = NULL;
+
+    ds_get_actived_device_config(NULL, NULL, SR_CONF_SAMPLERATE, &gvar);
+
+	if (gvar != NULL) {
+        v = g_variant_get_uint64(gvar);
+		g_variant_unref(gvar);
+	}
+    else {
+		v = 0U;
+	}
+
+	return v;
+}
+
+uint64_t DeviceAgent::get_time_base()
+{
+    assert(_dev_handle);
+
+    uint64_t v;
+    GVariant* gvar = NULL;
+
+    ds_get_actived_device_config(NULL, NULL, SR_CONF_TIMEBASE, &gvar);
+
+	if (gvar != NULL) {
+        v = g_variant_get_uint64(gvar);
+		g_variant_unref(gvar);
+	}
+    else {
+		v = 0U;
+	}
+
+	return v;
+}
+
+double DeviceAgent::get_sample_time()
+{
+    assert(_dev_handle);
+
+    uint64_t sample_rate = get_sample_rate();
+    uint64_t sample_limit = get_sample_limit();
+    double sample_time;
+
+    if (sample_rate == 0)
+        sample_time = 0;
+    else
+        sample_time = sample_limit * 1.0 / sample_rate;
+
+    return sample_time;
+}
+
+const GSList* DeviceAgent::get_dev_mode_list()
+{
+    assert(_dev_handle);
+    return ds_get_actived_device_mode_list();
+}
+
+bool DeviceAgent::is_trigger_enabled()
+{
+    assert(_dev_handle);
+    if (ds_trigger_is_enabled() > 0){
+        return true;
+    }
+    return false;
+}
+
+bool DeviceAgent::start()
+{
+    assert(_dev_handle);
+
+    if (ds_start_collect() == SR_OK){
+        return true;
+    }
+    return false;
+}
+
+bool DeviceAgent::stop()
+{
+    assert(_dev_handle);
+
+    if (ds_stop_collect() == SR_OK){
+        return true;
+    }
+    return false;
+}
+

DSView/pv/deviceagent.h

@@ -0,0 +1,136 @@
+/*
+ * This file is part of the DSView project.
+ * DSView is based on PulseView.
+ * 
+ * Copyright (C) 2022 DreamSourceLab <support@dreamsourcelab.com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
+ */
+
+#ifndef DEVICE_AGENT_H
+#define DEVICE_AGENT_H
+ 
+#include <glib.h>
+#include <stdint.h>
+#include <libsigrok.h>
+#include <QString>
+#include <QObject>
+
+class DeviceAgent: public QObject
+{
+    Q_OBJECT
+
+signals:
+    void device_updated();
+	void config_changed();
+
+public:
+    DeviceAgent();
+
+    void update();
+
+    inline bool have_instance(){
+        return _dev_handle != NULL;
+    }
+
+    inline QString name(){
+        return _dev_name;
+    }
+
+    inline bool isFile(){
+        return _dev_type == DEV_TYPE_FILELOG;
+    }
+
+    inline bool isDemo(){
+        return _dev_type == DEV_TYPE_DEMO;
+    }
+
+    inline bool isHardware(){
+        return _dev_type == DEV_TYPE_USB;
+    }
+
+    GVariant* get_config(const sr_channel *ch, const sr_channel_group *group, int key);
+
+    bool set_config(sr_channel *ch, sr_channel_group *group, int key, GVariant *data);
+
+	GVariant* list_config(const sr_channel_group *group, int key);
+
+	void enable_probe(const sr_channel *probe, bool enable = true);
+
+    /**
+	 * @brief Gets the sample limit from the driver.
+	 *
+	 * @return The returned sample limit from the driver, or 0 if the
+	 * 	sample limit could not be read.
+	 */
+	uint64_t get_sample_limit();
+
+     /**
+     * @brief Gets the sample rate from the driver.
+     *
+     * @return The returned sample rate from the driver, or 0 if the
+     * 	sample rate could not be read.
+     */
+    uint64_t get_sample_rate();
+
+       /**
+     * @brief Gets the time base from the driver.
+     *
+     * @return The returned time base from the driver, or 0 if the
+     * 	time base could not be read.
+     */
+    uint64_t get_time_base();
+
+     /**
+     * @brief Gets the sample time from the driver.
+     *
+     * @return The returned sample time from the driver, or 0 if the
+     * 	sample time could not be read.
+     */
+    double get_sample_time();
+
+    /**
+     * @brief Gets the device mode list from the driver.
+     *
+     * @return The returned device mode list from the driver, or NULL if the
+     * 	mode list could not be read.
+     */
+    const GSList *get_dev_mode_list();
+
+    /**
+     * Check whether the trigger exists
+     */
+    bool is_trigger_enabled();
+
+    /**
+     * Start collect data.
+     */
+    bool start();
+
+    /**
+     * Stop collect
+     */
+    bool stop();
+
+
+private:
+    ds_device_handle _dev_handle;
+    int         _dev_type;
+    QString     _dev_name;
+
+
+};
+
+#endif