| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2015 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2015 The WebRTC Project Authors. All rights reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 547 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 558 TransportStats* stats) { | 558 TransportStats* stats) { |
| 559 RTC_DCHECK(network_thread_->IsCurrent()); | 559 RTC_DCHECK(network_thread_->IsCurrent()); |
| 560 | 560 |
| 561 Transport* transport = GetTransport_n(transport_name); | 561 Transport* transport = GetTransport_n(transport_name); |
| 562 if (!transport) { | 562 if (!transport) { |
| 563 return false; | 563 return false; |
| 564 } | 564 } |
| 565 return transport->GetStats(stats); | 565 return transport->GetStats(stats); |
| 566 } | 566 } |
| 567 | 567 |
| 568 void TransportController::OnChannelWritableState_n(TransportChannel* channel) { | 568 void TransportController::OnChannelWritableState_n( |
| 569 rtc::PacketTransportInterface* transport) { |
| 569 RTC_DCHECK(network_thread_->IsCurrent()); | 570 RTC_DCHECK(network_thread_->IsCurrent()); |
| 570 LOG(LS_INFO) << channel->transport_name() << " TransportChannel " | 571 LOG(LS_INFO) << " TransportChannel " << transport->debug_name() |
| 571 << channel->component() << " writability changed to " | 572 << " writability changed to " << transport->writable() << "."; |
| 572 << channel->writable() << "."; | |
| 573 UpdateAggregateStates_n(); | 573 UpdateAggregateStates_n(); |
| 574 } | 574 } |
| 575 | 575 |
| 576 void TransportController::OnChannelReceivingState_n(TransportChannel* channel) { | 576 void TransportController::OnChannelReceivingState_n(TransportChannel* channel) { |
| 577 RTC_DCHECK(network_thread_->IsCurrent()); | 577 RTC_DCHECK(network_thread_->IsCurrent()); |
| 578 UpdateAggregateStates_n(); | 578 UpdateAggregateStates_n(); |
| 579 } | 579 } |
| 580 | 580 |
| 581 void TransportController::OnChannelGatheringState_n( | 581 void TransportController::OnChannelGatheringState_n( |
| 582 TransportChannelImpl* channel) { | 582 TransportChannelImpl* channel) { |
| (...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 707 | 707 |
| 708 void TransportController::SetMetricsObserver( | 708 void TransportController::SetMetricsObserver( |
| 709 webrtc::MetricsObserverInterface* metrics_observer) { | 709 webrtc::MetricsObserverInterface* metrics_observer) { |
| 710 metrics_observer_ = metrics_observer; | 710 metrics_observer_ = metrics_observer; |
| 711 for (auto channel : channels_) { | 711 for (auto channel : channels_) { |
| 712 channel->SetMetricsObserver(metrics_observer); | 712 channel->SetMetricsObserver(metrics_observer); |
| 713 } | 713 } |
| 714 } | 714 } |
| 715 | 715 |
| 716 } // namespace cricket | 716 } // namespace cricket |
| OLD | NEW |