add:多台控制

QtScrcpy/QtScrcpy.pro

@@ -41,6 +41,7 @@ include ($$PWD/uibase/uibase.pri)
 include ($$PWD/fontawesome/fontawesome.pri)
 include ($$PWD/util/util.pri)
 include ($$PWD/device/device.pri)
+include ($$PWD/devicemanage/devicemanage.pri)
 
 # 附加包含路径
 INCLUDEPATH += \
@@ -49,6 +50,7 @@ INCLUDEPATH += \
         $$PWD/uibase \        
         $$PWD/util \
         $$PWD/device \
+        $$PWD/devicemanage \
         $$PWD/fontawesome
 
 

QtScrcpy/device/device.cpp

@@ -9,6 +9,7 @@
 #include "filehandler.h"
 #include "stream.h"
 #include "videoform.h"
+#include "controller.h"
 
 Device::Device(DeviceParams params, QObject *parent)
     : QObject(parent)
@@ -69,6 +70,7 @@ Device::~Device()
     if (m_videoForm) {
         delete m_videoForm;
     }
+    emit deviceDisconnect(m_params.serial);
 }
 
 VideoForm *Device::getVideoForm()
@@ -81,6 +83,11 @@ Controller *Device::getController()
     return m_controller;
 }
 
+Server *Device::getServer()
+{
+    return m_server;
+}
+
 void Device::initSignals()
 {
     if (m_controller && m_videoForm) {

QtScrcpy/device/device.h

@@ -4,8 +4,6 @@
 #include <QPointer>
 #include <QTime>
 
-#include "controller.h"
-
 class Recorder;
 class Server;
 class VideoBuffer;
@@ -13,6 +11,7 @@ class Decoder;
 class FileHandler;
 class Stream;
 class VideoForm;
+class Controller;
 class Device : public QObject
 {
     Q_OBJECT
@@ -32,6 +31,10 @@ public:
 
     VideoForm *getVideoForm();
     Controller *getController();
+    Server *getServer();
+
+signals:
+    void deviceDisconnect(QString serial);
 
 private:
     void initSignals();

QtScrcpy/device/server/server.cpp

@@ -168,6 +168,16 @@ bool Server::connectTo()
     return true;
 }
 
+bool Server::isReverse()
+{
+    return !m_tunnelForward;
+}
+
+Server::ServerParams Server::getParams()
+{
+    return m_params;
+}
+
 void Server::timerEvent(QTimerEvent *event)
 {
     if (event && m_acceptTimeoutTimer == event->timerId()) {

QtScrcpy/device/server/server.h

@@ -38,6 +38,8 @@ public:
 
     bool start(Server::ServerParams params);
     bool connectTo();
+    bool isReverse();
+    Server::ServerParams getParams();
 
     VideoSocket* getVideoSocket();
     QTcpSocket* getControlSocket();

QtScrcpy/devicemanage/devicemanage.cpp

@@ -0,0 +1,87 @@
+#include <QDebug>
+
+#include "devicemanage.h"
+#include "server.h"
+
+#define DM_MAX_DEVICES_NUM 16
+
+DeviceManage::DeviceManage(QObject *parent) : QObject(parent)
+{
+
+}
+
+DeviceManage::~DeviceManage()
+{
+
+}
+
+bool DeviceManage::connectDevice(Device::DeviceParams params)
+{
+    if (params.serial.trimmed().isEmpty()) {
+        return false;
+    }
+    if (m_devices.contains(params.serial)) {
+        return false;
+    }
+    if (DM_MAX_DEVICES_NUM < m_devices.size()) {
+        qInfo("over the maximum number of connections");
+        return false;
+    }
+    quint16 port = 0;
+    if (params.useReverse) {
+         port = getFreePort();
+        if (0 == port) {
+            qInfo("no port available, automatically switch to forward");
+            params.useReverse = false;
+        } else {
+            qInfo("free port %d", port);
+        }
+    }
+    Device *device = new Device(params);
+    connect(device, &Device::deviceDisconnect, this, &DeviceManage::onDeviceDisconnect);
+    m_devices[params.serial] = device;
+    return true;
+}
+
+bool DeviceManage::disconnectDevice(const QString &serial)
+{
+    bool ret = false;
+    if (!serial.isEmpty() && m_devices.contains(serial)) {
+        auto it = m_devices.find(serial);
+        if (it->data()) {
+            it->data()->deleteLater();
+            ret = true;
+        }
+    }
+    return ret;
+}
+
+void DeviceManage::onDeviceDisconnect(QString serial)
+{
+    if (!serial.isEmpty() && m_devices.contains(serial)) {
+        m_devices.remove(serial);
+    }
+}
+
+quint16 DeviceManage::getFreePort()
+{
+    quint16 port = m_localPortStart;
+    QMapIterator<QString, QPointer<Device>> i(m_devices);
+    while (port < m_localPortStart + DM_MAX_DEVICES_NUM) {
+        bool used = false;
+        while (i.hasNext()) {
+            i.next();
+            auto device = i.value();
+            if (device && device->getServer()
+                    && device->getServer()->isReverse()
+                    && port == device->getServer()->getParams().localPort) {
+                used = true;
+                break;
+            }
+        }
+        if (!used) {
+            return port;
+        }
+    }
+    return 0;
+}

QtScrcpy/devicemanage/devicemanage.h

@@ -0,0 +1,30 @@
+#ifndef DEVICEMANAGE_H
+#define DEVICEMANAGE_H
+
+#include <QPointer>
+#include <QMap>
+
+#include "device.h"
+
+class DeviceManage : public QObject
+{
+    Q_OBJECT
+public:
+    explicit DeviceManage(QObject *parent = nullptr);
+    virtual ~DeviceManage();
+
+    bool connectDevice(Device::DeviceParams params);
+    bool disconnectDevice(const QString &serial);
+
+protected slots:
+    void onDeviceDisconnect(QString serial);
+
+private:
+    quint16 getFreePort();
+
+private:
+    QMap<QString, QPointer<Device>> m_devices;
+    quint16 m_localPortStart = 27183;
+};
+
+#endif // DEVICEMANAGE_H

QtScrcpy/devicemanage/devicemanage.pri

@@ -0,0 +1,5 @@
+HEADERS += \
+    $$PWD/devicemanage.h
+
+SOURCES += \
+    $$PWD/devicemanage.cpp

QtScrcpy/dialog.cpp

@@ -102,7 +102,6 @@ void Dialog::on_updateDevice_clicked()
 
 void Dialog::on_startServerBtn_clicked()
 {
-    if (!m_device) {
     outLog("start server...", false);
 
     QString absFilePath;
@@ -127,17 +126,18 @@ void Dialog::on_startServerBtn_clicked()
     params.closeScreen = ui->closeScreenCheck->isChecked();
     params.useReverse = ui->useReverseCheck->isChecked();
     params.display = !ui->notDisplayCheck->isChecked();
-        m_device = new Device(params, this);
+    m_deviceManage.connectDevice(params);
+
+/*
         if (ui->alwaysTopCheck->isChecked() && m_device->getVideoForm()) {
             m_device->getVideoForm()->staysOnTop();
         }         
-    }    
+    */
 }
 
 void Dialog::on_stopServerBtn_clicked()
 {    
-    if (m_device) {
-        m_device->deleteLater();
+    if (m_deviceManage.disconnectDevice(ui->serialBox->currentText().trimmed())) {
         outLog("stop server");
     }
 }
@@ -258,9 +258,5 @@ void Dialog::on_stopAdbBtn_clicked()
 
 void Dialog::on_clearOut_clicked()
 {    
-    static bool show = true;
-    m_adb.setShowTouchesEnabled("", show);
-    show = !show;
-
     ui->outEdit->clear();
 }

QtScrcpy/dialog.h

@@ -5,12 +5,12 @@
 #include <QPointer>
 
 #include "adbprocess.h"
+#include "devicemanage.h"
 
 namespace Ui {
 class Dialog;
 }
 
-class Device;
 class QYUVOpenGLWidget;
 class Dialog : public QDialog
 {
@@ -55,7 +55,7 @@ private:
 private:
     Ui::Dialog *ui;
     AdbProcess m_adb;
-    QPointer<Device> m_device;
+    DeviceManage m_deviceManage;
 };
 
 #endif // DIALOG_H