LocalTrackIf.hxx

Go to the documentation of this file.

 
#ifndef _DCC_LOCALTRACKIF_HXX_
#define _DCC_LOCALTRACKIF_HXX_
 
#include "executor/Executor.hxx"
#include "executor/StateFlow.hxx"
#include "dcc/Packet.hxx"
 
namespace dcc
{
 
class LocalTrackIf : public StateFlow<Buffer<dcc::Packet>, QList<1>>
{
public:
    LocalTrackIf(Service *service, int pool_size);
 
    FixedPool *pool() OVERRIDE
    {
        return &pool_;
    }
 
    void set_fd(int fd)
    {
        fd_ = fd;
    }
 
protected:
    Action entry() OVERRIDE;
 
    Action finish()
    {
        return release_and_exit();
    }
 
    int fd_;
    FixedPool pool_;
};
 
class LocalTrackIfSelect : public LocalTrackIf
{
public:
    LocalTrackIfSelect(Service *service, int pool_size)
        : LocalTrackIf(service, pool_size)
    {
    }
 
protected:
    Action entry() OVERRIDE;
 
    StateFlowSelectHelper helper_{this};
};
 
} // namespace dcc
 
#endif // _DCC_LOCALTRACKIF_HXX_