Chromium Code Reviews| Index: webrtc/p2p/base/dtlstransportchannel.cc |
| diff --git a/webrtc/p2p/base/dtlstransportchannel.cc b/webrtc/p2p/base/dtlstransportchannel.cc |
| index d95bdcd916b1814ae4eda1eaeebd4f333e59f2ac..ebfe56dfb9b51c01be4b78ea7b6a1f0e9113cc7f 100644 |
| --- a/webrtc/p2p/base/dtlstransportchannel.cc |
| +++ b/webrtc/p2p/base/dtlstransportchannel.cc |
| @@ -14,6 +14,7 @@ |
| #include "webrtc/p2p/base/dtlstransportchannel.h" |
| #include "webrtc/p2p/base/common.h" |
| +#include "webrtc/p2p/base/packettransport.h" |
| #include "webrtc/base/buffer.h" |
| #include "webrtc/base/checks.h" |
| #include "webrtc/base/dscp.h" |
| @@ -437,9 +438,10 @@ bool DtlsTransportChannelWrapper::IsDtlsConnected() { |
| // start the DTLS handshake |
| // - Once the DTLS handshake completes, the state is that of the |
| // impl again |
| -void DtlsTransportChannelWrapper::OnWritableState(TransportChannel* channel) { |
| +void DtlsTransportChannelWrapper::OnWritableState(rtc::PacketTransport* pt) { |
| + TransportChannel* channel = static_cast<TransportChannel*>(pt); |
|
pthatcher1
2016/10/13 20:26:37
The only thing this method needs from pt is ->writ
johan
2016/10/14 16:09:33
Done.
|
| ASSERT(rtc::Thread::Current() == worker_thread_); |
| - ASSERT(channel == channel_); |
| + RTC_DCHECK(channel == channel_); |
| LOG_J(LS_VERBOSE, this) |
| << "DTLSTransportChannelWrapper: channel writable state changed to " |
| << channel_->writable(); |
| @@ -471,7 +473,7 @@ void DtlsTransportChannelWrapper::OnWritableState(TransportChannel* channel) { |
| void DtlsTransportChannelWrapper::OnReceivingState(TransportChannel* channel) { |
| ASSERT(rtc::Thread::Current() == worker_thread_); |
| - ASSERT(channel == channel_); |
| + RTC_DCHECK(channel == channel_); |
| LOG_J(LS_VERBOSE, this) |
| << "DTLSTransportChannelWrapper: channel receiving state changed to " |
| << channel_->receiving(); |
| @@ -482,10 +484,14 @@ void DtlsTransportChannelWrapper::OnReceivingState(TransportChannel* channel) { |
| } |
| void DtlsTransportChannelWrapper::OnReadPacket( |
| - TransportChannel* channel, const char* data, size_t size, |
| - const rtc::PacketTime& packet_time, int flags) { |
| + rtc::PacketTransport* pt, |
| + const char* data, |
| + size_t size, |
| + const rtc::PacketTime& packet_time, |
| + int flags) { |
| + TransportChannel* channel = static_cast<TransportChannel*>(pt); |
| ASSERT(rtc::Thread::Current() == worker_thread_); |
| - ASSERT(channel == channel_); |
| + RTC_DCHECK(channel == channel_); |
| ASSERT(flags == 0); |
| if (!dtls_active_) { |
| @@ -558,14 +564,14 @@ void DtlsTransportChannelWrapper::OnReadPacket( |
| } |
| void DtlsTransportChannelWrapper::OnSentPacket( |
| - TransportChannel* channel, |
| + rtc::PacketTransport* pt, |
| const rtc::SentPacket& sent_packet) { |
| ASSERT(rtc::Thread::Current() == worker_thread_); |
| SignalSentPacket(this, sent_packet); |
| } |
| -void DtlsTransportChannelWrapper::OnReadyToSend(TransportChannel* channel) { |
| +void DtlsTransportChannelWrapper::OnReadyToSend(rtc::PacketTransport* pt) { |
| if (writable()) { |
| SignalReadyToSend(this); |
| } |