GeezerVison is showing github.com — AliceO2/Algorithm/test/o2formatparser.cxx at dev · nstrangm/AliceO2

Expand file tree

o2formatparser.cxx

Copy path

More file actions

Latest commit

History

82 lines (73 loc) · 3.01 KB

o2formatparser.cxx

Copy path

File metadata and controls

82 lines (73 loc) · 3.01 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

// 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.

/// @file o2formatparser.cxx

/// @author Matthias Richter

/// @since 2017-10-18

/// @brief Unit test for O2 format parser

#define BOOST_TEST_MODULE Test Algorithm HeaderStack

#define BOOST_TEST_MAIN

#define BOOST_TEST_DYN_LINK

#include <boost/test/unit_test.hpp>

#include <iostream>

#include <iomanip>

#include <cstring> // memcmp

#include "Headers/DataHeader.h" // hexdump, DataHeader

#include "../include/Algorithm/O2FormatParser.h"

template <typename... Targs>

void hexDump(Targs... Fargs)

{

// a simple redirect to enable/disable the hexdump printout

o2::header::hexDump(Fargs...);

}

BOOST_AUTO_TEST_CASE(test_o2formatparser)

{

std::vector<const char*> thedata = {

"I'm raw data",

"reconstructed data"};

unsigned dataidx = 0;

std::vector<o2::header::DataHeader> dataheaders;

dataheaders.emplace_back(o2::header::DataDescription("RAWDATA"),

o2::header::DataOrigin("DET"),

strlen(thedata[dataidx++]));

dataheaders.emplace_back(o2::header::DataDescription("RECODATA"),

o2::header::DataOrigin("DET"),

strlen(thedata[dataidx++]));

std::vector<std::pair<const char*, size_t>> messages;

for (dataidx = 0; dataidx < thedata.size(); ++dataidx) {

messages.emplace_back(reinterpret_cast<char*>(&dataheaders[dataidx]),

sizeof(o2::header::DataHeader));

messages.emplace_back(thedata[dataidx],

dataheaders[dataidx].payloadSize);

}

// handler callback for parseO2Format method

auto insertFct = [&](const auto& dataheader,

auto ptr,

auto size) {

hexDump("header", &dataheader, sizeof(dataheader));

hexDump("data", ptr, size);

BOOST_CHECK(dataheader == dataheaders[dataidx]);

BOOST_CHECK(strncmp(ptr, thedata[dataidx], size) == 0);

++dataidx;

}; // end handler callback

// handler callback to get the pointer for message

auto getPointerFct = [](auto arg) { return arg.first; };

// handler callback to get the size for message

auto getSizeFct = [](auto arg) { return arg.second; };

dataidx = 0;

auto result = o2::algorithm::parseO2Format(messages,

getPointerFct,

getSizeFct,

insertFct);

BOOST_REQUIRE(result >= 0);

BOOST_CHECK(result == 2);

}