[vlc-devel] [PATCH 08/10] chromecast: pause immediatly the device when pausing the player
Steve Lhomme
robux4 at videolabs.io
Tue May 3 16:01:44 CEST 2016
---
modules/stream_out/chromecast/chromecast.h | 6 ++++
modules/stream_out/chromecast/chromecast_common.h | 4 +++
modules/stream_out/chromecast/chromecast_ctrl.cpp | 33 ++++++++++++++++++++++
modules/stream_out/chromecast/chromecast_demux.cpp | 24 ++++++++++++++++
4 files changed, 67 insertions(+)
diff --git a/modules/stream_out/chromecast/chromecast.h b/modules/stream_out/chromecast/chromecast.h
index bbb634c..11eccbd 100644
--- a/modules/stream_out/chromecast/chromecast.h
+++ b/modules/stream_out/chromecast/chromecast.h
@@ -158,6 +158,8 @@ private:
bool requested_stop;
bool requested_seek;
+ void setInputState(input_state_e state);
+
int sendMessage(const castchannel::CastMessage &msg);
void buildMessage(const std::string & namespace_,
@@ -182,6 +184,8 @@ private:
unsigned i_requestId;
bool has_input;
+ input_state_e input_state;
+
static void* ChromecastThread(void* p_data);
mtime_t getPlaybackTimestamp() const
@@ -235,6 +239,8 @@ private:
static void request_seek(void*, mtime_t pos);
static void wait_seek_done(void*);
+
+ static void set_input_state(void*, input_state_e state);
};
#endif /* VLC_CHROMECAST_H */
diff --git a/modules/stream_out/chromecast/chromecast_common.h b/modules/stream_out/chromecast/chromecast_common.h
index 632b37b..45d3ebc 100644
--- a/modules/stream_out/chromecast/chromecast_common.h
+++ b/modules/stream_out/chromecast/chromecast_common.h
@@ -25,6 +25,8 @@
#ifndef VLC_CHROMECAST_COMMON_H
#define VLC_CHROMECAST_COMMON_H
+#include <vlc_input.h>
+
# ifdef __cplusplus
extern "C" {
# endif
@@ -43,6 +45,8 @@ typedef struct
void (*pf_request_seek)(void*, mtime_t pos);
void (*pf_wait_seek_done)(void*);
+
+ void (*pf_set_input_state)(void*, input_state_e state);
} chromecast_common;
# ifdef __cplusplus
diff --git a/modules/stream_out/chromecast/chromecast_ctrl.cpp b/modules/stream_out/chromecast/chromecast_ctrl.cpp
index 8df7409..f1bec5f 100644
--- a/modules/stream_out/chromecast/chromecast_ctrl.cpp
+++ b/modules/stream_out/chromecast/chromecast_ctrl.cpp
@@ -111,6 +111,7 @@ intf_sys_t::intf_sys_t(vlc_object_t * const p_this, int port, std::string device
, i_receiver_requestId(0)
, i_requestId(0)
, has_input(false)
+ , input_state( INIT_S )
, m_time_playback_started( VLC_TS_INVALID )
, i_ts_local_start( VLC_TS_INVALID )
, i_length( VLC_TS_INVALID )
@@ -128,6 +129,7 @@ intf_sys_t::intf_sys_t(vlc_object_t * const p_this, int port, std::string device
common.pf_wait_app_started = wait_app_started;
common.pf_request_seek = request_seek;
common.pf_wait_seek_done = wait_seek_done;
+ common.pf_set_input_state = set_input_state;
assert( var_Type( p_module->p_parent->p_parent, CC_SHARED_VAR_NAME) == 0 );
if (var_Create( p_module->p_parent->p_parent, CC_SHARED_VAR_NAME, VLC_VAR_ADDRESS ) == VLC_SUCCESS )
@@ -1079,6 +1081,31 @@ void intf_sys_t::requestPlayerSeek(mtime_t pos)
notifySendRequest();
}
+void intf_sys_t::setInputState(input_state_e state)
+{
+ input_state = state;
+ msg_Dbg( p_module, "new %d state", state );
+ switch( input_state )
+ {
+ case PLAYING_S:
+ if ( !mediaSessionId.empty() && receiverState != RECEIVER_IDLE )
+ {
+ msgPlayerPlay();
+ setPlayerStatus(CMD_PLAYBACK_SENT);
+ }
+ break;
+ case PAUSE_S:
+ if ( !mediaSessionId.empty() && receiverState != RECEIVER_IDLE )
+ {
+ msgPlayerPause();
+ setPlayerStatus(CMD_PLAYBACK_SENT);
+ }
+ break;
+ default:
+ break;
+ }
+}
+
void intf_sys_t::waitAppStarted()
{
vlc_mutex_locker locker(&lock);
@@ -1148,3 +1175,9 @@ void intf_sys_t::wait_seek_done(void *pt)
intf_sys_t *p_this = reinterpret_cast<intf_sys_t*>(pt);
p_this->waitSeekDone();
}
+
+void intf_sys_t::set_input_state(void *pt, input_state_e state)
+{
+ intf_sys_t *p_this = reinterpret_cast<intf_sys_t*>(pt);
+ p_this->setInputState( state );
+}
diff --git a/modules/stream_out/chromecast/chromecast_demux.cpp b/modules/stream_out/chromecast/chromecast_demux.cpp
index ac0d138..91a9cfd 100644
--- a/modules/stream_out/chromecast/chromecast_demux.cpp
+++ b/modules/stream_out/chromecast/chromecast_demux.cpp
@@ -46,10 +46,16 @@ struct demux_sys_t
,canSeek(false)
,m_seektime( VLC_TS_INVALID )
{
+ input_thread_t *p_input = demux_FilterDemuxer( p_demux )->p_input;
+ p_renderer->pf_set_input_state( p_renderer->p_opaque,
+ (input_state_e) var_GetInteger( p_input, "state" ) );
+ var_AddCallback( p_input, "intf-event", InputEvent, this );
}
~demux_sys_t()
{
+ input_thread_t *p_input = demux_FilterDemuxer( p_demux )->p_input;
+ var_DelCallback( p_input, "intf-event", InputEvent, this );
}
/**
@@ -125,6 +131,9 @@ protected:
bool canSeek;
/* seek time kept while waiting for the chromecast to "seek" */
mtime_t m_seektime;
+
+ static int InputEvent( vlc_object_t *p_this, char const *psz_var,
+ vlc_value_t oldval, vlc_value_t val, void * );
};
static int Demux( demux_filter_t *p_demux_filter )
@@ -222,6 +231,21 @@ static int Control( demux_filter_t *p_demux_filter, int i_query, va_list args)
return demux_vaFilterControlNext( p_demux_filter, i_query, args );
}
+int demux_sys_t::InputEvent( vlc_object_t *p_this, char const *psz_var,
+ vlc_value_t oldval, vlc_value_t val, void *p_data )
+{
+ VLC_UNUSED(psz_var);
+ VLC_UNUSED(oldval);
+ input_thread_t *p_input = reinterpret_cast<input_thread_t*>( p_this );
+ demux_sys_t *p_sys = reinterpret_cast<demux_sys_t*>( p_data );
+
+ if( val.i_int == INPUT_EVENT_STATE )
+ p_sys->p_renderer->pf_set_input_state( p_sys->p_renderer->p_opaque,
+ (input_state_e) var_GetInteger( p_input, "state" ) );
+
+ return VLC_SUCCESS;
+}
+
int Open(vlc_object_t *p_this)
{
demux_filter_t *p_demux = reinterpret_cast<demux_filter_t*>(p_this);
--
2.7.0
More information about the vlc-devel
mailing list