mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
104 lines
3.9 KiB
C
104 lines
3.9 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_TXNODE_H_
|
||
|
|
#define _TD_TXNODE_H_
|
||
|
|
|
||
|
|
#undef malloc
|
||
|
|
#define malloc malloc
|
||
|
|
#undef free
|
||
|
|
#define free free
|
||
|
|
#undef realloc
|
||
|
|
#define alloc alloc
|
||
|
|
|
||
|
|
#include <stdbool.h>
|
||
|
|
#include <stdint.h>
|
||
|
|
#include "dnode/xnode/xnode.h"
|
||
|
|
#include "tcommon.h"
|
||
|
|
#include "tdatablock.h"
|
||
|
|
#include "tmsg.h"
|
||
|
|
|
||
|
|
#ifdef __cplusplus
|
||
|
|
extern "C" {
|
||
|
|
#endif
|
||
|
|
|
||
|
|
#define TAOS_UV_LIB_ERROR_RET(ret) \
|
||
|
|
do { \
|
||
|
|
if (0 != ret) { \
|
||
|
|
terrno = TSDB_CODE_BNODE_UV_EXEC_FAILURE; \
|
||
|
|
return TSDB_CODE_BNODE_UV_EXEC_FAILURE; \
|
||
|
|
} \
|
||
|
|
} while (0)
|
||
|
|
|
||
|
|
#define TAOS_UV_CHECK_ERRNO(CODE) \
|
||
|
|
do { \
|
||
|
|
if (0 != CODE) { \
|
||
|
|
terrln = __LINE__; \
|
||
|
|
terrno = (CODE); \
|
||
|
|
goto _exit; \
|
||
|
|
} \
|
||
|
|
} while (0)
|
||
|
|
|
||
|
|
#define TAOS_XNODED_MGMT_CHECK_PTR_RCODE(...) \
|
||
|
|
do { \
|
||
|
|
const void *ptrs[] = {__VA_ARGS__}; \
|
||
|
|
for (int i = 0; i < sizeof(ptrs) / sizeof(ptrs[0]); ++i) { \
|
||
|
|
if (ptrs[i] == NULL) { \
|
||
|
|
xndError("taosxnode %dth parameter invalid, NULL PTR.line:%d", i, __LINE__); \
|
||
|
|
return TSDB_CODE_INVALID_PARA; \
|
||
|
|
} \
|
||
|
|
} \
|
||
|
|
} while (0)
|
||
|
|
|
||
|
|
#define TAOS_XNODED_MGMT_CHECK_PTR_RVOID(...) \
|
||
|
|
do { \
|
||
|
|
const void *ptrs[] = {__VA_ARGS__}; \
|
||
|
|
for (int i = 0; i < sizeof(ptrs) / sizeof(ptrs[0]); ++i) { \
|
||
|
|
if (ptrs[i] == NULL) { \
|
||
|
|
xndError("taosxnode %dth parameter invalid, NULL PTR.line:%d", i, __LINE__); \
|
||
|
|
return; \
|
||
|
|
} \
|
||
|
|
} \
|
||
|
|
} while (0)
|
||
|
|
|
||
|
|
#define TAOS_XNODED_MGMT_CHECK_CONDITION(o, code) \
|
||
|
|
do { \
|
||
|
|
if ((o) == false) { \
|
||
|
|
xndError("Condition not met.line:%d", __LINE__); \
|
||
|
|
return code; \
|
||
|
|
} \
|
||
|
|
} while (0)
|
||
|
|
|
||
|
|
/**
|
||
|
|
* start taosmqtt that serves mqtt function invocation under dnode startDnodeId
|
||
|
|
* @param startDnodeId
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
// int32_t xnodeMgmtStartXnoded(int32_t startDnodeId, int64_t clusterId, int32_t uplen, const char *userPass);
|
||
|
|
int32_t xnodeMgmtStartXnoded(SXnode *pXnode);
|
||
|
|
/**
|
||
|
|
* stop taosmqtt
|
||
|
|
* @return
|
||
|
|
*/
|
||
|
|
void xnodeMgmtStopXnoded(void);
|
||
|
|
|
||
|
|
#ifdef __cplusplus
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
void getXnodedPipeName(char *pipeName, int32_t size);
|
||
|
|
|
||
|
|
#endif // _TD_TXNODE_H_
|