xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

tq (#8416) 

add tq header
This commit is contained in:
Liu Jicong 2021-10-25 15:16:39 +08:00 committed by GitHub
parent 0acfddf32c
commit 05c07ba6f9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -18,6 +18,7 @@ mac/
.mypy_cache .mypy_cache
*.tmp *.tmp
*.swp *.swp
*.orig
src/connector/nodejs/node_modules/ src/connector/nodejs/node_modules/
src/connector/nodejs/out/ src/connector/nodejs/out/
tests/test/ tests/test/

4
include/libs/wal/wal.h
View File

@ -58,9 +58,9 @@ void walStop(twalh);
void walClose(twalh); void walClose(twalh);
//write //write
int64_t walWriteWithMsgType(twalh, int8_t msgType, void* body, int32_t bodyLen); //int64_t walWriteWithMsgType(twalh, int8_t msgType, void* body, int32_t bodyLen);
int64_t walWrite(twalh, void* body, int32_t bodyLen); int64_t walWrite(twalh, void* body, int32_t bodyLen);
int64_t walWriteBatch(twalh, void* body, int32_t* bodyLen, int32_t batchSize); int64_t walWriteBatch(twalh, void** bodies, int32_t* bodyLen, int32_t batchSize);
//apis for lifecycle management //apis for lifecycle management
void walFsync(twalh, bool force); void walFsync(twalh, bool force);

16
source/server/vnode/tq/src/tq.c
View File

@ -59,13 +59,27 @@ int tqOpenTGroup(STQ* pTq, const char* topic, int cgId) {
/*int tqCloseTCGroup(STQ* pTq, const char* topic, int cgId) {*/ /*int tqCloseTCGroup(STQ* pTq, const char* topic, int cgId) {*/
/*tqGroupHandle* handle = tqLookupGroupHandle(pTq, topic, cgId);*/ /*tqGroupHandle* handle = tqLookupGroupHandle(pTq, topic, cgId);*/
/*return tqCommitTCGroup(handle);*/ /*return tqCommitTCGroup(handle);*/
} /*}*/
int tqDropTCGroup(STQ* pTq, const char* topic, int cgId) { int tqDropTCGroup(STQ* pTq, const char* topic, int cgId) {
//delete from disk //delete from disk
return 0; return 0;
} }
int tqFetchMsg(tqGroupHandle* handle, void* msg) {
return 0;
}
int tqMoveOffsetToNext(tqGroupHandle* handle) {
return 0;
}
tqGroupHandle* tqFindGHandleBycId(STQ* pTq, int64_t cId) {
return NULL;
}
int tqPushMsg(STQ* pTq , void* p, int64_t version) { int tqPushMsg(STQ* pTq , void* p, int64_t version) {
//add reference //add reference
//judge and launch new query //judge and launch new query