#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/ServiceRegistry.h"
#include "Framework/ServiceRegistryRef.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 651 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [2/12]

TEST_CASE ( "ForwardInputOldestPossibleSingleRoute" )

Definition at line 699 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [3/12]

TEST_CASE ( "ForwardInputsEmpty" )

Definition at line 32 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [4/12]

TEST_CASE ( "ForwardInputsMultiMessageMultipleRoutes" )

Definition at line 418 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [5/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutes" )

Definition at line 286 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [6/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutesExternals" )

Definition at line 352 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [7/12]

TEST_CASE ( "ForwardInputsSingleMessageMultipleRoutesOnlyOneMatches" )

Definition at line 499 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [8/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRoute" )

Definition at line 56 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [9/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteAtEOS" )

Definition at line 164 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [10/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteNoConsume" )

Definition at line 110 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [11/12]

TEST_CASE ( "ForwardInputsSingleMessageSingleRouteWithOldestPossible" )

Definition at line 225 of file test_ForwardInputs.cxx.

◆ TEST_CASE() [12/12]

TEST_CASE ( "ForwardInputsSplitPayload" )

Definition at line 565 of file test_ForwardInputs.cxx.

Functions