#3599

Committed 08 Feb 2025 11:23AM UTC coverage: 1.77% (-61.6%) from 63.396%

Build # #3599

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #29712 from taosdata/fix/TD-33652-3.0

fix: reduce write rows from 30w to 3w

Run Details

3776 of 278949 branches covered (1.35%)

Branch coverage included in aggregate %.

6012 of 274147 relevant lines covered (2.19%)

1642.73 hits per line

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

0.0

/source/dnode/vnode/src/vnd/vnodeModule.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/>.
 */

#include "cos.h"
#include "monitor.h"
#include "tsdb.h"
#include "vnd.h"

static volatile int32_t VINIT = 0;

int vnodeInit(StopDnodeFp stopDnodeFp) {
  if (atomic_val_compare_exchange_32(&VINIT, 0, 1)) {
    return 0;
  }

  TAOS_CHECK_RETURN(vnodeAsyncOpen());
  TAOS_CHECK_RETURN(walInit(stopDnodeFp));

  monInitVnode();

  return 0;
}

void vnodeCleanup() {
  if (atomic_val_compare_exchange_32(&VINIT, 1, 0) == 0) return;
  vnodeAsyncClose();
  walCleanUp();
  smaCleanUp();
}

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	#include "cos.h"
17	#include "monitor.h"
18	#include "tsdb.h"
19	#include "vnd.h"
20
21	static volatile int32_t VINIT = 0;
22
23	int vnodeInit(StopDnodeFp stopDnodeFp) {	×
24	if (atomic_val_compare_exchange_32(&VINIT, 0, 1)) {	×
25	return 0;	×
26	}
27
28	TAOS_CHECK_RETURN(vnodeAsyncOpen());	×
29	TAOS_CHECK_RETURN(walInit(stopDnodeFp));	×
30
31	monInitVnode();	×
32
33	return 0;	×
34	}
35
36	void vnodeCleanup() {	×
37	if (atomic_val_compare_exchange_32(&VINIT, 1, 0) == 0) return;	×
38	vnodeAsyncClose();	×
39	walCleanUp();	×
40	smaCleanUp();	×
41	}

taosdata / TDengine / #3599

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