#3364

Committed 19 Mar 2024 08:44AM UTC coverage: 65.771% (-0.3%) from 66.083%

Build # #3364

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

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

fix(stream):adjust current offset by using the scanning version, not …

Run Details

91234 of 173099 branches covered (52.71%)

Branch coverage included in aggregate %.

9 of 9 new or added lines in 4 files covered. (100.0%)

5628 existing lines in 117 files now uncovered.

162744 of 213054 relevant lines covered (76.39%)

2650125.89 hits per line

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

77.08

/source/dnode/vnode/src/meta/metaCommit.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 "meta.h"

static FORCE_INLINE void *metaMalloc(void *pPool, size_t size) {
  return vnodeBufPoolMallocAligned((SVBufPool *)pPool, size);
}
static FORCE_INLINE void metaFree(void *pPool, void *p) { vnodeBufPoolFree((SVBufPool *)pPool, p); }

// begin a meta txn
int metaBegin(SMeta *pMeta, int8_t heap) {
  void *(*xMalloc)(void *, size_t) = NULL;
  void (*xFree)(void *, void *) = NULL;
  void *xArg = NULL;

  // default heap to META_BEGIN_HEAP_NIL
  if (heap == META_BEGIN_HEAP_OS) {
    xMalloc = tdbDefaultMalloc;
    xFree = tdbDefaultFree;
  } else if (heap == META_BEGIN_HEAP_BUFFERPOOL) {
    xMalloc = metaMalloc;
    xFree = metaFree;
    xArg = pMeta->pVnode->inUse;
  }

  if (tdbBegin(pMeta->pEnv, &pMeta->txn, xMalloc, xFree, xArg, TDB_TXN_WRITE | TDB_TXN_READ_UNCOMMITTED) < 0) {
    return -1;
  }

  tdbCommit(pMeta->pEnv, pMeta->txn);

  return 0;
}

// commit the meta txn
TXN *metaGetTxn(SMeta *pMeta) { return pMeta->txn; }
int  metaCommit(SMeta *pMeta, TXN *txn) { return tdbCommit(pMeta->pEnv, txn); }
int  metaFinishCommit(SMeta *pMeta, TXN *txn) { return tdbPostCommit(pMeta->pEnv, txn); }
int  metaPrepareAsyncCommit(SMeta *pMeta) {
   // return tdbPrepareAsyncCommit(pMeta->pEnv, pMeta->txn);
  int code = 0;
  metaWLock(pMeta);
  code = ttlMgrFlush(pMeta->pTtlMgr, pMeta->txn);
  metaULock(pMeta);
  code = tdbCommit(pMeta->pEnv, pMeta->txn);
  pMeta->changed = false;
  return code;
}

// abort the meta txn
int metaAbort(SMeta *pMeta) {
  if (!pMeta->txn) return 0;
  int code = tdbAbort(pMeta->pEnv, pMeta->txn);
  if (code) {
    metaError("vgId:%d, failed to abort meta since %s", TD_VID(pMeta->pVnode), tstrerror(terrno));
  } else {
    pMeta->txn = NULL;
  }

  return code;
}

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 "meta.h"
17
18	static FORCE_INLINE void metaMalloc(void pPool, size_t size) {	1,618✔
19	return vnodeBufPoolMallocAligned((SVBufPool *)pPool, size);	1,618✔
20	}
21	static FORCE_INLINE void metaFree(void pPool, void p) { vnodeBufPoolFree((SVBufPool *)pPool, p); }	1,618✔
22
23	// begin a meta txn
24	int metaBegin(SMeta *pMeta, int8_t heap) {	9,323✔
25	void (xMalloc)(void *, size_t) = NULL;	9,323✔
26	void (xFree)(void , void *) = NULL;	9,323✔
27	void *xArg = NULL;	9,323✔
28
29	// default heap to META_BEGIN_HEAP_NIL
30	if (heap == META_BEGIN_HEAP_OS) {	9,323!
31	xMalloc = tdbDefaultMalloc;	×
32	xFree = tdbDefaultFree;	×
33	} else if (heap == META_BEGIN_HEAP_BUFFERPOOL) {	9,323!
34	xMalloc = metaMalloc;	9,326✔
35	xFree = metaFree;	9,326✔
36	xArg = pMeta->pVnode->inUse;	9,326✔
37	}
38
39	if (tdbBegin(pMeta->pEnv, &pMeta->txn, xMalloc, xFree, xArg, TDB_TXN_WRITE \| TDB_TXN_READ_UNCOMMITTED) < 0) {	9,323!
40	return -1;	×
41	}
42
43	tdbCommit(pMeta->pEnv, pMeta->txn);	9,323✔
44
45	return 0;	9,328✔
46	}
47
48	// commit the meta txn
49	TXN metaGetTxn(SMeta pMeta) { return pMeta->txn; }	4,688✔
50	int metaCommit(SMeta pMeta, TXN txn) { return tdbCommit(pMeta->pEnv, txn); }	2✔
51	int metaFinishCommit(SMeta pMeta, TXN txn) { return tdbPostCommit(pMeta->pEnv, txn); }	4,690✔
52	int metaPrepareAsyncCommit(SMeta *pMeta) {	4,688✔
53	// return tdbPrepareAsyncCommit(pMeta->pEnv, pMeta->txn);
54	int code = 0;	4,688✔
55	metaWLock(pMeta);	4,688✔
56	code = ttlMgrFlush(pMeta->pTtlMgr, pMeta->txn);	4,688✔
57	metaULock(pMeta);	4,687✔
58	code = tdbCommit(pMeta->pEnv, pMeta->txn);	4,688✔
59	pMeta->changed = false;	4,654✔
60	return code;	4,654✔
61	}
62
63	// abort the meta txn
64	int metaAbort(SMeta *pMeta) {	4,638✔
65	if (!pMeta->txn) return 0;	4,638!
66	int code = tdbAbort(pMeta->pEnv, pMeta->txn);	4,638✔
67	if (code) {	4,637!
UNCOV 68	metaError("vgId:%d, failed to abort meta since %s", TD_VID(pMeta->pVnode), tstrerror(terrno));	×
69	} else {
70	pMeta->txn = NULL;	4,637✔
71	}
72
73	return code;	4,637✔
74	}

taosdata / TDengine / #3364

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