mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
51 lines
No EOL
1.7 KiB
C
51 lines
No EOL
1.7 KiB
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 "os.h"
|
|
#include "tstep.h"
|
|
#include "vnodeMain.h"
|
|
#include "vnodeMgmt.h"
|
|
#include "vnodeRead.h"
|
|
#include "vnodeWorker.h"
|
|
#include "vnodeWrite.h"
|
|
|
|
static struct {
|
|
struct SSteps *steps;
|
|
SVnodeFp fp;
|
|
} tsVint;
|
|
|
|
int32_t vnodeInit(SVnodePara para) {
|
|
tsVint.fp = para.fp;
|
|
|
|
struct SSteps *steps = taosStepInit(8, NULL);
|
|
if (steps == NULL) return -1;
|
|
|
|
taosStepAdd(steps, "vnode-main", vnodeInitMain, vnodeCleanupMain);
|
|
taosStepAdd(steps, "vnode-worker",vnodeInitWorker, vnodeCleanupWorker);
|
|
taosStepAdd(steps, "vnode-read", vnodeInitRead, vnodeCleanupRead);
|
|
taosStepAdd(steps, "vnode-mgmt", vnodeInitMgmt, vnodeCleanupMgmt);
|
|
taosStepAdd(steps, "vnode-write", vnodeInitWrite, vnodeCleanupWrite);
|
|
// taosStepAdd(steps, "vnode-queue", tsdbInitCommitQueue, tsdbDestroyCommitQueue);
|
|
|
|
tsVint.steps = steps;
|
|
return taosStepExec(tsVint.steps);
|
|
}
|
|
|
|
void vnodeCleanup() { taosStepCleanup(tsVint.steps); }
|
|
|
|
void vnodeGetDnodeEp(int32_t dnodeId, char *ep, char *fqdn, uint16_t *port) {
|
|
return (*tsVint.fp.GetDnodeEp)(dnodeId, ep, fqdn, port);
|
|
} |