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

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
« no previous file with comments | « content/renderer/p2p/p2p_transport_impl.h ('k') | content/renderer/p2p/port_allocator.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 // 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),
25 state_(STATE_NONE), 27 state_(STATE_NONE),
28 ice_username_fragment_(
29 talk_base::CreateRandomString(cricket::ICE_UFRAG_LENGTH)),
Sergey Ulanov 2012/05/10 21:36:25 Given that these values are used only once in the
Mallinath (Gone from Chromium) 2012/05/10 21:41:21 Done.
30 ice_password_(talk_base::CreateRandomString(cricket::ICE_PWD_LENGTH)),
26 network_manager_(network_manager), 31 network_manager_(network_manager),
27 socket_factory_(socket_factory) { 32 socket_factory_(socket_factory) {
28 } 33 }
29 34
30 P2PTransportImpl::P2PTransportImpl(P2PSocketDispatcher* socket_dispatcher) 35 P2PTransportImpl::P2PTransportImpl(P2PSocketDispatcher* socket_dispatcher)
31 : socket_dispatcher_(socket_dispatcher), 36 : socket_dispatcher_(socket_dispatcher),
32 event_handler_(NULL), 37 event_handler_(NULL),
33 state_(STATE_NONE), 38 state_(STATE_NONE),
34 network_manager_(new IpcNetworkManager(socket_dispatcher)), 39 network_manager_(new IpcNetworkManager(socket_dispatcher)),
35 socket_factory_(new IpcPacketSocketFactory(socket_dispatcher)) { 40 socket_factory_(new IpcPacketSocketFactory(socket_dispatcher)) {
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
69 } else { 74 } else {
70 // Use BasicPortAllocator if we don't have P2PSocketDispatcher 75 // Use BasicPortAllocator if we don't have P2PSocketDispatcher
71 // (for unittests). 76 // (for unittests).
72 allocator_.reset(new cricket::BasicPortAllocator( 77 allocator_.reset(new cricket::BasicPortAllocator(
73 network_manager_.get(), socket_factory_.get())); 78 network_manager_.get(), socket_factory_.get()));
74 } 79 }
75 80
76 DCHECK(!channel_.get()); 81 DCHECK(!channel_.get());
77 channel_.reset(new cricket::P2PTransportChannel( 82 channel_.reset(new cricket::P2PTransportChannel(
78 name, 0, NULL, allocator_.get())); 83 name, 0, NULL, allocator_.get()));
84 channel_->SetIceUfrag(ice_username_fragment_);
85 channel_->SetIcePwd(ice_password_);
79 channel_->SignalRequestSignaling.connect( 86 channel_->SignalRequestSignaling.connect(
80 this, &P2PTransportImpl::OnRequestSignaling); 87 this, &P2PTransportImpl::OnRequestSignaling);
81 channel_->SignalCandidateReady.connect( 88 channel_->SignalCandidateReady.connect(
82 this, &P2PTransportImpl::OnCandidateReady); 89 this, &P2PTransportImpl::OnCandidateReady);
83 90
84 if (protocol == PROTOCOL_UDP) { 91 if (protocol == PROTOCOL_UDP) {
85 channel_->SignalReadableState.connect( 92 channel_->SignalReadableState.connect(
86 this, &P2PTransportImpl::OnReadableState); 93 this, &P2PTransportImpl::OnReadableState);
87 channel_->SignalWritableState.connect( 94 channel_->SignalWritableState.connect(
88 this, &P2PTransportImpl::OnWriteableState); 95 this, &P2PTransportImpl::OnWriteableState);
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after
160 void P2PTransportImpl::OnTcpConnected(int result) { 167 void P2PTransportImpl::OnTcpConnected(int result) {
161 if (result < 0) { 168 if (result < 0) {
162 event_handler_->OnError(result); 169 event_handler_->OnError(result);
163 return; 170 return;
164 } 171 }
165 state_ = static_cast<State>(STATE_READABLE | STATE_WRITABLE); 172 state_ = static_cast<State>(STATE_READABLE | STATE_WRITABLE);
166 event_handler_->OnStateChange(state_); 173 event_handler_->OnStateChange(state_);
167 } 174 }
168 175
169 } // namespace content 176 } // namespace content
OLDNEW
« no previous file with comments | « content/renderer/p2p/p2p_transport_impl.h ('k') | content/renderer/p2p/port_allocator.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698