Browse Source

HPCC-12346 Control:resetquerystats is not resetting counts

Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
Richard Chapman 10 years ago
parent
commit
277fc1bd2e
1 changed files with 12 additions and 0 deletions
  1. 12 0
      roxie/ccd/ccdserver.cpp

+ 12 - 0
roxie/ccd/ccdserver.cpp

@@ -554,6 +554,7 @@ public:
     {
         CActivityFactory::resetNodeProgressInfo();
         CriticalBlock b(statsCrit);
+        processed = 0;
         started = 0;
         totalCycles = 0;
         localCycles = 0;
@@ -804,6 +805,17 @@ protected:
         putStatsValue(&edge, "started", "sum", startedArray[idx]);
     }
 
+    virtual void resetNodeProgressInfo()
+    {
+        CRoxieServerActivityFactory::resetNodeProgressInfo();
+        CriticalBlock b(statsCrit);
+        for (unsigned i = 0; i < numOutputs; i++)
+        {
+            processedArray[i] = 0;
+            startedArray[i] = 0;
+        }
+    }
+
     virtual void noteProcessed(unsigned idx, unsigned _processed, unsigned __int64 _totalCycles, unsigned __int64 _localCycles) const
     {
         assertex(numOutputs ? idx < numOutputs : idx==0);