O2FormatParser.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
#ifndef ALGORITHM_O2FORMATPARSER_H
#define ALGORITHM_O2FORMATPARSER_H
 
 
#include "HeaderStack.h"
 
namespace o2
{
 
namespace algorithm
{
 
template <
  typename InputListT, typename GetPointerFctT, typename GetSizeFctT, typename InsertFctT, // (const auto&, ptr, size)
  typename... HeaderStackTypes                                                             // pairs of HeaderType and CallbackType
  >
int parseO2Format(const InputListT& list,
                  GetPointerFctT getPointer,
                  GetSizeFctT getSize,
                  InsertFctT insert,
                  HeaderStackTypes&&... stackArgs)
{
  const o2::header::DataHeader* dh = nullptr;
  for (auto& part : list) {
    if (!dh) {
      // new header - payload pair, read DataHeader
      dh = o2::header::get<o2::header::DataHeader*>(getPointer(part), getSize(part));
      if (!dh) {
        return -ENOMSG;
      }
      o2::algorithm::dispatchHeaderStackCallback(getPointer(part),
                                                 getSize(part),
                                                 stackArgs...);
    } else {
      insert(*dh, getPointer(part), getSize(part));
      dh = nullptr;
    }
  }
  if (dh) {
    return -ENOMSG;
  }
  return list.size() / 2;
}
 
} // namespace algorithm
 
} // namespace o2
 
#endif // ALGORITHM_O2FORMATPARSER_H