TCPSourceTest.cpp File Reference

#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/TCPSourceType.hpp>
#include <Operators/LogicalOperators/Sources/TCPSourceDescriptor.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Sources/SourceCreator.hpp>
#include <Util/Logger/Logger.hpp>
#include <gtest/gtest.h>
#include <iostream>
#include <string>
#include <Catalogs/Query/QueryCatalog.hpp>
#include <Components/NesCoordinator.hpp>
#include <Components/NesWorker.hpp>
#include <Configurations/Coordinator/CoordinatorConfiguration.hpp>
#include <Configurations/Worker/WorkerConfiguration.hpp>
#include <Identifiers/Identifiers.hpp>
#include <Plans/Global/Query/GlobalQueryPlan.hpp>
#include <Runtime/HardwareManager.hpp>
#include <Runtime/MemoryLayout/RowLayout.hpp>
#include <Runtime/QueryManager.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Util/TestUtils.hpp>
#include <arpa/inet.h>
#include <netinet/in.h>

Include dependency graph for TCPSourceTest.cpp:

Classes
class	NES::TCPSourceTest

Namespaces
	NES
	This exception represents a network error.

Macros
#define	OPERATORID   OperatorId(1)
#define	ORIGINID   OriginId(1)
#define	STATISTICID   1
#define	NUMSOURCELOCALBUFFERS   12
#define	SUCCESSORS    {}
#define	INPUTFORMAT   InputFormat::JSON

Functions
void	setup_read_from_buffer (std::vector< char > data)
std::string	get_ip_address ()
short	get_port ()
int	socket (int domain, int type, int protocol)
int	connect (int fd, const sockaddr *addr, [[maybe_unused]] socklen_t addrlen)
ssize_t	__real_read (int fd, void *data, size_t size)
ssize_t	__wrap_read (int fd, void *data, size_t size)
	NES::TEST_F (TCPSourceTest, TCPSourceUserSpecifiedTupleSizePrint)
	NES::TEST_F (TCPSourceTest, TCPSourceTupleSeparatorPrint)
	NES::TEST_F (TCPSourceTest, TCPSourceBufferSizeFromSocketPrint)
	NES::TEST_F (TCPSourceTest, TCPSourceBufferSizeFromSocketNesFormatPrint)

Macro Definition Documentation

INPUTFORMAT

#define INPUTFORMAT   InputFormat::JSON

NUMSOURCELOCALBUFFERS

#define NUMSOURCELOCALBUFFERS   12

OPERATORID

#define OPERATORID   OperatorId(1)

ORIGINID

#define ORIGINID   OriginId(1)

STATISTICID

#define STATISTICID   1

SUCCESSORS

#define SUCCESSORS    {}

Function Documentation

__real_read()

ssize_t __real_read	(	int	fd,
		void *	data,
		size_t	size
	)

__wrap_read()

ssize_t __wrap_read	(	int	fd,
		void *	data,
		size_t	size
	)

References fd.

connect()

int connect	(	int	fd,
		const sockaddr *	addr,
		[[maybe_unused] ] socklen_t	addrlen
	)

Referenced by NES::TCPSource::createOrLoadPersistedProperties(), and NES::TEST_F().

Here is the caller graph for this function:

get_ip_address()

std::string get_ip_address

(

)

get_port()

short get_port

(

)

setup_read_from_buffer()

void setup_read_from_buffer

(

std::vector< char >

data

)

Referenced by NES::TEST_F().

Here is the caller graph for this function:

socket()

int socket	(	int	domain,
		int	type,
		int	protocol
	)

Referenced by NES::TCPSource::createOrLoadPersistedProperties(), NES::TCPSourceIntegrationTest::startServer(), and TEST_F().

Here is the caller graph for this function:

Variable Documentation

addr_in

sockaddr_in addr_in = {}

called_connect

bool called_connect = false

called_socket_create

bool called_socket_create = false

connect_fd

size_t connect_fd = 0

connection_fd

int connection_fd = 0

data

std::vector<char> data

Referenced by NES::Schema::addField(), NES::asciiBufferSize(), NES::binaryBufferSize(), NES::ChunkCollector< NodeSize, Alignment >::collect(), NES::ArrayPhysicalType::convertRawToString(), NES::BasicPhysicalType::convertRawToString(), NES::TextPhysicalType::convertRawToString(), NES::ArrayPhysicalType::convertRawToStringWithoutFill(), NES::BasicPhysicalType::convertRawToStringWithoutFill(), NES::TextPhysicalType::convertRawToStringWithoutFill(), NES::Statistic::StatisticFormatFactory::createFromSchema(), NES::Util::findAndReplaceAll(), Yaml::impl::StringConverter< T >::Get(), Yaml::impl::StringConverter< std::string >::Get(), Yaml::impl::StringConverter< bool >::Get(), jitify::KernelInstantiation::get_global_array(), jitify::experimental::KernelInstantiation::get_global_array(), NES::Testing::detail::PortDispatcher::getNextPort(), NES::Monitoring::Metric::getValue(), MMapCircularBuffer::MMapCircularBuffer(), Yaml::Parse(), MMapCircularBuffer::read(), NES::Testing::detail::PortDispatcher::recyclePort(), jitify::KernelInstantiation::set_global_array(), jitify::experimental::KernelInstantiation::set_global_array(), Yaml::ScalarImp::SetData(), NES::sizeUntilSearchToken(), NES::TEST_F(), MMapCircularBuffer::write(), NES::Statistic::CountMinStatisticFormat::writeStatisticsIntoBuffers(), NES::Statistic::HyperLogLogStatisticFormat::writeStatisticsIntoBuffers(), and MMapCircularBuffer::~MMapCircularBuffer().

domain

int domain = 0

fd

int fd = 0

Referenced by __wrap_read(), NES::Util::FileMutex::lock(), NES::Util::FileMutex::try_lock(), and NES::Util::FileMutex::unlock().

index

size_t index = 0

Referenced by magic_enum::enum_index(), magic_enum::enum_value(), Yaml::SequenceImp::Erase(), Yaml::Node::Erase(), magic_enum::detail::fuse_one_enum(), NES::Schema::get(), NES::TestSink::get(), Yaml::SequenceImp::GetNode(), NES::Runtime::Execution::PipelineExecutionContext::getOperatorHandler(), NES::TestSink::getResultBuffer(), Yaml::SequenceImp::Insert(), Yaml::Node::Insert(), NES::Runtime::detail::BufferControlBlock::loadChildBuffer(), Yaml::Node::operator[](), NES::Testing::detail::SharedMemoryFixedVector< T >::operator[](), Yaml::SequenceImp::PushBack(), NES::Runtime::MemoryLayouts::DynamicTuple::readVarSized(), NES::Runtime::TupleBuffer::storeChildBuffer(), TEST_P(), NES::Runtime::MemoryLayouts::DynamicTuple::toString(), and NES::Runtime::MemoryLayouts::DynamicTuple::writeVarSized().

numbers_of_reads

size_t numbers_of_reads = 0

protocol

int protocol = 0

Referenced by NES::Network::EventOnlyNetworkChannel::create(), NES::Network::NetworkChannel::create(), NES::Network::detail::createNetworkChannel(), NES::Network::NetworkManager::registerSubpartitionEventProducerAsync(), and NES::Network::NetworkManager::registerSubpartitionProducerAsync().

read_ptr

std::vector<const void*> read_ptr

read_sizes

std::vector<size_t> read_sizes

socklen

socklen_t socklen = 0

type

int type = 0

Referenced by NES::RequestProcessor::TwoPhaseLockingStorageHandler::acquireResources(), NES::Schema::addField(), NES::Attribute(), NES::DataTypeFactory::createArrayValueFromContainerType(), NES::DataTypeFactory::createArrayValueWithContainedType(), NES::DataTypeFactory::createBasicValue(), NES::Monitoring::MetricUtils::createCollectorFromCollectorType(), NES::Monitoring::MetricUtils::createCollectorTypeFromMetricType(), NES::createField(), NES::Statistic::StatisticFormatFactory::createFromSchema(), NES::Monitoring::MetricUtils::createMetricFromCollectorType(), NES::createMonitoringSink(), NES::DataTypeFactory::createType(), Yaml::impl::StringConverter< T >::Get(), NES::Runtime::BufferManager::getAvailableBuffersInFixedSizePools(), NES::Monitoring::MonitoringAgent::getMetricsAsJson(), NES::Monitoring::MonitoringAgent::getMetricsFromPlan(), NES::Monitoring::MetricUtils::getSchemaFromCollectorType(), NES::Schema::getSchemaSizeInBytes(), NES::Schema::replaceField(), magic_enum::detail::result_type(), NES::Runtime::AbstractQueryManager::stopExecutableQueryPlan(), NES::Testing::TestExecutionEngine::stopQuery(), and NES::TEST_F().