X-Git-Url: http://git.tdb.fi/?p=xinema.git;a=blobdiff_plain;f=source%2Fclient.cpp;h=161c57f252eed6e1ef85872743255ab6cfc9af72;hp=604779662b5f0fc6944bf07542bd686ce390bdfb;hb=85d198e71b7d1d6279db4e2f22d9a1393b8369ff;hpb=a4982bb4d3fd9908aa01c824ac6202ac8618ac24

diff --git a/source/client.cpp b/source/client.cpp
index 6047796..161c57f 100644
--- a/source/client.cpp
+++ b/source/client.cpp
@@ -74,6 +74,14 @@ XineStream &Client::get_stream() const
 	throw runtime_error("No stream");
 }
 
+int Client::convert_channel(const string &arg)
+{
+	if(arg=="off")
+		return XineStream::OFF;
+	else
+		return lexical_cast<unsigned>(arg);
+}
+
 void Client::process_command(const string &cmd)
 {
 	string::size_type space = cmd.find(' ');
@@ -95,9 +103,9 @@ void Client::process_command(const string &cmd)
 	else if(keyword=="stop")
 		get_stream().stop();
 	else if(keyword=="select_audio")
-		set_audio_channel(args);
+		get_stream().select_audio_channel(convert_channel(args));
 	else if(keyword=="select_spu")
-		set_spu_channel(args);
+		get_stream().select_spu_channel(convert_channel(args));
 	else
 		throw runtime_error("Invalid command");
 }
@@ -128,24 +136,7 @@ void Client::list_directory(const FS::Path &dn)
 		else
 			send_reply("file "+*i);
 	}
-}
-
-void Client::set_audio_channel(const string &arg)
-{
-	XineStream &stream = get_stream();
-	if(arg=="off")
-		stream.set_audio_off();
-	else
-		stream.set_audio_channel(lexical_cast<unsigned>(arg));
-}
 
-void Client::set_spu_channel(const string &arg)
-{
-	XineStream &stream = get_stream();
-	if(arg=="off")
-		stream.set_spu_off();
-	else
-		stream.set_spu_channel(lexical_cast<unsigned>(arg));
 }
 
 void Client::stream_created(XineStream &stream)
@@ -155,6 +146,8 @@ void Client::stream_created(XineStream &stream)
 	stream.signal_duration_changed.connect(sigc::mem_fun(this, &Client::stream_duration_changed));
 	stream.signal_position_changed.connect(sigc::mem_fun(this, &Client::stream_position_changed));
 	stream.signal_channels_changed.connect(sigc::mem_fun(this, &Client::stream_channels_changed));
+	stream.signal_current_audio_channel_changed.connect(sigc::mem_fun(this, &Client::stream_audio_channel_changed));
+	stream.signal_current_spu_channel_changed.connect(sigc::mem_fun(this, &Client::stream_spu_channel_changed));
 
 	MutexLock lock(stream.get_mutex());
 	stream_state_changed(stream.get_state());
@@ -167,6 +160,8 @@ void Client::stream_created(XineStream &stream)
 		stream_duration_changed(dur);
 
 	stream_channels_changed();
+	stream_audio_channel_changed(stream.get_current_audio_channel());
+	stream_spu_channel_changed(stream.get_current_spu_channel());
 }
 
 void Client::stream_destroyed()
@@ -214,3 +209,19 @@ void Client::stream_channels_changed()
 
 	send_reply("channels_end");
 }
+
+void Client::stream_audio_channel_changed(int chan)
+{
+	if(chan==XineStream::OFF)
+		send_reply("current_audio off");
+	else
+		send_reply(format("current_audio %d", chan));
+}
+
+void Client::stream_spu_channel_changed(int chan)
+{
+	if(chan==XineStream::OFF)
+		send_reply("current_spu off");
+	else
+		send_reply(format("current_spu %d", chan));
+}