Jelajahi Sumber

HPCC-17170 Remove unneeded addTimingToWorkunit option

Signed-off-by: Gavin Halliday <gavin.halliday@lexisnexis.com>
Gavin Halliday 8 tahun lalu
induk
melakukan
c4292e80da

+ 2 - 4
ecl/eclcc/eclcc.cpp

@@ -1187,8 +1187,7 @@ void EclCC::processSingleQuery(EclCompileInstance & instance,
             unsigned __int64 parseTimeNs = cycle_to_nanosec(get_cycles_now() - startCycles);
             instance.stats.parseTime = (unsigned)nanoToMilli(parseTimeNs);
 
-            if (instance.wu->getDebugValueBool("addTimingToWorkunit", true))
-                updateWorkunitTimeStat(instance.wu, SSTcompilestage, "compile:parseTime", StTimeElapsed, NULL, parseTimeNs);
+            updateWorkunitTimeStat(instance.wu, SSTcompilestage, "compile:parseTime", StTimeElapsed, NULL, parseTimeNs);
 
             if (exportDependencies)
             {
@@ -1290,8 +1289,7 @@ void EclCC::processSingleQuery(EclCompileInstance & instance,
     unsigned __int64 totalTimeNs = cycle_to_nanosec(get_cycles_now() - startCycles);
     instance.stats.generateTime = (unsigned)nanoToMilli(totalTimeNs) - instance.stats.parseTime;
     //MORE: This is done too late..
-    if (instance.wu->getDebugValueBool("addTimingToWorkunit", true))
-        updateWorkunitTimeStat(instance.wu, SSTcompilestage, "compile", StTimeElapsed, NULL, totalTimeNs);
+    updateWorkunitTimeStat(instance.wu, SSTcompilestage, "compile", StTimeElapsed, NULL, totalTimeNs);
 }
 
 void EclCC::processDefinitions(EclRepositoryArray & repositories)

+ 10 - 14
ecl/eclccserver/eclccserver.cpp

@@ -202,16 +202,14 @@ class EclccCompileThread : implements IPooledThread, implements IErrorReporter,
                 timings.findstr(max, 3);
                 timings.findstr(count, 4);
                 timings.findstr(ave, 5);
-                if (workunit->getDebugValueBool("addTimingToWorkunit", true))
-                {
-                    unsigned __int64 nval = atoi64(total) * 1000000; // in milliseconds
-                    unsigned __int64 nmax = atoi64(max) * 1000; // in microseconds
-                    unsigned __int64 cnt = atoi64(count);
-                    const char * scope = section.str();
-                    StatisticScopeType scopeType = SSTcompilestage;
-                    StatisticKind kind = StTimeElapsed;
-                    workunit->setStatistic(queryStatisticsComponentType(), queryStatisticsComponentName(), scopeType, scope, kind, NULL, nval, cnt, nmax, StatsMergeReplace);
-                }
+
+                unsigned __int64 nval = atoi64(total) * 1000000; // in milliseconds
+                unsigned __int64 nmax = atoi64(max) * 1000; // in microseconds
+                unsigned __int64 cnt = atoi64(count);
+                const char * scope = section.str();
+                StatisticScopeType scopeType = SSTcompilestage;
+                StatisticKind kind = StTimeElapsed;
+                workunit->setStatistic(queryStatisticsComponentType(), queryStatisticsComponentName(), scopeType, scope, kind, NULL, nval, cnt, nmax, StatsMergeReplace);
             }
             else
             {
@@ -330,8 +328,7 @@ class EclccCompileThread : implements IPooledThread, implements IErrorReporter,
             eclccCmd.append(" -");
         if (mainDefinition.length())
             eclccCmd.append(" -main ").append(mainDefinition);
-        if (workunit->getDebugValueBool("addTimingToWorkunit", true))
-            eclccCmd.append(" --timings");
+        eclccCmd.append(" --timings");
 
         Owned<IPipeProcess> pipe = createPipeProcess();
         pipe->setenv("ECLCCSERVER_THREAD_INDEX", idxStr.str());
@@ -415,8 +412,7 @@ class EclccCompileThread : implements IPooledThread, implements IErrorReporter,
                 queryDllServer().registerDll(realdllname.str(), "Workunit DLL", dllurl.str());
 
                 cycle_t elapsedCycles = get_cycles_now() - startCycles;
-                if (workunit->getDebugValueBool("addTimingToWorkunit", true))
-                    updateWorkunitTimeStat(workunit, SSTcompilestage, "compile", StTimeElapsed, NULL, cycle_to_nanosec(elapsedCycles));
+                updateWorkunitTimeStat(workunit, SSTcompilestage, "compile", StTimeElapsed, NULL, cycle_to_nanosec(elapsedCycles));
 
                 workunit->commit();
                 return true;

+ 0 - 1
ecl/hqlcpp/hqlcpp.cpp

@@ -1602,7 +1602,6 @@ void HqlCppTranslator::cacheOptions()
 #else
         DebugOption(options.regressionTest,"regressionTest", false),
 #endif
-        DebugOption(options.addTimingToWorkunit, "addTimingToWorkunit", true),
         //recreating case can cause duplicate branches in weird situations.
         DebugOption(options.recreateMapFromIf,"recreateMapFromIf", !targetThor()),
 

+ 1 - 3
ecl/hqlcpp/hqlcpp.ipp

@@ -607,7 +607,6 @@ struct HqlCppOptions
     bool                allowAmbiguousSelector;
     bool                regressionTest;
     bool                recreateMapFromIf;
-    bool                addTimingToWorkunit;
     bool                reduceNetworkTraffic;
     bool                optimizeProjectsPreservePersists;
     bool                showMetaText;
@@ -1086,8 +1085,7 @@ public:
     ITimeReporter * queryTimeReporter() const { return timeReporter; }
     void noteFinishedTiming(const char * name, cycle_t startCycles)
     {
-        if (options.addTimingToWorkunit)
-            timeReporter->addTiming(name, get_cycles_now()-startCycles);
+        timeReporter->addTiming(name, get_cycles_now()-startCycles);
     }
 
     void updateClusterType();

+ 4 - 7
ecl/hqlcpp/hqlecl.cpp

@@ -467,11 +467,9 @@ bool HqlDllGenerator::generateCode(HqlQueryContext & query)
             setSaveGeneratedFiles(true);
 
         doExpand(translator);
-        if (wu->getDebugValueBool("addTimingToWorkunit", true))
-        {
-            unsigned __int64 elapsed = cycle_to_nanosec(get_cycles_now() - startCycles);
-            updateWorkunitTimeStat(wu, SSTcompilestage, "compile:generate c++", StTimeElapsed, NULL, elapsed);
-        }
+        unsigned __int64 elapsed = cycle_to_nanosec(get_cycles_now() - startCycles);
+        updateWorkunitTimeStat(wu, SSTcompilestage, "compile:generate c++", StTimeElapsed, NULL, elapsed);
+
         if (wu->getDebugValueBool("addMemoryToWorkunit", true))
         {
             memsize_t peakVm, peakResident;
@@ -525,8 +523,7 @@ void HqlDllGenerator::doExpand(HqlCppTranslator & translator)
     }
 
     cycle_t elapsedCycles = get_cycles_now() - startCycles;
-    if (wu->getDebugValueBool("addTimingToWorkunit", true))
-        updateWorkunitTimeStat(wu, SSTcompilestage, "compile:write c++", StTimeElapsed, NULL, cycle_to_nanosec(elapsedCycles));
+    updateWorkunitTimeStat(wu, SSTcompilestage, "compile:write c++", StTimeElapsed, NULL, cycle_to_nanosec(elapsedCycles));
 }
 
 bool HqlDllGenerator::abortRequested()

+ 1 - 1
ecl/hqlcpp/hqlhtcpp.cpp

@@ -5970,7 +5970,7 @@ protected:
 
 void HqlCppTranslator::ensureWorkUnitUpdated()
 {
-    if (timeReporter && options.addTimingToWorkunit)
+    if (timeReporter)
     {
         WuTimingUpdater updater(wu());
         timeReporter->report(updater);

+ 1 - 1
ecl/hqlcpp/hqlnlp.cpp

@@ -684,7 +684,7 @@ ABoundActivity * HqlCppTranslator::doBuildActivityParse(BuildCtx & ctx, IHqlExpr
 
     //This will become conditional on the flags....
     cycle_t startPrepareCycles = get_cycles_now();
-    ITimeReporter * reporter = options.addTimingToWorkunit ? timeReporter : NULL;
+    ITimeReporter * reporter = timeReporter;
     if (expr->hasAttribute(tomitaAtom))
         nlpParse = createTomitaContext(expr, code->workunit, options, reporter);
     else