More groundwork for flat file based response storage.

webkit/appcache/appcache_response.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 "webkit/appcache/appcache_response.h"
 
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/pickle.h"
 #include "base/string_util.h"
@@ skipping 54 matching lines @@
     : response_data_size(kUnkownResponseDataSize) {}
 
 HttpResponseInfoIOBuffer::HttpResponseInfoIOBuffer(net::HttpResponseInfo* info)
     : http_info(info), response_data_size(kUnkownResponseDataSize) {}
 
 HttpResponseInfoIOBuffer::~HttpResponseInfoIOBuffer() {}
 
 // AppCacheResponseIO ----------------------------------------------
 
 AppCacheResponseIO::AppCacheResponseIO(
-    int64 response_id, AppCacheDiskCacheInterface* disk_cache)
-    : response_id_(response_id), disk_cache_(disk_cache),
+    int64 response_id, int64 group_id, AppCacheDiskCacheInterface* disk_cache)
+    : response_id_(response_id), group_id_(group_id), disk_cache_(disk_cache),
       entry_(NULL), buffer_len_(0), user_callback_(NULL),
       ALLOW_THIS_IN_INITIALIZER_LIST(method_factory_(this)),
       ALLOW_THIS_IN_INITIALIZER_LIST(raw_callback_(
           new net::CancelableOldCompletionCallback<AppCacheResponseIO>(
               this, &AppCacheResponseIO::OnRawIOComplete))) {
 }
 
 AppCacheResponseIO::~AppCacheResponseIO() {
   raw_callback_->Cancel();
   if (entry_)
@@ skipping 41 matching lines @@
 void AppCacheResponseIO::OnRawIOComplete(int result) {
   DCHECK_NE(net::ERR_IO_PENDING, result);
   raw_callback_->Release();  // Balance the AddRefs
   OnIOComplete(result);
 }
 
 
 // AppCacheResponseReader ----------------------------------------------
 
 AppCacheResponseReader::AppCacheResponseReader(
-    int64 response_id, AppCacheDiskCacheInterface* disk_cache)
-    : AppCacheResponseIO(response_id, disk_cache),
+    int64 response_id, int64 group_id, AppCacheDiskCacheInterface* disk_cache)
+    : AppCacheResponseIO(response_id, group_id, disk_cache),
       range_offset_(0), range_length_(kint32max),
       read_position_(0) {
 }
 
 AppCacheResponseReader::~AppCacheResponseReader() {
   if (open_callback_)
     open_callback_.release()->Cancel();
 }
 
 void AppCacheResponseReader::ReadInfo(HttpResponseInfoIOBuffer* info_buf,
@@ skipping 112 matching lines @@
 
   if (info_buffer_)
     ContinueReadInfo();
   else
     ContinueReadData();
 }
 
 // AppCacheResponseWriter ----------------------------------------------
 
 AppCacheResponseWriter::AppCacheResponseWriter(
-    int64 response_id, AppCacheDiskCacheInterface* disk_cache)
-    : AppCacheResponseIO(response_id, disk_cache),
+    int64 response_id, int64 group_id, AppCacheDiskCacheInterface* disk_cache)
+    : AppCacheResponseIO(response_id, group_id, disk_cache),
       info_size_(0), write_position_(0), write_amount_(0),
       creation_phase_(INITIAL_ATTEMPT) {
 }
 
 AppCacheResponseWriter::~AppCacheResponseWriter() {
   if (create_callback_)
     create_callback_.release()->Cancel();
 }
 
 void AppCacheResponseWriter::WriteInfo(HttpResponseInfoIOBuffer* info_buf,
@@ skipping 103 matching lines @@
   }
 
   if (info_buffer_)
     ContinueWriteInfo();
   else
     ContinueWriteData();
 }
 
 }  // namespace appcache