Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2)

Side by Side Diff: webrtc/p2p/base/session.cc

Issue 1353713002: Remove GICE (again). (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Undo .gclient Created 5 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « webrtc/p2p/base/session.h ('k') | webrtc/p2p/base/transport.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. 2 * Copyright 2004 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 19 matching lines...) Expand all
30 using rtc::Bind; 30 using rtc::Bind;
31 31
32 TransportProxy::~TransportProxy() { 32 TransportProxy::~TransportProxy() {
33 for (ChannelMap::iterator iter = channels_.begin(); 33 for (ChannelMap::iterator iter = channels_.begin();
34 iter != channels_.end(); ++iter) { 34 iter != channels_.end(); ++iter) {
35 iter->second->SignalDestroyed(iter->second); 35 iter->second->SignalDestroyed(iter->second);
36 delete iter->second; 36 delete iter->second;
37 } 37 }
38 } 38 }
39 39
40 const std::string& TransportProxy::type() const {
41 return transport_->get()->type();
42 }
43
44 TransportChannel* TransportProxy::GetChannel(int component) { 40 TransportChannel* TransportProxy::GetChannel(int component) {
45 ASSERT(rtc::Thread::Current() == worker_thread_); 41 ASSERT(rtc::Thread::Current() == worker_thread_);
46 return GetChannelProxy(component); 42 return GetChannelProxy(component);
47 } 43 }
48 44
49 TransportChannel* TransportProxy::CreateChannel(int component) { 45 TransportChannel* TransportProxy::CreateChannel(int component) {
50 ASSERT(rtc::Thread::Current() == worker_thread_); 46 ASSERT(rtc::Thread::Current() == worker_thread_);
51 ASSERT(GetChannel(component) == NULL); 47 ASSERT(GetChannel(component) == NULL);
52 ASSERT(!transport_->get()->HasChannel(component)); 48 ASSERT(!transport_->get()->HasChannel(component));
53 49
(...skipping 278 matching lines...) Expand 10 before | Expand all | Expand 10 after
332 const std::string& sid, 328 const std::string& sid,
333 const std::string& content_type, 329 const std::string& content_type,
334 bool initiator) 330 bool initiator)
335 : state_(STATE_INIT), 331 : state_(STATE_INIT),
336 error_(ERROR_NONE), 332 error_(ERROR_NONE),
337 signaling_thread_(signaling_thread), 333 signaling_thread_(signaling_thread),
338 worker_thread_(worker_thread), 334 worker_thread_(worker_thread),
339 port_allocator_(port_allocator), 335 port_allocator_(port_allocator),
340 sid_(sid), 336 sid_(sid),
341 content_type_(content_type), 337 content_type_(content_type),
342 transport_type_(NS_GINGLE_P2P),
343 initiator_(initiator), 338 initiator_(initiator),
344 ssl_max_version_(rtc::SSL_PROTOCOL_DTLS_10), 339 ssl_max_version_(rtc::SSL_PROTOCOL_DTLS_10),
345 ice_tiebreaker_(rtc::CreateRandomId64()), 340 ice_tiebreaker_(rtc::CreateRandomId64()),
346 role_switch_(false), 341 role_switch_(false),
347 ice_receiving_timeout_(-1) { 342 ice_receiving_timeout_(-1) {
348 ASSERT(signaling_thread->IsCurrent()); 343 ASSERT(signaling_thread->IsCurrent());
349 } 344 }
350 345
351 BaseSession::~BaseSession() { 346 BaseSession::~BaseSession() {
352 ASSERT(signaling_thread()->IsCurrent()); 347 ASSERT(signaling_thread()->IsCurrent());
(...skipping 220 matching lines...) Expand 10 before | Expand all | Expand 10 after
573 void BaseSession::DestroyTransportProxy( 568 void BaseSession::DestroyTransportProxy(
574 const std::string& content_name) { 569 const std::string& content_name) {
575 TransportMap::iterator iter = transports_.find(content_name); 570 TransportMap::iterator iter = transports_.find(content_name);
576 if (iter != transports_.end()) { 571 if (iter != transports_.end()) {
577 delete iter->second; 572 delete iter->second;
578 transports_.erase(content_name); 573 transports_.erase(content_name);
579 } 574 }
580 } 575 }
581 576
582 Transport* BaseSession::CreateTransport(const std::string& content_name) { 577 Transport* BaseSession::CreateTransport(const std::string& content_name) {
583 ASSERT(transport_type_ == NS_GINGLE_P2P);
584 Transport* transport = new DtlsTransport<P2PTransport>( 578 Transport* transport = new DtlsTransport<P2PTransport>(
585 signaling_thread(), worker_thread(), content_name, port_allocator(), 579 signaling_thread(), worker_thread(), content_name, port_allocator(),
586 certificate_); 580 certificate_);
587 transport->SetChannelReceivingTimeout(ice_receiving_timeout_); 581 transport->SetChannelReceivingTimeout(ice_receiving_timeout_);
588 return transport; 582 return transport;
589 } 583 }
590 584
591 void BaseSession::SetState(State state) { 585 void BaseSession::SetState(State state) {
592 ASSERT(signaling_thread_->IsCurrent()); 586 ASSERT(signaling_thread_->IsCurrent());
593 if (state != state_) { 587 if (state != state_) {
(...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after
773 // Role will be reverse of initial role setting. 767 // Role will be reverse of initial role setting.
774 IceRole role = initiator_ ? ICEROLE_CONTROLLED : ICEROLE_CONTROLLING; 768 IceRole role = initiator_ ? ICEROLE_CONTROLLED : ICEROLE_CONTROLLING;
775 iter->second->SetIceRole(role); 769 iter->second->SetIceRole(role);
776 } 770 }
777 } 771 }
778 772
779 void BaseSession::LogState(State old_state, State new_state) { 773 void BaseSession::LogState(State old_state, State new_state) {
780 LOG(LS_INFO) << "Session:" << id() 774 LOG(LS_INFO) << "Session:" << id()
781 << " Old state:" << StateToString(old_state) 775 << " Old state:" << StateToString(old_state)
782 << " New state:" << StateToString(new_state) 776 << " New state:" << StateToString(new_state)
783 << " Type:" << content_type() 777 << " Type:" << content_type();
784 << " Transport:" << transport_type();
785 } 778 }
786 779
787 // static 780 // static
788 bool BaseSession::GetTransportDescription(const SessionDescription* description, 781 bool BaseSession::GetTransportDescription(const SessionDescription* description,
789 const std::string& content_name, 782 const std::string& content_name,
790 TransportDescription* tdesc) { 783 TransportDescription* tdesc) {
791 if (!description || !tdesc) { 784 if (!description || !tdesc) {
792 return false; 785 return false;
793 } 786 }
794 const TransportInfo* transport_info = 787 const TransportInfo* transport_info =
(...skipping 21 matching lines...) Expand all
816 809
817 default: 810 default:
818 // Explicitly ignoring some states here. 811 // Explicitly ignoring some states here.
819 break; 812 break;
820 } 813 }
821 break; 814 break;
822 } 815 }
823 } 816 }
824 817
825 } // namespace cricket 818 } // namespace cricket
OLDNEW
« no previous file with comments | « webrtc/p2p/base/session.h ('k') | webrtc/p2p/base/transport.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698