| 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 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 59 void TransportController::SetIceConfig(const IceConfig& config) { | 59 void TransportController::SetIceConfig(const IceConfig& config) { |
| 60 worker_thread_->Invoke<void>( | 60 worker_thread_->Invoke<void>( |
| 61 rtc::Bind(&TransportController::SetIceConfig_w, this, config)); | 61 rtc::Bind(&TransportController::SetIceConfig_w, this, config)); |
| 62 } | 62 } |
| 63 | 63 |
| 64 void TransportController::SetIceRole(IceRole ice_role) { | 64 void TransportController::SetIceRole(IceRole ice_role) { |
| 65 worker_thread_->Invoke<void>( | 65 worker_thread_->Invoke<void>( |
| 66 rtc::Bind(&TransportController::SetIceRole_w, this, ice_role)); | 66 rtc::Bind(&TransportController::SetIceRole_w, this, ice_role)); |
| 67 } | 67 } |
| 68 | 68 |
| 69 bool TransportController::GetSslRole(rtc::SSLRole* role) { | 69 bool TransportController::GetSslRole(const std::string& transport_name, |
| 70 return worker_thread_->Invoke<bool>( | 70 rtc::SSLRole* role) { |
| 71 rtc::Bind(&TransportController::GetSslRole_w, this, role)); | 71 return worker_thread_->Invoke<bool>(rtc::Bind( |
| 72 &TransportController::GetSslRole_w, this, transport_name, role)); |
| 72 } | 73 } |
| 73 | 74 |
| 74 bool TransportController::SetLocalCertificate( | 75 bool TransportController::SetLocalCertificate( |
| 75 const rtc::scoped_refptr<rtc::RTCCertificate>& certificate) { | 76 const rtc::scoped_refptr<rtc::RTCCertificate>& certificate) { |
| 76 return worker_thread_->Invoke<bool>(rtc::Bind( | 77 return worker_thread_->Invoke<bool>(rtc::Bind( |
| 77 &TransportController::SetLocalCertificate_w, this, certificate)); | 78 &TransportController::SetLocalCertificate_w, this, certificate)); |
| 78 } | 79 } |
| 79 | 80 |
| 80 bool TransportController::GetLocalCertificate( | 81 bool TransportController::GetLocalCertificate( |
| 81 const std::string& transport_name, | 82 const std::string& transport_name, |
| (...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 336 } | 337 } |
| 337 | 338 |
| 338 void TransportController::SetIceRole_w(IceRole ice_role) { | 339 void TransportController::SetIceRole_w(IceRole ice_role) { |
| 339 RTC_DCHECK(worker_thread_->IsCurrent()); | 340 RTC_DCHECK(worker_thread_->IsCurrent()); |
| 340 ice_role_ = ice_role; | 341 ice_role_ = ice_role; |
| 341 for (const auto& kv : transports_) { | 342 for (const auto& kv : transports_) { |
| 342 kv.second->SetIceRole(ice_role_); | 343 kv.second->SetIceRole(ice_role_); |
| 343 } | 344 } |
| 344 } | 345 } |
| 345 | 346 |
| 346 bool TransportController::GetSslRole_w(rtc::SSLRole* role) { | 347 bool TransportController::GetSslRole_w(const std::string& transport_name, |
| 348 rtc::SSLRole* role) { |
| 347 RTC_DCHECK(worker_thread()->IsCurrent()); | 349 RTC_DCHECK(worker_thread()->IsCurrent()); |
| 348 | 350 |
| 349 if (transports_.empty()) { | 351 Transport* t = GetTransport_w(transport_name); |
| 352 if (!t) { |
| 350 return false; | 353 return false; |
| 351 } | 354 } |
| 352 return transports_.begin()->second->GetSslRole(role); | 355 |
| 356 return t->GetSslRole(role); |
| 353 } | 357 } |
| 354 | 358 |
| 355 bool TransportController::SetLocalCertificate_w( | 359 bool TransportController::SetLocalCertificate_w( |
| 356 const rtc::scoped_refptr<rtc::RTCCertificate>& certificate) { | 360 const rtc::scoped_refptr<rtc::RTCCertificate>& certificate) { |
| 357 RTC_DCHECK(worker_thread_->IsCurrent()); | 361 RTC_DCHECK(worker_thread_->IsCurrent()); |
| 358 | 362 |
| 359 if (certificate_) { | 363 if (certificate_) { |
| 360 return false; | 364 return false; |
| 361 } | 365 } |
| 362 if (!certificate) { | 366 if (!certificate) { |
| (...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 596 } | 600 } |
| 597 if (gathering_state_ != new_gathering_state) { | 601 if (gathering_state_ != new_gathering_state) { |
| 598 gathering_state_ = new_gathering_state; | 602 gathering_state_ = new_gathering_state; |
| 599 signaling_thread_->Post( | 603 signaling_thread_->Post( |
| 600 this, MSG_ICEGATHERINGSTATE, | 604 this, MSG_ICEGATHERINGSTATE, |
| 601 new rtc::TypedMessageData<IceGatheringState>(new_gathering_state)); | 605 new rtc::TypedMessageData<IceGatheringState>(new_gathering_state)); |
| 602 } | 606 } |
| 603 } | 607 } |
| 604 | 608 |
| 605 } // namespace cricket | 609 } // namespace cricket |
| OLD | NEW |