fix(os): add win32 taosd case

source/libs/scalar/src/sclvector.c

@@ -348,7 +348,7 @@ static FORCE_INLINE void varToNchar(char* buf, SScalarParam* pOut, int32_t rowIn
   int32_t outputMaxLen = (inputLen + 1) * TSDB_NCHAR_SIZE + VARSTR_HEADER_SIZE;
 
   char* t = taosMemoryCalloc(1, outputMaxLen);
-  /*int32_t resLen = */taosMbsToUcs4(varDataVal(buf), inputLen, (TdUcs4*) varDataVal(t), outputMaxLen, &len);
+  /*int32_t resLen = */taosMbsToUcs4(varDataVal(buf), inputLen, (TdUcs4*) varDataVal(t), outputMaxLen - VARSTR_HEADER_SIZE, &len);
   varDataSetLen(t, len);
 
   colDataAppend(pOut->columnData, rowIndex, t, false);

source/os/src/osTime.c

@@ -28,29 +28,29 @@
 
 #ifdef WINDOWS
 
-#include <time.h>  
 #include <stdlib.h>
 #include <string.h>
+#include <time.h>
 //#define TM_YEAR_BASE 1970 //origin
-#define TM_YEAR_BASE 1900 //slguan
+#define TM_YEAR_BASE 1900  // slguan
 /*
-* We do not implement alternate representations. However, we always
-* check whether a given modifier is allowed for a certain conversion.
-*/
+ * We do not implement alternate representations. However, we always
+ * check whether a given modifier is allowed for a certain conversion.
+ */
 #define ALT_E 0x01
 #define ALT_O 0x02
-#define	LEGAL_ALT(x)		{ if (alt_format & ~(x)) return (0); }
-
+#define LEGAL_ALT(x)                   \
+  {                                    \
+    if (alt_format & ~(x)) return (0); \
+  }
 
-static int conv_num(const char **buf, int *dest, int llim, int ulim)
-{
+static int conv_num(const char **buf, int *dest, int llim, int ulim) {
   int result = 0;
 
   /* The limit also determines the number of valid digits. */
   int rulim = ulim;
 
-    if (**buf < '0' || **buf > '9')
-        return (0);
+  if (**buf < '0' || **buf > '9') return (0);
 
   do {
     result *= 10;
@@ -58,62 +58,18 @@ static int conv_num(const char **buf, int *dest, int llim, int ulim)
     rulim /= 10;
   } while ((result * 10 <= ulim) && rulim && **buf >= '0' && **buf <= '9');
 
-    if (result < llim || result > ulim)
-        return (0);
+  if (result < llim || result > ulim) return (0);
 
   *dest = result;
   return (1);
 }
 
-static const char *day[7] = {
-    "Sunday", "Monday", "Tuesday", "Wednesday", "Thursday",
-    "Friday", "Saturday"
-};
-static const char *abday[7] = {
-    "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"
-};
-static const char *mon[12] = {
-    "January", "February", "March", "April", "May", "June", "July",
-    "August", "September", "October", "November", "December"
-};
-static const char *abmon[12] = {
-    "Jan", "Feb", "Mar", "Apr", "May", "Jun",
-    "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
-};
-static const char *am_pm[2] = {
-    "AM", "PM"
-};
-
-#define BILLION                             (1E9)
-
-static BOOL g_first_time = 1;
-static LARGE_INTEGER g_counts_per_sec;
-
-int clock_gettime(int dummy, struct timespec *ct)
-{
-    LARGE_INTEGER count;
-
-    if (g_first_time)
-    {
-        g_first_time = 0;
-
-        if (0 == QueryPerformanceFrequency(&g_counts_per_sec))
-        {
-            g_counts_per_sec.QuadPart = 0;
-        }
-    }
-
-    if ((NULL == ct) || (g_counts_per_sec.QuadPart <= 0) ||
-            (0 == QueryPerformanceCounter(&count)))
-    {
-        return -1;
-    }
-
-    ct->tv_sec = count.QuadPart / g_counts_per_sec.QuadPart;
-    ct->tv_nsec = ((count.QuadPart % g_counts_per_sec.QuadPart) * BILLION) / g_counts_per_sec.QuadPart;
-
-    return 0;
-}
+static const char *day[7] = {"Sunday", "Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday"};
+static const char *abday[7] = {"Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"};
+static const char *mon[12] = {"January", "February", "March",     "April",   "May",      "June",
+                              "July",    "August",   "September", "October", "November", "December"};
+static const char *abmon[12] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"};
+static const char *am_pm[2] = {"AM", "PM"};
 
 #else
 #include <sys/time.h>
@@ -134,22 +90,19 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
 
     /* Eat up white-space. */
     if (isspace(c)) {
-            while (isspace(*bp))
-                bp++;
+      while (isspace(*bp)) bp++;
 
       fmt++;
       continue;
     }
 
-        if ((c = *fmt++) != '%')
-            goto literal;
-
+    if ((c = *fmt++) != '%') goto literal;
 
-    again:		switch (c = *fmt++) {
+  again:
+    switch (c = *fmt++) {
       case '%': /* "%%" is converted to "%". */
-        literal :
-            if (c != *bp++)
-                return (0);
+      literal:
+        if (c != *bp++) return (0);
         break;
 
         /*
@@ -171,44 +124,37 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
          */
       case 'c': /* Date and time, using the locale's format. */
         LEGAL_ALT(ALT_E);
-        if (!(bp = taosStrpTime(bp, "%x %X", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%x %X", tm))) return (0);
         break;
 
       case 'D': /* The date as "%m/%d/%y". */
         LEGAL_ALT(0);
-        if (!(bp = taosStrpTime(bp, "%m/%d/%y", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%m/%d/%y", tm))) return (0);
         break;
 
       case 'R': /* The time as "%H:%M". */
         LEGAL_ALT(0);
-        if (!(bp = taosStrpTime(bp, "%H:%M", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%H:%M", tm))) return (0);
         break;
 
       case 'r': /* The time in 12-hour clock representation. */
         LEGAL_ALT(0);
-        if (!(bp = taosStrpTime(bp, "%I:%M:%S %p", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%I:%M:%S %p", tm))) return (0);
         break;
 
       case 'T': /* The time as "%H:%M:%S". */
         LEGAL_ALT(0);
-        if (!(bp = taosStrpTime(bp, "%H:%M:%S", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%H:%M:%S", tm))) return (0);
         break;
 
       case 'X': /* The time, using the locale's format. */
         LEGAL_ALT(ALT_E);
-        if (!(bp = taosStrpTime(bp, "%H:%M:%S", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%H:%M:%S", tm))) return (0);
         break;
 
       case 'x': /* The date, using the locale's format. */
         LEGAL_ALT(ALT_E);
-        if (!(bp = taosStrpTime(bp, "%m/%d/%y", tm)))
-            return (0);
+        if (!(bp = taosStrpTime(bp, "%m/%d/%y", tm))) return (0);
         break;
 
         /*
@@ -220,18 +166,15 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
         for (i = 0; i < 7; i++) {
           /* Full name. */
           len = strlen(day[i]);
-            if (strncmp(day[i], bp, len) == 0)
-                break;
+          if (strncmp(day[i], bp, len) == 0) break;
 
           /* Abbreviated name. */
           len = strlen(abday[i]);
-            if (strncmp(abday[i], bp, len) == 0)
-                break;
+          if (strncmp(abday[i], bp, len) == 0) break;
         }
 
         /* Nothing matched. */
-        if (i == 7)
-            return (0);
+        if (i == 7) return (0);
 
         tm->tm_wday = i;
         bp += len;
@@ -244,18 +187,15 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
         for (i = 0; i < 12; i++) {
           /* Full name. */
           len = strlen(mon[i]);
-            if (strncmp(mon[i], bp, len) == 0)
-                break;
+          if (strncmp(mon[i], bp, len) == 0) break;
 
           /* Abbreviated name. */
           len = strlen(abmon[i]);
-            if (strncmp(abmon[i], bp, len) == 0)
-                break;
+          if (strncmp(abmon[i], bp, len) == 0) break;
         }
 
         /* Nothing matched. */
-        if (i == 12)
-            return (0);
+        if (i == 12) return (0);
 
         tm->tm_mon = i;
         bp += len;
@@ -263,13 +203,11 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
 
       case 'C': /* The century number. */
         LEGAL_ALT(ALT_E);
-        if (!(conv_num(&bp, &i, 0, 99)))
-            return (0);
+        if (!(conv_num(&bp, &i, 0, 99))) return (0);
 
         if (split_year) {
           tm->tm_year = (tm->tm_year % 100) + (i * 100);
-        }
-        else {
+        } else {
           tm->tm_year = i * 100;
           split_year = 1;
         }
@@ -278,8 +216,7 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
       case 'd': /* The day of month. */
       case 'e':
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_mday, 1, 31)))
-            return (0);
+        if (!(conv_num(&bp, &tm->tm_mday, 1, 31))) return (0);
         break;
 
       case 'k': /* The hour (24-hour clock representation). */
@@ -287,8 +224,7 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
         /* FALLTHROUGH */
       case 'H':
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_hour, 0, 23)))
-            return (0);
+        if (!(conv_num(&bp, &tm->tm_hour, 0, 23))) return (0);
         break;
 
       case 'l': /* The hour (12-hour clock representation). */
@@ -296,29 +232,24 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
         /* FALLTHROUGH */
       case 'I':
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_hour, 1, 12)))
-            return (0);
-        if (tm->tm_hour == 12)
-            tm->tm_hour = 0;
+        if (!(conv_num(&bp, &tm->tm_hour, 1, 12))) return (0);
+        if (tm->tm_hour == 12) tm->tm_hour = 0;
         break;
 
       case 'j': /* The day of year. */
         LEGAL_ALT(0);
-        if (!(conv_num(&bp, &i, 1, 366)))
-            return (0);
+        if (!(conv_num(&bp, &i, 1, 366))) return (0);
         tm->tm_yday = i - 1;
         break;
 
       case 'M': /* The minute. */
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_min, 0, 59)))
-            return (0);
+        if (!(conv_num(&bp, &tm->tm_min, 0, 59))) return (0);
         break;
 
       case 'm': /* The month. */
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &i, 1, 12)))
-            return (0);
+        if (!(conv_num(&bp, &i, 1, 12))) return (0);
         tm->tm_mon = i - 1;
         break;
 
@@ -326,16 +257,14 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
         LEGAL_ALT(0);
         /* AM? */
         if (strcmp(am_pm[0], bp) == 0) {
-            if (tm->tm_hour > 11)
-                return (0);
+          if (tm->tm_hour > 11) return (0);
 
           bp += strlen(am_pm[0]);
           break;
         }
         /* PM? */
         else if (strcmp(am_pm[1], bp) == 0) {
-            if (tm->tm_hour > 11)
-                return (0);
+          if (tm->tm_hour > 11) return (0);
 
           tm->tm_hour += 12;
           bp += strlen(am_pm[1]);
@@ -347,8 +276,7 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
 
       case 'S': /* The seconds. */
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_sec, 0, 61)))
-            return (0);
+        if (!(conv_num(&bp, &tm->tm_sec, 0, 61))) return (0);
         break;
 
       case 'U': /* The week of year, beginning on sunday. */
@@ -360,28 +288,24 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
          * point to calculate a real value, so just check the
          * range for now.
          */
-        if (!(conv_num(&bp, &i, 0, 53)))
-            return (0);
+        if (!(conv_num(&bp, &i, 0, 53))) return (0);
         break;
 
       case 'w': /* The day of week, beginning on sunday. */
         LEGAL_ALT(ALT_O);
-        if (!(conv_num(&bp, &tm->tm_wday, 0, 6)))
-            return (0);
+        if (!(conv_num(&bp, &tm->tm_wday, 0, 6))) return (0);
         break;
 
       case 'Y': /* The year. */
         LEGAL_ALT(ALT_E);
-        if (!(conv_num(&bp, &i, 0, 9999)))
-            return (0);
+        if (!(conv_num(&bp, &i, 0, 9999))) return (0);
 
         tm->tm_year = i - TM_YEAR_BASE;
         break;
 
       case 'y': /* The year within 100 years of the epoch. */
         LEGAL_ALT(ALT_E | ALT_O);
-        if (!(conv_num(&bp, &i, 0, 99)))
-            return (0);
+        if (!(conv_num(&bp, &i, 0, 99))) return (0);
 
         if (split_year) {
           tm->tm_year = ((tm->tm_year / 100) * 100) + i;
@@ -400,16 +324,12 @@ char *taosStrpTime(const char *buf, const char *fmt, struct tm *tm) {
       case 'n': /* Any kind of white-space. */
       case 't':
         LEGAL_ALT(0);
-        while (isspace(*bp))
-            bp++;
+        while (isspace(*bp)) bp++;
         break;
 
-
       default: /* Unknown/unsupported conversion. */
         return (0);
     }
-
-
   }
 
   /* LINTED functional specification */
@@ -435,13 +355,9 @@ FORCE_INLINE int32_t taosGetTimeOfDay(struct timeval *tv) {
 #endif
 }
 
-time_t taosTime(time_t *t) {
-  return time(t);
-}
+time_t taosTime(time_t *t) { return time(t); }
 
-time_t taosMktime(struct tm *timep) {
-  return mktime(timep);
-}
+time_t taosMktime(struct tm *timep) { return mktime(timep); }
 
 struct tm *taosLocalTime(const time_t *timep, struct tm *result) {
   if (result == NULL) {
@@ -456,5 +372,36 @@ struct tm *taosLocalTime(const time_t *timep, struct tm *result) {
 }
 
 int32_t taosGetTimestampSec() { return (int32_t)time(NULL); }
-
-int32_t taosClockGetTime(int clock_id, struct timespec *pTS) { return clock_gettime(clock_id, pTS); }
+int32_t taosClockGetTime(int clock_id, struct timespec *pTS) {
+#ifdef WINDOWS
\ No newline at end of file
+  LARGE_INTEGER        t;
+  FILETIME             f;
+  static FILETIME      ff;
+  static SYSTEMTIME    ss;
+  static LARGE_INTEGER offset;
+
+  ss.wYear = 1970;
+  ss.wMonth = 1;
+  ss.wDay = 1;
+  ss.wHour = 0;
+  ss.wMinute = 0;
+  ss.wSecond = 0;
+  ss.wMilliseconds = 0;
+  SystemTimeToFileTime(&ss, &ff);
+  offset.QuadPart = ff.dwHighDateTime;
+  offset.QuadPart <<= 32;
+  offset.QuadPart |= ff.dwLowDateTime;
+
+  GetSystemTimeAsFileTime(&f);
+  t.QuadPart = f.dwHighDateTime;
+  t.QuadPart <<= 32;
+  t.QuadPart |= f.dwLowDateTime;
+
+  t.QuadPart -= offset.QuadPart;
+  pTS->tv_sec = t.QuadPart / 10000000;
+  pTS->tv_nsec = (t.QuadPart % 10000000)*100;
+  return (0);
+#else
+  return clock_gettime(clock_id, pTS);
+#endif
+}
\ No newline at end of file

tests/pytest/util/dnodes.py

@@ -574,6 +574,9 @@ class TDDnodes:
 
     def stopAll(self):
         tdLog.info("stop all dnodes")
+        if (not self.dnodes[0].remoteIP == ""):
+            self.dnodes[0].remoteExec(self.dnodes[0].cfgDict, "for i in range(len(tdDnodes.dnodes)):\n    tdDnodes.dnodes[i].running=1\ntdDnodes.stopAll()")
+            return
         for i in range(len(self.dnodes)):
             self.dnodes[i].stop()
 

tests/system-test/0-others/taosdlog.py

@@ -23,7 +23,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/0-others/udf_cluster.py

@@ -37,7 +37,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/0-others/udf_create.py

@@ -9,8 +9,9 @@ from util.sql import *
 from util.cases import *
 from util.dnodes import *
 import subprocess
-# import win32gui
-# import threading
+if (platform.system().lower() == 'windows'):
+    import win32gui
+import threading
 
 class TDTestCase:
 
@@ -535,17 +536,18 @@ class TDTestCase:
         return udf1_sqls ,udf2_sqls
 
 
-    # def checkRunTimeError(self):
-    #     while 1:
-    #         time.sleep(1)
-    #         hwnd = win32gui.FindWindow(None, "Microsoft Visual C++ Runtime Library")
-    #         if hwnd:
-    #             os.system("TASKKILL /F /IM udfd.exe")
+    def checkRunTimeError(self):
+        if (platform.system().lower() == 'windows' and tdDnodes.dnodes[0].remoteIP == ""):
+            while 1:
+                time.sleep(1)
+                hwnd = win32gui.FindWindow(None, "Microsoft Visual C++ Runtime Library")
+                if hwnd:
+                    os.system("TASKKILL /F /IM udfd.exe")
 
     def unexpected_create(self):
-        # if (platform.system().lower() == 'windows' and tdDnodes.dnodes[0].remoteIP == ""):
-        #     checkErrorThread = threading.Thread(target=self.checkRunTimeError,daemon=True)
-        #     checkErrorThread.start()
+        if (platform.system().lower() == 'windows' and tdDnodes.dnodes[0].remoteIP == ""):
+            checkErrorThread = threading.Thread(target=self.checkRunTimeError,daemon=True)
+            checkErrorThread.start()
 
         tdLog.info(" create function with out bufsize ")
         tdSql.query("drop function udf1 ")

tests/system-test/0-others/user_control.py

@@ -3,6 +3,7 @@ import taos
 import time
 import inspect
 import traceback
+import socket
 from dataclasses  import dataclass
 
 from util.log import *
@@ -102,7 +103,7 @@ class TDconnect:
 
 
 def taos_connect(
-    host    = "127.0.0.1",
+    host    = socket.gethostname(),
     port    = 6030,
     user    = "root",
     passwd  = "taosdata",

tests/system-test/1-insert/insertWithMoreVgroup.py

@@ -54,7 +54,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root)-len("/build/bin")]

tests/system-test/1-insert/mutipythonnodebugtaosd.py

@@ -52,7 +52,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root)-len("/build/bin")]

tests/system-test/1-insert/test_stmt_insert_query_ex.py

@@ -49,7 +49,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root)-len("/build/bin")]

tests/system-test/1-insert/test_stmt_muti_insert_query.py

@@ -49,7 +49,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root)-len("/build/bin")]

tests/system-test/1-insert/test_stmt_set_tbname_tag.py

@@ -49,7 +49,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root)-len("/build/bin")]

tests/system-test/2-query/histogram.py

@@ -400,7 +400,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/2-query/timezone.py

@@ -3,6 +3,8 @@ from util.log import *
 from util.sql import *
 from util.cases import *
 
+import tzlocal
+import platform
 import os
 
 
@@ -15,8 +17,12 @@ class TDTestCase:
     def run(self):  # sourcery skip: extract-duplicate-method
         tdSql.prepare()
         # get system timezone
-        time_zone_arr = os.popen('timedatectl | grep zone').read(
-        ).strip().split(':')
+        if platform.system().lower() == 'windows':
+            time_zone_1 = tzlocal.get_localzone_name()
+            time_zone_2 = time.strftime('(UTC, %z)')
+            time_zone = time_zone_1 + " " + time_zone_2
+        else:
+            time_zone_arr = os.popen('timedatectl | grep zone').read().strip().split(':')
             if len(time_zone_arr) > 1:
                 time_zone = time_zone_arr[1].lstrip()
             else:

tests/system-test/7-tmq/basic5.py

@@ -13,6 +13,12 @@ from util.dnodes import *
 
 class TDTestCase:
     hostname = socket.gethostname()
+    if (platform.system().lower() == 'windows' and not tdDnodes.dnodes[0].remoteIP == ""):
+        try:
+            config = eval(tdDnodes.dnodes[0].remoteIP)
+            hostname = config["host"]
+        except Exception:
+            hostname = tdDnodes.dnodes[0].remoteIP
     #rpcDebugFlagVal = '143'
     #clientCfgDict = {'serverPort': '', 'firstEp': '', 'secondEp':'', 'rpcDebugFlag':'135', 'fqdn':''}
     #clientCfgDict["rpcDebugFlag"]  = rpcDebugFlagVal
@@ -34,7 +40,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]
@@ -192,6 +198,9 @@ class TDTestCase:
         
         shellCmd = 'nohup ' + buildPath + '/build/bin/tmq_sim -c ' + cfgPath
         shellCmd += " -y %d -d %s -g %d -r %d -w %s "%(pollDelay, parameterDict["dbName"], showMsg, showRow, cdbName) 
+        if (platform.system().lower() == 'windows'):
+            shellCmd += "> nul 2>&1 &"   
+        else:
             shellCmd += "> /dev/null 2>&1 &"  
         tdLog.info(shellCmd)
         os.system(shellCmd)        
@@ -306,6 +315,9 @@ class TDTestCase:
         
         shellCmd = 'nohup ' + buildPath + '/build/bin/tmq_sim -c ' + cfgPath
         shellCmd += " -y %d -d %s -g %d -r %d -w %s "%(pollDelay, parameterDict["dbName"], showMsg, showRow, cdbName) 
+        if (platform.system().lower() == 'windows'):
+            shellCmd += "> nul 2>&1 &"   
+        else:
             shellCmd += "> /dev/null 2>&1 &"  
         tdLog.info(shellCmd)
         os.system(shellCmd)        
@@ -438,6 +450,9 @@ class TDTestCase:
         
         shellCmd = 'nohup ' + buildPath + '/build/bin/tmq_sim -c ' + cfgPath
         shellCmd += " -y %d -d %s -g %d -r %d -w %s "%(pollDelay, parameterDict["dbName"], showMsg, showRow, cdbName) 
+        if (platform.system().lower() == 'windows'):
+            shellCmd += "> nul 2>&1 &"   
+        else:
             shellCmd += "> /dev/null 2>&1 &"        
         tdLog.info(shellCmd)
         os.system(shellCmd)        

tests/system-test/7-tmq/db.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/schema.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeDb.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeDb0.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeDb1.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb0.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb1.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb2.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb3.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/subscribeStb4.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/tmqDnode.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/7-tmq/tmqModule.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/99-TDcase/TD-15517.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/99-TDcase/TD-15554.py

@@ -33,7 +33,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/99-TDcase/TD-15557.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/99-TDcase/TD-15563.py

@@ -34,7 +34,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/99-TDcase/TD-16025.py

@@ -41,7 +41,7 @@ class TDTestCase:
             projPath = selfPath[:selfPath.find("tests")]
 
         for root, dirs, files in os.walk(projPath):
-            if ("taosd" in files):
+            if ("taosd" in files or "taosd.exe" in files):
                 rootRealPath = os.path.dirname(os.path.realpath(root))
                 if ("packaging" not in rootRealPath):
                     buildPath = root[:len(root) - len("/build/bin")]

tests/system-test/test.py

@@ -20,6 +20,7 @@ import time
 import base64
 import json
 import platform
+import socket
 from distutils.log import warn as printf
 from fabric2 import Connection
 sys.path.append("../pytest")
@@ -149,7 +150,7 @@ if __name__ == "__main__":
         tdLog.info('stop All dnodes')
     
     if masterIp == "":
-        host = '127.0.0.1'
+        host = socket.gethostname()
     else:
         try:
             config = eval(masterIp)
@@ -170,8 +171,8 @@ if __name__ == "__main__":
         try:
             if key_word in open(fileName, encoding='UTF-8').read():
                 is_test_framework = 1
-        except:
-            pass
+        except Exception as r:
+            print(r)
         updateCfgDictStr = ''
         if is_test_framework:
             moduleName = fileName.replace(".py", "").replace(os.sep, ".")
@@ -181,8 +182,8 @@ if __name__ == "__main__":
                 if ((json.dumps(updateCfgDict) == '{}') and (ucase.updatecfgDict is not None)):
                     updateCfgDict = ucase.updatecfgDict
                     updateCfgDictStr = "-d %s"%base64.b64encode(json.dumps(updateCfgDict).encode()).decode()
-            except :
-                pass
+            except Exception as r:
+                print(r)
         else:
             pass
         tdDnodes.deploy(1,updateCfgDict)