Add P2PDatagramSocket and P2PStreamSocket interfaces.

remoting/signaling/xmpp_signal_strategy.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "remoting/signaling/xmpp_signal_strategy.h"
 
 #include <vector>
 
 #include "base/bind.h"
 #include "base/location.h"
@@ skipping 344 matching lines @@
 }
 
 void XmppSignalStrategy::Core::OnSocketConnected(int result) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   if (result != net::OK) {
     OnNetworkError(result);
     return;
   }
 
-  writer_.reset(new BufferedSocketWriter());
-  writer_->Init(socket_.get(), base::Bind(&Core::OnNetworkError,
-                                          base::Unretained(this)));
+  writer_ = BufferedSocketWriter::CreateForSocket(
+      socket_.get(), base::Bind(&Core::OnNetworkError, base::Unretained(this)));
 
   XmppLoginHandler::TlsMode tls_mode;
   if (xmpp_server_config_.use_tls) {
     tls_mode = (xmpp_server_config_.port == kDefaultXmppPort)
                    ? XmppLoginHandler::TlsMode::WITH_HANDSHAKE
                    : XmppLoginHandler::TlsMode::WITHOUT_HANDSHAKE;
   } else {
     tls_mode = XmppLoginHandler::TlsMode::NO_TLS;
   }
 
@@ skipping 21 matching lines @@
 void XmppSignalStrategy::Core::OnTlsConnected(int result) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(tls_state_ == TlsState::CONNECTING);
   tls_state_ = TlsState::CONNECTED;
 
   if (result != net::OK) {
     OnNetworkError(result);
     return;
   }
 
-  writer_.reset(new BufferedSocketWriter());
-  writer_->Init(socket_.get(), base::Bind(&Core::OnNetworkError,
-                                          base::Unretained(this)));
+  writer_ = BufferedSocketWriter::CreateForSocket(
+      socket_.get(), base::Bind(&Core::OnNetworkError, base::Unretained(this)));
 
   login_handler_->OnTlsStarted();
 
   ReadSocket();
 }
 
 void XmppSignalStrategy::Core::ReadSocket() {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   while (socket_ && !read_pending_ && (tls_state_ == TlsState::NOT_REQUESTED ||
@@ skipping 105 matching lines @@
 std::string XmppSignalStrategy::GetNextId() {
   return base::Uint64ToString(base::RandUint64());
 }
 
 void XmppSignalStrategy::SetAuthInfo(const std::string& username,
                                      const std::string& auth_token) {
   core_->SetAuthInfo(username, auth_token);
 }
 
 }  // namespace remoting