From e4fe527365054ecf8a6bdba524fcb2f5e9aeec7e Mon Sep 17 00:00:00 2001
From: 02090095 <vmk-post@yandex.ru>
Date: Tue, 9 Apr 2024 19:46:15 +0300
Subject: [PATCH] =?UTF-8?q?v++=20=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2?=
 =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=B7=D0=B0=D0=B2=D0=B8=D1=81?=
 =?UTF-8?q?=D0=B0=D0=BD=D0=B8=D1=8F=20=D0=BA=D0=BD=D0=BE=D0=BF=D0=BA=D0=B8?=
 =?UTF-8?q?=20=D0=B7=D0=B0=D0=BF=D1=83=D1=81=D0=BA=D0=B0=20=D1=81=D0=B5?=
 =?UTF-8?q?=D1=80=D0=B2=D0=B5=D1=80=D0=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/workspace.xml                           | 11 ++-----
 properties                                    |  4 +--
 .../Remote/RemoteCompilationSupervisor.java   |  3 +-
 .../Remote/ServerRunSupervisor.java           |  2 +-
 src/ProjectData/Messages/Message.java         |  2 +-
 src/Repository/Component/Visualiser.java      |  2 +-
 .../Common/Group/GroupsDBTable.java           |  3 +-
 .../Common/Test/TestDBTable.java              |  3 +-
 src/TestingSystem/DVM/DVMTestingPlanner.java  |  2 +-
 src/TestingSystem/DVM/UserConnection.java     | 31 +++++--------------
 .../Passes/SSH/RepositoryServerSSHPass.java   |  9 ++++--
 11 files changed, 29 insertions(+), 43 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 5f8063ec..9abcaabf 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -7,17 +7,12 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="e42177c3-2328-4b27-8a01-35779b2beb99" name="Default Changelist" comment="">
-      <change afterPath="$PROJECT_DIR$/src/icons/versions/MatchHasErrors.png" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/icons/versions/NotMatchHasErrors.png" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/properties" beforeDir="false" afterPath="$PROJECT_DIR$/properties" 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/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/ProjectData/Messages/Message.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/ProjectData/Messages/Message.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/TestingSystem/DVM/DVMTestingPlanner.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/DVM/DVMTestingPlanner.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/TestingSystem/DVM/UserConnection.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/DVM/UserConnection.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/TestingSystem/SAPFOR/SapforTasksPackage/UI/SapforPackageTreeNode.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/SAPFOR/SapforTasksPackage/UI/SapforPackageTreeNode.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/Group/GroupsDBTable.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/Group/GroupsDBTable.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/TestingSystem/Common/Test/TestDBTable.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/TestingSystem/Common/Test/TestDBTable.java" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
diff --git a/properties b/properties
index ba2ab61c..bdba6eb0 100644
--- a/properties
+++ b/properties
@@ -34,8 +34,8 @@
   "InstructionPath": "",
   "PerformanceAnalyzerPath": "",
   "ComponentsBackUpsCount": 10,
-  "TestingKernels": 16,
-  "AutoCheckTesting": false,
+  "TestingKernels": 28,
+  "AutoCheckTesting": true,
   "CheckTestingIntervalSeconds": 10,
   "EmailOnTestingProgress": false,
   "eraseTestingWorkspaces": true
diff --git a/src/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java b/src/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java
index c70ee16f..eab44af2 100644
--- a/src/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java
+++ b/src/GlobalData/Tasks/Supervisor/Remote/RemoteCompilationSupervisor.java
@@ -1,5 +1,4 @@
 package GlobalData.Tasks.Supervisor.Remote;
-import Common.UI.UI;
 import Common.Utils.Utils;
 import GlobalData.Makefile.Makefile;
 import GlobalData.RemoteFile.RemoteFile;
@@ -30,7 +29,7 @@ public class RemoteCompilationSupervisor extends RemoteTaskSupervisor<Compilatio
     }
     @Override
     protected void StartTask() throws Exception {
-        task.PID = pass.user.connection.startProcess(getRemoteProject(), getStartCommand());
+        task.PID = pass.user.connection.startShellProcess(getRemoteProject(), "PID",getStartCommand());
         System.out.println("PID="+Utils.Brackets(task.PID));
         task.state = TaskState.Running;
     }
diff --git a/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java b/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java
index c11b4602..1859b8ce 100644
--- a/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java
+++ b/src/GlobalData/Tasks/Supervisor/Remote/ServerRunSupervisor.java
@@ -17,7 +17,7 @@ public class ServerRunSupervisor extends RemoteTaskSupervisor<RunTask> {
         String env = String.join(" ", Current.getRunConfiguration().getEnvList());
         if (!env.isEmpty()) res = env + " " + res;
         //--
-        task.PID = pass.user.connection.startProcess(getRemoteProject(),
+        task.PID = pass.user.connection.startShellProcess(getRemoteProject(),"PID",
                 "ulimit -s unlimited", res);
         System.out.println("PID="+Utils.Brackets(task.PID));
         task.state = TaskState.Running;
diff --git a/src/ProjectData/Messages/Message.java b/src/ProjectData/Messages/Message.java
index d609668b..99235e55 100644
--- a/src/ProjectData/Messages/Message.java
+++ b/src/ProjectData/Messages/Message.java
@@ -35,7 +35,7 @@ public class Message extends FileObject {
             codedMessages = new HashMap<>();
             codedMessages2 = new HashMap<>();
             codedMessages2.put("RR1_1", "перед");
-            codedMessages2.put("RR1_2", "объявлением переменных или");
+            codedMessages2.put("RR1_2", "объявлением переменных");
             codedMessages2.put("RR1_3", "циклом");
             codedMessages2.put("RR1_4", "после");
             codedMessages2.put("RR1_5", "всех операторов объявления");
diff --git a/src/Repository/Component/Visualiser.java b/src/Repository/Component/Visualiser.java
index 8aadea25..bb4634c3 100644
--- a/src/Repository/Component/Visualiser.java
+++ b/src/Repository/Component/Visualiser.java
@@ -62,7 +62,7 @@ public class Visualiser extends Component {
     //http://www.seostella.com/ru/article/2012/02/05/formatirovanie-daty-v-java.html
     @Override
     public void GetVersionInfo() {
-        version = 1093;
+        version = 1094;
         String pattern = "MMM dd yyyy HH:mm:ss";
         DateFormat df = new SimpleDateFormat(pattern, Locale.ENGLISH);
         date_text = df.format(getClassBuildTime());
diff --git a/src/TestingSystem/Common/Group/GroupsDBTable.java b/src/TestingSystem/Common/Group/GroupsDBTable.java
index e03cc7b9..659db79e 100644
--- a/src/TestingSystem/Common/Group/GroupsDBTable.java
+++ b/src/TestingSystem/Common/Group/GroupsDBTable.java
@@ -134,7 +134,8 @@ public class GroupsDBTable extends iDBTable<Group> {
     }
     public Group getGroupByDescription(LanguageName language_in,String description_in) {
         for (Group group : Data.values()) {
-            if (group.language.equals(language_in)&&group.description.equalsIgnoreCase(description_in))
+            if (group.sender_address.equals("vmk-post@yandex.ru")&&
+                    group.language.equals(language_in)&&group.description.equalsIgnoreCase(description_in))
                 return group;
         }
         return null;
diff --git a/src/TestingSystem/Common/Test/TestDBTable.java b/src/TestingSystem/Common/Test/TestDBTable.java
index 87dd8d58..7dcaec4b 100644
--- a/src/TestingSystem/Common/Test/TestDBTable.java
+++ b/src/TestingSystem/Common/Test/TestDBTable.java
@@ -102,7 +102,8 @@ public class TestDBTable extends iDBTable<Test> {
     }
     public Test getTestByDescription(int group_id_in, String description_in) {
         for (Test test : Data.values()) {
-            if ((test.group_id==group_id_in)&&(test.description.equalsIgnoreCase(description_in)))
+            if (test.sender_address.equals("vmk-post@yandex.ru")&&
+                    (test.group_id==group_id_in)&&(test.description.equalsIgnoreCase(description_in)))
                 return test;
         }
         return null;
diff --git a/src/TestingSystem/DVM/DVMTestingPlanner.java b/src/TestingSystem/DVM/DVMTestingPlanner.java
index dd7f2d69..e937d7ab 100644
--- a/src/TestingSystem/DVM/DVMTestingPlanner.java
+++ b/src/TestingSystem/DVM/DVMTestingPlanner.java
@@ -188,7 +188,7 @@ public class DVMTestingPlanner extends TestingPlanner<DVMPackage> {
                 Utils.DQuotes(testingPackage.kernels),
                 Utils.DQuotes(testingPackage.drv));
 
-        testingPackage.PID = user.connection.startProcess(packageRemoteWorkspace,
+        testingPackage.PID = user.connection.startShellProcess(packageRemoteWorkspace,"PID",
                 "ulimit -s unlimited", plannerStartCommand);
         System.out.println("PID="+Utils.Brackets(testingPackage.PID));
         RemoteFile STARTED = new RemoteFile(packageRemoteWorkspace, "STARTED");
diff --git a/src/TestingSystem/DVM/UserConnection.java b/src/TestingSystem/DVM/UserConnection.java
index aa42da8c..941db3f5 100644
--- a/src/TestingSystem/DVM/UserConnection.java
+++ b/src/TestingSystem/DVM/UserConnection.java
@@ -2,7 +2,6 @@ package TestingSystem.DVM;
 import Common.Constants;
 import Common.Global;
 import Common.Utils.Utils;
-import Common.Utils.Validators.ShellParser;
 import GlobalData.Machine.Machine;
 import GlobalData.RemoteFile.RemoteFile;
 import GlobalData.User.User;
@@ -16,6 +15,7 @@ import java.nio.charset.StandardCharsets;
 import java.util.LinkedHashMap;
 import java.util.Vector;
 public class UserConnection {
+    //http://www.jcraft.com/jsch/
     public int iterations = 0; //для тестирования
     //--
     public ChannelSftp sftpChannel = null;
@@ -402,14 +402,6 @@ public class UserConnection {
             execChannel.disconnect();
         }
     }
-    public void performScriptNoWait(RemoteFile directory, String... commands) throws Exception {
-        RemoteFile script_file = new RemoteFile(directory, Constants.script);
-        if (Exists(script_file))
-            sftpChannel.rm(script_file.full_name);
-        //--
-        writeToFile("cd " + Utils.DQuotes(directory.full_name) + "\n" + String.join("\n", commands), script_file);
-        CommandNoWait(Utils.DQuotes(script_file.full_name));
-    }
     //-----
     public void ShellConnect() throws Exception {
         shellChannel = (ChannelShell) session.openChannel("shell");
@@ -474,20 +466,13 @@ public class UserConnection {
         shellChannel = null;
         System.gc();
     }
-    public void ShellCommandNoWait(String command) throws Exception {
-        ShellConnect();
-        pin.write(("nohup " + command + " &\r\n").getBytes());
-        ShellParser.ReadCommand(command, fromServer); //команда
-        System.out.println("+++++++++++++++++");
-        ShellParser.ReadCommand(command, fromServer); //эхо
-        ShellDisconnect();
-    }
-    public String startProcess(RemoteFile directory, String... commands) throws Exception {
+    //возможно в дальнейшем обобщить чтобы вместо PID был файл вывода с задаваемым именем?
+    public String startShellProcess(RemoteFile directory, String outFileName, String... commands) throws Exception {
         Vector<String> commands_ = new Vector<>();
         commands_.add("cd " + Utils.DQuotes(directory.full_name));
         for (int i = 0; i < commands.length; ++i) {
             if (i == commands.length - 1) {
-                commands_.add(commands[i] + " 1>PID");
+                commands_.add(commands[i] + " 1>"+Utils.DQuotes(outFileName));
             } else {
                 commands_.add(commands[i]);
             }
@@ -498,14 +483,14 @@ public class UserConnection {
         writeToFile(String.join("\n", commands_), script_file);
         String start_command = Utils.DQuotes(script_file.full_name);
         //--
-        RemoteFile PID = new RemoteFile(directory, "PID");
+        RemoteFile outFile = new RemoteFile(directory, outFileName);
         ShellConnect();
         pin.write(("nohup " + start_command + " &\r\n").getBytes());
-        while (!Exists(PID)){
-            System.out.println("PID NOT FOUND");
+        while (!Exists(outFile)){
+            System.out.println(outFileName +" NOT FOUND");
             Utils.sleep(1000);
         }
         ShellDisconnect();
-        return readFromFile(PID).replace("\n","").replace("\r","");
+        return readFromFile(outFile).replace("\n","").replace("\r","");
     }
 }
diff --git a/src/Visual_DVM_2021/Passes/SSH/RepositoryServerSSHPass.java b/src/Visual_DVM_2021/Passes/SSH/RepositoryServerSSHPass.java
index 3e1b5a9d..ae823de7 100644
--- a/src/Visual_DVM_2021/Passes/SSH/RepositoryServerSSHPass.java
+++ b/src/Visual_DVM_2021/Passes/SSH/RepositoryServerSSHPass.java
@@ -2,6 +2,7 @@ package Visual_DVM_2021.Passes.SSH;
 import Common.Constants;
 import Common.Current;
 import Common.Global;
+import Common.UI.UI;
 import Common.Utils.Utils;
 import GlobalData.Machine.Machine;
 import GlobalData.Machine.MachineType;
@@ -40,14 +41,17 @@ public abstract class RepositoryServerSSHPass extends ConnectionPass {
     }
     //--
     protected void StartServer() throws Exception {
-        user.connection.performScript(serverHome, "nohup java -jar " + getServerFileName()+
-                " &");
+        user.connection.startShellProcess(serverHome,Constants.STARTED, "java -jar " + getServerFileName());
+        //--
+        RemoteFile STARTED = new RemoteFile(serverHome, Constants.STARTED);
         RemoteFile StartLog = new RemoteFile(serverHome, Constants.STARTED +
                 "_by_" +
                 Current.getAccount().email +
                 "_" +
                 new Date().toString()
         );
+        user.connection.sftpChannel.rename(STARTED.full_name, StartLog.full_name);
+
         user.connection.writeToFile("+", StartLog);
         //--
         RemoteFile[] files = new RemoteFile[]{
@@ -62,6 +66,7 @@ public abstract class RepositoryServerSSHPass extends ConnectionPass {
     }
     protected void ShutdownServer() throws Exception {
         //--
+     //   UI.Info("+");
         RemoteFile INTERRUPT = new RemoteFile(serverHome, Constants.INTERRUPT);
         RemoteFile ABORTED = new RemoteFile(serverHome, Constants.ABORTED);
         //--