- AliHLTReconstructor: added helper functions to run HLTOUT processing stand alone

[u/mrichter/AliRoot.git] / HLT / BASE / AliHLTTask.cxx

diff --git a/HLT/BASE/AliHLTTask.cxx b/HLT/BASE/AliHLTTask.cxx
index 384c4edbbda0fc1e6f9b65d5b3569273a49bccc0..b0f8caf73a4a723421f5c0b9c1ac84a6e4ad948f 100644 (file)
--- a/HLT/BASE/AliHLTTask.cxx
+++ b/HLT/BASE/AliHLTTask.cxx
@@ -496,6 +496,14 @@ int AliHLTTask::ProcessTask(Int_t eventNo)
     AliHLTUInt32_t size=0;
     if (iResult>=0) {
     do {
+      long unsigned int iOutputDataSize=0;
+      AliHLTConfiguration* pConf=GetConf();
+      assert(pConf);
+      // check if there was a buffer size specified, query output size
+      // estimator from component otherwize
+      if (pConf && pConf->GetOutputBufferSize()>=0) {
+       iOutputDataSize=pConf->GetOutputBufferSize();
+      } else {
       long unsigned int iConstBase=0;
       double fInputMultiplier=0;
       if (pComponent->GetComponentType()!=AliHLTComponent::kSink)
@@ -504,8 +512,9 @@ int AliHLTTask::ProcessTask(Int_t eventNo)
        HLTWarning("ignoring negative input multiplier");
        fInputMultiplier=0;
       }
-      long unsigned int iOutputDataSize=int(fInputMultiplier*iInputDataVolume) + iConstBase;
+      iOutputDataSize=int(fInputMultiplier*iInputDataVolume) + iConstBase;
       //HLTDebug("task %s: reqired output size %d", GetName(), iOutputDataSize);
+      }
       if (iNofTrial>0) {
        // dont process again if the buffer size is the same
        if (size==iOutputDataSize) break;