| Index: webrtc/pc/channel.cc
|
| diff --git a/webrtc/pc/channel.cc b/webrtc/pc/channel.cc
|
| index a03b46df164ff7afc70e28e7bbe7ca3a5bc31aac..0f0f663d45cd63087aa218b887b60a1aa171ae62 100644
|
| --- a/webrtc/pc/channel.cc
|
| +++ b/webrtc/pc/channel.cc
|
| @@ -23,7 +23,7 @@
|
| #include "webrtc/base/trace_event.h"
|
| #include "webrtc/media/base/mediaconstants.h"
|
| #include "webrtc/media/base/rtputils.h"
|
| -#include "webrtc/p2p/base/packettransportinterface.h"
|
| +#include "webrtc/p2p/base/packettransportinternal.h"
|
| #include "webrtc/pc/channelmanager.h"
|
|
|
| namespace cricket {
|
| @@ -214,8 +214,8 @@ void BaseChannel::DisconnectTransportChannels_n() {
|
|
|
| bool BaseChannel::Init_w(DtlsTransportInternal* rtp_dtls_transport,
|
| DtlsTransportInternal* rtcp_dtls_transport,
|
| - rtc::PacketTransportInterface* rtp_packet_transport,
|
| - rtc::PacketTransportInterface* rtcp_packet_transport) {
|
| + rtc::PacketTransportInternal* rtp_packet_transport,
|
| + rtc::PacketTransportInternal* rtcp_packet_transport) {
|
| if (!network_thread_->Invoke<bool>(
|
| RTC_FROM_HERE, Bind(&BaseChannel::InitNetwork_n, this,
|
| rtp_dtls_transport, rtcp_dtls_transport,
|
| @@ -232,8 +232,8 @@ bool BaseChannel::Init_w(DtlsTransportInternal* rtp_dtls_transport,
|
| bool BaseChannel::InitNetwork_n(
|
| DtlsTransportInternal* rtp_dtls_transport,
|
| DtlsTransportInternal* rtcp_dtls_transport,
|
| - rtc::PacketTransportInterface* rtp_packet_transport,
|
| - rtc::PacketTransportInterface* rtcp_packet_transport) {
|
| + rtc::PacketTransportInternal* rtp_packet_transport,
|
| + rtc::PacketTransportInternal* rtcp_packet_transport) {
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| SetTransports_n(rtp_dtls_transport, rtcp_dtls_transport, rtp_packet_transport,
|
| rtcp_packet_transport);
|
| @@ -271,8 +271,8 @@ void BaseChannel::SetTransports(DtlsTransportInternal* rtp_dtls_transport,
|
| }
|
|
|
| void BaseChannel::SetTransports(
|
| - rtc::PacketTransportInterface* rtp_packet_transport,
|
| - rtc::PacketTransportInterface* rtcp_packet_transport) {
|
| + rtc::PacketTransportInternal* rtp_packet_transport,
|
| + rtc::PacketTransportInternal* rtcp_packet_transport) {
|
| network_thread_->Invoke<void>(
|
| RTC_FROM_HERE, Bind(&BaseChannel::SetTransports_n, this, nullptr, nullptr,
|
| rtp_packet_transport, rtcp_packet_transport));
|
| @@ -281,8 +281,8 @@ void BaseChannel::SetTransports(
|
| void BaseChannel::SetTransports_n(
|
| DtlsTransportInternal* rtp_dtls_transport,
|
| DtlsTransportInternal* rtcp_dtls_transport,
|
| - rtc::PacketTransportInterface* rtp_packet_transport,
|
| - rtc::PacketTransportInterface* rtcp_packet_transport) {
|
| + rtc::PacketTransportInternal* rtp_packet_transport,
|
| + rtc::PacketTransportInternal* rtcp_packet_transport) {
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| // Validate some assertions about the input.
|
| RTC_DCHECK(rtp_packet_transport);
|
| @@ -357,11 +357,11 @@ void BaseChannel::SetTransports_n(
|
| void BaseChannel::SetTransport_n(
|
| bool rtcp,
|
| DtlsTransportInternal* new_dtls_transport,
|
| - rtc::PacketTransportInterface* new_packet_transport) {
|
| + rtc::PacketTransportInternal* new_packet_transport) {
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| DtlsTransportInternal*& old_dtls_transport =
|
| rtcp ? rtcp_dtls_transport_ : rtp_dtls_transport_;
|
| - rtc::PacketTransportInterface*& old_packet_transport =
|
| + rtc::PacketTransportInternal*& old_packet_transport =
|
| rtcp ? rtcp_packet_transport_ : rtp_packet_transport_;
|
|
|
| if (!old_packet_transport && !new_packet_transport) {
|
| @@ -428,7 +428,7 @@ void BaseChannel::DisconnectFromDtlsTransport(
|
| }
|
|
|
| void BaseChannel::ConnectToPacketTransport(
|
| - rtc::PacketTransportInterface* transport) {
|
| + rtc::PacketTransportInternal* transport) {
|
| RTC_DCHECK_RUN_ON(network_thread_);
|
| transport->SignalWritableState.connect(this, &BaseChannel::OnWritableState);
|
| transport->SignalReadPacket.connect(this, &BaseChannel::OnPacketRead);
|
| @@ -437,7 +437,7 @@ void BaseChannel::ConnectToPacketTransport(
|
| }
|
|
|
| void BaseChannel::DisconnectFromPacketTransport(
|
| - rtc::PacketTransportInterface* transport) {
|
| + rtc::PacketTransportInternal* transport) {
|
| RTC_DCHECK_RUN_ON(network_thread_);
|
| transport->SignalWritableState.disconnect(this);
|
| transport->SignalReadPacket.disconnect(this);
|
| @@ -564,7 +564,7 @@ int BaseChannel::SetOption_n(SocketType type,
|
| rtc::Socket::Option opt,
|
| int value) {
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| - rtc::PacketTransportInterface* transport = nullptr;
|
| + rtc::PacketTransportInternal* transport = nullptr;
|
| switch (type) {
|
| case ST_RTP:
|
| transport = rtp_packet_transport_;
|
| @@ -585,14 +585,14 @@ bool BaseChannel::SetCryptoOptions(const rtc::CryptoOptions& crypto_options) {
|
| return true;
|
| }
|
|
|
| -void BaseChannel::OnWritableState(rtc::PacketTransportInterface* transport) {
|
| +void BaseChannel::OnWritableState(rtc::PacketTransportInternal* transport) {
|
| RTC_DCHECK(transport == rtp_packet_transport_ ||
|
| transport == rtcp_packet_transport_);
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| UpdateWritableState_n();
|
| }
|
|
|
| -void BaseChannel::OnPacketRead(rtc::PacketTransportInterface* transport,
|
| +void BaseChannel::OnPacketRead(rtc::PacketTransportInternal* transport,
|
| const char* data,
|
| size_t len,
|
| const rtc::PacketTime& packet_time,
|
| @@ -608,7 +608,7 @@ void BaseChannel::OnPacketRead(rtc::PacketTransportInterface* transport,
|
| HandlePacket(rtcp, &packet, packet_time);
|
| }
|
|
|
| -void BaseChannel::OnReadyToSend(rtc::PacketTransportInterface* transport) {
|
| +void BaseChannel::OnReadyToSend(rtc::PacketTransportInternal* transport) {
|
| RTC_DCHECK(transport == rtp_packet_transport_ ||
|
| transport == rtcp_packet_transport_);
|
| SetTransportChannelReadyToSend(transport == rtcp_packet_transport_, true);
|
| @@ -675,7 +675,7 @@ void BaseChannel::SetTransportChannelReadyToSend(bool rtcp, bool ready) {
|
| Bind(&MediaChannel::OnReadyToSend, media_channel_, ready_to_send));
|
| }
|
|
|
| -bool BaseChannel::PacketIsRtcp(const rtc::PacketTransportInterface* transport,
|
| +bool BaseChannel::PacketIsRtcp(const rtc::PacketTransportInternal* transport,
|
| const char* data,
|
| size_t len) {
|
| return (transport == rtcp_packet_transport_ ||
|
| @@ -707,7 +707,7 @@ bool BaseChannel::SendPacket(bool rtcp,
|
| // packet before doing anything. (We might get RTCP packets that we don't
|
| // intend to send.) If we've negotiated RTCP mux, send RTCP over the RTP
|
| // transport.
|
| - rtc::PacketTransportInterface* transport =
|
| + rtc::PacketTransportInternal* transport =
|
| (!rtcp || rtcp_mux_filter_.IsActive()) ? rtp_packet_transport_
|
| : rtcp_packet_transport_;
|
| if (!transport || !transport->writable()) {
|
| @@ -1506,7 +1506,7 @@ void BaseChannel::FlushRtcpMessages_n() {
|
| }
|
|
|
| void BaseChannel::SignalSentPacket_n(
|
| - rtc::PacketTransportInterface* /* transport */,
|
| + rtc::PacketTransportInternal* /* transport */,
|
| const rtc::SentPacket& sent_packet) {
|
| RTC_DCHECK(network_thread_->IsCurrent());
|
| invoker_.AsyncInvoke<void>(
|
| @@ -1697,7 +1697,7 @@ void VoiceChannel::GetActiveStreams_w(AudioInfo::StreamList* actives) {
|
| media_channel()->GetActiveStreams(actives);
|
| }
|
|
|
| -void VoiceChannel::OnPacketRead(rtc::PacketTransportInterface* transport,
|
| +void VoiceChannel::OnPacketRead(rtc::PacketTransportInternal* transport,
|
| const char* data,
|
| size_t len,
|
| const rtc::PacketTime& packet_time,
|
| @@ -2211,8 +2211,8 @@ RtpDataChannel::~RtpDataChannel() {
|
| bool RtpDataChannel::Init_w(
|
| DtlsTransportInternal* rtp_dtls_transport,
|
| DtlsTransportInternal* rtcp_dtls_transport,
|
| - rtc::PacketTransportInterface* rtp_packet_transport,
|
| - rtc::PacketTransportInterface* rtcp_packet_transport) {
|
| + rtc::PacketTransportInternal* rtp_packet_transport,
|
| + rtc::PacketTransportInternal* rtcp_packet_transport) {
|
| if (!BaseChannel::Init_w(rtp_dtls_transport, rtcp_dtls_transport,
|
| rtp_packet_transport, rtcp_packet_transport)) {
|
| return false;
|
|
|