#3653

Committed 14 Mar 2025 08:10AM UTC coverage: 22.565% (-41.0%) from 63.596%

Build # #3653

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

feat(keep): support keep on super table level. (#30097)

* Feat: support use keep while create super table.

* Test(keep): add test for create super table with keep option.

* Feat(keep): Add tmsg for create keep.

* Feat(keep): support alter table option keep.

* Fix(keep): Add baisc test for alter table option.

* Fix(keep): memory leek.

* Feat(keep): add keep to metaEntry&metaCache and fix earliestTs with stn keep.

* Test(keep): add some cases for select with stb keep.

* Fix: fix ci core while alter stb.

* Feat(keep): delete expired data in super table level.

* Feat: remove get stb keep while query.

* Fix : build error.

* Revert "Fix : build error."

This reverts commit 0ed66e4e8.

* Revert "Feat(keep): delete expired data in super table level."

This reverts commit 36330f6b4.

* Fix : build errors.

* Feat : support restart taosd.

* Fix : alter table comment problems.

* Test : add tests for super table keep.

* Fix: change sdb stb reserve size.

* Test: add more tests.

* Feat: Disable normal tables and sub tables from setting the keep parameter

* Fix: add more checks to avoid unknown address.

* Docs: Add docs for stable keep.

* Fix: some review changes.

* Fix: review errors.

Run Details

49248 of 302527 branches covered (16.28%)

Branch coverage included in aggregate %.

53 of 99 new or added lines in 12 files covered. (53.54%)

155872 existing lines in 443 files now uncovered.

87359 of 302857 relevant lines covered (28.84%)

570004.22 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/tools/shell/src/shellMain.c

/*
 * 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 __USE_XOPEN
#include "shellInt.h"
#include "shellAuto.h"

extern SShellObj shell;

void shellCrashHandler(int signum, void *sigInfo, void *context) {
  taosIgnSignal(SIGTERM);
  taosIgnSignal(SIGHUP);
  taosIgnSignal(SIGINT);
  taosIgnSignal(SIGBREAK);

#if !defined(WINDOWS)
  taosIgnSignal(SIGBUS);
#endif
  taosIgnSignal(SIGABRT);
  taosIgnSignal(SIGFPE);
  taosIgnSignal(SIGSEGV);
#ifdef USE_REPORT
  tscWriteCrashInfo(signum, sigInfo, context);
#endif
#ifdef _TD_DARWIN_64
  exit(signum);
#elif defined(WINDOWS)
  exit(signum);
#endif
}

int main(int argc, char *argv[]) {
  shell.exit = false;
#ifdef WEBSOCKET
  shell.args.timeout = SHELL_WS_TIMEOUT;
  shell.args.cloud = true;
  shell.args.local = false;
#endif

#if !defined(WINDOWS)
  taosSetSignal(SIGBUS, shellCrashHandler);
#endif
  taosSetSignal(SIGABRT, shellCrashHandler);
  taosSetSignal(SIGFPE, shellCrashHandler);
  taosSetSignal(SIGSEGV, shellCrashHandler);

  if (shellCheckIntSize() != 0) {
    return -1;
  }

  if (shellParseArgs(argc, argv) != 0) {
    return -1;
  }

  if (shell.args.is_version) {
    shellPrintVersion();
    return 0;
  }

  if (shell.args.is_gen_auth) {
    shellGenerateAuth();
    return 0;
  }

  if (shell.args.is_help) {
    shellPrintHelp();
    return 0;
  }
#ifdef WEBSOCKET
  shellCheckConnectMode();
#endif
  if (taos_init() != 0) {
    return -1;
  }

  // kill heart-beat thread when quit
  taos_set_hb_quit(1);

#ifndef TD_ASTRA
  if (shell.args.is_dump_config) {
    shellDumpConfig();
    taos_cleanup();
    return 0;
  }

  if (shell.args.is_startup || shell.args.is_check) {
    shellCheckServerStatus();
    taos_cleanup();
    return 0;
  }

  if (shell.args.netrole != NULL) {
    shellTestNetWork();
    taos_cleanup();
    return 0;
  }
#endif
  // support port feature
  shellAutoInit();
  int32_t ret = shellExecute(argc, argv);
  shellAutoExit();
  return ret;
}

1	/*
2	* Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3	*
4	* This program is free software: you can use, redistribute, and/or modify
5	* it under the terms of the GNU Affero General Public License, version 3
6	* or later ("AGPL"), as published by the Free Software Foundation.
7	*
8	* This program is distributed in the hope that it will be useful, but WITHOUT
9	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10	* FITNESS FOR A PARTICULAR PURPOSE.
11	*
12	* You should have received a copy of the GNU Affero General Public License
13	* along with this program. If not, see <http://www.gnu.org/licenses/>.
14	*/
15
16	#define __USE_XOPEN
17	#include "shellInt.h"
18	#include "shellAuto.h"
19
20	extern SShellObj shell;
21
22	void shellCrashHandler(int signum, void sigInfo, void context) {	×
23	taosIgnSignal(SIGTERM);	×
24	taosIgnSignal(SIGHUP);	×
25	taosIgnSignal(SIGINT);	×
26	taosIgnSignal(SIGBREAK);	×
27
28	#if !defined(WINDOWS)
29	taosIgnSignal(SIGBUS);	×
30	#endif
31	taosIgnSignal(SIGABRT);	×
32	taosIgnSignal(SIGFPE);	×
33	taosIgnSignal(SIGSEGV);	×
34	#ifdef USE_REPORT
35	tscWriteCrashInfo(signum, sigInfo, context);	×
36	#endif
37	#ifdef _TD_DARWIN_64
38	exit(signum);
39	#elif defined(WINDOWS)
40	exit(signum);
41	#endif
42	}	×
43
UNCOV 44	int main(int argc, char *argv[]) {	×
UNCOV 45	shell.exit = false;	×
46	#ifdef WEBSOCKET
UNCOV 47	shell.args.timeout = SHELL_WS_TIMEOUT;	×
UNCOV 48	shell.args.cloud = true;	×
UNCOV 49	shell.args.local = false;	×
50	#endif
51
52	#if !defined(WINDOWS)
UNCOV 53	taosSetSignal(SIGBUS, shellCrashHandler);	×
54	#endif
UNCOV 55	taosSetSignal(SIGABRT, shellCrashHandler);	×
UNCOV 56	taosSetSignal(SIGFPE, shellCrashHandler);	×
UNCOV 57	taosSetSignal(SIGSEGV, shellCrashHandler);	×
58
UNCOV 59	if (shellCheckIntSize() != 0) {	×
60	return -1;	×
61	}
62
UNCOV 63	if (shellParseArgs(argc, argv) != 0) {	×
UNCOV 64	return -1;	×
65	}
66
UNCOV 67	if (shell.args.is_version) {	×
68	shellPrintVersion();	×
69	return 0;	×
70	}
71
UNCOV 72	if (shell.args.is_gen_auth) {	×
UNCOV 73	shellGenerateAuth();	×
UNCOV 74	return 0;	×
75	}
76
UNCOV 77	if (shell.args.is_help) {	×
78	shellPrintHelp();	×
79	return 0;	×
80	}
81	#ifdef WEBSOCKET
UNCOV 82	shellCheckConnectMode();	×
83	#endif
UNCOV 84	if (taos_init() != 0) {	×
UNCOV 85	return -1;	×
86	}
87
88	// kill heart-beat thread when quit
UNCOV 89	taos_set_hb_quit(1);	×
90
91	#ifndef TD_ASTRA
UNCOV 92	if (shell.args.is_dump_config) {	×
UNCOV 93	shellDumpConfig();	×
UNCOV 94	taos_cleanup();	×
UNCOV 95	return 0;	×
96	}
97
UNCOV 98	if (shell.args.is_startup \|\| shell.args.is_check) {	×
UNCOV 99	shellCheckServerStatus();	×
UNCOV 100	taos_cleanup();	×
UNCOV 101	return 0;	×
102	}
103
UNCOV 104	if (shell.args.netrole != NULL) {	×
UNCOV 105	shellTestNetWork();	×
UNCOV 106	taos_cleanup();	×
UNCOV 107	return 0;	×
108	}
109	#endif
110	// support port feature
UNCOV 111	shellAutoInit();	×
UNCOV 112	int32_t ret = shellExecute(argc, argv);	×
UNCOV 113	shellAutoExit();	×
UNCOV 114	return ret;	×
115	}

taosdata / TDengine / #3653

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous