PoolToQueueFlow.hxx

Go to the documentation of this file.

 
#ifndef _EXECUTOR_POOLTOQUEUEFLOW_HXX_
#define _EXECUTOR_POOLTOQUEUEFLOW_HXX_
 
template <class T> class PoolToQueueFlow : public StateFlowBase
{
public:
    PoolToQueueFlow(Service *service, FixedPool *source, FlowInterface<T> *dest)
        : StateFlowBase(service)
        , source_(source)
        , dest_(dest)
    {
        get_next_entry();
    }
 
private:
    Action get_next_entry()
    {
        return allocate_and_call(dest_, STATE(got_entry), source_);
    }
 
    Action got_entry()
    {
        auto *b = get_allocation_result(dest_);
        dest_->send(b);
        return get_next_entry();
    }
 
    FixedPool *source_;
    FlowInterface<T> *dest_;
};
 
#endif // _EXECUTOR_POOLTOQUEUEFLOW_HXX_