Index: webrtc/p2p/base/transport.cc |
diff --git a/webrtc/p2p/base/transport.cc b/webrtc/p2p/base/transport.cc |
index 5f28c40e936d02e258957a22997ed485e85134ba..8cb124eea02378818188dc41cfaac7821cf77986 100644 |
--- a/webrtc/p2p/base/transport.cc |
+++ b/webrtc/p2p/base/transport.cc |
@@ -106,7 +106,6 @@ Transport::Transport(rtc::Thread* signaling_thread, |
content_name_(content_name), |
allocator_(allocator), |
destroyed_(false), |
- readable_(TRANSPORT_STATE_NONE), |
writable_(TRANSPORT_STATE_NONE), |
receiving_(TRANSPORT_STATE_NONE), |
was_writable_(false), |
@@ -238,7 +237,6 @@ TransportChannelImpl* Transport::CreateChannel_w(int component) { |
if (local_description_ && remote_description_) |
ApplyNegotiatedTransportDescription_w(impl, NULL); |
- impl->SignalReadableState.connect(this, &Transport::OnChannelReadableState); |
impl->SignalWritableState.connect(this, &Transport::OnChannelWritableState); |
impl->SignalReceivingState.connect(this, &Transport::OnChannelReceivingState); |
impl->SignalRequestSignaling.connect( |
@@ -493,20 +491,6 @@ void Transport::OnRemoteCandidate_w(const Candidate& candidate) { |
} |
} |
-void Transport::OnChannelReadableState(TransportChannel* channel) { |
- ASSERT(worker_thread()->IsCurrent()); |
- signaling_thread()->Post(this, MSG_READSTATE, NULL); |
-} |
- |
-void Transport::OnChannelReadableState_s() { |
- ASSERT(signaling_thread()->IsCurrent()); |
- TransportState readable = GetTransportState_s(TRANSPORT_READABLE_STATE); |
- if (readable_ != readable) { |
- readable_ = readable; |
- SignalReadableState(this); |
- } |
-} |
- |
void Transport::OnChannelWritableState(TransportChannel* channel) { |
ASSERT(worker_thread()->IsCurrent()); |
signaling_thread()->Post(this, MSG_WRITESTATE, NULL); |
@@ -547,9 +531,6 @@ TransportState Transport::GetTransportState_s(TransportStateType state_type) { |
for (const auto iter : channels_) { |
bool b = false; |
switch (state_type) { |
- case TRANSPORT_READABLE_STATE: |
- b = iter.second->readable(); |
- break; |
case TRANSPORT_WRITABLE_STATE: |
b = iter.second->writable(); |
break; |
@@ -870,9 +851,6 @@ void Transport::OnMessage(rtc::Message* msg) { |
case MSG_CONNECTING: |
OnConnecting_s(); |
break; |
- case MSG_READSTATE: |
- OnChannelReadableState_s(); |
- break; |
case MSG_WRITESTATE: |
OnChannelWritableState_s(); |
break; |