PartitionManager.hpp File Reference

#include <Network/NetworkForwardRefs.hpp>
#include <Network/PartitionRegistrationStatus.hpp>
#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Network/NodeLocation.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <memory>
#include <mutex>
#include <optional>
#include <unordered_map>
#include <vector>

Include dependency graph for PartitionManager.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Network::PartitionManager
	this class keeps track of all ready partitions (and their subpartitions) It keeps track of the ref cnt for each partition and associated data emitter A data emitter is notified once there is data for its partition. Pinning a partition for a Consumer/Producer means increasing its reference counter to n: Consumer: there are n "listeners" that are to consume the data of a partition Producer: there are n "emitters" that are to produce the data for a partition When the reference counter reaches 0, it means that none requires a partition. More...

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

Typedefs
using	NES::Network::PartitionManagerPtr = std::shared_ptr< PartitionManager >