#3831

Committed 02 Apr 2025 01:14AM UTC coverage: 34.081% (-0.02%) from 34.097%

Build # #3831

Build Type

push

travis-ci

Committed by

happyguoxy

Commit Message

test:alter gcda dir

Run Details

148596 of 599532 branches covered (24.79%)

Branch coverage included in aggregate %.

222550 of 489473 relevant lines covered (45.47%)

1589752.67 hits per line

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

0.0

/source/util/src/tthread.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 _DEFAULT_SOURCE
#include "tthread.h"

TdThread* taosCreateThread(void* (*__start_routine)(void*), void* param) {
  TdThread* pthread = (TdThread*)taosMemoryMalloc(sizeof(TdThread));
  if (pthread == NULL) {
    terrno = TSDB_CODE_OUT_OF_MEMORY;
    return NULL;
  }

  TdThreadAttr thattr;
  (void)taosThreadAttrInit(&thattr);
  (void)taosThreadAttrSetDetachState(&thattr, PTHREAD_CREATE_JOINABLE);
  int32_t ret = taosThreadCreate(pthread, &thattr, __start_routine, param);
  (void)taosThreadAttrDestroy(&thattr);

  if (ret != 0) {
    taosMemoryFree(pthread);
    terrno = TAOS_SYSTEM_ERROR(ret);
    return NULL;
  }
  return pthread;
}

bool taosDestroyThread(TdThread* pthread) {
  if (pthread == NULL) return false;
  if (taosThreadRunning(pthread)) {
    (void)taosThreadCancel(*pthread);
    (void)taosThreadJoin(*pthread, NULL);
  }

  taosMemoryFree(pthread);
  return true;
}

bool taosThreadRunning(TdThread* pthread) {
  if (pthread == NULL) return false;
  int32_t ret = taosThreadKill(*pthread, 0);
  if (ret == ESRCH) return false;
  if (ret == EINVAL) return false;
  // alive
  return true;
}

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 _DEFAULT_SOURCE
17	#include "tthread.h"
18
19	TdThread* taosCreateThread(void* (__start_routine)(void), void* param) {	×
20	TdThread* pthread = (TdThread*)taosMemoryMalloc(sizeof(TdThread));	×
21	if (pthread == NULL) {	×
22	terrno = TSDB_CODE_OUT_OF_MEMORY;	×
23	return NULL;	×
24	}
25
26	TdThreadAttr thattr;
27	(void)taosThreadAttrInit(&thattr);	×
28	(void)taosThreadAttrSetDetachState(&thattr, PTHREAD_CREATE_JOINABLE);	×
29	int32_t ret = taosThreadCreate(pthread, &thattr, __start_routine, param);	×
30	(void)taosThreadAttrDestroy(&thattr);	×
31
32	if (ret != 0) {	×
33	taosMemoryFree(pthread);	×
34	terrno = TAOS_SYSTEM_ERROR(ret);	×
35	return NULL;	×
36	}
37	return pthread;	×
38	}
39
40	bool taosDestroyThread(TdThread* pthread) {	×
41	if (pthread == NULL) return false;	×
42	if (taosThreadRunning(pthread)) {	×
43	(void)taosThreadCancel(*pthread);	×
44	(void)taosThreadJoin(*pthread, NULL);	×
45	}
46
47	taosMemoryFree(pthread);	×
48	return true;	×
49	}
50
51	bool taosThreadRunning(TdThread* pthread) {	×
52	if (pthread == NULL) return false;	×
53	int32_t ret = taosThreadKill(*pthread, 0);	×
54	if (ret == ESRCH) return false;	×
55	if (ret == EINVAL) return false;	×
56	// alive
57	return true;	×
58	}

taosdata / TDengine / #3831

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