X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=lib%2Fservice%2Fservicemp3.h;h=1d77483f3a95eae6312caec79795bd86ec0d6599;hp=aa342f4bf68604d59774cfd2150775cb4aa16bc3;hb=85cf8dd019e8c44fb42802b01efb0677f328fa7c;hpb=2f21e0048543192bc1a145f5ac3bd62da7822adf diff --git a/lib/service/servicemp3.h b/lib/service/servicemp3.h index aa342f4..a14a123 100644 --- a/lib/service/servicemp3.h +++ b/lib/service/servicemp3.h @@ -5,10 +5,16 @@ #include #include #include +#include +#include #include +/* for subtitles */ +#include class eStaticServiceMP3Info; +class eSubtitleWidget; + class eServiceFactoryMP3: public iServiceHandler { DECLARE_REF(eServiceFactoryMP3); @@ -35,12 +41,18 @@ class eStaticServiceMP3Info: public iStaticServiceInformation public: RESULT getName(const eServiceReference &ref, std::string &name); int getLength(const eServiceReference &ref); + int getInfo(const eServiceReference &ref, int w); }; typedef struct _GstElement GstElement; -class eServiceMP3: public iPlayableService, public iPauseableService, - public iServiceInformation, public iSeekableService, public iAudioTrackSelection, public iAudioChannelSelection, public Object +typedef enum { atUnknown, atMPEG, atMP3, atAC3, atDTS, atAAC, atPCM, atOGG, atFLAC } audiotype_t; +typedef enum { stUnknown, stPlainText, stSSA, stASS, stSRT, stVOB, stPGS } subtype_t; +typedef enum { ctNone, ctMPEGTS, ctMPEGPS, ctMKV, ctAVI, ctMP4, ctVCD, ctCDA } containertype_t; + +class eServiceMP3: public iPlayableService, public iPauseableService, + public iServiceInformation, public iSeekableService, public iAudioTrackSelection, public iAudioChannelSelection, + public iSubtitleOutput, public iStreamedService, public iAudioDelay, public Object { DECLARE_REF(eServiceMP3); public: @@ -59,17 +71,18 @@ public: RESULT seek(ePtr &ptr); RESULT audioTracks(ePtr &ptr); RESULT audioChannel(ePtr &ptr); + RESULT subtitle(ePtr &ptr); + RESULT audioDelay(ePtr &ptr); // not implemented (yet) RESULT frontendInfo(ePtr &ptr) { ptr = 0; return -1; } RESULT subServices(ePtr &ptr) { ptr = 0; return -1; } RESULT timeshift(ePtr &ptr) { ptr = 0; return -1; } RESULT cueSheet(ePtr &ptr) { ptr = 0; return -1; } - RESULT subtitle(ePtr &ptr) { ptr = 0; return -1; } - RESULT audioDelay(ePtr &ptr) { ptr = 0; return -1; } + RESULT rdsDecoder(ePtr &ptr) { ptr = 0; return -1; } - RESULT stream(ePtr &ptr) { ptr = 0; return -1; } RESULT keys(ePtr &ptr) { ptr = 0; return -1; } + RESULT stream(ePtr &ptr) { ptr = 0; return -1; } // iPausableService RESULT pause(); @@ -89,6 +102,7 @@ public: RESULT getName(std::string &name); int getInfo(int w); std::string getInfoString(int w); + PyObject *getInfoObject(int w); // iAudioTrackSelection int getNumberOfTracks(); @@ -100,37 +114,169 @@ public: int getCurrentChannel(); RESULT selectChannel(int i); + // iSubtitleOutput + RESULT enableSubtitles(eWidget *parent, SWIG_PYOBJECT(ePyObject) entry); + RESULT disableSubtitles(eWidget *parent); + PyObject *getSubtitleList(); + PyObject *getCachedSubtitle(); + + // iStreamedService + RESULT streamed(ePtr &ptr); + PyObject *getBufferCharge(); + int setBufferSize(int size); + + // iAudioDelay + int getAC3Delay(); + int getPCMDelay(); + void setAC3Delay(int); + void setPCMDelay(int); + struct audioStream { GstPad* pad; - enum { atMP2, atMP3, atAC3, atDTS, atAAC, atPCM, atOGG }; - int type; // mpeg2, ac3, dts, ... + audiotype_t type; std::string language_code; /* iso-639, if available. */ + std::string codec; /* clear text codec description */ + audioStream() + :pad(0), type(atUnknown) + { + } + }; + struct subtitleStream + { + GstPad* pad; + subtype_t type; + std::string language_code; /* iso-639, if available. */ + subtitleStream() + :pad(0) + { + } + }; + struct sourceStream + { + audiotype_t audiotype; + containertype_t containertype; + bool is_video; + bool is_streaming; + sourceStream() + :audiotype(atUnknown), containertype(ctNone), is_video(FALSE), is_streaming(FALSE) + { + } + }; + struct bufferInfo + { + int bufferPercent; + int avgInRate; + int avgOutRate; + long long bufferingLeft; + bufferInfo() + :bufferPercent(0), avgInRate(0), avgOutRate(0), bufferingLeft(-1) + { + } }; private: + static int pcm_delay; + static int ac3_delay; int m_currentAudioStream; - int m_currentTrickRate; + int m_currentSubtitleStream; + int selectAudioStream(int i); std::vector m_audioStreams; + std::vector m_subtitleStreams; + eSubtitleWidget *m_subtitle_widget; + int m_currentTrickRatio; + ePtr m_seekTimeout; + void seekTimeoutCB(); friend class eServiceFactoryMP3; - std::string m_filename; - eServiceMP3(const char *filename); + eServiceReference m_ref; + int m_buffer_size; + bufferInfo m_bufferInfo; + eServiceMP3(eServiceReference ref); Signal2 m_event; enum { stIdle, stRunning, stStopped, }; int m_state; - GstElement *m_gst_pipeline; + GstElement *m_gst_playbin; + GstElement *m_gst_subtitlebin; GstTagList *m_stream_tags; - eFixedMessagePump m_pump; + struct Message + { + Message() + :type(-1) + {} + Message(int type) + :type(type) + {} + Message(int type, GstPad *pad) + :type(type) + { + d.pad=pad; + } + + int type; + union { + GstPad *pad; // for msg type 3 + } d; + }; + + eFixedMessagePump m_pump; + std::string m_error_message; + + audiotype_t gstCheckAudioPad(GstStructure* structure); void gstBusCall(GstBus *bus, GstMessage *msg); static GstBusSyncReply gstBusSyncHandler(GstBus *bus, GstMessage *message, gpointer user_data); - static void gstCBpadAdded(GstElement *decodebin, GstPad *pad, gpointer data); /* for mpegdemux */ - static void gstCBfilterPadAdded(GstElement *filter, GstPad *pad, gpointer user_data); /* for id3demux */ - static void gstCBnewPad(GstElement *decodebin, GstPad *pad, gboolean last, gpointer data); /* for decodebin */ - static void gstCBunknownType(GstElement *decodebin, GstPad *pad, GstCaps *l, gpointer data); - void gstPoll(const int&); + static void gstHTTPSourceSetAgent(GObject *source, GParamSpec *unused, gpointer user_data); + static void gstCBsubtitleAvail(GstElement *element, gpointer user_data); + static GstCaps* gstGhostpadGetCAPS (GstPad * pad); + static gboolean gstGhostpadAcceptCAPS(GstPad * pad, GstCaps * caps); + static void gstGhostpadLink(gpointer user_data, GstCaps * caps); + static GstFlowReturn gstGhostpadBufferAlloc(GstPad *pad, guint64 offset, guint size, GstCaps *caps, GstBuffer **buf); + static void gstGhostpadHasCAPS(GstPad *pad, GParamSpec * unused, gpointer user_data); + static gboolean gstGhostpadSinkEvent(GstPad * pad, GstEvent * event); + static GstFlowReturn gstGhostpadChainFunction(GstPad * pad, GstBuffer * buffer); +/* static void gstCBsubtitleCAPS(GObject *obj, GParamSpec *pspec, gpointer user_data); + static void gstCBsubtitleLink(subtype_t type, gpointer user_data); + static gboolean gstCBsubtitleDrop(GstPad *pad, GstBuffer *buffer, gpointer user_data);*/ + void gstPoll(const Message&); + void gstGhostpadHasCAPS_synced(GstPad *pad); + + GstPadBufferAllocFunction m_ghost_pad_buffer_alloc; + GstPadChainFunction m_ghost_pad_chain_function; + GstPadEventFunction m_ghost_pad_subtitle_sink_event; + GstCaps *m_gst_prev_subtitle_caps; + GstSegment m_gst_subtitle_segment; + GstPadEventFunction m_gst_sink_event; + + struct SubtitlePage + { + enum { Unknown, Pango, Vob } type; + ePangoSubtitlePage pango_page; + eVobSubtitlePage vob_page; + }; + + std::list m_subtitle_pages; + ePtr m_subtitle_sync_timer; + ePtr m_subtitle_hide_timer; + ePtr m_streamingsrc_timeout; + pts_t m_prev_decoder_time; + int m_decoder_time_valid_state; + + void pushSubtitles(); + void pullSubtitle(); + void hideSubtitles(); + void sourceTimeout(); + int m_subs_to_pull; + sourceStream m_sourceinfo; + eSingleLock m_subs_to_pull_lock; + gulong m_subs_to_pull_handler_id; + + RESULT seekToImpl(pts_t to); + + gint m_aspect, m_width, m_height, m_framerate, m_progressive; + std::string m_useragent; + RESULT trickSeek(gdouble ratio); }; #endif