osSysinfo.c 27.6 KB
Newer Older
S
Shengliang Guan 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#define _DEFAULT_SOURCE
#include "os.h"
18
#include "taoserror.h"
S
Shengliang Guan 已提交
19

wafwerar's avatar
wafwerar 已提交
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36
#define PROCESS_ITEM 12

typedef struct {
  uint64_t user;
  uint64_t nice;
  uint64_t system;
  uint64_t idle;
} SysCpuInfo;

typedef struct {
  uint64_t utime;   // user time
  uint64_t stime;   // kernel time
  uint64_t cutime;  // all user time
  uint64_t cstime;  // all dead time
} ProcCpuInfo;

#ifdef WINDOWS
S
Shengliang Guan 已提交
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93

/*
 * windows implementation
 */

#if (_WIN64)
#include <iphlpapi.h>
#include <mswsock.h>
#include <psapi.h>
#include <stdio.h>
#include <windows.h>
#include <ws2tcpip.h>
#pragma comment(lib, "Mswsock.lib ")
#endif

#include <objbase.h>

#pragma warning(push)
#pragma warning(disable : 4091)
#include <DbgHelp.h>
#pragma warning(pop)

LONG WINAPI FlCrashDump(PEXCEPTION_POINTERS ep) {
  typedef BOOL(WINAPI * FxMiniDumpWriteDump)(IN HANDLE hProcess, IN DWORD ProcessId, IN HANDLE hFile,
                                             IN MINIDUMP_TYPE                           DumpType,
                                             IN CONST PMINIDUMP_EXCEPTION_INFORMATION   ExceptionParam,
                                             IN CONST PMINIDUMP_USER_STREAM_INFORMATION UserStreamParam,
                                             IN CONST PMINIDUMP_CALLBACK_INFORMATION    CallbackParam);

  HMODULE dll = LoadLibrary("dbghelp.dll");
  if (dll == NULL) return EXCEPTION_CONTINUE_SEARCH;
  FxMiniDumpWriteDump mdwd = (FxMiniDumpWriteDump)(GetProcAddress(dll, "MiniDumpWriteDump"));
  if (mdwd == NULL) {
    FreeLibrary(dll);
    return EXCEPTION_CONTINUE_SEARCH;
  }

  TCHAR path[MAX_PATH];
  DWORD len = GetModuleFileName(NULL, path, _countof(path));
  path[len - 3] = 'd';
  path[len - 2] = 'm';
  path[len - 1] = 'p';

  HANDLE file = CreateFile(path, GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);

  MINIDUMP_EXCEPTION_INFORMATION mei;
  mei.ThreadId = GetCurrentThreadId();
  mei.ExceptionPointers = ep;
  mei.ClientPointers = FALSE;

  (*mdwd)(GetCurrentProcess(), GetCurrentProcessId(), file, MiniDumpWithHandleData, &mei, NULL, NULL);

  CloseHandle(file);
  FreeLibrary(dll);

  return EXCEPTION_CONTINUE_SEARCH;
}
wafwerar's avatar
wafwerar 已提交
94
LONG WINAPI exceptionHandler(LPEXCEPTION_POINTERS exception);
S
Shengliang Guan 已提交
95 96 97 98 99 100 101 102 103 104 105 106 107 108 109

#elif defined(_TD_DARWIN_64)

#include <errno.h>
#include <libproc.h>

#else

#include <argp.h>
#include <linux/sysctl.h>
#include <sys/file.h>
#include <sys/resource.h>
#include <sys/statvfs.h>
#include <sys/syscall.h>
#include <sys/utsname.h>
S
Shengliang Guan 已提交
110
#include <unistd.h>
S
Shengliang Guan 已提交
111 112 113 114 115 116 117 118

static pid_t tsProcId;
static char  tsSysNetFile[] = "/proc/net/dev";
static char  tsSysCpuFile[] = "/proc/stat";
static char  tsProcCpuFile[25] = {0};
static char  tsProcMemFile[25] = {0};
static char  tsProcIOFile[25] = {0};

S
monitor  
Shengliang Guan 已提交
119
static void taosGetProcIOnfos() {
S
Shengliang Guan 已提交
120
  tsPageSizeKB = sysconf(_SC_PAGESIZE) / 1024;
S
Shengliang Guan 已提交
121 122 123 124
  tsOpenMax = sysconf(_SC_OPEN_MAX);
  tsStreamMax = sysconf(_SC_STREAM_MAX);
  tsProcId = (pid_t)syscall(SYS_gettid);

S
Shengliang Guan 已提交
125 126 127
  snprintf(tsProcMemFile, sizeof(tsProcMemFile), "/proc/%d/status", tsProcId);
  snprintf(tsProcCpuFile, sizeof(tsProcCpuFile), "/proc/%d/stat", tsProcId);
  snprintf(tsProcIOFile, sizeof(tsProcIOFile), "/proc/%d/io", tsProcId);
S
Shengliang Guan 已提交
128
}
wafwerar's avatar
wafwerar 已提交
129
#endif
S
Shengliang Guan 已提交
130

wafwerar's avatar
wafwerar 已提交
131
static int32_t taosGetSysCpuInfo(SysCpuInfo *cpuInfo) {
wafwerar's avatar
wafwerar 已提交
132
#ifdef WINDOWS
133 134 135 136 137 138
  FILETIME pre_idleTime = {0};
  FILETIME pre_kernelTime = {0};
  FILETIME pre_userTime = {0};
  FILETIME idleTime;
  FILETIME kernelTime;
  FILETIME userTime;
H
Hongze Cheng 已提交
139
  bool     res = GetSystemTimes(&idleTime, &kernelTime, &userTime);
140 141 142 143 144 145
  if (res) {
    cpuInfo->idle = CompareFileTime(&pre_idleTime, &idleTime);
    cpuInfo->system = CompareFileTime(&pre_kernelTime, &kernelTime);
    cpuInfo->user = CompareFileTime(&pre_userTime, &userTime);
    cpuInfo->nice = 0;
  }
wafwerar's avatar
wafwerar 已提交
146 147 148 149 150
#elif defined(DARWIN)
  cpuInfo->idle = 0;
  cpuInfo->system = 0;
  cpuInfo->user = 0;
  cpuInfo->nice = 0;
wafwerar's avatar
wafwerar 已提交
151
#else
wafwerar's avatar
wafwerar 已提交
152
  TdFilePtr pFile = taosOpenFile(tsSysCpuFile, TD_FILE_READ | TD_FILE_STREAM);
153
  if (pFile == NULL) {
S
Shengliang Guan 已提交
154
    return -1;
S
Shengliang Guan 已提交
155 156
  }

wafwerar's avatar
wafwerar 已提交
157
  char    line[1024];
H
Haojun Liao 已提交
158 159
  ssize_t bytes = taosGetsFile(pFile, sizeof(line), line);
  if (bytes < 0) {
160
    taosCloseFile(&pFile);
S
Shengliang Guan 已提交
161
    return -1;
S
Shengliang Guan 已提交
162 163
  }

wafwerar's avatar
wafwerar 已提交
164 165 166
  char cpu[10] = {0};
  sscanf(line, "%s %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64, cpu, &cpuInfo->user, &cpuInfo->nice, &cpuInfo->system,
         &cpuInfo->idle);
S
Shengliang Guan 已提交
167

168
  taosCloseFile(&pFile);
wafwerar's avatar
wafwerar 已提交
169
#endif
S
Shengliang Guan 已提交
170
  return 0;
S
Shengliang Guan 已提交
171 172
}

wafwerar's avatar
wafwerar 已提交
173
static int32_t taosGetProcCpuInfo(ProcCpuInfo *cpuInfo) {
wafwerar's avatar
wafwerar 已提交
174
#ifdef WINDOWS
175 176
  FILETIME pre_krnlTm = {0};
  FILETIME pre_usrTm = {0};
H
Hongze Cheng 已提交
177
  FILETIME creatTm, exitTm, krnlTm, usrTm;
178

H
Hongze Cheng 已提交
179
  if (GetThreadTimes(GetCurrentThread(), &creatTm, &exitTm, &krnlTm, &usrTm)) {
180 181 182 183
    cpuInfo->stime = CompareFileTime(&pre_krnlTm, &krnlTm);
    cpuInfo->utime = CompareFileTime(&pre_usrTm, &usrTm);
    cpuInfo->cutime = 0;
    cpuInfo->cstime = 0;
H
Hongze Cheng 已提交
184
  }
wafwerar's avatar
wafwerar 已提交
185 186 187 188 189
#elif defined(DARWIN)
  cpuInfo->stime = 0;
  cpuInfo->utime = 0;
  cpuInfo->cutime = 0;
  cpuInfo->cstime = 0;
wafwerar's avatar
wafwerar 已提交
190
#else
wafwerar's avatar
wafwerar 已提交
191
  TdFilePtr pFile = taosOpenFile(tsProcCpuFile, TD_FILE_READ | TD_FILE_STREAM);
192
  if (pFile == NULL) {
S
Shengliang Guan 已提交
193
    return -1;
S
Shengliang Guan 已提交
194 195
  }

H
Haojun Liao 已提交
196 197 198
  char    line[1024] = {0};
  ssize_t bytes = taosGetsFile(pFile, sizeof(line), line);
  if (bytes < 0) {
199
    taosCloseFile(&pFile);
S
Shengliang Guan 已提交
200
    return -1;
S
Shengliang Guan 已提交
201 202
  }

wafwerar's avatar
wafwerar 已提交
203 204 205 206 207 208 209 210
  for (int i = 0, blank = 0; line[i] != 0; ++i) {
    if (line[i] == ' ') blank++;
    if (blank == PROCESS_ITEM) {
      sscanf(line + i + 1, "%" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64, &cpuInfo->utime, &cpuInfo->stime,
             &cpuInfo->cutime, &cpuInfo->cstime);
      break;
    }
  }
S
Shengliang Guan 已提交
211

212
  taosCloseFile(&pFile);
wafwerar's avatar
wafwerar 已提交
213
#endif
S
Shengliang Guan 已提交
214
  return 0;
S
Shengliang Guan 已提交
215 216
}

D
dapan1121 已提交
217
bool taosCheckSystemIsLittleEnd() {
218 219 220 221 222 223
  union check {
    int16_t i;
    char    ch[2];
  } c;
  c.i = 1;
  return c.ch[0] == 1;
wafwerar's avatar
wafwerar 已提交
224 225 226
}

void taosGetSystemInfo() {
wafwerar's avatar
wafwerar 已提交
227
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
228 229
  taosGetCpuCores(&tsNumOfCores);
  taosGetTotalMemory(&tsTotalMemoryKB);
S
Shengliang Guan 已提交
230
  taosGetCpuUsage(NULL, NULL);
wafwerar's avatar
wafwerar 已提交
231 232 233 234 235 236 237 238 239 240
#elif defined(_TD_DARWIN_64)
  long physical_pages = sysconf(_SC_PHYS_PAGES);
  long page_size = sysconf(_SC_PAGESIZE);
  tsTotalMemoryKB = physical_pages * page_size / 1024;
  tsPageSizeKB = page_size / 1024;
  tsNumOfCores = sysconf(_SC_NPROCESSORS_ONLN);
#else
  taosGetProcIOnfos();
  taosGetCpuCores(&tsNumOfCores);
  taosGetTotalMemory(&tsTotalMemoryKB);
S
Shengliang Guan 已提交
241
  taosGetCpuUsage(NULL, NULL);
H
Haojun Liao 已提交
242
  taosGetCpuInstructions(&tsSSE42Enable, &tsAVXEnable, &tsAVX2Enable, &tsFMAEnable);
wafwerar's avatar
wafwerar 已提交
243 244 245 246
#endif
}

int32_t taosGetEmail(char *email, int32_t maxLen) {
wafwerar's avatar
wafwerar 已提交
247
#ifdef WINDOWS
248
  // assert(0);
wafwerar's avatar
wafwerar 已提交
249 250 251 252 253 254 255 256
#elif defined(_TD_DARWIN_64)
  const char *filepath = "/usr/local/taos/email";

  TdFilePtr pFile = taosOpenFile(filepath, TD_FILE_READ);
  if (pFile == NULL) return false;

  if (taosReadFile(pFile, (void *)email, maxLen) < 0) {
    taosCloseFile(&pFile);
S
Shengliang Guan 已提交
257
    return -1;
S
Shengliang Guan 已提交
258 259
  }

wafwerar's avatar
wafwerar 已提交
260 261 262 263 264 265 266 267 268
  taosCloseFile(&pFile);
  return 0;
#else
  const char *filepath = "/usr/local/taos/email";

  TdFilePtr pFile = taosOpenFile(filepath, TD_FILE_READ);
  if (pFile == NULL) return false;

  if (taosReadFile(pFile, (void *)email, maxLen) < 0) {
269
    taosCloseFile(&pFile);
S
Shengliang Guan 已提交
270
    return -1;
S
Shengliang Guan 已提交
271 272
  }

wafwerar's avatar
wafwerar 已提交
273 274 275 276 277 278
  taosCloseFile(&pFile);
  return 0;
#endif
}

int32_t taosGetOsReleaseName(char *releaseName, int32_t maxLen) {
wafwerar's avatar
wafwerar 已提交
279
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
280 281
  snprintf(releaseName, maxLen, "Windows");
  return 0;
wafwerar's avatar
wafwerar 已提交
282
#elif defined(_TD_DARWIN_64)
wafwerar's avatar
wafwerar 已提交
283
  char    line[1024];
wafwerar's avatar
wafwerar 已提交
284 285 286 287 288 289
  size_t  size = 0;
  int32_t code = -1;

  TdFilePtr pFile = taosOpenFile("/etc/os-release", TD_FILE_READ | TD_FILE_STREAM);
  if (pFile == NULL) return false;

wafwerar's avatar
wafwerar 已提交
290
  while ((size = taosGetsFile(pFile, sizeof(line), line)) != -1) {
wafwerar's avatar
wafwerar 已提交
291 292 293 294 295 296 297 298 299
    line[size - 1] = '\0';
    if (strncmp(line, "PRETTY_NAME", 11) == 0) {
      const char *p = strchr(line, '=') + 1;
      if (*p == '"') {
        p++;
        line[size - 2] = 0;
      }
      tstrncpy(releaseName, p, maxLen);
      code = 0;
S
Shengliang Guan 已提交
300 301 302 303
      break;
    }
  }

304
  taosCloseFile(&pFile);
wafwerar's avatar
wafwerar 已提交
305 306
  return code;
#else
wafwerar's avatar
wafwerar 已提交
307
  char    line[1024];
wafwerar's avatar
wafwerar 已提交
308 309 310 311 312 313
  size_t  size = 0;
  int32_t code = -1;

  TdFilePtr pFile = taosOpenFile("/etc/os-release", TD_FILE_READ | TD_FILE_STREAM);
  if (pFile == NULL) return false;

wafwerar's avatar
wafwerar 已提交
314
  while ((size = taosGetsFile(pFile, sizeof(line), line)) != -1) {
wafwerar's avatar
wafwerar 已提交
315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333
    line[size - 1] = '\0';
    if (strncmp(line, "PRETTY_NAME", 11) == 0) {
      const char *p = strchr(line, '=') + 1;
      if (*p == '"') {
        p++;
        line[size - 2] = 0;
      }
      tstrncpy(releaseName, p, maxLen);
      code = 0;
      break;
    }
  }

  taosCloseFile(&pFile);
  return code;
#endif
}

int32_t taosGetCpuInfo(char *cpuModel, int32_t maxLen, float *numOfCores) {
wafwerar's avatar
wafwerar 已提交
334
#ifdef WINDOWS
H
Hongze Cheng 已提交
335
  char  value[100];
wafwerar's avatar
wafwerar 已提交
336
  DWORD bufferSize = sizeof(value);
H
Hongze Cheng 已提交
337 338
  RegGetValue(HKEY_LOCAL_MACHINE, "HARDWARE\\DESCRIPTION\\System\\CentralProcessor\\0", "ProcessorNameString",
              RRF_RT_ANY, NULL, (PVOID)&value, &bufferSize);
wafwerar's avatar
wafwerar 已提交
339 340
  tstrncpy(cpuModel, value, maxLen);
  SYSTEM_INFO si;
H
Hongze Cheng 已提交
341
  memset(&si, 0, sizeof(SYSTEM_INFO));
wafwerar's avatar
wafwerar 已提交
342 343 344
  GetSystemInfo(&si);
  *numOfCores = si.dwNumberOfProcessors;
  return 0;
wafwerar's avatar
wafwerar 已提交
345
#elif defined(_TD_DARWIN_64)
wafwerar's avatar
wafwerar 已提交
346
  char    buf[16];
wafwerar's avatar
wafwerar 已提交
347 348 349
  int32_t done = 0;
  int32_t code = -1;

wafwerar's avatar
wafwerar 已提交
350 351 352 353 354
  TdCmdPtr pCmd = taosOpenCmd("sysctl -n machdep.cpu.brand_string");
  if (pCmd == NULL) return code;
  if (taosGetsCmd(pCmd, maxLen, cpuModel) > 0) {
    code = 0;
    done |= 1;
wafwerar's avatar
wafwerar 已提交
355
  }
wafwerar's avatar
wafwerar 已提交
356 357 358 359 360
  taosCloseCmd(&pCmd);

  pCmd = taosOpenCmd("sysctl -n machdep.cpu.core_count");
  if (pCmd == NULL) return code;
  memset(buf, 0, sizeof(buf));
wafwerar's avatar
wafwerar 已提交
361
  if (taosGetsCmd(pCmd, sizeof(buf) - 1, buf) > 0) {
wafwerar's avatar
wafwerar 已提交
362 363 364 365 366
    code = 0;
    done |= 2;
    *numOfCores = atof(buf);
  }
  taosCloseCmd(&pCmd);
wafwerar's avatar
wafwerar 已提交
367 368 369

  return code;
#else
H
Haojun Liao 已提交
370
  char    line[1024] = {0};
wafwerar's avatar
wafwerar 已提交
371 372 373
  size_t  size = 0;
  int32_t done = 0;
  int32_t code = -1;
wafwerar's avatar
wafwerar 已提交
374
  float   coreCount = 0;
wafwerar's avatar
wafwerar 已提交
375 376

  TdFilePtr pFile = taosOpenFile("/proc/cpuinfo", TD_FILE_READ | TD_FILE_STREAM);
wafwerar's avatar
wafwerar 已提交
377
  if (pFile == NULL) return code;
wafwerar's avatar
wafwerar 已提交
378

wafwerar's avatar
wafwerar 已提交
379
  while (done != 3 && (size = taosGetsFile(pFile, sizeof(line), line)) != -1) {
wafwerar's avatar
wafwerar 已提交
380 381 382 383 384 385 386 387 388 389 390
    line[size - 1] = '\0';
    if (((done & 1) == 0) && strncmp(line, "model name", 10) == 0) {
      const char *v = strchr(line, ':') + 2;
      tstrncpy(cpuModel, v, maxLen);
      code = 0;
      done |= 1;
    } else if (((done & 2) == 0) && strncmp(line, "cpu cores", 9) == 0) {
      const char *v = strchr(line, ':') + 2;
      *numOfCores = atof(v);
      done |= 2;
    }
wafwerar's avatar
wafwerar 已提交
391
    if (strncmp(line, "processor", 9) == 0) coreCount += 1;
wafwerar's avatar
wafwerar 已提交
392 393 394 395
  }

  taosCloseFile(&pFile);

wafwerar's avatar
wafwerar 已提交
396
  if (code != 0 && (done & 1) == 0) {
wafwerar's avatar
wafwerar 已提交
397 398 399 400 401 402 403 404
    TdFilePtr pFile1 = taosOpenFile("/proc/device-tree/model", TD_FILE_READ | TD_FILE_STREAM);
    if (pFile1 == NULL) return code;
    taosGetsFile(pFile1, maxLen, cpuModel);
    taosCloseFile(&pFile1);
    code = 0;
    done |= 1;
  }

wafwerar's avatar
wafwerar 已提交
405 406 407 408 409 410 411 412 413 414
  if (code != 0 && (done & 1) == 0) {
    TdCmdPtr pCmd = taosOpenCmd("uname -a");
    if (pCmd == NULL) return code;
    if (taosGetsCmd(pCmd, maxLen, cpuModel) > 0) {
      code = 0;
      done |= 1;
    }
    taosCloseCmd(&pCmd);
  }

wafwerar's avatar
wafwerar 已提交
415
  if ((done & 2) == 0) {
H
Hongze Cheng 已提交
416 417
    *numOfCores = coreCount;
    done |= 2;
wafwerar's avatar
wafwerar 已提交
418
  }
H
Hongze Cheng 已提交
419

wafwerar's avatar
wafwerar 已提交
420 421
  return code;
#endif
S
Shengliang Guan 已提交
422 423
}

S
Shengliang Guan 已提交
424
int32_t taosGetCpuCores(float *numOfCores) {
wafwerar's avatar
wafwerar 已提交
425
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
426 427 428 429 430
  SYSTEM_INFO info;
  GetSystemInfo(&info);
  *numOfCores = info.dwNumberOfProcessors;
  return 0;
#elif defined(_TD_DARWIN_64)
S
Shengliang Guan 已提交
431 432
  *numOfCores = sysconf(_SC_NPROCESSORS_ONLN);
  return 0;
wafwerar's avatar
wafwerar 已提交
433 434 435 436
#else
  *numOfCores = sysconf(_SC_NPROCESSORS_ONLN);
  return 0;
#endif
S
Shengliang Guan 已提交
437
}
S
Shengliang Guan 已提交
438

439 440 441 442 443 444 445 446
void taosGetCpuUsage(double *cpu_system, double *cpu_engine) {
  static int64_t lastSysUsed = 0;
  static int64_t lastSysTotal = 0;
  static int64_t lastProcTotal = 0;
  static int64_t curSysUsed = 0;
  static int64_t curSysTotal = 0;
  static int64_t curProcTotal = 0;

S
Shengliang Guan 已提交
447 448
  if (cpu_system != NULL) *cpu_system = 0;
  if (cpu_engine != NULL) *cpu_engine = 0;
S
Shengliang Guan 已提交
449

450 451 452 453 454 455
  SysCpuInfo  sysCpu = {0};
  ProcCpuInfo procCpu = {0};
  if (taosGetSysCpuInfo(&sysCpu) == 0 && taosGetProcCpuInfo(&procCpu) == 0) {
    curSysUsed = sysCpu.user + sysCpu.nice + sysCpu.system;
    curSysTotal = curSysUsed + sysCpu.idle;
    curProcTotal = procCpu.utime + procCpu.stime + procCpu.cutime + procCpu.cstime;
S
Shengliang Guan 已提交
456

457
    if (curSysTotal > lastSysTotal && curSysUsed >= lastSysUsed && curProcTotal >= lastProcTotal) {
S
Shengliang Guan 已提交
458 459 460 461 462 463
      if (cpu_system != NULL) {
        *cpu_system = (curSysUsed - lastSysUsed) / (double)(curSysTotal - lastSysTotal) * 100;
      }
      if (cpu_engine != NULL) {
        *cpu_engine = (curProcTotal - lastProcTotal) / (double)(curSysTotal - lastSysTotal) * 100;
      }
464
    }
S
Shengliang Guan 已提交
465

466 467 468
    lastSysUsed = curSysUsed;
    lastSysTotal = curSysTotal;
    lastProcTotal = curProcTotal;
S
Shengliang Guan 已提交
469 470 471
  }
}

H
Haojun Liao 已提交
472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511
#define __cpuid_fix(level, a, b, c, d) \
              __asm__("xor %%ecx, %%ecx\n" \
                      "cpuid\n" \
                      : "=a"(a), "=b"(b), "=c"(c), "=d"(d) \
                      : "0"(level))

// todo add for windows and mac
int32_t taosGetCpuInstructions(char* sse42, char* avx, char* avx2, char* fma) {
#ifdef WINDOWS
#elif defined(_TD_DARWIN_64)
#else

  // Since the compiler is not support avx/avx2 instructions, the global variables always need to be
  // set to be false
#if __AVX__ || __AVX2__
  tsSIMDEnable = true;
#else
  tsSIMDEnable = false;
#endif

  uint32_t eax = 0, ebx = 0, ecx = 0, edx = 0;

  int32_t ret = __get_cpuid(1, &eax, &ebx, &ecx, &edx);
  if (ret == 0) {
    return -1;  // failed to get the cpuid info
  }

  *sse42 = (char) ((ecx & bit_SSE4_2) == bit_SSE4_2);
  *avx   = (char) ((ecx & bit_AVX) == bit_AVX);
  *fma   = (char) ((ecx & bit_FMA) == bit_FMA);

  // work around a bug in GCC.
  // Ref to https://gcc.gnu.org/bugzilla/show_bug.cgi?id=77756
  __cpuid_fix(7u, eax, ebx, ecx, edx);
  *avx2 = (char) ((ebx & bit_AVX2) == bit_AVX2);
  return 0;

#endif
}

wafwerar's avatar
wafwerar 已提交
512
int32_t taosGetTotalMemory(int64_t *totalKB) {
wafwerar's avatar
wafwerar 已提交
513
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
514 515 516
  MEMORYSTATUSEX memsStat;
  memsStat.dwLength = sizeof(memsStat);
  if (!GlobalMemoryStatusEx(&memsStat)) {
S
Shengliang Guan 已提交
517 518
    return -1;
  }
wafwerar's avatar
wafwerar 已提交
519 520 521 522 523 524 525 526 527

  *totalKB = memsStat.ullTotalPhys / 1024;
  return 0;
#elif defined(_TD_DARWIN_64)
  return 0;
#else
  *totalKB = (int64_t)(sysconf(_SC_PHYS_PAGES) * tsPageSizeKB);
  return 0;
#endif
S
Shengliang Guan 已提交
528 529
}

wafwerar's avatar
wafwerar 已提交
530
int32_t taosGetProcMemory(int64_t *usedKB) {
wafwerar's avatar
wafwerar 已提交
531
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553
  unsigned bytes_used = 0;

#if defined(_WIN64) && defined(_MSC_VER)
  PROCESS_MEMORY_COUNTERS pmc;
  HANDLE                  cur_proc = GetCurrentProcess();

  if (GetProcessMemoryInfo(cur_proc, &pmc, sizeof(pmc))) {
    bytes_used = (unsigned)(pmc.WorkingSetSize + pmc.PagefileUsage);
  }
#endif

  *usedKB = bytes_used / 1024;
  return 0;
#elif defined(_TD_DARWIN_64)
  *usedKB = 0;
  return 0;
#else
  TdFilePtr pFile = taosOpenFile(tsProcMemFile, TD_FILE_READ | TD_FILE_STREAM);
  if (pFile == NULL) {
    // printf("open file:%s failed", tsProcMemFile);
    return -1;
  }
S
Shengliang Guan 已提交
554

H
Haojun Liao 已提交
555 556
  ssize_t bytes = 0;
  char    line[1024] = {0};
557
  while (!taosEOFFile(pFile)) {
H
Haojun Liao 已提交
558 559
    bytes = taosGetsFile(pFile, sizeof(line), line);
    if (bytes < 0) {
S
Shengliang Guan 已提交
560 561
      break;
    }
wafwerar's avatar
wafwerar 已提交
562 563
    if (strstr(line, "VmRSS:") != NULL) {
      break;
S
Shengliang Guan 已提交
564
    }
wafwerar's avatar
wafwerar 已提交
565
  }
S
Shengliang Guan 已提交
566

H
Haojun Liao 已提交
567
  if (strlen(line) < 0) {
wafwerar's avatar
wafwerar 已提交
568 569 570
    // printf("read file:%s failed", tsProcMemFile);
    taosCloseFile(&pFile);
    return -1;
S
Shengliang Guan 已提交
571 572
  }

wafwerar's avatar
wafwerar 已提交
573 574 575
  char tmp[10];
  sscanf(line, "%s %" PRId64, tmp, usedKB);

576
  taosCloseFile(&pFile);
wafwerar's avatar
wafwerar 已提交
577 578 579 580 581
  return 0;
#endif
}

int32_t taosGetSysMemory(int64_t *usedKB) {
wafwerar's avatar
wafwerar 已提交
582
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
583 584 585 586 587
  MEMORYSTATUSEX memsStat;
  memsStat.dwLength = sizeof(memsStat);
  if (!GlobalMemoryStatusEx(&memsStat)) {
    return -1;
  }
S
Shengliang Guan 已提交
588

wafwerar's avatar
wafwerar 已提交
589 590 591 592 593 594 595 596 597 598
  int64_t nMemFree = memsStat.ullAvailPhys / 1024;
  int64_t nMemTotal = memsStat.ullTotalPhys / 1024.0;

  *usedKB = nMemTotal - nMemFree;
  return 0;
#elif defined(_TD_DARWIN_64)
  *usedKB = 0;
  return 0;
#else
  *usedKB = sysconf(_SC_AVPHYS_PAGES) * tsPageSizeKB;
S
monitor  
Shengliang Guan 已提交
599
  return 0;
wafwerar's avatar
wafwerar 已提交
600 601 602 603
#endif
}

int32_t taosGetDiskSize(char *dataDir, SDiskSize *diskSize) {
604
#if defined(WINDOWS)
wafwerar's avatar
wafwerar 已提交
605 606 607 608 609 610 611
  unsigned _int64 i64FreeBytesToCaller;
  unsigned _int64 i64TotalBytes;
  unsigned _int64 i64FreeBytes;

  BOOL fResult = GetDiskFreeSpaceExA(dataDir, (PULARGE_INTEGER)&i64FreeBytesToCaller, (PULARGE_INTEGER)&i64TotalBytes,
                                     (PULARGE_INTEGER)&i64FreeBytes);
  if (fResult) {
612
    diskSize->total = (int64_t)(i64TotalBytes);
wafwerar's avatar
wafwerar 已提交
613 614 615 616 617 618 619 620 621 622 623 624 625 626 627
    diskSize->avail = (int64_t)(i64FreeBytesToCaller);
    diskSize->used = (int64_t)(i64TotalBytes - i64FreeBytes);
    return 0;
  } else {
    // printf("failed to get disk size, dataDir:%s errno:%s", tsDataDir, strerror(errno));
    terrno = TAOS_SYSTEM_ERROR(errno);
    return -1;
  }
#elif defined(_TD_DARWIN_64)
  struct statvfs info;
  if (statvfs(dataDir, &info)) {
    // printf("failed to get disk size, dataDir:%s errno:%s", tsDataDir, strerror(errno));
    terrno = TAOS_SYSTEM_ERROR(errno);
    return -1;
  } else {
628
    diskSize->total = info.f_blocks * info.f_frsize;
wafwerar's avatar
wafwerar 已提交
629 630 631 632 633 634 635
    diskSize->avail = info.f_bavail * info.f_frsize;
    diskSize->used = (info.f_blocks - info.f_bfree) * info.f_frsize;
    return 0;
  }
#else
  struct statvfs info;
  if (statvfs(dataDir, &info)) {
wafwerar's avatar
wafwerar 已提交
636
    terrno = TAOS_SYSTEM_ERROR(errno);
wafwerar's avatar
wafwerar 已提交
637 638 639 640 641 642 643 644
    return -1;
  } else {
    diskSize->total = info.f_blocks * info.f_frsize;
    diskSize->avail = info.f_bavail * info.f_frsize;
    diskSize->used = diskSize->total - diskSize->avail;
    return 0;
  }
#endif
S
Shengliang Guan 已提交
645 646
}

S
monitor  
Shengliang Guan 已提交
647
int32_t taosGetProcIO(int64_t *rchars, int64_t *wchars, int64_t *read_bytes, int64_t *write_bytes) {
wafwerar's avatar
wafwerar 已提交
648
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664
  IO_COUNTERS io_counter;
  if (GetProcessIoCounters(GetCurrentProcess(), &io_counter)) {
    if (rchars) *rchars = io_counter.ReadTransferCount;
    if (wchars) *wchars = io_counter.WriteTransferCount;
    if (read_bytes) *read_bytes = 0;
    if (write_bytes) *write_bytes = 0;
    return 0;
  }
  return -1;
#elif defined(_TD_DARWIN_64)
  if (rchars) *rchars = 0;
  if (wchars) *wchars = 0;
  if (read_bytes) *read_bytes = 0;
  if (write_bytes) *write_bytes = 0;
  return 0;
#else
665
  TdFilePtr pFile = taosOpenFile(tsProcIOFile, TD_FILE_READ | TD_FILE_STREAM);
S
Shengliang Guan 已提交
666
  if (pFile == NULL) return -1;
S
Shengliang Guan 已提交
667

H
Haojun Liao 已提交
668 669
  ssize_t bytes = 0;
  char    line[1024] = {0};
S
Shengliang Guan 已提交
670
  char    tmp[24];
S
Shengliang Guan 已提交
671 672
  int     readIndex = 0;

673
  while (!taosEOFFile(pFile)) {
H
Haojun Liao 已提交
674 675
    bytes = taosGetsFile(pFile, sizeof(line), line);
    if (bytes < 10) {
S
Shengliang Guan 已提交
676 677 678 679 680 681 682 683
      break;
    }
    if (strstr(line, "rchar:") != NULL) {
      sscanf(line, "%s %" PRId64, tmp, rchars);
      readIndex++;
    } else if (strstr(line, "wchar:") != NULL) {
      sscanf(line, "%s %" PRId64, tmp, wchars);
      readIndex++;
S
Shengliang Guan 已提交
684
    } else if (strstr(line, "read_bytes:") != NULL) {  // read_bytes
S
Shengliang Guan 已提交
685 686
      sscanf(line, "%s %" PRId64, tmp, read_bytes);
      readIndex++;
S
Shengliang Guan 已提交
687
    } else if (strstr(line, "write_bytes:") != NULL) {  // write_bytes
S
Shengliang Guan 已提交
688 689
      sscanf(line, "%s %" PRId64, tmp, write_bytes);
      readIndex++;
S
Shengliang Guan 已提交
690
    } else {
S
Shengliang Guan 已提交
691 692
    }

wafwerar's avatar
wafwerar 已提交
693 694 695 696 697 698 699 700 701 702 703 704 705
    if (readIndex >= 4) break;
  }

  taosCloseFile(&pFile);

  if (readIndex < 4) {
    return -1;
  }

  return 0;
#endif
}

706 707 708 709 710 711 712 713 714
void taosGetProcIODelta(int64_t *rchars, int64_t *wchars, int64_t *read_bytes, int64_t *write_bytes) {
  static int64_t last_rchars = 0;
  static int64_t last_wchars = 0;
  static int64_t last_read_bytes = 0;
  static int64_t last_write_bytes = 0;
  static int64_t cur_rchars = 0;
  static int64_t cur_wchars = 0;
  static int64_t cur_read_bytes = 0;
  static int64_t cur_write_bytes = 0;
715
  if (taosGetProcIO(&cur_rchars, &cur_wchars, &cur_read_bytes, &cur_write_bytes) == 0) {
716 717 718 719 720 721 722 723
    *rchars = cur_rchars - last_rchars;
    *wchars = cur_wchars - last_wchars;
    *read_bytes = cur_read_bytes - last_read_bytes;
    *write_bytes = cur_write_bytes - last_write_bytes;
    last_rchars = cur_rchars;
    last_wchars = cur_wchars;
    last_read_bytes = cur_read_bytes;
    last_write_bytes = cur_write_bytes;
724 725 726 727 728
  } else {
    *rchars = 0;
    *wchars = 0;
    *read_bytes = 0;
    *write_bytes = 0;
729 730 731
  }
}

wafwerar's avatar
wafwerar 已提交
732
int32_t taosGetCardInfo(int64_t *receive_bytes, int64_t *transmit_bytes) {
wafwerar's avatar
wafwerar 已提交
733
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
734 735 736 737 738 739 740 741 742 743 744 745
  *receive_bytes = 0;
  *transmit_bytes = 0;
  return 0;
#elif defined(_TD_DARWIN_64)
  *receive_bytes = 0;
  *transmit_bytes = 0;
  return 0;
#else
  TdFilePtr pFile = taosOpenFile(tsSysNetFile, TD_FILE_READ | TD_FILE_STREAM);
  if (pFile == NULL) return -1;

  ssize_t _bytes = 0;
H
Hongze Cheng 已提交
746
  char    line[1024];
wafwerar's avatar
wafwerar 已提交
747 748 749 750 751 752 753 754 755 756 757 758 759 760

  while (!taosEOFFile(pFile)) {
    int64_t o_rbytes = 0;
    int64_t rpackts = 0;
    int64_t o_tbytes = 0;
    int64_t tpackets = 0;
    int64_t nouse1 = 0;
    int64_t nouse2 = 0;
    int64_t nouse3 = 0;
    int64_t nouse4 = 0;
    int64_t nouse5 = 0;
    int64_t nouse6 = 0;
    char    nouse0[200] = {0};

wafwerar's avatar
wafwerar 已提交
761
    _bytes = taosGetsFile(pFile, sizeof(line), line);
wafwerar's avatar
wafwerar 已提交
762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777
    if (_bytes < 0) {
      break;
    }

    line[_bytes - 1] = 0;

    if (strstr(line, "lo:") != NULL) {
      continue;
    }

    sscanf(line,
           "%s %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64 " %" PRId64
           " %" PRId64,
           nouse0, &o_rbytes, &rpackts, &nouse1, &nouse2, &nouse3, &nouse4, &nouse5, &nouse6, &o_tbytes, &tpackets);
    *receive_bytes = o_rbytes;
    *transmit_bytes = o_tbytes;
S
Shengliang Guan 已提交
778 779
  }

780
  taosCloseFile(&pFile);
S
Shengliang Guan 已提交
781

S
io  
Shengliang Guan 已提交
782
  return 0;
wafwerar's avatar
wafwerar 已提交
783
#endif
S
Shengliang Guan 已提交
784 785
}

786 787 788 789 790
void taosGetCardInfoDelta(int64_t *receive_bytes, int64_t *transmit_bytes) {
  static int64_t last_receive_bytes = 0;
  static int64_t last_transmit_bytes = 0;
  static int64_t cur_receive_bytes = 0;
  static int64_t cur_transmit_bytes = 0;
791
  if (taosGetCardInfo(&cur_receive_bytes, &cur_transmit_bytes) == 0) {
792 793 794 795
    *receive_bytes = cur_receive_bytes - last_receive_bytes;
    *transmit_bytes = cur_transmit_bytes - last_transmit_bytes;
    last_receive_bytes = cur_receive_bytes;
    last_transmit_bytes = cur_transmit_bytes;
796 797 798
  } else {
    *receive_bytes = 0;
    *transmit_bytes = 0;
799 800 801
  }
}

wafwerar's avatar
wafwerar 已提交
802
void taosKillSystem() {
wafwerar's avatar
wafwerar 已提交
803
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
804 805 806 807 808 809 810 811 812 813 814 815 816
  printf("function taosKillSystem, exit!");
  exit(0);
#elif defined(_TD_DARWIN_64)
  printf("function taosKillSystem, exit!");
  exit(0);
#else
  // SIGINT
  printf("taosd will shut down soon");
  kill(tsProcId, 2);
#endif
}

int32_t taosGetSystemUUID(char *uid, int32_t uidlen) {
wafwerar's avatar
wafwerar 已提交
817
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
818 819
  GUID guid;
  CoCreateGuid(&guid);
H
Hongze Cheng 已提交
820 821 822
  snprintf(uid, uidlen, "%08X-%04X-%04X-%02X%02X-%02X%02X%02X%02X%02X%02X", guid.Data1, guid.Data2, guid.Data3,
           guid.Data4[0], guid.Data4[1], guid.Data4[2], guid.Data4[3], guid.Data4[4], guid.Data4[5], guid.Data4[6],
           guid.Data4[7]);
wafwerar's avatar
wafwerar 已提交
823 824 825 826

  return 0;
#elif defined(_TD_DARWIN_64)
  uuid_t uuid = {0};
H
Hongze Cheng 已提交
827
  char   buf[37] = {0};
wafwerar's avatar
wafwerar 已提交
828 829
  uuid_generate(uuid);
  // it's caller's responsibility to make enough space for `uid`, that's 36-char + 1-null
wafwerar's avatar
wafwerar 已提交
830 831
  uuid_unparse_lower(uuid, buf);
  memcpy(uid, buf, uidlen);
wafwerar's avatar
wafwerar 已提交
832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854
  return 0;
#else
  int len = 0;

  // fd = open("/proc/sys/kernel/random/uuid", 0);
  TdFilePtr pFile = taosOpenFile("/proc/sys/kernel/random/uuid", TD_FILE_READ);
  if (pFile == NULL) {
    return -1;
  } else {
    len = taosReadFile(pFile, uid, uidlen);
    taosCloseFile(&pFile);
  }

  if (len >= 36) {
    uid[36] = 0;
    return 0;
  }

  return 0;
#endif
}

char *taosGetCmdlineByPID(int pid) {
wafwerar's avatar
wafwerar 已提交
855
#ifdef WINDOWS
856
  assert(0);
wafwerar's avatar
wafwerar 已提交
857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888
  return "";
#elif defined(_TD_DARWIN_64)
  static char cmdline[1024];
  errno = 0;

  if (proc_pidpath(pid, cmdline, sizeof(cmdline)) <= 0) {
    fprintf(stderr, "PID is %d, %s", pid, strerror(errno));
    return strerror(errno);
  }

  return cmdline;
#else
  static char cmdline[1024];
  sprintf(cmdline, "/proc/%d/cmdline", pid);

  // int fd = open(cmdline, O_RDONLY);
  TdFilePtr pFile = taosOpenFile(cmdline, TD_FILE_READ);
  if (pFile != NULL) {
    int n = taosReadFile(pFile, cmdline, sizeof(cmdline) - 1);
    if (n < 0) n = 0;

    if (n > 0 && cmdline[n - 1] == '\n') --n;

    cmdline[n] = 0;

    taosCloseFile(&pFile);
  } else {
    cmdline[0] = 0;
  }

  return cmdline;
#endif
S
Shengliang Guan 已提交
889 890 891
}

void taosSetCoreDump(bool enable) {
wafwerar's avatar
wafwerar 已提交
892
  if (!enable) return;
wafwerar's avatar
wafwerar 已提交
893
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
894 895
  SetUnhandledExceptionFilter(exceptionHandler);
  SetUnhandledExceptionFilter(&FlCrashDump);
wafwerar's avatar
wafwerar 已提交
896 897
#elif defined(_TD_DARWIN_64)
#else
S
Shengliang Guan 已提交
898 899 900 901 902
  // 1. set ulimit -c unlimited
  struct rlimit rlim;
  struct rlimit rlim_new;
  if (getrlimit(RLIMIT_CORE, &rlim) == 0) {
#ifndef _ALPINE
S
Shengliang Guan 已提交
903
    // printf("the old unlimited para: rlim_cur=%" PRIu64 ", rlim_max=%" PRIu64, rlim.rlim_cur, rlim.rlim_max);
S
Shengliang Guan 已提交
904
#else
S
Shengliang Guan 已提交
905
    // printf("the old unlimited para: rlim_cur=%llu, rlim_max=%llu", rlim.rlim_cur, rlim.rlim_max);
S
Shengliang Guan 已提交
906 907 908 909
#endif
    rlim_new.rlim_cur = RLIM_INFINITY;
    rlim_new.rlim_max = RLIM_INFINITY;
    if (setrlimit(RLIMIT_CORE, &rlim_new) != 0) {
S
Shengliang Guan 已提交
910
      // printf("set unlimited fail, error: %s", strerror(errno));
S
Shengliang Guan 已提交
911 912 913 914 915 916 917 918
      rlim_new.rlim_cur = rlim.rlim_max;
      rlim_new.rlim_max = rlim.rlim_max;
      (void)setrlimit(RLIMIT_CORE, &rlim_new);
    }
  }

  if (getrlimit(RLIMIT_CORE, &rlim) == 0) {
#ifndef _ALPINE
S
Shengliang Guan 已提交
919
    // printf("the new unlimited para: rlim_cur=%" PRIu64 ", rlim_max=%" PRIu64, rlim.rlim_cur, rlim.rlim_max);
S
Shengliang Guan 已提交
920
#else
S
Shengliang Guan 已提交
921
    // printf("the new unlimited para: rlim_cur=%llu, rlim_max=%llu", rlim.rlim_cur, rlim.rlim_max);
S
Shengliang Guan 已提交
922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945
#endif
  }

#ifndef _TD_ARM_
  // 2. set the path for saving core file
  struct __sysctl_args args;

  int    old_usespid = 0;
  size_t old_len = 0;
  int    new_usespid = 1;
  size_t new_len = sizeof(new_usespid);

  int name[] = {CTL_KERN, KERN_CORE_USES_PID};

  memset(&args, 0, sizeof(struct __sysctl_args));
  args.name = name;
  args.nlen = sizeof(name) / sizeof(name[0]);
  args.oldval = &old_usespid;
  args.oldlenp = &old_len;
  args.newval = &new_usespid;
  args.newlen = new_len;

  old_len = sizeof(old_usespid);

946
#ifndef __loongarch64
S
Shengliang Guan 已提交
947
  if (syscall(SYS__sysctl, &args) == -1) {
S
Shengliang Guan 已提交
948
    // printf("_sysctl(kern_core_uses_pid) set fail: %s", strerror(errno));
S
Shengliang Guan 已提交
949
  }
950
#endif
S
Shengliang Guan 已提交
951

S
Shengliang Guan 已提交
952
  // printf("The old core_uses_pid[%" PRIu64 "]: %d", old_len, old_usespid);
S
Shengliang Guan 已提交
953 954 955 956 957 958 959 960 961 962 963

  old_usespid = 0;
  old_len = 0;
  memset(&args, 0, sizeof(struct __sysctl_args));
  args.name = name;
  args.nlen = sizeof(name) / sizeof(name[0]);
  args.oldval = &old_usespid;
  args.oldlenp = &old_len;

  old_len = sizeof(old_usespid);

964
#ifndef __loongarch64
S
Shengliang Guan 已提交
965
  if (syscall(SYS__sysctl, &args) == -1) {
S
Shengliang Guan 已提交
966
    // printf("_sysctl(kern_core_uses_pid) get fail: %s", strerror(errno));
S
Shengliang Guan 已提交
967
  }
968
#endif
S
Shengliang Guan 已提交
969

S
Shengliang Guan 已提交
970
  // printf("The new core_uses_pid[%" PRIu64 "]: %d", old_len, old_usespid);
S
Shengliang Guan 已提交
971 972
#endif
#endif
wafwerar's avatar
wafwerar 已提交
973
}
S
Shengliang Guan 已提交
974 975

SysNameInfo taosGetSysNameInfo() {
wafwerar's avatar
wafwerar 已提交
976
#ifdef WINDOWS
wafwerar's avatar
wafwerar 已提交
977
  SysNameInfo info = {0};
H
Hongze Cheng 已提交
978
  DWORD       dwVersion = GetVersion();
wafwerar's avatar
wafwerar 已提交
979

wafwerar's avatar
wafwerar 已提交
980 981 982 983 984
  char *tmp = NULL;
  tmp = getenv("OS");
  if (tmp != NULL) tstrncpy(info.sysname, tmp, sizeof(info.sysname));
  tmp = getenv("COMPUTERNAME");
  if (tmp != NULL) tstrncpy(info.nodename, tmp, sizeof(info.nodename));
wafwerar's avatar
wafwerar 已提交
985 986
  sprintf_s(info.release, sizeof(info.release), "%d", dwVersion & 0x0F);
  sprintf_s(info.version, sizeof(info.release), "%d", (dwVersion >> 8) & 0x0F);
wafwerar's avatar
wafwerar 已提交
987 988
  tmp = getenv("PROCESSOR_ARCHITECTURE");
  if (tmp != NULL) tstrncpy(info.machine, tmp, sizeof(info.machine));
wafwerar's avatar
wafwerar 已提交
989 990

  return info;
wafwerar's avatar
wafwerar 已提交
991
#elif defined(_TD_DARWIN_64)
S
Shengliang Guan 已提交
992 993
  SysNameInfo info = {0};

994 995
  struct utsname uts;
  if (!uname(&uts)) {
H
Haojun Liao 已提交
996 997 998 999 1000
    tstrncpy(info.sysname, uts.sysname, sizeof(info.sysname));
    tstrncpy(info.nodename, uts.nodename, sizeof(info.nodename));
    tstrncpy(info.release, uts.release, sizeof(info.release));
    tstrncpy(info.version, uts.version, sizeof(info.version));
    tstrncpy(info.machine, uts.machine, sizeof(info.machine));
S
Shengliang Guan 已提交
1001 1002 1003
  }

  return info;
wafwerar's avatar
wafwerar 已提交
1004 1005
#else
  SysNameInfo info = {0};
1006

wafwerar's avatar
wafwerar 已提交
1007 1008 1009 1010 1011 1012 1013
  struct utsname uts;
  if (!uname(&uts)) {
    tstrncpy(info.sysname, uts.sysname, sizeof(info.sysname));
    tstrncpy(info.nodename, uts.nodename, sizeof(info.nodename));
    tstrncpy(info.release, uts.release, sizeof(info.release));
    tstrncpy(info.version, uts.version, sizeof(info.version));
    tstrncpy(info.machine, uts.machine, sizeof(info.machine));
1014 1015
  }

wafwerar's avatar
wafwerar 已提交
1016
  return info;
1017
#endif
wafwerar's avatar
wafwerar 已提交
1018
}
wafwerar's avatar
wafwerar 已提交
1019 1020 1021 1022

bool taosCheckCurrentInDll() {
#ifdef WINDOWS
  MEMORY_BASIC_INFORMATION mbi;
H
Hongze Cheng 已提交
1023 1024 1025 1026
  char                     path[PATH_MAX] = {0};
  GetModuleFileName(
      ((VirtualQuery(taosCheckCurrentInDll, &mbi, sizeof(mbi)) != 0) ? (HMODULE)mbi.AllocationBase : NULL), path,
      PATH_MAX);
wafwerar's avatar
wafwerar 已提交
1027
  int strLastIndex = strlen(path);
H
Hongze Cheng 已提交
1028 1029 1030
  if ((path[strLastIndex - 3] == 'd' || path[strLastIndex - 3] == 'D') &&
      (path[strLastIndex - 2] == 'l' || path[strLastIndex - 2] == 'L') &&
      (path[strLastIndex - 1] == 'l' || path[strLastIndex - 1] == 'L')) {
wafwerar's avatar
wafwerar 已提交
1031 1032 1033 1034 1035 1036
    return true;
  }
  return false;
#else
  return false;
#endif
1037
}