#include <catch_amalgamated.hpp>
#include "Headers/DataHeader.h"
#include "Framework/DataProcessingHeader.h"
#include "Framework/DataProcessingHelpers.h"
#include "Framework/SourceInfoHeader.h"
#include "Framework/DomainInfoHeader.h"
#include "Framework/Signpost.h"
#include "Framework/MessageSet.h"
#include "Framework/FairMQDeviceProxy.h"
#include "Headers/Stack.h"
#include "MemoryResources/MemoryResources.h"
#include <fairmq/TransportFactory.h>
#include <fairmq/Channel.h>
#include <vector>

Functions
	O2_DECLARE_DYNAMIC_LOG (forwarding)

	TEST_CASE ("ForwardInputsEmpty")

	TEST_CASE ("ForwardInputsSingleMessageSingleRoute")

	TEST_CASE ("ForwardInputsSingleMessageSingleRouteNoConsume")

	TEST_CASE ("ForwardInputsSingleMessageSingleRouteAtEOS")

	TEST_CASE ("ForwardInputsSingleMessageSingleRouteWithOldestPossible")

	TEST_CASE ("ForwardInputsSingleMessageMultipleRoutes")

	TEST_CASE ("ForwardInputsSingleMessageMultipleRoutesExternals")

	TEST_CASE ("ForwardInputsMultiMessageMultipleRoutes")

	TEST_CASE ("ForwardInputsSingleMessageMultipleRoutesOnlyOneMatches")

	TEST_CASE ("ForwardInputsSplitPayload")

	TEST_CASE ("ForwardInputEOSSingleRoute")

	TEST_CASE ("ForwardInputOldestPossibleSingleRoute")

Function Documentation

◆ O2_DECLARE_DYNAMIC_LOG()

O2_DECLARE_DYNAMIC_LOG ( forwarding )

◆ TEST_CASE() [1/12]

TEST_CASE ( "ForwardInputEOSSingleRoute" )

Definition at line 619 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [2/12]

TEST_CASE ( "ForwardInputOldestPossibleSingleRoute" )

Definition at line 664 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [3/12]

TEST_CASE ( "ForwardInputsEmpty" )

Definition at line 30 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [4/12]

TEST_CASE ( "ForwardInputsMultiMessageMultipleRoutes" )

Definition at line 396 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [5/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutes" )

Definition at line 270 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [6/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutesExternals" )

Definition at line 333 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [7/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutesOnlyOneMatches" )

Definition at line 474 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [8/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRoute" )

Definition at line 52 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [9/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteAtEOS" )

Definition at line 154 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [10/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteNoConsume" )

Definition at line 103 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [11/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteWithOldestPossible" )

Definition at line 212 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [12/12]

TEST_CASE ( "ForwardInputsSplitPayload" )

Definition at line 537 of file test_ForwardInputs.cxx.

Functions