X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/85cf8dd019e8c44fb42802b01efb0677f328fa7c..d0380b44396cbcd497f42eb0047b58b309596007:/lib/service/servicemp3.h diff --git a/lib/service/servicemp3.h b/lib/service/servicemp3.h index a14a1234..f3cc6ddf 100644 --- a/lib/service/servicemp3.h +++ b/lib/service/servicemp3.h @@ -1,7 +1,6 @@ #ifndef __servicemp3_h #define __servicemp3_h -#ifdef HAVE_GSTREAMER #include #include #include @@ -168,12 +167,18 @@ public: int bufferPercent; int avgInRate; int avgOutRate; - long long bufferingLeft; + int64_t bufferingLeft; bufferInfo() :bufferPercent(0), avgInRate(0), avgOutRate(0), bufferingLeft(-1) { } }; + struct errorInfo + { + std::string error_message; + std::string missing_codec; + }; + private: static int pcm_delay; static int ac3_delay; @@ -190,64 +195,48 @@ private: eServiceReference m_ref; int m_buffer_size; bufferInfo m_bufferInfo; + errorInfo m_errorInfo; eServiceMP3(eServiceReference ref); Signal2 m_event; enum { stIdle, stRunning, stStopped, - }; - int m_state; - GstElement *m_gst_playbin; - GstElement *m_gst_subtitlebin; - GstTagList *m_stream_tags; - - 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 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);*/ + }; + int m_state; + GstElement *m_gst_playbin; + GstTagList *m_stream_tags; + + 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; + + audiotype_t gstCheckAudioPad(GstStructure* structure); + void gstBusCall(GstBus *bus, GstMessage *msg); + static GstBusSyncReply gstBusSyncHandler(GstBus *bus, GstMessage *message, gpointer user_data); + static void gstTextpadHasCAPS(GstPad *pad, GParamSpec * unused, gpointer user_data); + void gstTextpadHasCAPS_synced(GstPad *pad); + static void gstCBsubtitleAvail(GstElement *element, gpointer user_data); + GstPad* gstCreateSubtitleSink(eServiceMP3* _this, subtype_t type); 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; + static void gstHTTPSourceSetAgent(GObject *source, GParamSpec *unused, gpointer user_data); struct SubtitlePage { @@ -256,19 +245,18 @@ private: 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; + std::list m_subtitle_pages; + ePtr m_subtitle_sync_timer; + + ePtr m_streamingsrc_timeout; + pts_t m_prev_decoder_time; + int m_decoder_time_valid_state; + + void pushSubtitles(); + void pullSubtitle(); + void sourceTimeout(); + int m_subs_to_pull; + sourceStream m_sourceinfo; eSingleLock m_subs_to_pull_lock; gulong m_subs_to_pull_handler_id; @@ -278,6 +266,5 @@ private: std::string m_useragent; RESULT trickSeek(gdouble ratio); }; -#endif #endif