Convert implicit scoped_refptr constructor calls to explicit ones, part 2

net/websockets/websocket.cc

 // Copyright (c) 2009 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 <algorithm>
 #include <limits>
 
 #include "net/websockets/websocket.h"
 
 #include "base/message_loop.h"
@@ skipping 62 matching lines @@
     return;
   }
   DCHECK(ready_state_ == OPEN);
   DCHECK(MessageLoop::current() == origin_loop_);
 
   IOBufferWithSize* buf = new IOBufferWithSize(msg.size() + 2);
   char* p = buf->data();
   *p = '\0';
   memcpy(p + 1, msg.data(), msg.size());
   *(p + 1 + msg.size()) = '\xff';
-  pending_write_bufs_.push_back(buf);
+  pending_write_bufs_.push_back(make_scoped_refptr(buf));
   SendPending();
 }
 
 void WebSocket::Close() {
   DCHECK(MessageLoop::current() == origin_loop_);
 
   // If connection has not yet started, do nothing.
   if (ready_state_ == INITIALIZED) {
     DCHECK(!socket_stream_);
     ready_state_ = CLOSED;
@@ skipping 71 matching lines @@
           request_->url(), request_->origin(), request_->location(),
           request_->protocol()));
       break;
     default:
       NOTREACHED() << "Unexpected protocol version:" << request_->version();
   }
 
   const std::string msg = handshake_->CreateClientHandshakeMessage();
   IOBufferWithSize* buf = new IOBufferWithSize(msg.size());
   memcpy(buf->data(), msg.data(), msg.size());
-  pending_write_bufs_.push_back(buf);
+  pending_write_bufs_.push_back(make_scoped_refptr(buf));
   origin_loop_->PostTask(FROM_HERE,
                          NewRunnableMethod(this, &WebSocket::SendPending));
 }
 
 void WebSocket::OnSentData(SocketStream* socket_stream, int amount_sent) {
   DCHECK(socket_stream == socket_stream_);
   DCHECK(current_write_buf_);
   current_write_buf_->DidConsume(amount_sent);
   DCHECK_GE(current_write_buf_->BytesRemaining(), 0);
   if (current_write_buf_->BytesRemaining() == 0) {
@@ skipping 237 matching lines @@
   // 4.2 *start the WebSocket closing handshake*.
   if (closing_handshake_started_ || client_closing_handshake_) {
     // 1. If the WebSocket closing handshake has started, then abort these
     // steps.
     return;
   }
   // 2.,3. Send a 0xFF and 0x00 byte to the server.
   client_closing_handshake_ = true;
   IOBufferWithSize* buf = new IOBufferWithSize(2);
   memcpy(buf->data(), kClosingFrame, 2);
-  pending_write_bufs_.push_back(buf);
+  pending_write_bufs_.push_back(make_scoped_refptr(buf));
   SendPending();
 }
 
 void WebSocket::DoForceCloseConnection() {
   // 4.2 *start the WebSocket closing handshake*
   // 6. If the WebSocket connection is not already closed, then close the
   // WebSocket connection.  (If this happens, then the closing handshake
   // doesn't finish.)
   DCHECK(MessageLoop::current() == origin_loop_);
   force_close_task_ = NULL;
@@ skipping 31 matching lines @@
   Release();
 }
 
 void WebSocket::DoSocketError(int error) {
   DCHECK(MessageLoop::current() == origin_loop_);
   if (delegate_)
     delegate_->OnSocketError(this, error);
 }
 
 }  // namespace net