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

Side by Side Diff: content/renderer/p2p/p2p_transport_impl.cc

Issue 10382003: Changes needed to roll libjingle r141 (Closed) Base URL: http://src.chromium.org/svn/trunk/src/
Patch Set: Created 8 years, 7 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 | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "content/renderer/p2p/p2p_transport_impl.h" 5 #include "content/renderer/p2p/p2p_transport_impl.h"
6 6
7 #include "content/renderer/p2p/ipc_network_manager.h" 7 #include "content/renderer/p2p/ipc_network_manager.h"
8 #include "content/renderer/p2p/ipc_socket_factory.h" 8 #include "content/renderer/p2p/ipc_socket_factory.h"
9 #include "content/renderer/p2p/port_allocator.h" 9 #include "content/renderer/p2p/port_allocator.h"
10 #include "jingle/glue/channel_socket_adapter.h" 10 #include "jingle/glue/channel_socket_adapter.h"
11 #include "jingle/glue/pseudotcp_adapter.h" 11 #include "jingle/glue/pseudotcp_adapter.h"
12 #include "jingle/glue/thread_wrapper.h" 12 #include "jingle/glue/thread_wrapper.h"
13 #include "jingle/glue/utils.h" 13 #include "jingle/glue/utils.h"
14 #include "net/base/net_errors.h" 14 #include "net/base/net_errors.h"
15 #include "third_party/libjingle/source/talk/base/helpers.h"
16 #include "third_party/libjingle/source/talk/p2p/base/constants.h"
15 #include "third_party/libjingle/source/talk/p2p/base/p2ptransportchannel.h" 17 #include "third_party/libjingle/source/talk/p2p/base/p2ptransportchannel.h"
16 #include "third_party/libjingle/source/talk/p2p/client/basicportallocator.h" 18 #include "third_party/libjingle/source/talk/p2p/client/basicportallocator.h"
17 19
18 namespace content { 20 namespace content {
19 21
20 P2PTransportImpl::P2PTransportImpl( 22 P2PTransportImpl::P2PTransportImpl(
21 talk_base::NetworkManager* network_manager, 23 talk_base::NetworkManager* network_manager,
22 talk_base::PacketSocketFactory* socket_factory) 24 talk_base::PacketSocketFactory* socket_factory)
23 : socket_dispatcher_(NULL), 25 : socket_dispatcher_(NULL),
24 event_handler_(NULL), 26 event_handler_(NULL),
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
68 socket_factory_.get(), config)); 70 socket_factory_.get(), config));
69 } else { 71 } else {
70 // Use BasicPortAllocator if we don't have P2PSocketDispatcher 72 // Use BasicPortAllocator if we don't have P2PSocketDispatcher
71 // (for unittests). 73 // (for unittests).
72 allocator_.reset(new cricket::BasicPortAllocator( 74 allocator_.reset(new cricket::BasicPortAllocator(
73 network_manager_.get(), socket_factory_.get())); 75 network_manager_.get(), socket_factory_.get()));
74 } 76 }
75 77
76 DCHECK(!channel_.get()); 78 DCHECK(!channel_.get());
77 channel_.reset(new cricket::P2PTransportChannel( 79 channel_.reset(new cricket::P2PTransportChannel(
78 name, 0, NULL, allocator_.get())); 80 0, NULL, allocator_.get()));
81 channel_->SetIceUfrag(
82 talk_base::CreateRandomString(cricket::ICE_UFRAG_LENGTH));
83 channel_->SetIcePwd(talk_base::CreateRandomString(cricket::ICE_PWD_LENGTH));
79 channel_->SignalRequestSignaling.connect( 84 channel_->SignalRequestSignaling.connect(
80 this, &P2PTransportImpl::OnRequestSignaling); 85 this, &P2PTransportImpl::OnRequestSignaling);
81 channel_->SignalCandidateReady.connect( 86 channel_->SignalCandidateReady.connect(
82 this, &P2PTransportImpl::OnCandidateReady); 87 this, &P2PTransportImpl::OnCandidateReady);
83 88
84 if (protocol == PROTOCOL_UDP) { 89 if (protocol == PROTOCOL_UDP) {
85 channel_->SignalReadableState.connect( 90 channel_->SignalReadableState.connect(
86 this, &P2PTransportImpl::OnReadableState); 91 this, &P2PTransportImpl::OnReadableState);
87 channel_->SignalWritableState.connect( 92 channel_->SignalWritableState.connect(
88 this, &P2PTransportImpl::OnWriteableState); 93 this, &P2PTransportImpl::OnWriteableState);
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after
160 void P2PTransportImpl::OnTcpConnected(int result) { 165 void P2PTransportImpl::OnTcpConnected(int result) {
161 if (result < 0) { 166 if (result < 0) {
162 event_handler_->OnError(result); 167 event_handler_->OnError(result);
163 return; 168 return;
164 } 169 }
165 state_ = static_cast<State>(STATE_READABLE | STATE_WRITABLE); 170 state_ = static_cast<State>(STATE_READABLE | STATE_WRITABLE);
166 event_handler_->OnStateChange(state_); 171 event_handler_->OnStateChange(state_);
167 } 172 }
168 173
169 } // namespace content 174 } // namespace content
OLDNEW
« no previous file with comments | « content/renderer/media/peer_connection_handler_unittest.cc ('k') | content/renderer/p2p/port_allocator.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698