mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
5ce61e1f29
* feat(xnode): support token auth when creating XNODE Closes [6725312703](https://project.feishu.cn/taosdata_td/feature/detail/6725312703) * chore: clean code & fix xnode transactions issues * chore: fix alter xnode job memory leak * fix: update workflow reference to use specific commit for new framework test --------- Co-authored-by: chenhaoran <haoran920c@163.com>
104 lines
3.2 KiB
C
104 lines
3.2 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/>.
|
|
*/
|
|
|
|
#ifndef _TD_XNODE_H_
|
|
#define _TD_XNODE_H_
|
|
|
|
/** cflags: -L../../common/ */
|
|
#include "common/tmsgcb.h"
|
|
#include "tglobal.h"
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
// clang-format off
|
|
|
|
#define xndFatal(...) do { if (xndDebugFlag & DEBUG_FATAL) { taosPrintLog("XND FATAL ", DEBUG_FATAL, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
#define xndError(...) do { if (xndDebugFlag & DEBUG_ERROR) { taosPrintLog("XND ERROR ", DEBUG_ERROR, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
#define xndWarn(...) do { if (xndDebugFlag & DEBUG_WARN) { taosPrintLog("XND WARN ", DEBUG_WARN, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
#define xndInfo(...) do { if (xndDebugFlag & DEBUG_INFO) { taosPrintLog("XND INFO ", DEBUG_INFO, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
#define xndDebug(...) do { if (xndDebugFlag & DEBUG_DEBUG) { taosPrintLog("XND DEBUG ", DEBUG_DEBUG, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
#define xndTrace(...) do { if (xndDebugFlag & DEBUG_TRACE) { taosPrintLog("XND TRACE ", DEBUG_TRACE, xndDebugFlag, __VA_ARGS__);}} while (0)
|
|
|
|
// clang-format on
|
|
|
|
/* ------------------------ TYPES EXPOSED ------------------------ */
|
|
#ifndef XNODE_USER_PASS_LEN
|
|
#define XNODE_USER_PASS_LEN (TSDB_USER_LEN + TSDB_USER_PASSWORD_LONGLEN + 16)
|
|
#endif
|
|
|
|
#define XNODED_MGMT_LISTEN_PIPE_NAME_LEN 32
|
|
#ifdef _WIN32
|
|
#define XNODED_MGMT_LISTEN_PIPE_NAME_PREFIX "\\\\?\\pipe\\taosxnode.sock"
|
|
#else
|
|
#define XNODED_MGMT_LISTEN_PIPE_NAME_PREFIX "." CUS_PROMPT "xnoded.sock"
|
|
#endif
|
|
|
|
typedef struct SXnode SXnode;
|
|
|
|
typedef struct {
|
|
SMsgCb msgCb;
|
|
int32_t dnodeId;
|
|
int64_t clusterId;
|
|
int32_t proto;
|
|
int32_t upLen;
|
|
char userPass[XNODE_USER_PASS_LEN];
|
|
char token[TSDB_TOKEN_LEN + 1];
|
|
SEp ep;
|
|
char machineId[TSDB_MACHINE_ID_LEN + 1];
|
|
} SXnodeOpt;
|
|
|
|
struct SXnode {
|
|
SMsgCb msgCb;
|
|
int8_t protocol;
|
|
int32_t dnodeId;
|
|
int64_t clusterId;
|
|
int32_t proto;
|
|
int32_t upLen;
|
|
char userPass[XNODE_USER_PASS_LEN];
|
|
char token[TSDB_TOKEN_LEN + 1];
|
|
SEp ep;
|
|
};
|
|
|
|
/* ------------------------ SXnode ------------------------ */
|
|
/**
|
|
* @brief Start one Xnode in Dnode.
|
|
*
|
|
* @param pOption Option of the qnode.
|
|
* @param pXnode The qnode object.
|
|
* @return int32_t The error code.
|
|
*/
|
|
int32_t xndOpen(const SXnodeOpt *pOption, SXnode **pXnode);
|
|
|
|
/**
|
|
* @brief Stop Xnode in Dnode.
|
|
*
|
|
* @param pXnode The qnode object to close.
|
|
*/
|
|
void xndClose(SXnode *pXnode);
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
int32_t mndOpenXnd(const SXnodeOpt *pOption);
|
|
void mndCloseXnd();
|
|
|
|
void getXnodedPipeName(char *pipeName, int32_t size);
|
|
|
|
int32_t mndXnodeCreateDefaultToken(SRpcMsg* pReq, char** ppToken);
|
|
|
|
#endif /*_TD_XNODE_H_*/
|