NodeEngineTest.cpp File Reference

#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Compiler/CPPCompiler/CPPCompiler.hpp>
#include <Compiler/JITCompilerBuilder.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>
#include <Exceptions/SignalHandling.hpp>
#include <Network/ExchangeProtocol.hpp>
#include <Network/NetworkManager.hpp>
#include <Network/PartitionManager.hpp>
#include <QueryCompiler/NautilusQueryCompiler.hpp>
#include <QueryCompiler/Phases/DefaultPhaseFactory.hpp>
#include <QueryCompiler/QueryCompilationRequest.hpp>
#include <QueryCompiler/QueryCompilationResult.hpp>
#include <QueryCompiler/QueryCompilerOptions.hpp>
#include <Runtime/Execution/ExecutablePipelineStage.hpp>
#include <Runtime/Execution/PipelineExecutionContext.hpp>
#include <Runtime/HardwareManager.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Runtime/OpenCLManager.hpp>
#include <Runtime/QueryManager.hpp>
#include <Runtime/WorkerContext.hpp>
#include <Sinks/Mediums/FileSink.hpp>
#include <Sinks/SinkCreator.hpp>
#include <Sources/SourceCreator.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestUtils.hpp>
#include <csignal>
#include <future>
#include <gtest/gtest.h>
#include <iostream>
#include <utility>

Include dependency graph for NodeEngineTest.cpp:

Classes
class	NES::TextExecutablePipeline
class	NES::NodeEngineTest
	test for the engine TODO: add more test cases More...
class	NES::MockedPipelineExecutionContext

Namespaces
	NES
	This exception represents a network error.
	NES::detail

Macros
#define	DEBUG_OUTPUT

Functions
template<typename MockedNodeEngine >
std::shared_ptr< MockedNodeEngine >	NES::createMockedEngine (const std::string &hostname, uint16_t port, uint64_t bufferSize=8192, uint64_t numBuffers=1024)
void	NES::testOutput (const std::string &path)
void	NES::testOutput (const std::string &path, const std::string &expectedOutput)
auto	NES::setupQEP (const NodeEnginePtr &engine, SharedQueryId sharedQueryId, const std::string &outPath)
	NES::TEST_F (NodeEngineTest, testStartStopEngineEmpty)
	NES::TEST_F (NodeEngineTest, teststartDeployStop)
	NES::TEST_F (NodeEngineTest, testStartDeployUndeployStop)
	NES::TEST_F (NodeEngineTest, testStartRegisterStartStopDeregisterStop)
	NES::TEST_F (NodeEngineTest, testParallelDifferentSource)
	NES::TEST_F (NodeEngineTest, testParallelSameSource)
	NES::TEST_F (NodeEngineTest, DISABLED_testParallelSameSink)
	NES::TEST_F (NodeEngineTest, DISABLED_testParallelSameSourceAndSinkRegstart)
	NES::TEST_F (NodeEngineTest, testStartStopStartStop)
	NES::TEST_F (NodeEngineTest, testBufferData)
	NES::TEST_F (NodeEngineTest, testReconfigureSink)
void	NES::detail::segkiller ()
void	NES::detail::assertKiller ()
	NES::TEST_F (NodeEngineTest, DISABLED_testExceptionCrash)
	NES::TEST_F (NodeEngineTest, DISABLED_testSemiUnhandledExceptionCrash)
	NES::TEST_F (NodeEngineTest, DISABLED_testFullyUnhandledExceptionCrash)
	NES::TEST_F (NodeEngineTest, DISABLED_testFatalCrash)

Variables
SharedQueryId	NES::testQueryId = SharedQueryId(123)
std::string	NES::expectedOutput = "sum:INTEGER(32 bits)\n10\n"
std::string	NES::joinedExpectedOutput = "sum:INTEGER(32 bits)\n10\n10\n"
std::string	NES::joinedExpectedOutput10

Macro Definition Documentation

DEBUG_OUTPUT

#define DEBUG_OUTPUT