diff options
Diffstat (limited to 'p2pvr/devices/mockTuner.h')
| -rw-r--r-- | p2pvr/devices/mockTuner.h | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/p2pvr/devices/mockTuner.h b/p2pvr/devices/mockTuner.h new file mode 100644 index 0000000..aa51580 --- /dev/null +++ b/p2pvr/devices/mockTuner.h @@ -0,0 +1,42 @@ +#ifndef P2PVR_MOCKTUNER_H +#define P2PVR_MOCKTUNER_H + +#include <dvb.h> +#include <Ice/BuiltinSequences.h> +#include <boost/thread.hpp> + +class MockTuner : public P2PVR::PrivateTuner { + public: + MockTuner(); + + void TuneTo(const DVBSI::DeliveryPtr &, const Ice::Current&); + int GetStatus(const Ice::Current&); + + void ScanAndSendNetworkInformation(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendNetworkInformation(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendBouquetAssociations(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendServiceDescriptions(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendProgramMap(Ice::Int pid, const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendProgramAssociationTable(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + void SendEventInformation(const P2PVR::RawDataClientPrx & client, const Ice::Current&); + + int StartSendingTS(const P2PVR::PacketIds & pids, const P2PVR::RawDataClientPrx & client, const Ice::Current &); + int StartSendingSection(Ice::Int pid, const P2PVR::RawDataClientPrx & client, const Ice::Current &); + void StopSending(int handle, const Ice::Current &); + + Ice::Long GetLastUsedTime(const Ice::Current&); + + static void SetEventsSet(int n); + + protected: + static Ice::ByteSeq Decompress(const Ice::ByteSeq &); + void DecompressAndSendPackets(const Ice::ByteSeq &, const P2PVR::RawDataClientPrx &, const Ice::Current&) const; + void SendLoop(const P2PVR::RawDataClientPrx & t, const Ice::ByteSeq & dataxz, const Ice::Current & ice) const; + + static int eventSet; + std::map<int, boost::thread *> senders; + int senderId; +}; + +#endif + |