feat: support -L -D for test.py submit

tests/army/frame/common.py

@@ -23,7 +23,7 @@ import taos
 from frame.log import *
 from frame.sql import *
 from frame.cases import *
-from TDengine.tests.army.frame.server.dnodes import *
+from frame.server.dnodes import *
 from frame.common import *
 from frame.constant import *
 from dataclasses import dataclass,field

tests/army/frame/server/dnodes.py

@@ -115,7 +115,7 @@ class TDSimClient:
 
 
 class TDDnode:
-    def __init__(self, index, level, disk):
+    def __init__(self, index=1, level=1, disk=1):
         self.index = index
         self.level = level
         self.disk  = disk
@@ -212,12 +212,19 @@ class TDDnode:
             self.remote_conn.run("python3 ./test.py %s -d %s -e %s"%(valgrindStr,remoteCfgDictStr,execCmdStr))
 
     def deploy(self, *updatecfgDict):
+        # logDir
         self.logDir = os.path.join(self.path,"sim","dnode%d" % self.index, "log")
+        # dataDir
         simPath = os.path.join(self.path, "sim", "dnode%d" % self.index)
-        for i in range(1, self.level):
+        primary = 1
-            for j in range(1, self.disk):
+        for i in range(self.level):
+            for j in range(self.disk):
                 eDir = os.path.join(simPath, f"data{i}{j}")
-                self.dataDir.append(eDir)
+                self.dataDir.append(f"{eDir} {i} {primary}")
+                if primary == 1:
+                    primary = 0
+
+        # taos.cfg
         self.cfgDir = os.path.join(self.path,"sim","dnode%d" % self.index, "cfg")
         self.cfgPath = os.path.join(self.path,"sim","dnode%d" % self.index, "cfg","taos.cfg")
         
@@ -238,7 +245,7 @@ class TDDnode:
         # if os.system(cmd) != 0:
         #     tdLog.exit(cmd)
         for eDir in self.dataDir:
-             os.makedirs(self.dataDir)
+             os.makedirs(eDir.split(' ')[0])
 
         # cmd = "mkdir -p " + self.logDir
         # if os.system(cmd) != 0:
@@ -284,6 +291,10 @@ class TDDnode:
                     self.addExtraCfg(key, value)
         if (self.remoteIP == ""):
             for key, value in self.cfgDict.items():
+                if type(value) == list:
+                    for v in value:
+                        self.cfg(key, v)
+                else:
                     self.cfg(key, value)
         else:
             self.remoteExec(self.cfgDict, "tdDnodes.deploy(%d,updateCfgDict)"%self.index)

tests/army/test.py

@@ -114,8 +114,9 @@ if __name__ == "__main__":
     level = 1
     disk  = 1
 
-    opts, args = getopt.gnu_getopt(sys.argv[1:], 'f:p:m:l:scghrd:k:e:N:M:Q:C:RWD:n:i:aP', [
+    opts, args = getopt.gnu_getopt(sys.argv[1:], 'f:p:m:l:scghrd:k:e:N:M:Q:C:RWU:n:i:aP:L:D:', [
-        'file=', 'path=', 'master', 'logSql', 'stop', 'cluster', 'valgrind', 'help', 'restart', 'updateCfgDict', 'killv', 'execCmd','dnodeNums','mnodeNums','queryPolicy','createDnodeNums','restful','websocket','adaptercfgupdate','replicaVar','independentMnode','previous'])
+        'file=', 'path=', 'master', 'logSql', 'stop', 'cluster', 'valgrind', 'help', 'restart', 'updateCfgDict', 'killv', 'execCmd','dnodeNums','mnodeNums',
+        'queryPolicy','createDnodeNums','restful','websocket','adaptercfgupdate','replicaVar','independentMnode',"asan",'previous','level','disk'])
     for key, value in opts:
         if key in ['-h', '--help']:
             tdLog.printNoPrefix(
@@ -137,7 +138,7 @@ if __name__ == "__main__":
             tdLog.printNoPrefix('-C create Dnode Numbers in one cluster')
             tdLog.printNoPrefix('-R restful realization form')
             tdLog.printNoPrefix('-W websocket connection')
-            tdLog.printNoPrefix('-D taosadapter update cfg dict ')
+            tdLog.printNoPrefix('-U taosadapter update cfg dict ')
             tdLog.printNoPrefix('-n the number of replicas')
             tdLog.printNoPrefix('-i independentMnode Mnode')
             tdLog.printNoPrefix('-a address sanitizer mode')