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

Merge pull request #29403 from taosdata/fix/session.list 

fix: session list issue
This commit is contained in:
Shengliang Guan 2024-12-30 14:55:10 +08:00 committed by GitHub
parent 210f47404b 549d26be95
commit 22c9cd60ad
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
source/libs/qworker/src/qworker.c
View File

@ -746,9 +746,19 @@ _return:
} }
int32_t qwAbortPrerocessQuery(QW_FPARAMS_DEF) { int32_t qwAbortPrerocessQuery(QW_FPARAMS_DEF) {
QW_ERR_RET(qwDropTask(QW_FPARAMS())); int32_t code = TSDB_CODE_SUCCESS;
SQWTaskCtx *ctx = NULL;
return TSDB_CODE_SUCCESS; QW_ERR_RET(qwAcquireTaskCtx(QW_FPARAMS(), &ctx));
QW_LOCK(QW_WRITE, &ctx->lock);
QW_ERR_JRET(qwDropTask(QW_FPARAMS()));
_return:
QW_UNLOCK(QW_WRITE, &ctx->lock);
return code;
} }
int32_t qwPreprocessQuery(QW_FPARAMS_DEF, SQWMsg *qwMsg) { int32_t qwPreprocessQuery(QW_FPARAMS_DEF, SQWMsg *qwMsg) {

2
source/util/inc/tmempoolInt.h
View File

@ -222,7 +222,7 @@ typedef struct SMPSessionChunk {
} SMPSessionChunk; } SMPSessionChunk;
typedef struct SMPSession { typedef struct SMPSession {
// SMPListNode list; SMPListNode list;
char* sessionId; char* sessionId;
SMPJob* pJob; SMPJob* pJob;