#ifndef MUXER_H #define MUXER_H #include #include class Muxer : public P2PVR::RawDataClient { public: Muxer(const P2PVR::RawDataClientPrx & target); ~Muxer(); bool NewData(const P2PVR::Data &, const Ice::Current &); private: bool ReadMuxerAndSend() const; const P2PVR::RawDataClientPrx & target; int fds[2]; std::mutex lock; }; #endif