vnodeInt.h 2.6 KB
Newer Older
H
save  
Hongze Cheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * 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/>.
 */

H
refact  
Hongze Cheng 已提交
16 17
#ifndef _TD_VNODE_DEF_H_
#define _TD_VNODE_DEF_H_
H
save  
Hongze Cheng 已提交
18

H
Hongze Cheng 已提交
19
#include "executor.h"
H
Hongze Cheng 已提交
20 21 22
#include "filter.h"
#include "qworker.h"
#include "sync.h"
H
Hongze Cheng 已提交
23
#include "tchecksum.h"
H
more  
Hongze Cheng 已提交
24
#include "tcoding.h"
H
Hongze Cheng 已提交
25
#include "tcompare.h"
H
Hongze Cheng 已提交
26
#include "tcompression.h"
L
Liu Jicong 已提交
27
#include "tdatablock.h"
H
refact  
Hongze Cheng 已提交
28
#include "tdbInt.h"
H
Hongze Cheng 已提交
29
#include "tencode.h"
H
refact  
Hongze Cheng 已提交
30
#include "tfs.h"
H
Hongze Cheng 已提交
31
#include "tglobal.h"
H
Hongze Cheng 已提交
32
#include "tjson.h"
H
Hongze Cheng 已提交
33
#include "tlist.h"
H
refact  
Hongze Cheng 已提交
34
#include "tlockfree.h"
H
Hongze Cheng 已提交
35
#include "tlosertree.h"
H
Hongze Cheng 已提交
36
#include "tmallocator.h"
H
Hongze Cheng 已提交
37
#include "tskiplist.h"
H
Hongze Cheng 已提交
38
#include "tstream.h"
H
Hongze Cheng 已提交
39
#include "ttime.h"
H
Hongze Cheng 已提交
40 41
#include "ttimer.h"
#include "wal.h"
H
save  
Hongze Cheng 已提交
42

H
Hongze Cheng 已提交
43 44
#include "vnode.h"

H
save  
Hongze Cheng 已提交
45 46 47 48
#ifdef __cplusplus
extern "C" {
#endif

H
Hongze Cheng 已提交
49
typedef struct SVnodeInfo   SVnodeInfo;
H
Hongze Cheng 已提交
50 51 52
typedef struct SMeta        SMeta;
typedef struct STsdb        STsdb;
typedef struct STQ          STQ;
H
Hongze Cheng 已提交
53 54 55
typedef struct SVState      SVState;
typedef struct SVBufPool    SVBufPool;
typedef struct SQWorkerMgmt SQHandle;
H
refact  
Hongze Cheng 已提交
56

H
Hongze Cheng 已提交
57 58 59 60 61
#define VNODE_META_DIR "meta"
#define VNODE_TSDB_DIR "tsdb"
#define VNODE_TQ_DIR   "tq"
#define VNODE_WAL_DIR  "wal"

L
Liu Jicong 已提交
62 63 64 65 66 67 68 69 70 71 72 73 74 75 76
typedef struct {
  int8_t  streamType;  // sma or other
  int8_t  dstType;
  int16_t padding;
  int32_t smaId;
  int64_t tbUid;
  int64_t lastReceivedVer;
  int64_t lastCommittedVer;
} SStreamSinkInfo;

typedef struct {
  SVnode*   pVnode;
  SHashObj* pHash;  // streamId -> SStreamSinkInfo
} SSink;

H
refact  
Hongze Cheng 已提交
77 78 79 80 81 82 83
// SVState
struct SVState {
  int64_t processed;
  int64_t committed;
  int64_t applied;
};

H
Hongze Cheng 已提交
84 85 86 87 88
struct SVnodeInfo {
  SVnodeCfg config;
  SVState   state;
};

H
save  
Hongze Cheng 已提交
89
struct SVnode {
H
refact  
Hongze Cheng 已提交
90 91 92
  char*      path;
  SVnodeCfg  config;
  SVState    state;
H
Hongze Cheng 已提交
93 94
  STfs*      pTfs;
  SMsgCb     msgCb;
H
Hongze Cheng 已提交
95 96 97 98
  SVBufPool* pPool;
  SVBufPool* inUse;
  SVBufPool* onCommit;
  SVBufPool* onRecycle;
H
refact  
Hongze Cheng 已提交
99 100 101
  SMeta*     pMeta;
  STsdb*     pTsdb;
  SWal*      pWal;
L
Liu Jicong 已提交
102 103
  STQ*       pTq;
  SSink*     pSink;
H
refact  
Hongze Cheng 已提交
104 105
  tsem_t     canCommit;
  SQHandle*  pQuery;
H
save  
Hongze Cheng 已提交
106 107
};

H
refact  
Hongze Cheng 已提交
108 109
#define TD_VID(PVNODE) (PVNODE)->config.vgId

L
Liu Jicong 已提交
110
// sma
L
Liu Jicong 已提交
111
void smaHandleRes(void* pVnode, int64_t smaId, const SArray* data);
L
Liu Jicong 已提交
112

H
Hongze Cheng 已提交
113 114
#include "vnd.h"

H
Hongze Cheng 已提交
115 116 117 118 119 120
#include "meta.h"

#include "tsdb.h"

#include "tq.h"

H
save  
Hongze Cheng 已提交
121 122 123 124
#ifdef __cplusplus
}
#endif

L
Liu Jicong 已提交
125
#endif /*_TD_VNODE_DEF_H_*/