diff options
Diffstat (limited to 'Plugins/jingle/libjingle/talk/session/phone/voicechannel.cc')
| -rw-r--r-- | Plugins/jingle/libjingle/talk/session/phone/voicechannel.cc | 330 |
1 files changed, 330 insertions, 0 deletions
diff --git a/Plugins/jingle/libjingle/talk/session/phone/voicechannel.cc b/Plugins/jingle/libjingle/talk/session/phone/voicechannel.cc new file mode 100644 index 0000000..58b8760 --- /dev/null +++ b/Plugins/jingle/libjingle/talk/session/phone/voicechannel.cc @@ -0,0 +1,330 @@ +/* + * libjingle + * Copyright 2004--2005, Google Inc. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright notice, + * this list of conditions and the following disclaimer in the documentation + * and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED + * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO + * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF + * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include "talk/session/phone/voicechannel.h" +#include "talk/base/common.h" +#include "talk/base/logging.h" +#include "talk/p2p/base/transportchannel.h" +#include "talk/session/phone/channelmanager.h" +#include "talk/session/phone/phonesessionclient.h" +#include <cassert> +#undef SetPort + +namespace cricket { + + +VoiceChannel::VoiceChannel(ChannelManager *manager, Session *session, + MediaChannel *channel) { + channel_manager_ = manager; + assert(channel_manager_->worker_thread() == talk_base::Thread::Current()); + media_channel_ = channel; + session_ = session; + socket_monitor_ = NULL; + audio_monitor_ = NULL; + transport_channel_ = session_->CreateChannel("rtp"); + transport_channel_->SignalWritableState.connect( + this, &VoiceChannel::OnWritableState); + transport_channel_->SignalReadPacket.connect( + this, &VoiceChannel::OnChannelRead); + media_channel_->SetInterface(this); + enabled_ = false; + paused_ = false; + writable_ = false; + muted_ = false; + LOG(INFO) << "Created voice channel"; + + session->SignalState.connect(this, &VoiceChannel::OnSessionState); + OnSessionState(session, session->state()); +} + +VoiceChannel::~VoiceChannel() { + assert(channel_manager_->worker_thread() == talk_base::Thread::Current()); + enabled_ = false; + ChangeState(); + delete socket_monitor_; + delete audio_monitor_; + talk_base::Thread::Current()->Clear(this); + if (transport_channel_ != NULL) + session_->DestroyChannel(transport_channel_); + LOG(INFO) << "Destroyed voice channel"; +} + +void VoiceChannel::OnMessage(talk_base::Message *pmsg) { + switch (pmsg->message_id) { + case MSG_ENABLE: + EnableMedia_w(); + break; + + case MSG_DISABLE: + DisableMedia_w(); + break; + + case MSG_MUTE: + MuteMedia_w(); + break; + + case MSG_UNMUTE: + UnmuteMedia_w(); + break; + + case MSG_SETSENDCODEC: + SetSendCodec_w(); + break; + } +} + +void VoiceChannel::Enable(bool enable) { + // Can be called from thread other than worker thread + channel_manager_->worker_thread()->Post(this, + enable ? MSG_ENABLE : MSG_DISABLE); +} + +void VoiceChannel::Mute(bool mute) { + // Can be called from thread other than worker thread + channel_manager_->worker_thread()->Post(this, mute ? MSG_MUTE : MSG_UNMUTE); +} + + +MediaChannel * VoiceChannel::channel() { + return media_channel_; +} + +void VoiceChannel::OnSessionState(Session* session, Session::State state) { + if ((state == Session::STATE_RECEIVEDACCEPT) || + (state == Session::STATE_RECEIVEDINITIATE)) { + channel_manager_->worker_thread()->Post(this, MSG_SETSENDCODEC); + } +} + +void VoiceChannel::SetSendCodec_w() { + assert(channel_manager_->worker_thread() == talk_base::Thread::Current()); + + const PhoneSessionDescription* desc = + static_cast<const PhoneSessionDescription*>( + session()->remote_description()); + + media_channel_->SetCodecs(desc->codecs()); +} + +void VoiceChannel::OnWritableState(TransportChannel* channel) { + ASSERT(channel == transport_channel_); + if (transport_channel_->writable()) { + ChannelWritable_w(); + } else { + ChannelNotWritable_w(); + } +} + +void VoiceChannel::OnChannelRead(TransportChannel* channel, + const char* data, + size_t len) { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + // OnChannelRead gets called from P2PSocket; now pass data to MediaEngine + media_channel_->OnPacketReceived(data, (int)len); +} + +void VoiceChannel::SendPacket(const void *data, size_t len) { + // SendPacket gets called from MediaEngine; send to socket + // MediaEngine will call us on a random thread. The Send operation on the + // socket is special in that it can handle this. + transport_channel_->SendPacket(static_cast<const char *>(data), len); +} + +void VoiceChannel::ChangeState() { + if (paused_ || !enabled_ || !writable_) { + media_channel_->SetPlayout(false); + media_channel_->SetSend(false); + } else { + if (muted_) { + media_channel_->SetSend(false); + media_channel_->SetPlayout(true); + } else { + media_channel_->SetSend(true); + media_channel_->SetPlayout(true); + } + } +} + +void VoiceChannel::PauseMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + ASSERT(!paused_); + + LOG(INFO) << "Voice channel paused"; + paused_ = true; + ChangeState(); +} + +void VoiceChannel::UnpauseMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + ASSERT(paused_); + + LOG(INFO) << "Voice channel unpaused"; + paused_ = false; + ChangeState(); +} + +void VoiceChannel::EnableMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (enabled_) + return; + + LOG(INFO) << "Voice channel enabled"; + enabled_ = true; + ChangeState(); +} + +void VoiceChannel::DisableMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (!enabled_) + return; + + LOG(INFO) << "Voice channel disabled"; + enabled_ = false; + ChangeState(); +} + +void VoiceChannel::MuteMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (muted_) + return; + + LOG(INFO) << "Voice channel muted"; + muted_ = true; + ChangeState(); +} + +void VoiceChannel::UnmuteMedia_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (!muted_) + return; + + LOG(INFO) << "Voice channel unmuted"; + muted_ = false; + ChangeState(); +} + +void VoiceChannel::ChannelWritable_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (writable_) + return; + + LOG(INFO) << "Voice channel socket writable"; + writable_ = true; + ChangeState(); +} + +void VoiceChannel::ChannelNotWritable_w() { + ASSERT(channel_manager_->worker_thread() == talk_base::Thread::Current()); + if (!writable_) + return; + + LOG(INFO) << "Voice channel socket not writable"; + writable_ = false; + ChangeState(); +} + + +void VoiceChannel::StartConnectionMonitor(int cms) { + delete socket_monitor_; + socket_monitor_ = + new SocketMonitor(session_, transport_channel_, + talk_base::Thread::Current()); + socket_monitor_->SignalUpdate.connect( + this, &VoiceChannel::OnConnectionMonitorUpdate); + socket_monitor_->Start(cms); +} + +void VoiceChannel::StopConnectionMonitor() { + if (socket_monitor_ != NULL) { + socket_monitor_->Stop(); + socket_monitor_->SignalUpdate.disconnect(this); + delete socket_monitor_; + socket_monitor_ = NULL; + } +} + +void VoiceChannel::OnConnectionMonitorUpdate( + SocketMonitor *monitor, const std::vector<ConnectionInfo> &infos) { + SignalConnectionMonitor(this, infos); +} + +void VoiceChannel::StartAudioMonitor(int cms) { + delete audio_monitor_; + audio_monitor_ = new AudioMonitor(this, talk_base::Thread::Current()); + audio_monitor_ + ->SignalUpdate.connect(this, &VoiceChannel::OnAudioMonitorUpdate); + audio_monitor_->Start(cms); +} + +void VoiceChannel::StopAudioMonitor() { + if (audio_monitor_ != NULL) { + audio_monitor_ ->Stop(); + audio_monitor_ ->SignalUpdate.disconnect(this); + delete audio_monitor_ ; + audio_monitor_ = NULL; + } +} + +void VoiceChannel::OnAudioMonitorUpdate(AudioMonitor *monitor, + const AudioInfo& info) { + SignalAudioMonitor(this, info); +} + +void VoiceChannel::StartMediaMonitor(int cms) { + media_channel_ + ->SignalMediaMonitor.connect(this, &VoiceChannel::OnMediaMonitorUpdate); + media_channel_->StartMediaMonitor(this, cms); +} + +void VoiceChannel::StopMediaMonitor() { + media_channel_->SignalMediaMonitor.disconnect(this); + media_channel_->StopMediaMonitor(); +} + +void VoiceChannel::OnMediaMonitorUpdate( + MediaChannel *media_channel, const MediaInfo &info) { + ASSERT(media_channel == media_channel_); + SignalMediaMonitor(this, info); +} + +Session *VoiceChannel::session() { + return session_; +} + +int VoiceChannel::GetInputLevel_w() { + return channel_manager_->media_engine()->GetInputLevel(); +} + +int VoiceChannel::GetOutputLevel_w() { + return media_channel_->GetOutputLevel(); +} + +talk_base::Thread* VoiceChannel::worker_thread() { + return channel_manager_->worker_thread(); +} + +} |