12 #ifndef HTGS_ANYCONNECTOR_HPP 13 #define HTGS_ANYCONNECTOR_HPP 58 virtual std::string getQueueTiming() = 0;
92 std::ostringstream inConn;
93 inConn <<
"x" <<
this;
94 std::string inConnStr = inConn.str();
109 +
", enqLock, deqLock, enqWait, deqWait::" + getQueueTiming()
111 +
"\",shape=box,style=rounded,color=black,width=.2,height=.2];\n";
168 virtual void profileConsume(
size_t numThreads,
bool showQueueSize) = 0;
193 #endif //HTGS_ANYCONNECTOR_HPP virtual void profileConsume(size_t numThreads, bool showQueueSize)=0
Provides profile output for the consume operation.
std::atomic_size_t producerTaskCount
The number of producers adding data to the connector.
Definition: AnyConnector.hpp:188
virtual void profileProduce(size_t numThreads)=0
Provide profile output for the produce operation.
AnyConnector()
Constructor initializing the producer task count to 0.
Definition: AnyConnector.hpp:45
virtual ~AnyConnector()
Virtual destructor.
Definition: AnyConnector.hpp:50
virtual void produceAnyData(std::shared_ptr< IData > data)=0
Produces any data into the queue.
std::string genDot(int flags)
Generates the dot representation for this connector.
Definition: AnyConnector.hpp:104
Parent class for Connector, which removes the template type of the Connector.
Definition: AnyConnector.hpp:39
void incrementInputTaskCount()
Increments the number of tasks producing data for the Connector.
Definition: AnyConnector.hpp:85
virtual AnyConnector * copy()=0
Creates a copy of the BaseConnector.
virtual bool isInputTerminated()=0
Checks whether the producer for this Connector has finished pushing data onto its queue...
void producerFinished()
Indicates to the Connector that the producer has finished producing data for the Connector.
Definition: AnyConnector.hpp:67
virtual size_t getQueueSize()=0
Gets the size of the queue that this connector has in its data queue.
virtual void wakeupConsumer()=0
Awakens all Tasks that are consuming data from this connector.
Implements the IData class, which is used for all data types entering/leaving a task graph...
size_t getProducerCount()
Gets the number of producers producing data for the connector.
Definition: AnyConnector.hpp:75
std::string getDotId()
Gets the id used for dot graphs for GraphViz.
Definition: AnyConnector.hpp:91
virtual size_t getMaxQueueSize()=0
Gets the maximum queue size that this connector has in its data queue.
virtual void resetMaxQueueSize()=0
Resets the max queue size profile.
virtual std::string typeName()=0
Gets the demangled type name of the connector.
Definition: Bookkeeper.hpp:23
Defines DOTGEN flags used for dot file generation.
#define DOTGEN_FLAG_SHOW_CONNECTOR_VERBOSE
Shows verbose information within each connector in the graph.
Definition: TaskGraphDotGenFlags.hpp:92
#define DOTGEN_FLAG_SHOW_CURRENT_Q_SZ
Displays the current queue size within each connector.
Definition: TaskGraphDotGenFlags.hpp:86