Remove ref-counting from StreamListenSocket

content/browser/devtools/tethering_handler.cc

 // Copyright (c) 2012 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 "content/browser/devtools/tethering_handler.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/stl_util.h"
 #include "base/values.h"
@@ skipping 43 matching lines @@
     server_socket_ = delegate_->CreateSocketForTethering(this, &channel_name);
     if (!server_socket_.get() || channel_name.empty())
       SelfDestruct();
     return channel_name;
   }
 
   virtual ~SocketPump() { }
 
  private:
   virtual void DidAccept(net::StreamListenSocket* server,
-                         net::StreamListenSocket* socket) OVERRIDE {
+                         scoped_ptr<net::StreamListenSocket> socket) OVERRIDE {
     if (accepted_socket_.get())
       return;
 
     buffer_ = new net::IOBuffer(kBufferSize);
     wire_buffer_ = new net::GrowableIOBuffer();
     wire_buffer_->SetCapacity(kBufferSize);
 
-    accepted_socket_ = socket;
+    accepted_socket_ = socket.Pass();
     int result = client_socket_->Read(
         buffer_.get(),
         kBufferSize,
         base::Bind(&SocketPump::OnClientRead, base::Unretained(this)));
     if (result != net::ERR_IO_PENDING)
       OnClientRead(result);
   }
 
   virtual void DidRead(net::StreamListenSocket* socket,
                        const char* data,
@@ skipping 68 matching lines @@
   void SelfDestruct() {
     if (wire_buffer_->offset() != wire_buffer_size_) {
       pending_destruction_ = true;
       return;
     }
     delete this;
   }
 
  private:
   scoped_ptr<net::StreamSocket> client_socket_;
-  scoped_refptr<net::StreamListenSocket> server_socket_;
-  scoped_refptr<net::StreamListenSocket> accepted_socket_;
+  scoped_ptr<net::StreamListenSocket> server_socket_;
+  scoped_ptr<net::StreamListenSocket> accepted_socket_;
   scoped_refptr<net::IOBuffer> buffer_;
   scoped_refptr<net::GrowableIOBuffer> wire_buffer_;
   DevToolsHttpHandlerDelegate* delegate_;
   int wire_buffer_size_;
   bool pending_destruction_;
 };
 
 }  // namespace
 
 const char TetheringHandler::kDomain[] = "Tethering";
@@ skipping 126 matching lines @@
   BoundSockets::iterator it = bound_sockets_.find(port);
   if (it == bound_sockets_.end())
     return command->InternalErrorResponse("Port is not bound");
 
   delete it->second;
   bound_sockets_.erase(it);
   return command->SuccessResponse(NULL);
 }
 
 }  // namespace content