Chromoting protocol implementation based on P2P Transport API.

remoting/protocol/pepper_transport_socket_adapter.cc

 // Copyright (c) 2011 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/protocol/pepper_transport_socket_adapter.h"
 
 #include "base/logging.h"
+#include "net/base/address_list.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
+#include "net/base/net_util.h"
 #include "ppapi/c/pp_errors.h"
 #include "ppapi/cpp/dev/transport_dev.h"
 #include "ppapi/cpp/var.h"
 
 namespace remoting {
 namespace protocol {
 
 namespace {
 
 const char kTcpProtocol[] = "tcp";
@@ skipping 12 matching lines @@
     case PP_ERROR_NOINTERFACE:
       return net::ERR_NOT_IMPLEMENTED;
     default:
       return net::ERR_FAILED;
   }
 }
 
 }  // namespace
 
 PepperTransportSocketAdapter::PepperTransportSocketAdapter(
-    pp::Instance* pp_instance,
+    pp::Transport_Dev* transport,
     const std::string& name,
     Observer* observer)
     : name_(name),
       observer_(observer),
+      transport_(transport),
       connected_(false),
       get_address_pending_(false),
       read_callback_(NULL),
       write_callback_(NULL) {
   callback_factory_.Initialize(this);
-  transport_.reset(new pp::Transport_Dev(
-      pp_instance, name_.c_str(), kTcpProtocol));
 }
 
 PepperTransportSocketAdapter::~PepperTransportSocketAdapter() {
   observer_->OnChannelDeleted();
 }
 
 void PepperTransportSocketAdapter::AddRemoteCandidate(
     const std::string& candidate) {
   DCHECK(CalledOnValidThread());
   transport_->ReceiveRemoteAddress(candidate);
@@ skipping 77 matching lines @@
   return connected_;
 }
 
 bool PepperTransportSocketAdapter::IsConnectedAndIdle() const {
   NOTIMPLEMENTED();
   return false;
 }
 
 int PepperTransportSocketAdapter::GetPeerAddress(
     net::AddressList* address) const {
-  NOTIMPLEMENTED();
-  return net::ERR_FAILED;
+  // We actually don't know the peer address. Returning so the upper layers
+  // won't complain.

[Wez, 2011/09/09 23:39:12]

nit: Wording.
"We don't have a meaningful peer address, but we can't return an error, so we
return a INADDR_ANY instead."

[Sergey Ulanov, 2011/09/12 19:50:50]

This comment was copied from pseudotcp_adapter.cc. Fixed here and in
PseudoTcpAdapter.

+  net::IPAddressNumber ip_address(4);
+  *address = net::AddressList::CreateFromIPAddress(ip_address, 0);
+  return net::OK;
 }
 
 int PepperTransportSocketAdapter::GetLocalAddress(
     net::IPEndPoint* address) const {
   NOTIMPLEMENTED();
   return net::ERR_FAILED;
 }
 
 const net::BoundNetLog& PepperTransportSocketAdapter::NetLog() const {
   return net_log_;
@@ skipping 87 matching lines @@
   DCHECK(write_buffer_);
 
   net::CompletionCallback* callback = write_callback_;
   write_callback_ = NULL;
   write_buffer_ = NULL;
   callback->Run(PPErrorToNetError(result));
 }
 
 }  // namespace protocol
 }  // namespace remoting