summaryrefslogtreecommitdiff
path: root/p2pvr/lib/muxer.h
blob: e4789cf2ac2a00df2974dc98a15d4d43f70ed26d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
#ifndef MUXER_H
#define MUXER_H

#include <dvb.h>
#include <mutex>

class Muxer : public P2PVR::RawDataClient {
	public:
		Muxer(const P2PVR::RawDataClientPrx & target, const std::string & cmd);
		~Muxer();

		bool NewData(const P2PVR::Data &, const Ice::Current &);

	private:
		bool ReadWaiting() const;
		bool ReadAvailable() const;
		bool ReadMuxerAndSend(int wait) const;
		const P2PVR::RawDataClientPrx target;
		int fds[3];
		pid_t muxerPid;
		mutable std::mutex wlock;
		mutable std::mutex rlock;
};

#endif