Index: webrtc/p2p/base/transportchannelproxy.cc |
diff --git a/webrtc/p2p/base/transportchannelproxy.cc b/webrtc/p2p/base/transportchannelproxy.cc |
index 74d1e1db762c016525ad7f0f22a2c73ea70ef626..f7946dd96f9a2ec4befabf1413e222052a1bdbcd 100644 |
--- a/webrtc/p2p/base/transportchannelproxy.cc |
+++ b/webrtc/p2p/base/transportchannelproxy.cc |
@@ -55,10 +55,10 @@ |
impl_ = impl; |
if (impl_) { |
+ impl_->SignalReadableState.connect( |
+ this, &TransportChannelProxy::OnReadableState); |
impl_->SignalWritableState.connect( |
this, &TransportChannelProxy::OnWritableState); |
- impl_->SignalReceivingState.connect( |
- this, &TransportChannelProxy::OnReceivingState); |
impl_->SignalReadPacket.connect( |
this, &TransportChannelProxy::OnReadPacket); |
impl_->SignalReadyToSend.connect( |
@@ -229,18 +229,18 @@ |
return impl_->GetIceRole(); |
} |
+void TransportChannelProxy::OnReadableState(TransportChannel* channel) { |
+ ASSERT(rtc::Thread::Current() == worker_thread_); |
+ ASSERT(channel == impl_); |
+ set_readable(impl_->readable()); |
+ // Note: SignalReadableState fired by set_readable. |
+} |
+ |
void TransportChannelProxy::OnWritableState(TransportChannel* channel) { |
ASSERT(rtc::Thread::Current() == worker_thread_); |
ASSERT(channel == impl_); |
set_writable(impl_->writable()); |
- // Note: SignalWritableState fired by set_writable. |
-} |
- |
-void TransportChannelProxy::OnReceivingState(TransportChannel* channel) { |
- ASSERT(rtc::Thread::Current() == worker_thread_); |
- ASSERT(channel == impl_); |
- set_receiving(impl_->receiving()); |
- // Note: SignalReceivingState fired by set_receiving. |
+ // Note: SignalWritableState fired by set_readable. |
} |
void TransportChannelProxy::OnReadPacket( |
@@ -267,9 +267,9 @@ |
void TransportChannelProxy::OnMessage(rtc::Message* msg) { |
ASSERT(rtc::Thread::Current() == worker_thread_); |
if (msg->message_id == MSG_UPDATESTATE) { |
- // If impl_ is already receiving or writable, push up those signals. |
- set_writable(impl_ ? impl_->writable() : false); |
- set_receiving(impl_ ? impl_->receiving() : false); |
+ // If impl_ is already readable or writable, push up those signals. |
+ set_readable(impl_ ? impl_->readable() : false); |
+ set_writable(impl_ ? impl_->writable() : false); |
} |
} |