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); |
} |