From b6b6e2e642c9a534da0cc19e59c4b6a282de032f Mon Sep 17 00:00:00 2001
From: 02090095 <vmk-post@yandex.ru>
Date: Thu, 21 Mar 2024 19:02:08 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A0=D0=B0=D0=B7=D0=B4=D0=B5=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=BD=D0=B8=D0=B5=20=D0=BE=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8?=
 =?UTF-8?q?=20=D0=BD=D0=B0=20=D1=80=D0=B0=D0=B7=D0=BD=D1=8B=D0=B5=20=D0=BC?=
 =?UTF-8?q?=D0=B0=D1=88=D0=B8=D0=BD=D1=8B,=20=D0=B8=20=D0=B8=D1=81=D0=BF?=
 =?UTF-8?q?=D1=80=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=B1=D0=B0?=
 =?UTF-8?q?=D0=B3=D0=B0.=20=D0=BC=D0=BE=D0=B3=D0=BB=D0=BE=20=D0=B2=D1=8B?=
 =?UTF-8?q?=D0=BF=D0=BE=D0=BB=D0=BD=D1=8F=D1=82=D1=8C=D1=81=D1=8F=20=D0=B1?=
 =?UTF-8?q?=D0=BE=D0=BB=D0=B5=D0=B5=20=D0=BE=D0=B4=D0=BD=D0=BE=D0=B3=D0=BE?=
 =?UTF-8?q?=20=D0=BF=D0=B0=D0=BA=D0=B5=D1=82=D0=B0=20=D0=BE=D0=B4=D0=BD?=
 =?UTF-8?q?=D0=BE=D0=B2=D1=80=D0=B5=D0=BC=D0=B5=D0=BD=D0=BD=D0=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/workspace.xml                           |  12 +-
 properties                                    |   6 +-
 src/Repository/Server/ServerCode.java         |   3 +-
 .../Common/TasksPackageState.java             |   2 +-
 src/TestingSystem/Common/TestingPlanner.java  |  78 ++++++-----
 src/TestingSystem/Common/TestingServer.java   |  31 ++---
 src/TestingSystem/Common/TestsDatabase.java   | 130 +++++++++++-------
 src/TestingSystem/DVM/DVMTestingPlanner.java  |   4 +-
 .../SAPFOR/SapforTestingPlanner.java          |   5 +-
 src/Visual_DVM_2021/UI/Main/MainForm.java     |   2 +-
 10 files changed, 154 insertions(+), 119 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 290bd87d..8c91ffd7 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -8,9 +8,15 @@
   <component name="ChangeListManager">
     <list default="true" id="e42177c3-2328-4b27-8a01-35779b2beb99" name="Default Changelist" comment="">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/Common/Utils/Validators/ShellParser.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Common/Utils/Validators/ShellParser.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/Repository/Component/Visualiser.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Repository/Component/Visualiser.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/Visual_DVM_2021/UI/Main/TestingForm.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Visual_DVM_2021/UI/Main/TestingForm.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/properties" beforeDir="false" afterPath="$PROJECT_DIR$/properties" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/Repository/Server/ServerCode.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Repository/Server/ServerCode.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/TasksPackageState.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/TasksPackageState.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/TestingPlanner.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/TestingPlanner.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/TestingServer.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/TestingServer.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/TestsDatabase.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/TestsDatabase.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/DVM/DVMTestingPlanner.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/DVM/DVMTestingPlanner.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/SAPFOR/SapforTestingPlanner.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/SAPFOR/SapforTestingPlanner.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/Visual_DVM_2021/UI/Main/MainForm.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Visual_DVM_2021/UI/Main/MainForm.java" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
diff --git a/properties b/properties
index ae4caf4e..21e2e2cb 100644
--- a/properties
+++ b/properties
@@ -4,7 +4,7 @@
   "ServerUserName": "testuser",
   "ServerUserSHHPort": 23,
   "ComponentsServerPort": 7995,
-  "TestingServerPort": 7998,
+  "TestingServerPort": 7996,
   "SocketTimeout": 5000,
   "OldServer": false,
   "SMTPHost": "smtp.mail.ru",
@@ -31,10 +31,10 @@
   "PerformanceAnalyzerPath": "",
   "ComponentsBackUpsCount": 10,
   "TestingKernels": 28,
-  "AutoCheckTesting": false,
+  "AutoCheckTesting": true,
   "CheckTestingIntervalSeconds": 10,
   "EmailOnTestingProgress": false,
-  "collapseCredentials": true,
+  "collapseCredentials": false,
   "collapseFileGraphs": false,
   "collapseFileMessages": false,
   "collapseProjectTrees": false
diff --git a/src/Repository/Server/ServerCode.java b/src/Repository/Server/ServerCode.java
index b2639ccf..7a92a236 100644
--- a/src/Repository/Server/ServerCode.java
+++ b/src/Repository/Server/ServerCode.java
@@ -70,7 +70,7 @@ public enum ServerCode {
     GetFirstActiveDVMPackage,
     DVMPackageNeedsKill,  // не доделано.
     UpdateActiveDVMPackages,
-    GetFirstActiveSapforPackage,
+    GetFirstActiveSapforPackages,
     SapforPackageNeedsKill,
     UpdateActiveSapforPackages,
     DownloadDVMPackage,
@@ -80,5 +80,6 @@ public enum ServerCode {
     ReplaceTestCode,
     ReplaceTestsCodes,
     GetSapforPackagesJson,
+    GetFirstsActiveDVMPackages
     ;
 }
diff --git a/src/TestingSystem/Common/TasksPackageState.java b/src/TestingSystem/Common/TasksPackageState.java
index 2726a4ae..ae5b9705 100644
--- a/src/TestingSystem/Common/TasksPackageState.java
+++ b/src/TestingSystem/Common/TasksPackageState.java
@@ -25,8 +25,8 @@ public enum TasksPackageState implements StatusEnum {
     RunningExecution,
     //--
     RunningEnd, //скачка архива
-    //---------------------------------------
     Analysis,
+    //-
     Done,
     Aborted;
     public boolean isActive() {
diff --git a/src/TestingSystem/Common/TestingPlanner.java b/src/TestingSystem/Common/TestingPlanner.java
index ce474135..db5bd425 100644
--- a/src/TestingSystem/Common/TestingPlanner.java
+++ b/src/TestingSystem/Common/TestingPlanner.java
@@ -11,6 +11,7 @@ import Visual_DVM_2021.Passes.Server.TestingSystemPass;
 import java.io.FileWriter;
 import java.io.Serializable;
 import java.util.Date;
+import java.util.Vector;
 public abstract class TestingPlanner<P extends TestingPackage> {
     protected P testingPackage;
     protected int getSleepMillis() {
@@ -83,7 +84,7 @@ public abstract class TestingPlanner<P extends TestingPackage> {
         }
     }
     //---
-    protected abstract ServerCode getActivePackageCode();
+    protected abstract ServerCode getActivePackagesCode();
     protected abstract ServerCode getCheckIfNeedsKillCode();
     protected abstract TasksPackageState getStateAfterStart();
     protected void InitSessionCredentials() {
@@ -130,44 +131,49 @@ public abstract class TestingPlanner<P extends TestingPackage> {
         }
     }
     // ---
+    protected void PerformPackage(TestingPackage package_in) throws Exception{
+        testingPackage = (P) package_in;
+        //--
+        Print(testingPackage.id + ":" + testingPackage.state.getDescription());
+        //--
+        InitSessionCredentials();
+        if (testingPackage.state.equals(TasksPackageState.Analysis)) {
+            AnalyseResults();
+            UpdatePackageState(TasksPackageState.Done);
+        } else {
+            try {
+                if (Connect()) {
+                    int ptk_id = (int) ServerCommand(getCheckIfNeedsKillCode(), testingPackage.id);
+                    if (ptk_id != Constants.Nan) {
+                        Print("package " + testingPackage.id + " NEEDS TO KILL");
+                        Kill();
+                        UpdatePackageState(TasksPackageState.Aborted);
+                        ServerCommand(ServerCode.DeleteObjectByPK, ptk_id);
+                    } else {
+                        Session();
+                    }
+                }
+            } catch (Exception ex) {
+                Print("Ошибка сеанса. Соединение будет разорвано.");
+                Print(ex.getMessage());
+                Disconnect();
+            } finally {
+            }
+        }
+        //--
+        testingPackage.destructor();
+        testingPackage = null;
+        System.gc();
+        //--
+
+    }
     public void Perform() {
         try {
             testingPackage = null;
-            testingPackage = (P) ServerCommand(getActivePackageCode());
-            if (testingPackage != null) {
-                Print(testingPackage.id + ":" + testingPackage.state.getDescription());
-                //--
-                InitSessionCredentials();
-                if (testingPackage.state.equals(TasksPackageState.Analysis)) {
-                    AnalyseResults();
-                    UpdatePackageState(TasksPackageState.Done);
-                } else {
-                    try {
-                        if (Connect()) {
-                            int ptk_id = (int) ServerCommand(getCheckIfNeedsKillCode(), testingPackage.id);
-                            if (ptk_id != Constants.Nan) {
-                                Print("package " + testingPackage.id + " NEEDS TO KILL");
-                                Kill();
-                                UpdatePackageState(TasksPackageState.Aborted);
-                                ServerCommand(ServerCode.DeleteObjectByPK, ptk_id);
-                            } else {
-                                Session();
-                            }
-                        }
-                    } catch (Exception ex) {
-                        Print("Ошибка сеанса. Соединение будет разорвано.");
-                        Print(ex.getMessage());
-                        Disconnect();
-                    } finally {
-                    }
-                }
-                //--
-                testingPackage.destructor();
-                testingPackage = null;
-                System.gc();
-                //--
-            }
-            //else Print(this.getClass().getSimpleName()+": no active package found");
+            Vector<P> activePackages = (Vector<P>) ServerCommand(getActivePackagesCode());
+          //  System.out.println(this.getClass().getSimpleName()+": found "+activePackages.size()+" active packages"); //Тесты:
+            for (P activePackage: activePackages)
+                PerformPackage(activePackage);
         } catch (Exception ex) {
             ex.printStackTrace();
         } finally {
diff --git a/src/TestingSystem/Common/TestingServer.java b/src/TestingSystem/Common/TestingServer.java
index 25743922..5350bee9 100644
--- a/src/TestingSystem/Common/TestingServer.java
+++ b/src/TestingSystem/Common/TestingServer.java
@@ -202,10 +202,6 @@ public class TestingServer extends RepositoryServer<TestsDatabase> {
                 response = new ServerExchangeUnit_2021(ServerCode.OK);
                 RefreshDVMTests((Account) request.object, Integer.parseInt(request.arg));
                 break;
-            case GetFirstActiveDVMPackage:
-                Print("Получить первый активный пакет задач DVM");
-                GetFirstActiveDVMPackage();
-                break;
             case DVMPackageNeedsKill:
                 Print("Проверить нуждается ли пакет DVM в убийстве");
                 DVMPackageNeedsKill();
@@ -214,9 +210,9 @@ public class TestingServer extends RepositoryServer<TestsDatabase> {
                 Print("Получить данные по пакетам DVM");
                 UpdateActiveDVMPackages();
                 break;
-            case GetFirstActiveSapforPackage:
+            case GetFirstActiveSapforPackages:
                 Print("Получить первый активный пакет задач SAPFOR");
-                GetFirstActiveSapforPackage();
+                GetFirstActiveSapforPackages();
                 break;
             case SapforPackageNeedsKill:
                 Print("Проверить нуждает ли пакет SAPFOR в убийстве");
@@ -254,6 +250,10 @@ public class TestingServer extends RepositoryServer<TestsDatabase> {
                 Print("Получить информацию о задачах пакетов SAPFOR");
                 GetSapforPackagesJson();
                 break;
+            case GetFirstsActiveDVMPackages:
+                Print("Получить первые активные пакеты задач DVM на машинах");
+                GetFirstActiveDVMPackagesByMachines();
+                break;
             default:
                 throw new RepositoryRefuseException("Неподдерживаемый код: " + code);
         }
@@ -385,24 +385,13 @@ public class TestingServer extends RepositoryServer<TestsDatabase> {
             }
         }
     }
-    //-------------------------------------------------------------------------------------->>>
-    void GetFirstActiveDVMPackage() throws Exception {
+    private void GetFirstActiveDVMPackagesByMachines() {
         response = new ServerExchangeUnit_2021(ServerCode.OK);
-        response.object = null;
-        DVMPackage dvmPackage = db.getFirstActiveDVMPackage();
-        if (dvmPackage != null) {
-            //нужно вернуть копию объекта с иным адресом!!
-            response.object = new DVMPackage(dvmPackage);
-        }
+        response.object = db.getFirstActiveDVMPackagesCopies();
     }
-    private void GetFirstActiveSapforPackage() throws Exception {
+    private void GetFirstActiveSapforPackages() throws Exception {
         response = new ServerExchangeUnit_2021(ServerCode.OK);
-        response.object = null;
-        SapforPackage sapforPackage = db.getFirstActiveSapforPackage();
-        if (sapforPackage != null) {
-            //нужно вернуть копию объекта с иным адресом!!
-            response.object = new SapforPackage(sapforPackage);
-        }
+        response.object = db.getFirstActiveSapforPackagesCopies();
     }
     //---
     void UpdateActiveDVMPackages() throws Exception {
diff --git a/src/TestingSystem/Common/TestsDatabase.java b/src/TestingSystem/Common/TestsDatabase.java
index 2e42bee9..69e58163 100644
--- a/src/TestingSystem/Common/TestsDatabase.java
+++ b/src/TestingSystem/Common/TestsDatabase.java
@@ -16,6 +16,9 @@ import TestingSystem.SAPFOR.ServerSapfor.ServerSapforsDBTable;
 import Visual_DVM_2021.Passes.PassCode_2021;
 
 import java.nio.file.Paths;
+import java.util.Comparator;
+import java.util.LinkedHashMap;
+import java.util.Vector;
 public class TestsDatabase extends SQLiteDatabase {
     public ConfigurationDBTable configurations;
     public TestDBTable tests;
@@ -52,64 +55,93 @@ public class TestsDatabase extends SQLiteDatabase {
     public PassCode_2021 getSynchronizePassCode() {
         return PassCode_2021.SynchronizeTests;
     }
-    public DVMPackage getFirstActiveDVMPackage() {
-        DVMPackage first_active = null;
-        DVMPackage first_queued = null;
-        if (!dvmPackages.Data.isEmpty()) {
-            for (DVMPackage p : dvmPackages.Data.values()) {
-                switch (p.state) {
-                    case Done:
-                    case Aborted:
-                        break;
-                    case Queued:
-                        if (first_queued == null) first_queued = p;
-                        break;
-                    default:
-                        if (first_active == null) first_active = p; //это и будет первый активный.
-                        break;
-                }
+    public Vector<SapforPackage> getFirstActiveSapforPackagesCopies() {
+        Vector<SapforPackage> res = new Vector<>();
+        Vector<SapforPackage> packages = new Vector<>();
+        SapforPackage activePackage = null;
+        //1. получить активные пакеты.
+        for (SapforPackage p : sapforPackages.Data.values()) {
+            switch (p.state) {
+                case Done:
+                case Aborted:
+                case Draft:
+                    break;
+                default:
+                    packages.add(p);
+                    break;
             }
-            if (first_active != null) return first_active;
-            if (first_queued != null) {
-                first_queued.state = TasksPackageState.TestsSynchronize;
+        }
+        //2. отсортировать по приоритету.
+        packages.sort(new Comparator<SapforPackage>() {
+            @Override
+            public int compare(SapforPackage o1, SapforPackage o2) {
+                return Integer.compare(o1.state.ordinal(), o2.state.ordinal());
+            }
+        });
+        if (!packages.isEmpty()) {
+            activePackage = packages.lastElement();
+            if (activePackage.state.equals(TasksPackageState.Queued)) {
+                activePackage.state = TasksPackageState.TestsSynchronize;
                 try {
-                    Update(first_queued);
+                    Update(activePackage);
                 } catch (Exception ex) {
                     ex.printStackTrace();
                 }
             }
-            return first_queued;
+            res.add(new SapforPackage(activePackage));
+            ; //копия чтобы не было конфликта доступа с нитью планировщика.
         }
-        return null;
+        return res;
     }
-    public SapforPackage getFirstActiveSapforPackage() {
-        SapforPackage first_active = null;
-        SapforPackage first_queued = null;
-        if (!sapforPackages.Data.isEmpty()) {
-            for (SapforPackage p : sapforPackages.Data.values()) {
-                switch (p.state) {
-                    case Done:
-                    case Aborted:
-                        break;
-                    case Queued:
-                        if (first_queued == null) first_queued = p;
-                        break;
-                    default:
-                        if (first_active == null) first_active = p; //это и будет первый активный.
-                        break;
-                }
+    public Vector<DVMPackage> getFirstActiveDVMPackagesCopies() {
+        Vector<DVMPackage> res = new Vector<>();
+        //--
+        LinkedHashMap<String, Vector<DVMPackage>> packagesByMachines = new LinkedHashMap<>();
+        //----
+        //1. Получить список активных пакетов по машинам.
+        for (DVMPackage dvmPackage : dvmPackages.Data.values()) {
+            switch (dvmPackage.state) {
+                case Done:
+                case Aborted:
+                case Draft:
+                    break;
+                default:
+                    //активен.
+                    Vector<DVMPackage> packages = null;
+                    //--
+                    if (packagesByMachines.containsKey(dvmPackage.machine_address)) {
+                        packages = packagesByMachines.get(dvmPackage.machine_address);
+                    } else {
+                        packages = new Vector<>();
+                        packagesByMachines.put(dvmPackage.machine_address, packages);
+                    }
+                    packages.add(dvmPackage);
+                    break;
             }
-            if (first_active != null) return first_active;
-            if (first_queued != null) {
-                first_queued.state = TasksPackageState.TestsSynchronize;
-                try {
-                    Update(first_queued);
-                } catch (Exception ex) {
-                    ex.printStackTrace();
-                }
-            }
-            return first_queued;
         }
-        return null;
+        //2. Выбрать для каждой машины наиболее приоритетный пакет.
+        for (String machine : packagesByMachines.keySet()) {
+            Vector<DVMPackage> packages = packagesByMachines.get(machine);
+            if (!packages.isEmpty()) {
+                packages.sort(new Comparator<DVMPackage>() {
+                    @Override
+                    public int compare(DVMPackage o1, DVMPackage o2) {
+                        return Integer.compare(o1.state.ordinal(), o2.state.ordinal());
+                    }
+                });
+                //-
+                DVMPackage activePackage = packages.lastElement();
+                if (activePackage.state.equals(TasksPackageState.Queued)) {
+                    activePackage.state = TasksPackageState.TestsSynchronize;
+                    try {
+                        Update(activePackage);
+                    } catch (Exception ex) {
+                        ex.printStackTrace();
+                    }
+                }
+                res.add(new DVMPackage(activePackage)); //копия чтобы не было конфликта доступа с нитью планировщика.
+            }
+        }
+        return res;
     }
 }
diff --git a/src/TestingSystem/DVM/DVMTestingPlanner.java b/src/TestingSystem/DVM/DVMTestingPlanner.java
index 922657b0..59a335f6 100644
--- a/src/TestingSystem/DVM/DVMTestingPlanner.java
+++ b/src/TestingSystem/DVM/DVMTestingPlanner.java
@@ -125,8 +125,8 @@ public class DVMTestingPlanner extends TestingPlanner<DVMPackage> {
     }
     //---
     @Override
-    protected ServerCode getActivePackageCode() {
-        return ServerCode.GetFirstActiveDVMPackage;
+    protected ServerCode getActivePackagesCode() {
+        return ServerCode.GetFirstsActiveDVMPackages;
     }
     @Override
     protected ServerCode getCheckIfNeedsKillCode() {
diff --git a/src/TestingSystem/SAPFOR/SapforTestingPlanner.java b/src/TestingSystem/SAPFOR/SapforTestingPlanner.java
index 7ce79846..cc224ccd 100644
--- a/src/TestingSystem/SAPFOR/SapforTestingPlanner.java
+++ b/src/TestingSystem/SAPFOR/SapforTestingPlanner.java
@@ -19,8 +19,8 @@ import java.util.Date;
 public class SapforTestingPlanner extends TestingPlanner<SapforPackage> {
     File workspace;
     @Override
-    protected ServerCode getActivePackageCode() {
-        return ServerCode.GetFirstActiveSapforPackage;
+    protected ServerCode getActivePackagesCode() {
+        return ServerCode.GetFirstActiveSapforPackages;
     }
     @Override
     protected ServerCode getCheckIfNeedsKillCode() {
@@ -139,4 +139,5 @@ public class SapforTestingPlanner extends TestingPlanner<SapforPackage> {
         killer.waitFor();
         Print("done!");
     }
+    //--
 }
diff --git a/src/Visual_DVM_2021/UI/Main/MainForm.java b/src/Visual_DVM_2021/UI/Main/MainForm.java
index 2d720633..1d5fd9ee 100644
--- a/src/Visual_DVM_2021/UI/Main/MainForm.java
+++ b/src/Visual_DVM_2021/UI/Main/MainForm.java
@@ -171,7 +171,7 @@ public class MainForm extends Form implements MainWindow {
                 res += selected_tests.size();
         }
         //--
-        globalTabs.setTitleAt(3, "Тесты: " + res);
+        globalTabs.setTitleAt(2, "Тесты: " + res);
     }
     private void SaveTestingPanel() {
         if (testingForm != null) {