X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FSocket%2FProtocols%2FDVB%2FDVBProtocolWrapper.hh;h=ca47c00cbc0dea658395b3f96ef1ccb1a128366b;hb=7661548b20e6c7627f54bff87e0758396fd523ef;hp=5651a6c6b6f2710383b25864e6c77a64d868c1bf;hpb=26610f603ebdd465307b9621f532c1fe19fd5571;p=senf.git diff --git a/senf/Socket/Protocols/DVB/DVBProtocolWrapper.hh b/senf/Socket/Protocols/DVB/DVBProtocolWrapper.hh index 5651a6c..ca47c00 100644 --- a/senf/Socket/Protocols/DVB/DVBProtocolWrapper.hh +++ b/senf/Socket/Protocols/DVB/DVBProtocolWrapper.hh @@ -1,4 +1,4 @@ -// $Id: DVBSocketController.hh 1119 2009-02-16 13:36:59Z tho $ +// $Id$ // // Copyright (C) 2007 // Fraunhofer Institute for Open Communication Systems (FOKUS) @@ -23,149 +23,87 @@ #ifndef HH_SENF_Socket_Protocols_DVB_DVBProtocolWrapper_ #define HH_SENF_Socket_Protocols_DVB_DVBProtocolWrapper_ 1 -#include -#include -#include "DVBDemuxHandles.hh" + // Custom includes +#include +#include +#include "DVBDemuxHandles.hh" + +//-///////////////////////////////////////////////////////////////////////////////////////////////// -SENF_CONSOLE_REGISTER_ENUM( dmx_input_t, (DMX_IN_FRONTEND)(DMX_IN_DVR) ) -; -SENF_CONSOLE_REGISTER_ENUM( dmx_output_t, (DMX_OUT_DECODER)(DMX_OUT_TAP)(DMX_OUT_TS_TAP) ) -; +SENF_CONSOLE_REGISTER_ENUM( dmx_input_t, (DMX_IN_FRONTEND)(DMX_IN_DVR) ); +SENF_CONSOLE_REGISTER_ENUM( dmx_output_t, (DMX_OUT_DECODER)(DMX_OUT_TAP)(DMX_OUT_TS_TAP) ); SENF_CONSOLE_REGISTER_ENUM( dmx_pes_type_t, (DMX_PES_AUDIO0)(DMX_PES_VIDEO0)(DMX_PES_TELETEXT0)(DMX_PES_SUBTITLE0)(DMX_PES_PCR0) (DMX_PES_AUDIO1)(DMX_PES_VIDEO1)(DMX_PES_TELETEXT1)(DMX_PES_SUBTITLE1)(DMX_PES_PCR1) (DMX_PES_AUDIO2)(DMX_PES_VIDEO2)(DMX_PES_TELETEXT2)(DMX_PES_SUBTITLE2)(DMX_PES_PCR2) (DMX_PES_AUDIO3)(DMX_PES_VIDEO3)(DMX_PES_TELETEXT3)(DMX_PES_SUBTITLE3)(DMX_PES_PCR3) - (DMX_PES_OTHER)) -; + (DMX_PES_OTHER)); namespace senf { - /** \brief Helperclass for configuration and controlling DVB protokoll handles. - + /** \brief Helperclass for configuration and controlling DVB protocol handles. */ + class DVBSectionProtocolWrapper : public DVBProtocolWrapper + { + private: + const DVBDemuxSectionSocketProtocol& protocol; - class DVBSectionProtocolWrapper : public senf::DVBProtocolWrapper { - -public: + public: enum Flags {CHECK_CRC = DMX_CHECK_CRC, ONESHOT = DMX_ONESHOT, IMMEDIATE_START = DMX_IMMEDIATE_START, KERNEL_CLIENT = DMX_KERNEL_CLIENT}; senf::console::ScopedDirectory dir; -private: - const senf::DVBDemuxSectionSocketProtocol& protocol; -public: - DVBSectionProtocolWrapper(senf::DVBDemuxSectionHandle sh) : - dir(this), protocol(sh.protocol()) { - - namespace kw = senf::console::kw; - dir.add("buffersize", &DVBSectionProtocolWrapper::setBufferSize) - .doc("Set the size of the circular buffer used for filtered data.") - .arg("size", "in byte"); - - dir.add("start", &DVBSectionProtocolWrapper::startFiltering) - .doc("Starts filtering"); - - dir.add("stop", &DVBSectionProtocolWrapper::setBufferSize) - .doc("Stops filtering"); - - dir.node().add("filter", boost::function, unsigned, unsigned, unsigned)>(senf::membind(&DVBSectionProtocolWrapper::setSectionFilter, this))) - .arg("pid", "pid to filter") - .arg("filter", "filter", kw::default_value = 62, kw::default_doc = "0x3e") - .arg("flags", "or-able: CHECK_CRC, ONESHOT, IMMEDIATE_START, KERNEL_CLIENT", kw::default_value = DMX_IMMEDIATE_START | DMX_CHECK_CRC, kw::default_doc = "(IMMEDIATE_START CHECK_CRC)") - .arg("mask", "mask", kw::default_value = 0xff, kw::default_doc = "0xff") - .arg("mode", "mode", kw::default_value = 0, kw::default_doc = "0x00") - .arg("timeout", "timeout", kw::default_value = 0, kw::default_doc = "0x00") - .doc("Sets parameters for section filter."); - - dir.add("stop", &DVBSectionProtocolWrapper::setBufferSize) - .doc("Stops filtering"); - } - ~DVBSectionProtocolWrapper() { - } - void setSectionFilter(unsigned short int pid, u_int8_t filter, - unsigned int flags, u_int8_t mask, u_int8_t mode, - unsigned int timeout) { - protocol.setSectionFilter(pid, timeout, flags, filter, mask, mode); - - } - - ///< Set the size of the circular buffer used for filtered data. - /**< The default size is two maximum sized sections, i.e. if - this function is not called a buffer size of 2 * 4096 - bytes will be used. - \param[in] size Size of circular buffer. */ - void setBufferSize(unsigned long size) { - protocol.setBufferSize(size); - } - - void startFiltering() ///< Starts filtering - { - protocol.startFiltering(); - } - - void stopFiltering() ///< Stops filtering - { - protocol.stopFiltering(); - } + DVBSectionProtocolWrapper(senf::DVBDemuxSectionHandle sh); + ~DVBSectionProtocolWrapper() { } + + void setSectionFilter(unsigned short int pid, u_int8_t filter, + unsigned int flags, u_int8_t mask, u_int8_t mode, unsigned int timeout); + + void setBufferSize(unsigned long size); + ///< Set the size of the circular buffer used for filtered data. + /**< The default size is two maximum sized sections, i.e. if + this function is not called a buffer size of 2 * 4096 bytes + will be used. + \param[in] size Size of circular buffer. */ + void startFiltering(); ///< Starts filtering + void stopFiltering(); ///< Stops filtering }; + SENF_CONSOLE_REGISTER_ENUM_MEMBER(DVBSectionProtocolWrapper, Flags, - (CHECK_CRC)(ONESHOT)(IMMEDIATE_START)(KERNEL_CLIENT)) - ; + (CHECK_CRC)(ONESHOT)(IMMEDIATE_START)(KERNEL_CLIENT)); - class DVBPESProtocolWrapper : public senf::DVBProtocolWrapper { -public: + class DVBPESProtocolWrapper : public senf::DVBProtocolWrapper + { + private: + const senf::DVBDemuxPESSocketProtocol& protocol; + + public: enum Flags {CHECK_CRC = DMX_CHECK_CRC, ONESHOT = DMX_ONESHOT, IMMEDIATE_START = DMX_IMMEDIATE_START, KERNEL_CLIENT = DMX_KERNEL_CLIENT}; senf::console::ScopedDirectory dir; -private: - const senf::DVBDemuxPESSocketProtocol& protocol; -public: - DVBPESProtocolWrapper(senf::DVBDemuxPESHandle sh) : - dir(this), protocol(sh.protocol()) { - namespace kw = senf::console::kw; - - dir.node().add("filter", boost::function)>(senf::membind(&DVBPESProtocolWrapper::setPESFilter, this))) - .arg("pid", "pid to filter") - .arg("input", "input-filter: DMX_IN_FRONTEND DMX_IN_DVR ") - .arg("output", "output-filter: DMX_OUT_DECODER DMX_OUT_TAP DMX_OUT_TS_TAP ") - .arg("pesType", "PES type: DMX_PES_AUDIO[0-3] DMX_PES_VIDEO[0-3] DMX_PES_TELETEXT[0-3], DMX_PES_SUBTITLE[0-3], DMX_PES_PCR[0-3], DMX_PES_OTHER") - .arg("flags", "or-able: CHECK_CRC, ONESHOT, IMMEDIATE_START, KERNEL_CLIENT", kw::default_value = DMX_IMMEDIATE_START | DMX_CHECK_CRC, kw::default_doc = "(IMMEDIATE_START CHECK_CRC)") - .doc("Sets parameters for PES filter."); - dir.add("start", &DVBPESProtocolWrapper::startFiltering) - .doc("Starts filtering"); - - dir.add("stop", &DVBPESProtocolWrapper::stopFiltering) - .doc("Stops filtering"); - } - ~DVBPESProtocolWrapper() { - } - ; + + DVBPESProtocolWrapper(senf::DVBDemuxPESHandle sh); + ~DVBPESProtocolWrapper() { }; void setPESFilter(unsigned short int pid, dmx_input_t input, - dmx_output_t output, dmx_pes_type_t pesType, unsigned int flags) { - protocol.setPESFilter(pid, input, output, pesType, flags); - } - void startFiltering() ///< Starts filtering - { - protocol.startFiltering(); - } - - void stopFiltering() ///< Stops filtering - { - protocol.stopFiltering(); - } + dmx_output_t output, dmx_pes_type_t pesType, unsigned int flags); + void startFiltering(); ///< Starts filtering + void stopFiltering(); ///< Stops filtering }; + SENF_CONSOLE_REGISTER_ENUM_MEMBER(DVBPESProtocolWrapper, Flags, - (CHECK_CRC)(ONESHOT)(IMMEDIATE_START)(KERNEL_CLIENT)) - ; + (CHECK_CRC)(ONESHOT)(IMMEDIATE_START)(KERNEL_CLIENT)); } +//-///////////////////////////////////////////////////////////////////////////////////////////////// +#include "DVBProtocolWrapper.cci" +//#include "DVBProtocolWrapper.ct" +//#include "DVBProtocolWrapper.cti" #endif