added debug mode to bypass aggregation

Author: sy-c

src/DataBlockAggregator.cxx

@@ -162,6 +162,30 @@ Thread::CallbackResult DataBlockAggregator::executeCallback() {
   for (unsigned int ix=0; ix<nInputs; ix++) {
     int i=(ix + nextIndex) % nInputs;
 
+if (0) {
+    // no slicing... pass through
+    if (output->isFull()) {
+      return Thread::CallbackResult::Idle;
+    }
+    if (inputs[i]->isEmpty()) {
+      continue;
+    }
+    DataBlockContainerReference b=nullptr;
+    inputs[i]->pop(b);
+    nBlocksIn++;
+    DataSetReference bcv=nullptr;
+    try {
+      bcv=std::make_shared<DataSet>();
+    }
+    catch(...) {
+      return Thread::CallbackResult::Error;
+    }
+    bcv->push_back(b);
+    output->push(bcv);
+    nSlicesOut++;
+    continue;
+ }   
+
     for (int j=0;j<1024;j++) {
       if (inputs[i]->isEmpty()) {
         break;
@@ -230,7 +254,6 @@ int DataBlockSlicer::appendBlock(DataBlockContainerReference const &block) {
       //theLog.log("TF %d link %d is complete",tfId,linkId);
       slices.push(partialSlices[linkId].currentDataSet);
       partialSlices[linkId].currentDataSet=nullptr;
-
     }
   }
   if (partialSlices[linkId].currentDataSet==nullptr) {