#include <FairMQBenchmarkSampler.h>
Inheritance diagram for FairMQBenchmarkSampler:
Collaboration diagram for FairMQBenchmarkSampler:
Public Member Functions | |
| void | InitTask () override |
| Task initialization (can be overloaded in child classes) | |
| void | Run () override |
| Runs the device (to be overloaded in child classes) | |
 Public Member Functions inherited from FairMQDevice | |
| FairMQDevice () | |
| Default constructor. | |
| FairMQDevice (fair::mq::ProgOptions &config) | |
| Constructor with external fair::mq::ProgOptions. | |
| FairMQDevice (const fair::mq::tools::Version version) | |
| Constructor that sets the version. | |
| FairMQDevice (fair::mq::ProgOptions &config, const fair::mq::tools::Version version) | |
| Constructor that sets the version and external fair::mq::ProgOptions. | |
| FairMQDevice (const FairMQDevice &)=delete | |
| Copy constructor (disabled) | |
| FairMQDevice | operator= (const FairMQDevice &)=delete |
| Assignment operator (disabled) | |
| virtual | ~FairMQDevice () |
| Default destructor. | |
| virtual void | LogSocketRates () |
| Outputs the socket transfer rates. | |
| template<typename Serializer , typename DataType , typename... Args> | |
| void | Serialize (FairMQMessage &msg, DataType &&data, Args &&... args) const |
| template<typename Deserializer , typename DataType , typename... Args> | |
| void | Deserialize (FairMQMessage &msg, DataType &&data, Args &&... args) const |
| int64_t | Send (FairMQMessagePtr &msg, const std::string &channel, const int index=0, int sndTimeoutInMs=-1) |
| int64_t | Receive (FairMQMessagePtr &msg, const std::string &channel, const int index=0, int rcvTimeoutInMs=-1) |
| int64_t | Send (FairMQParts &parts, const std::string &channel, const int index=0, int sndTimeoutInMs=-1) |
| int64_t | Receive (FairMQParts &parts, const std::string &channel, const int index=0, int rcvTimeoutInMs=-1) |
| auto | Transport () const -> FairMQTransportFactory * |
| Getter for default transport factory. | |
| template<typename... Args> | |
| FairMQMessagePtr | NewMessage (Args &&... args) |
| template<typename... Args> | |
| FairMQMessagePtr | NewMessageFor (const std::string &channel, int index, Args &&... args) |
| template<typename T > | |
| FairMQMessagePtr | NewStaticMessage (const T &data) |
| template<typename T > | |
| FairMQMessagePtr | NewStaticMessageFor (const std::string &channel, int index, const T &data) |
| template<typename T > | |
| FairMQMessagePtr | NewSimpleMessage (const T &data) |
| template<typename T > | |
| FairMQMessagePtr | NewSimpleMessageFor (const std::string &channel, int index, const T &data) |
| template<typename... Args> | |
| FairMQUnmanagedRegionPtr | NewUnmanagedRegion (Args &&... args) |
| template<typename... Args> | |
| FairMQUnmanagedRegionPtr | NewUnmanagedRegionFor (const std::string &channel, int index, Args &&... args) |
| template<typename ... Ts> | |
| FairMQPollerPtr | NewPoller (const Ts &... inputs) |
| FairMQPollerPtr | NewPoller (const std::vector< FairMQChannel * > &channels) |
| std::shared_ptr< FairMQTransportFactory > | AddTransport (const fair::mq::Transport transport) |
| void | SetConfig (fair::mq::ProgOptions &config) |
| Assigns config to the device. | |
| fair::mq::ProgOptions * | GetConfig () const |
| Get pointer to the config. | |
| template<typename T > | |
| void | OnData (const std::string &channelName, bool(T::*memberFunction)(FairMQMessagePtr &msg, int index)) |
| void | OnData (const std::string &channelName, InputMsgCallback callback) |
| template<typename T > | |
| void | OnData (const std::string &channelName, bool(T::*memberFunction)(FairMQParts &parts, int index)) |
| void | OnData (const std::string &channelName, InputMultipartCallback callback) |
| FairMQChannel & | GetChannel (const std::string &channelName, const int index=0) |
| virtual void | RegisterChannelEndpoints () |
| bool | RegisterChannelEndpoint (const std::string &channelName, uint16_t minNumSubChannels=1, uint16_t maxNumSubChannels=1) |
| void | PrintRegisteredChannels () |
| void | SetId (const std::string &id) |
| std::string | GetId () |
| const fair::mq::tools::Version | GetVersion () const |
| void | SetNumIoThreads (int numIoThreads) |
| int | GetNumIoThreads () const |
| void | SetNetworkInterface (const std::string &networkInterface) |
| std::string | GetNetworkInterface () const |
| void | SetDefaultTransport (const std::string &name) |
| std::string | GetDefaultTransport () const |
| void | SetInitTimeoutInS (int initTimeoutInS) |
| int | GetInitTimeoutInS () const |
| void | SetTransport (const std::string &transport) |
| std::string | GetTransportName () const |
| Gets the default transport name. | |
| void | SetRawCmdLineArgs (const std::vector< std::string > &args) |
| std::vector< std::string > | GetRawCmdLineArgs () const |
| void | RunStateMachine () |
| template<typename Rep , typename Period > | |
| bool | WaitFor (std::chrono::duration< Rep, Period > const &duration) |
| void | AddChannel (const std::string &name, FairMQChannel &&channel) |
| bool | ChangeState (const fair::mq::Transition transition) |
| Request a device state transition. More... | |
| bool | ChangeState (const std::string &transition) |
| Request a device state transition. More... | |
| fair::mq::State | WaitForNextState () |
| waits for the next state (any) to occur | |
| void | WaitForState (fair::mq::State state) |
| waits for the specified state to occur More... | |
| void | WaitForState (const std::string &state) |
| waits for the specified state to occur More... | |
| void | TransitionTo (const fair::mq::State state) |
| void | SubscribeToStateChange (const std::string &key, std::function< void(const fair::mq::State)> callback) |
| Subscribe with a callback to state changes. More... | |
| void | UnsubscribeFromStateChange (const std::string &key) |
| Unsubscribe from state changes. More... | |
| void | SubscribeToNewTransition (const std::string &key, std::function< void(const fair::mq::Transition)> callback) |
| Subscribe with a callback to incoming state transitions. More... | |
| void | UnsubscribeFromNewTransition (const std::string &key) |
| Unsubscribe from state transitions. More... | |
| bool | NewStatePending () const |
| Returns true if a new state has been requested, signaling the current handler to stop. | |
| fair::mq::State | GetCurrentState () const |
| Returns the current state. | |
| std::string | GetCurrentStateName () const |
| Returns the name of the current state as a string. | |
Protected Attributes | |
| bool | fMultipart |
| bool | fMemSet |
| size_t | fNumParts |
| size_t | fMsgSize |
| size_t | fMsgAlignment |
| float | fMsgRate |
| uint64_t | fNumIterations |
| uint64_t | fMaxIterations |
| std::string | fOutChannelName |
| Protected Attributes inherited from FairMQDevice | |
| std::shared_ptr< FairMQTransportFactory > | fTransportFactory |
| Default transport factory. | |
| std::unordered_map< fair::mq::Transport, std::shared_ptr< FairMQTransportFactory > > | fTransports |
| Container for transports. | |
| std::string | fId |
| Device ID. | |
Additional Inherited Members | |
| Static Public Member Functions inherited from FairMQDevice | |
| static std::string | GetStateName (const fair::mq::State state) |
| Returns name of the given state as a string. More... | |
| static std::string | GetTransitionName (const fair::mq::Transition transition) |
| Returns name of the given transition as a string. More... | |
| Public Attributes inherited from FairMQDevice | |
| std::unordered_map< std::string, std::vector< FairMQChannel > > | fChannels |
| Device channels. | |
| std::unique_ptr< fair::mq::ProgOptions > | fInternalConfig |
| Internal program options configuration. | |
| fair::mq::ProgOptions * | fConfig |
| Pointer to config (internal or external) | |
| Static Public Attributes inherited from FairMQDevice | |
| static constexpr const char * | DefaultId = "" |
| static constexpr int | DefaultIOThreads = 1 |
| static constexpr const char * | DefaultTransportName = "zeromq" |
| static constexpr fair::mq::Transport | DefaultTransportType = fair::mq::Transport::ZMQ |
| static constexpr const char * | DefaultNetworkInterface = "default" |
| static constexpr int | DefaultInitTimeout = 120 |
| static constexpr uint64_t | DefaultMaxRunTime = 0 |
| static constexpr float | DefaultRate = 0. |
| static constexpr const char * | DefaultSession = "default" |
| Protected Member Functions inherited from FairMQDevice | |
| virtual void | Init () |
| Additional user initialization (can be overloaded in child classes). Prefer to use InitTask(). | |
| virtual void | Bind () |
| virtual void | Connect () |
| virtual void | PreRun () |
| Called in the RUNNING state once before executing the Run()/ConditionalRun() method. | |
| virtual bool | ConditionalRun () |
| Called during RUNNING state repeatedly until it returns false or device state changes. | |
| virtual void | PostRun () |
| Called in the RUNNING state once after executing the Run()/ConditionalRun() method. | |
| virtual void | ResetTask () |
| Resets the user task (to be overloaded in child classes) | |
| virtual void | Reset () |
| Resets the device (can be overloaded in child classes) | |
Detailed Description
Sampler to generate traffic for benchmarking.
The documentation for this class was generated from the following file:
- fairmq/devices/FairMQBenchmarkSampler.h