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