| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2004 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2004 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 1687 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1698 } else { | 1698 } else { |
| 1699 new_codecs.push_back(codec); | 1699 new_codecs.push_back(codec); |
| 1700 } | 1700 } |
| 1701 } | 1701 } |
| 1702 if (new_codecs.empty()) { | 1702 if (new_codecs.empty()) { |
| 1703 // There are no new codecs to configure. Already configured codecs are | 1703 // There are no new codecs to configure. Already configured codecs are |
| 1704 // never removed. | 1704 // never removed. |
| 1705 return true; | 1705 return true; |
| 1706 } | 1706 } |
| 1707 | 1707 |
| 1708 if (playout_) { |
| 1709 // Receive codecs can not be changed while playing. So we temporarily |
| 1710 // pause playout. |
| 1711 ChangePlayout(false); |
| 1712 } |
| 1713 |
| 1708 bool result = true; | 1714 bool result = true; |
| 1709 for (const AudioCodec& codec : new_codecs) { | 1715 for (const AudioCodec& codec : new_codecs) { |
| 1710 webrtc::CodecInst voe_codec = {0}; | 1716 webrtc::CodecInst voe_codec = {0}; |
| 1711 if (WebRtcVoiceEngine::ToCodecInst(codec, &voe_codec)) { | 1717 if (WebRtcVoiceEngine::ToCodecInst(codec, &voe_codec)) { |
| 1712 LOG(LS_INFO) << ToString(codec); | 1718 LOG(LS_INFO) << ToString(codec); |
| 1713 voe_codec.pltype = codec.id; | 1719 voe_codec.pltype = codec.id; |
| 1714 for (const auto& ch : recv_streams_) { | 1720 for (const auto& ch : recv_streams_) { |
| 1715 if (engine()->voe()->codec()->SetRecPayloadType( | 1721 if (engine()->voe()->codec()->SetRecPayloadType( |
| 1716 ch.second->channel(), voe_codec) == -1) { | 1722 ch.second->channel(), voe_codec) == -1) { |
| 1717 LOG_RTCERR2(SetRecPayloadType, ch.second->channel(), | 1723 LOG_RTCERR2(SetRecPayloadType, ch.second->channel(), |
| 1718 ToString(voe_codec)); | 1724 ToString(voe_codec)); |
| 1719 result = false; | 1725 result = false; |
| 1720 } | 1726 } |
| 1721 } | 1727 } |
| 1722 } else { | 1728 } else { |
| 1723 LOG(LS_WARNING) << "Unknown codec " << ToString(codec); | 1729 LOG(LS_WARNING) << "Unknown codec " << ToString(codec); |
| 1724 result = false; | 1730 result = false; |
| 1725 break; | 1731 break; |
| 1726 } | 1732 } |
| 1727 } | 1733 } |
| 1728 if (result) { | 1734 if (result) { |
| 1729 recv_codecs_ = codecs; | 1735 recv_codecs_ = codecs; |
| 1730 } | 1736 } |
| 1731 | 1737 |
| 1738 if (desired_playout_ && !playout_) { |
| 1739 ChangePlayout(desired_playout_); |
| 1740 } |
| 1732 return result; | 1741 return result; |
| 1733 } | 1742 } |
| 1734 | 1743 |
| 1735 // Utility function called from SetSendParameters() to extract current send | 1744 // Utility function called from SetSendParameters() to extract current send |
| 1736 // codec settings from the given list of codecs (originally from SDP). Both send | 1745 // codec settings from the given list of codecs (originally from SDP). Both send |
| 1737 // and receive streams may be reconfigured based on the new settings. | 1746 // and receive streams may be reconfigured based on the new settings. |
| 1738 bool WebRtcVoiceMediaChannel::SetSendCodecs( | 1747 bool WebRtcVoiceMediaChannel::SetSendCodecs( |
| 1739 const std::vector<AudioCodec>& codecs) { | 1748 const std::vector<AudioCodec>& codecs) { |
| 1740 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); | 1749 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
| 1741 // TODO(solenberg): Validate input - that payload types don't overlap, are | 1750 // TODO(solenberg): Validate input - that payload types don't overlap, are |
| (...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1976 } | 1985 } |
| 1977 | 1986 |
| 1978 if (engine()->voe()->codec()->SetSendCodec(channel, send_codec) == -1) { | 1987 if (engine()->voe()->codec()->SetSendCodec(channel, send_codec) == -1) { |
| 1979 LOG_RTCERR2(SetSendCodec, channel, ToString(send_codec)); | 1988 LOG_RTCERR2(SetSendCodec, channel, ToString(send_codec)); |
| 1980 return false; | 1989 return false; |
| 1981 } | 1990 } |
| 1982 return true; | 1991 return true; |
| 1983 } | 1992 } |
| 1984 | 1993 |
| 1985 void WebRtcVoiceMediaChannel::SetPlayout(bool playout) { | 1994 void WebRtcVoiceMediaChannel::SetPlayout(bool playout) { |
| 1986 TRACE_EVENT0("webrtc", "WebRtcVoiceMediaChannel::SetPlayout"); | 1995 desired_playout_ = playout; |
| 1996 return ChangePlayout(desired_playout_); |
| 1997 } |
| 1998 |
| 1999 void WebRtcVoiceMediaChannel::ChangePlayout(bool playout) { |
| 2000 TRACE_EVENT0("webrtc", "WebRtcVoiceMediaChannel::ChangePlayout"); |
| 1987 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); | 2001 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
| 1988 if (playout_ == playout) { | 2002 if (playout_ == playout) { |
| 1989 return; | 2003 return; |
| 1990 } | 2004 } |
| 1991 | 2005 |
| 1992 for (const auto& kv : recv_streams_) { | 2006 for (const auto& kv : recv_streams_) { |
| 1993 kv.second->SetPlayout(playout); | 2007 kv.second->SetPlayout(playout); |
| 1994 } | 2008 } |
| 1995 playout_ = playout; | 2009 playout_ = playout; |
| 1996 } | 2010 } |
| (...skipping 653 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2650 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); | 2664 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
| 2651 const auto it = send_streams_.find(ssrc); | 2665 const auto it = send_streams_.find(ssrc); |
| 2652 if (it != send_streams_.end()) { | 2666 if (it != send_streams_.end()) { |
| 2653 return it->second->channel(); | 2667 return it->second->channel(); |
| 2654 } | 2668 } |
| 2655 return -1; | 2669 return -1; |
| 2656 } | 2670 } |
| 2657 } // namespace cricket | 2671 } // namespace cricket |
| 2658 | 2672 |
| 2659 #endif // HAVE_WEBRTC_VOICE | 2673 #endif // HAVE_WEBRTC_VOICE |
| OLD | NEW |