database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-08 14:22:09 +03:00
Code Activity

chore(): reduced error-prone boilerplate for STS functionality

Browse Source
This commit is contained in:
drrtuy
2025-03-17 13:55:12 +00:00
parent ade75eb4d7
commit 481267dca8
12 changed files with 90 additions and 167 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
dbcon/joblist/windowfunctionstep.cpp
View File

@@ -18,7 +18,7 @@
// $Id: windowfunctionstep.cpp 9681 2013-07-11 22:58:05Z xlou $
//#define NDEBUG
// #define NDEBUG
#include <cassert>
#include <sstream>
#include <iomanip>
@@ -865,12 +865,10 @@ void WindowFunctionStep::execute()
if (traceOn())
dlTimes.setFirstReadTime();
StepTeleStats sts;
sts.query_uuid = fQueryUuid;
sts.step_uuid = fStepUuid;
sts.msg_type = StepTeleStats::ST_START;
sts.total_units_of_work = 1;
postStepStartTele(sts);
{
StepTeleStats sts(fQueryUuid, fStepUuid, StepTeleStats::ST_START, 1);
postStepStartTele(sts);
}
try
{
@@ -930,9 +928,7 @@ void WindowFunctionStep::execute()
fOutputDL->endOfInput();
sts.msg_type = StepTeleStats::ST_SUMMARY;
sts.total_units_of_work = sts.units_of_work_completed = 1;
sts.rows = fRowsReturned;
StepTeleStats sts(fQueryUuid, fStepUuid, StepTeleStats::ST_SUMMARY, 1, 1, fRowsReturned);
postStepSummaryTele(sts);
if (traceOn())
@@ -982,9 +978,7 @@ void WindowFunctionStep::execute()
fOutputDL->endOfInput();
sts.msg_type = StepTeleStats::ST_SUMMARY;
sts.total_units_of_work = sts.units_of_work_completed = 1;
sts.rows = fRowsReturned;
StepTeleStats sts(fQueryUuid, fStepUuid, StepTeleStats::ST_SUMMARY, 1, 1, fRowsReturned);
postStepSummaryTele(sts);
if (traceOn())