Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
570ef3d3
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
未验证
提交
570ef3d3
编写于
1月 29, 2022
作者:
L
Liu Jicong
提交者:
GitHub
1月 29, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #10099 from taosdata/feature/tq
clear unused code in tq
上级
0e8009b3
2da85fb9
变更
1
显示空白变更内容
内联
并排
Showing
1 changed file
with
0 addition
and
123 deletion
+0
-123
source/dnode/vnode/inc/tq.h
source/dnode/vnode/inc/tq.h
+0
-123
未找到文件。
source/dnode/vnode/inc/tq.h
浏览文件 @
570ef3d3
...
...
@@ -35,71 +35,8 @@
extern
"C"
{
#endif
typedef
struct
STqMsgHead
{
int32_t
protoVer
;
int32_t
msgType
;
int64_t
cgId
;
int64_t
clientId
;
}
STqMsgHead
;
typedef
struct
STqOneAck
{
int64_t
topicId
;
int64_t
consumeOffset
;
}
STqOneAck
;
typedef
struct
STqAcks
{
int32_t
ackNum
;
// should be sorted
STqOneAck
acks
[];
}
STqAcks
;
typedef
struct
STqSetCurReq
{
STqMsgHead
head
;
int64_t
topicId
;
int64_t
offset
;
}
STqSetCurReq
;
typedef
struct
STqConsumeReq
{
STqMsgHead
head
;
int64_t
blockingTime
;
// milisec
STqAcks
acks
;
}
STqConsumeReq
;
typedef
struct
STqMsgContent
{
int64_t
topicId
;
int64_t
msgLen
;
char
msg
[];
}
STqMsgContent
;
typedef
struct
STqConsumeRsp
{
STqMsgHead
head
;
int64_t
bodySize
;
STqMsgContent
msgs
[];
}
STqConsumeRsp
;
typedef
struct
STqSubscribeReq
{
STqMsgHead
head
;
int32_t
topicNum
;
int64_t
topic
[];
}
STqSubscribeReq
;
typedef
struct
STqHeartbeatReq
{
}
STqHeartbeatReq
;
typedef
struct
STqHeartbeatRsp
{
}
STqHeartbeatRsp
;
#define TQ_BUFFER_SIZE 8
typedef
struct
STqExec
{
void
*
runtimeEnv
;
SSDataBlock
*
(
*
exec
)(
void
*
runtimeEnv
);
void
*
(
*
assign
)(
void
*
runtimeEnv
,
void
*
inputData
);
void
(
*
clear
)(
void
*
runtimeEnv
);
char
*
(
*
serialize
)(
struct
STqExec
*
);
struct
STqExec
*
(
*
deserialize
)(
char
*
);
}
STqExec
;
typedef
struct
STqRspHandle
{
void
*
handle
;
void
*
ahandle
;
...
...
@@ -107,47 +44,6 @@ typedef struct STqRspHandle {
typedef
enum
{
TQ_ITEM_READY
,
TQ_ITEM_PROCESS
,
TQ_ITEM_EMPTY
}
STqItemStatus
;
typedef
struct
STqTopic
STqTopic
;
typedef
struct
STqBufferItem
{
int64_t
offset
;
// executors are identical but not concurrent
// so there must be a copy in each item
STqExec
*
executor
;
int32_t
status
;
int64_t
size
;
void
*
content
;
STqTopic
*
pTopic
;
}
STqMsgItem
;
struct
STqTopic
{
// char* topic; //c style, end with '\0'
// int64_t cgId;
// void* ahandle;
// int32_t head;
// int32_t tail;
int64_t
nextConsumeOffset
;
int64_t
floatingCursor
;
int64_t
topicId
;
void
*
logReader
;
STqMsgItem
buffer
[
TQ_BUFFER_SIZE
];
};
typedef
struct
STqListHandle
{
STqTopic
topic
;
struct
STqListHandle
*
next
;
}
STqList
;
typedef
struct
STqGroup
{
int64_t
clientId
;
int64_t
cgId
;
void
*
ahandle
;
int32_t
topicNum
;
STqList
*
head
;
SList
*
topicList
;
// SList<STqTopic>
STqRspHandle
rspHandle
;
}
STqGroup
;
typedef
struct
STqTaskItem
{
int8_t
status
;
int64_t
offset
;
...
...
@@ -182,11 +78,6 @@ typedef struct STqConsumerHandle {
SArray
*
topics
;
// SArray<STqClientTopic>
}
STqConsumerHandle
;
typedef
struct
STqQueryMsg
{
STqMsgItem
*
item
;
struct
STqQueryMsg
*
next
;
}
STqQueryMsg
;
typedef
struct
STqMemRef
{
SMemAllocatorFactory
*
pAllocatorFactory
;
SMemAllocator
*
pAllocator
;
...
...
@@ -305,20 +196,6 @@ void tqClose(STQ*);
int
tqPushMsg
(
STQ
*
,
void
*
msg
,
int64_t
version
);
int
tqCommit
(
STQ
*
);
int
tqSetCursor
(
STQ
*
,
STqSetCurReq
*
pMsg
);
#if 0
int tqConsume(STQ*, SRpcMsg* pReq, SRpcMsg** pRsp);
int tqSetCursor(STQ*, STqSetCurReq* pMsg);
int tqBufferSetOffset(STqTopic*, int64_t offset);
STqTopic* tqFindTopic(STqGroup*, int64_t topicId);
STqGroup* tqGetGroup(STQ*, int64_t clientId);
STqGroup* tqOpenGroup(STQ*, int64_t topicId, int64_t cgId, int64_t cId);
int tqCloseGroup(STQ*, int64_t topicId, int64_t cgId, int64_t cId);
int tqRegisterContext(STqGroup*, void* ahandle);
int tqSendLaunchQuery(STqMsgItem*, int64_t offset);
#endif
int32_t
tqProcessConsumeReq
(
STQ
*
pTq
,
SRpcMsg
*
pMsg
);
int32_t
tqProcessSetConnReq
(
STQ
*
pTq
,
char
*
msg
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录