diff --git a/include/server/dnode/dnode.h b/include/server/dnode/dnode.h deleted file mode 100644 index bc0d1e89b00be24dedd2b036c66d42d02ff2fbcc..0000000000000000000000000000000000000000 --- a/include/server/dnode/dnode.h +++ /dev/null @@ -1,79 +0,0 @@ -/* - * Copyright (c) 2019 TAOS Data, Inc. - * - * 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 . - */ - -#ifndef _TD_DNODE_H_ -#define _TD_DNODE_H_ - -#ifdef __cplusplus -extern "C" { -#endif - -struct SRpcEpSet; -struct SRpcMsg; -/** - * Initialize and start the dnode module. - * - * @return Error code. - */ -int32_t dnodeInit(); - -/** - * Stop and cleanup dnode module. - */ -void dnodeCleanup(); - -/** - * Send messages to other dnodes, such as create vnode message. - * - * @param epSet, the endpoint list of the dnodes. - * @param rpcMsg, message to be sent. - */ -void dnodeSendMsgToDnode(struct SRpcEpSet *epSet, struct SRpcMsg *rpcMsg); - -/** - * Send messages to mnode, such as config message. - * - * @param rpcMsg, message to be sent. - */ -void dnodeSendMsgToMnode(struct SRpcMsg *rpcMsg); - -/** - * Send redirect message to dnode or shell. - * - * @param rpcMsg, message to be sent. - * @param forShell, used to identify whether to send to shell or dnode. - */ -void dnodeSendRedirectMsg(struct SRpcMsg *rpcMsg, bool forShell); - -/** - * Get the corresponding endpoint information from dnodeId. - * - * @param dnodeId, the id ot dnode. - * @param ep, the endpoint of dnode. - * @param fqdn, the fqdn of dnode. - * @param port, the port of dnode. - */ -void dnodeGetEp(int32_t dnodeId, char *ep, char *fqdn, uint16_t *port); - -/** - * Report the startup progress. - */ -void dnodeReportStartup(char *name, char *desc); - -#ifdef __cplusplus -} -#endif - -#endif /*_TD_DNODE_H_*/ diff --git a/source/dnode/mgmt/inc/dnodeInt.h b/source/dnode/mgmt/inc/dnodeInt.h index 85f474a391cbb8496ade003aff113418c07e8c15..20257140d6ed3a7ecd300f41a739c64c478f59a1 100644 --- a/source/dnode/mgmt/inc/dnodeInt.h +++ b/source/dnode/mgmt/inc/dnodeInt.h @@ -25,7 +25,6 @@ extern "C" { #include "tlog.h" #include "trpc.h" #include "ttimer.h" -#include "dnode.h" extern int32_t dDebugFlag; @@ -38,6 +37,9 @@ extern int32_t dDebugFlag; typedef enum { DN_RUN_STAT_INIT, DN_RUN_STAT_RUNNING, DN_RUN_STAT_STOPPED } EDnStat; +int32_t dnodeInit(); +void dnodeCleanup(); + EDnStat dnodeGetRunStat(); void dnodeSetRunStat(); void dnodeGetStartup(SStartupStep *); diff --git a/source/dnode/mgmt/src/dnodeMain.c b/source/dnode/mgmt/src/dnodeMain.c index 67e8e7bc5851de5c2f653065fc7a7825a6578df7..c41acc685360859b7d2aeee5e7ca80a46c2add27 100644 --- a/source/dnode/mgmt/src/dnodeMain.c +++ b/source/dnode/mgmt/src/dnodeMain.c @@ -14,7 +14,7 @@ */ #include "os.h" #include "ulog.h" -#include "dnode.h" +#include "dnodeInt.h" static bool stop = false; static void sigintHandler(int32_t signum, void *info, void *ctx) { stop = true; }