#3371

Committed 26 Mar 2024 02:29AM UTC coverage: 12.991% (-38.0%) from 51.035%

Build # #3371

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #25184 from taosdata/fix/3_liaohj

fix(stream): not return error when failing to load stream task meta.

Run Details

15183 of 172261 branches covered (8.81%)

Branch coverage included in aggregate %.

6 of 16 new or added lines in 2 files covered. (37.5%)

91513 existing lines in 374 files now uncovered.

34699 of 211698 relevant lines covered (16.39%)

21051.36 hits per line

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

44.83

/source/libs/audit/src/auditMain.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 "tarray.h"
#include "auditInt.h"
#include "taoserror.h"
#include "thttp.h"
#include "ttime.h"
#include "tjson.h"
#include "tglobal.h"
#include "mnode.h"
#include "audit.h"
#include "osMemory.h"

SAudit tsAudit = {0};
char* tsAuditUri = "/audit";
char* tsAuditBatchUri = "/audit-batch";

int32_t auditInit(const SAuditCfg *pCfg) {
  tsAudit.cfg = *pCfg;
  tsAudit.records = taosArrayInit(0, sizeof(SAuditRecord *));
  taosThreadMutexInit(&tsAudit.lock, NULL);
  return 0;
}

static FORCE_INLINE void auditDeleteRecord(SAuditRecord * record) {
  if (record) {
    taosMemoryFree(record->detail);
    taosMemoryFree(record);
  }
}

void auditCleanup() {
  tsLogFp = NULL;
  taosThreadMutexLock(&tsAudit.lock);
  taosArrayDestroyP(tsAudit.records, (FDelete)auditDeleteRecord);
  taosThreadMutexUnlock(&tsAudit.lock);
  tsAudit.records = NULL;
  taosThreadMutexDestroy(&tsAudit.lock);
}

extern void auditRecordImp(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                          char *detail, int32_t len);
extern void auditAddRecordImp(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                          char *detail, int32_t len);
extern void auditSendRecordsInBatchImp();

void auditRecord(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                char *detail, int32_t len) {
  auditRecordImp(pReq, clusterId, operation, target1, target2, detail, len);
}

void auditAddRecord(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                char *detail, int32_t len) {
  auditAddRecordImp(pReq, clusterId, operation, target1, target2, detail, len);
}

void auditSendRecordsInBatch(){
  auditSendRecordsInBatchImp();
}

#ifndef TD_ENTERPRISE
void auditRecordImp(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                    char *detail, int32_t len) {
}

void auditAddRecordImp(SRpcMsg *pReq, int64_t clusterId, char *operation, char *target1, char *target2, 
                    char *detail, int32_t len) {
}

void auditSendRecordsInBatchImp(){

}
#endif

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
18	#include "tarray.h"
19	#include "auditInt.h"
20	#include "taoserror.h"
21	#include "thttp.h"
22	#include "ttime.h"
23	#include "tjson.h"
24	#include "tglobal.h"
25	#include "mnode.h"
26	#include "audit.h"
27	#include "osMemory.h"
28
29	SAudit tsAudit = {0};
30	char* tsAuditUri = "/audit";
31	char* tsAuditBatchUri = "/audit-batch";
32
33	int32_t auditInit(const SAuditCfg *pCfg) {	2✔
34	tsAudit.cfg = *pCfg;	2✔
35	tsAudit.records = taosArrayInit(0, sizeof(SAuditRecord *));	2✔
36	taosThreadMutexInit(&tsAudit.lock, NULL);	2✔
37	return 0;	2✔
38	}
39
40	static FORCE_INLINE void auditDeleteRecord(SAuditRecord * record) {	×
41	if (record) {	×
42	taosMemoryFree(record->detail);	×
43	taosMemoryFree(record);	×
44	}
45	}	×
46
47	void auditCleanup() {	2✔
48	tsLogFp = NULL;	2✔
49	taosThreadMutexLock(&tsAudit.lock);	2✔
50	taosArrayDestroyP(tsAudit.records, (FDelete)auditDeleteRecord);	2✔
51	taosThreadMutexUnlock(&tsAudit.lock);	2✔
52	tsAudit.records = NULL;	2✔
53	taosThreadMutexDestroy(&tsAudit.lock);	2✔
54	}	2✔
55
56	extern void auditRecordImp(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,
57	char *detail, int32_t len);
58	extern void auditAddRecordImp(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,
59	char *detail, int32_t len);
60	extern void auditSendRecordsInBatchImp();
61
UNCOV 62	void auditRecord(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,	×
63	char *detail, int32_t len) {
UNCOV 64	auditRecordImp(pReq, clusterId, operation, target1, target2, detail, len);	×
UNCOV 65	}	×
66
UNCOV 67	void auditAddRecord(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,	×
68	char *detail, int32_t len) {
UNCOV 69	auditAddRecordImp(pReq, clusterId, operation, target1, target2, detail, len);	×
UNCOV 70	}	×
71
UNCOV 72	void auditSendRecordsInBatch(){	×
UNCOV 73	auditSendRecordsInBatchImp();	×
UNCOV 74	}	×
75
76	#ifndef TD_ENTERPRISE
77	void auditRecordImp(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,
78	char *detail, int32_t len) {
79	}
80
81	void auditAddRecordImp(SRpcMsg pReq, int64_t clusterId, char operation, char target1, char target2,
82	char *detail, int32_t len) {
83	}
84
85	void auditSendRecordsInBatchImp(){
86
87	}
88	#endif

taosdata / TDengine / #3371

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