Change URLRequest to use a ref-counted buffer for actual IO....

net/url_request/url_request_file_dir_job.cc

 // Copyright (c) 2006-2008 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 "net/url_request/url_request_file_dir_job.h"
 
 #include "base/file_util.h"
 #include "base/message_loop.h"
 #include "base/string_util.h"
 #include "base/time.h"
 #include "googleurl/src/gurl.h"
 #include "net/base/net_util.h"
 #include "net/url_request/url_request.h"
 
 #if defined(OS_POSIX)
 #include <sys/stat.h>
 #endif
 
 using std::string;
 
 URLRequestFileDirJob::URLRequestFileDirJob(URLRequest* request,
                                            const FilePath& dir_path)
     : URLRequestJob(request),
       dir_path_(dir_path),
       canceled_(false),
       list_complete_(false),
       wrote_header_(false),
       read_pending_(false),
-      read_buffer_(NULL),
       read_buffer_length_(0) {
 }
 
 URLRequestFileDirJob::~URLRequestFileDirJob() {
   DCHECK(read_pending_ == false);
   DCHECK(lister_ == NULL);
 }
 
 void URLRequestFileDirJob::Start() {
   // Start reading asynchronously so that all error reporting and data
@@ skipping 21 matching lines @@
 
   canceled_ = true;
 
   // Don't call CloseLister or dispatch an error to the URLRequest because we
   // want OnListDone to be called to also write the error to the output stream.
   // OnListDone will notify the URLRequest at this time.
   if (lister_)
     lister_->Cancel();
 }
 
-bool URLRequestFileDirJob::ReadRawData(char* buf, int buf_size,
+bool URLRequestFileDirJob::ReadRawData(net::IOBuffer* buf, int buf_size,
                                        int *bytes_read) {
   DCHECK(bytes_read);
   *bytes_read = 0;
 
   if (is_done())
     return true;
 
-  if (FillReadBuffer(buf, buf_size, bytes_read))
+  if (FillReadBuffer(buf->data(), buf_size, bytes_read))
     return true;
 
   // We are waiting for more data
   read_pending_ = true;
   read_buffer_ = buf;
   read_buffer_length_ = buf_size;
   SetStatus(URLRequestStatus(URLRequestStatus::IO_PENDING, 0));
   return false;
 }
 
@@ skipping 86 matching lines @@
   } else if (list_complete_) {
     // EOF
     return true;
   }
   return false;
 }
 
 void URLRequestFileDirJob::CompleteRead() {
   if (read_pending_) {
     int bytes_read;
-    if (FillReadBuffer(read_buffer_, read_buffer_length_, &bytes_read)) {
+    if (FillReadBuffer(read_buffer_->data(), read_buffer_length_,
+                       &bytes_read)) {
       // We completed the read, so reset the read buffer.
       read_pending_ = false;
       read_buffer_ = NULL;
       read_buffer_length_ = 0;
 
       SetStatus(URLRequestStatus());
       NotifyReadComplete(bytes_read);
     } else {
       NOTREACHED();
       // TODO: Better error code.
@@ skipping 16 matching lines @@
     replacements.SetPathStr(new_path);
 
     *location = request_->url().ReplaceComponents(replacements);
     *http_status_code = 301;  // simulate a permanent redirect
     return true;
   }
 
   return false;
 }