OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2012 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 544 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
555 // since it's about to be destroyed. | 555 // since it's about to be destroyed. |
556 for (const auto& sender : senders_) { | 556 for (const auto& sender : senders_) { |
557 sender->Stop(); | 557 sender->Stop(); |
558 } | 558 } |
559 for (const auto& receiver : receivers_) { | 559 for (const auto& receiver : receivers_) { |
560 receiver->Stop(); | 560 receiver->Stop(); |
561 } | 561 } |
562 } | 562 } |
563 | 563 |
564 bool PeerConnection::Initialize( | 564 bool PeerConnection::Initialize( |
565 const cricket::MediaConfig& media_config, | |
566 const PeerConnectionInterface::RTCConfiguration& configuration, | 565 const PeerConnectionInterface::RTCConfiguration& configuration, |
567 rtc::scoped_ptr<cricket::PortAllocator> allocator, | 566 rtc::scoped_ptr<cricket::PortAllocator> allocator, |
568 rtc::scoped_ptr<DtlsIdentityStoreInterface> dtls_identity_store, | 567 rtc::scoped_ptr<DtlsIdentityStoreInterface> dtls_identity_store, |
569 PeerConnectionObserver* observer) { | 568 PeerConnectionObserver* observer) { |
570 TRACE_EVENT0("webrtc", "PeerConnection::Initialize"); | 569 TRACE_EVENT0("webrtc", "PeerConnection::Initialize"); |
571 RTC_DCHECK(observer != nullptr); | 570 RTC_DCHECK(observer != nullptr); |
572 if (!observer) { | 571 if (!observer) { |
573 return false; | 572 return false; |
574 } | 573 } |
575 observer_ = observer; | 574 observer_ = observer; |
(...skipping 23 matching lines...) Expand all Loading... |
599 | 598 |
600 if (configuration.tcp_candidate_policy == kTcpCandidatePolicyDisabled) { | 599 if (configuration.tcp_candidate_policy == kTcpCandidatePolicyDisabled) { |
601 portallocator_flags |= cricket::PORTALLOCATOR_DISABLE_TCP; | 600 portallocator_flags |= cricket::PORTALLOCATOR_DISABLE_TCP; |
602 LOG(LS_INFO) << "TCP candidates are disabled."; | 601 LOG(LS_INFO) << "TCP candidates are disabled."; |
603 } | 602 } |
604 | 603 |
605 port_allocator_->set_flags(portallocator_flags); | 604 port_allocator_->set_flags(portallocator_flags); |
606 // No step delay is used while allocating ports. | 605 // No step delay is used while allocating ports. |
607 port_allocator_->set_step_delay(cricket::kMinimumStepDelay); | 606 port_allocator_->set_step_delay(cricket::kMinimumStepDelay); |
608 | 607 |
609 media_controller_.reset(factory_->CreateMediaController(media_config)); | 608 media_controller_.reset( |
| 609 factory_->CreateMediaController(configuration.media_config)); |
610 | 610 |
611 remote_stream_factory_.reset( | 611 remote_stream_factory_.reset( |
612 new RemoteMediaStreamFactory(factory_->signaling_thread())); | 612 new RemoteMediaStreamFactory(factory_->signaling_thread())); |
613 | 613 |
614 session_.reset( | 614 session_.reset( |
615 new WebRtcSession(media_controller_.get(), factory_->signaling_thread(), | 615 new WebRtcSession(media_controller_.get(), factory_->signaling_thread(), |
616 factory_->worker_thread(), port_allocator_.get())); | 616 factory_->worker_thread(), port_allocator_.get())); |
617 stats_.reset(new StatsCollector(this)); | 617 stats_.reset(new StatsCollector(this)); |
618 | 618 |
619 // Initialize the WebRtcSession. It creates transport channels etc. | 619 // Initialize the WebRtcSession. It creates transport channels etc. |
(...skipping 1501 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2121 DataChannel* PeerConnection::FindDataChannelBySid(int sid) const { | 2121 DataChannel* PeerConnection::FindDataChannelBySid(int sid) const { |
2122 for (const auto& channel : sctp_data_channels_) { | 2122 for (const auto& channel : sctp_data_channels_) { |
2123 if (channel->id() == sid) { | 2123 if (channel->id() == sid) { |
2124 return channel; | 2124 return channel; |
2125 } | 2125 } |
2126 } | 2126 } |
2127 return nullptr; | 2127 return nullptr; |
2128 } | 2128 } |
2129 | 2129 |
2130 } // namespace webrtc | 2130 } // namespace webrtc |
OLD | NEW |