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

refactor(stream): record the elapsed time for close stream tasks.

This commit is contained in:
Haojun Liao 2025-02-08 23:47:29 +08:00
parent a2dcba10a7
commit cb7e2cb1e0
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/dnode/mgmt/mgmt_vnode/src/vmInt.c
View File

@ -711,7 +711,8 @@ static void vmCloseVnodes(SVnodeMgmt *pMgmt) {
pMgmt->state.openVnodes = 0; pMgmt->state.openVnodes = 0;
dInfo("close %d vnodes with %d threads", numOfVnodes, threadNum); dInfo("close %d vnodes with %d threads", numOfVnodes, threadNum);
dInfo("notify all streams closed in all %d vnodes", numOfVnodes); int64_t st = taosGetTimestampMs();
dInfo("notify all streams closed in all %d vnodes, ts:%" PRId64, numOfVnodes, st);
if (ppVnodes != NULL) { if (ppVnodes != NULL) {
for (int32_t i = 0; i < numOfVnodes; ++i) { for (int32_t i = 0; i < numOfVnodes; ++i) {
if (ppVnodes[i] != NULL) { if (ppVnodes[i] != NULL) {
@ -721,7 +722,9 @@ static void vmCloseVnodes(SVnodeMgmt *pMgmt) {
} }
} }
} }
dInfo("notify close stream completed in %d vnodes", numOfVnodes);
int64_t et = taosGetTimestampMs();
dInfo("notify close stream completed in %d vnodes, elapsed time: %" PRId64 "ms", numOfVnodes, et - st);
for (int32_t t = 0; t < threadNum; ++t) { for (int32_t t = 0; t < threadNum; ++t) {
SVnodeThread *pThread = &threads[t]; SVnodeThread *pThread = &threads[t];