NetworkChannel.cpp File Reference

#include <Network/ExchangeProtocol.hpp>
#include <Network/NetworkChannel.hpp>
#include <Network/NetworkMessage.hpp>
#include <Runtime/BufferManager.hpp>
#include <Runtime/NesThread.hpp>
#include <future>

Include dependency graph for NetworkChannel.cpp:

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

Functions
template<typename T >
std::unique_ptr< T >	NES::Network::detail::createNetworkChannel (std::shared_ptr< zmq::context_t > const &zmqContext, std::string &&socketAddr, NesPartition nesPartition, ExchangeProtocol &protocol, Runtime::BufferManagerPtr bufferManager, int highWaterMark, std::chrono::milliseconds waitTime, uint8_t retryTimes, DecomposedQueryPlanVersion version=0, std::optional< std::future< bool >> abortConnection=std::nullopt)