Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(963)

Unified Diff: webkit/browser/appcache/appcache_response.h

Issue 344493002: Move all remaining appcache-related code to content namespace (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webkit/browser/appcache/appcache_response.h
diff --git a/webkit/browser/appcache/appcache_response.h b/webkit/browser/appcache/appcache_response.h
deleted file mode 100644
index d9695b34222780bf04f41bdec2eb0a72b7138793..0000000000000000000000000000000000000000
--- a/webkit/browser/appcache/appcache_response.h
+++ /dev/null
@@ -1,266 +0,0 @@
-// 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.
-
-#ifndef WEBKIT_BROWSER_APPCACHE_APPCACHE_RESPONSE_H_
-#define WEBKIT_BROWSER_APPCACHE_APPCACHE_RESPONSE_H_
-
-#include "base/compiler_specific.h"
-#include "base/memory/ref_counted.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/memory/weak_ptr.h"
-#include "net/base/completion_callback.h"
-#include "net/http/http_response_info.h"
-#include "url/gurl.h"
-#include "webkit/browser/webkit_storage_browser_export.h"
-#include "webkit/common/appcache/appcache_interfaces.h"
-
-namespace net {
-class IOBuffer;
-}
-
-namespace content {
-class MockAppCacheStorage;
-}
-
-namespace appcache {
-
-class AppCacheStorage;
-
-static const int kUnkownResponseDataSize = -1;
-
-// Response info for a particular response id. Instances are tracked in
-// the working set.
-class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheResponseInfo
- : public base::RefCounted<AppCacheResponseInfo> {
- public:
- // AppCacheResponseInfo takes ownership of the http_info.
- AppCacheResponseInfo(AppCacheStorage* storage, const GURL& manifest_url,
- int64 response_id, net::HttpResponseInfo* http_info,
- int64 response_data_size);
-
- const GURL& manifest_url() const { return manifest_url_; }
- int64 response_id() const { return response_id_; }
- const net::HttpResponseInfo* http_response_info() const {
- return http_response_info_.get();
- }
- int64 response_data_size() const { return response_data_size_; }
-
- private:
- friend class base::RefCounted<AppCacheResponseInfo>;
- virtual ~AppCacheResponseInfo();
-
- const GURL manifest_url_;
- const int64 response_id_;
- const scoped_ptr<net::HttpResponseInfo> http_response_info_;
- const int64 response_data_size_;
- AppCacheStorage* storage_;
-};
-
-// A refcounted wrapper for HttpResponseInfo so we can apply the
-// refcounting semantics used with IOBuffer with these structures too.
-struct WEBKIT_STORAGE_BROWSER_EXPORT HttpResponseInfoIOBuffer
- : public base::RefCountedThreadSafe<HttpResponseInfoIOBuffer> {
- scoped_ptr<net::HttpResponseInfo> http_info;
- int response_data_size;
-
- HttpResponseInfoIOBuffer();
- explicit HttpResponseInfoIOBuffer(net::HttpResponseInfo* info);
-
- protected:
- friend class base::RefCountedThreadSafe<HttpResponseInfoIOBuffer>;
- virtual ~HttpResponseInfoIOBuffer();
-};
-
-// Low level storage API used by the response reader and writer.
-class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheDiskCacheInterface {
- public:
- class Entry {
- public:
- virtual int Read(int index, int64 offset, net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback) = 0;
- virtual int Write(int index, int64 offset, net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback) = 0;
- virtual int64 GetSize(int index) = 0;
- virtual void Close() = 0;
- protected:
- virtual ~Entry() {}
- };
-
- virtual int CreateEntry(int64 key, Entry** entry,
- const net::CompletionCallback& callback) = 0;
- virtual int OpenEntry(int64 key, Entry** entry,
- const net::CompletionCallback& callback) = 0;
- virtual int DoomEntry(int64 key, const net::CompletionCallback& callback) = 0;
-
- protected:
- friend class base::RefCounted<AppCacheDiskCacheInterface>;
- virtual ~AppCacheDiskCacheInterface() {}
-};
-
-// Common base class for response reader and writer.
-class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheResponseIO {
- public:
- virtual ~AppCacheResponseIO();
- int64 response_id() const { return response_id_; }
-
- protected:
- AppCacheResponseIO(int64 response_id,
- int64 group_id,
- AppCacheDiskCacheInterface* disk_cache);
-
- virtual void OnIOComplete(int result) = 0;
-
- bool IsIOPending() { return !callback_.is_null(); }
- void ScheduleIOCompletionCallback(int result);
- void InvokeUserCompletionCallback(int result);
- void ReadRaw(int index, int offset, net::IOBuffer* buf, int buf_len);
- void WriteRaw(int index, int offset, net::IOBuffer* buf, int buf_len);
-
- const int64 response_id_;
- const int64 group_id_;
- AppCacheDiskCacheInterface* disk_cache_;
- AppCacheDiskCacheInterface::Entry* entry_;
- scoped_refptr<HttpResponseInfoIOBuffer> info_buffer_;
- scoped_refptr<net::IOBuffer> buffer_;
- int buffer_len_;
- net::CompletionCallback callback_;
- base::WeakPtrFactory<AppCacheResponseIO> weak_factory_;
-
- private:
- void OnRawIOComplete(int result);
-};
-
-// Reads existing response data from storage. If the object is deleted
-// and there is a read in progress, the implementation will return
-// immediately but will take care of any side effect of cancelling the
-// operation. In other words, instances are safe to delete at will.
-class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheResponseReader
- : public AppCacheResponseIO {
- public:
- virtual ~AppCacheResponseReader();
-
- // Reads http info from storage. Always returns the result of the read
- // asynchronously through the 'callback'. Returns the number of bytes read
- // or a net:: error code. Guaranteed to not perform partial reads of
- // the info data. The reader acquires a reference to the 'info_buf' until
- // completion at which time the callback is invoked with either a negative
- // error code or the number of bytes read. The 'info_buf' argument should
- // contain a NULL http_info when ReadInfo is called. The 'callback' is a
- // required parameter.
- // Should only be called where there is no Read operation in progress.
- // (virtual for testing)
- virtual void ReadInfo(HttpResponseInfoIOBuffer* info_buf,
- const net::CompletionCallback& callback);
-
- // Reads data from storage. Always returns the result of the read
- // asynchronously through the 'callback'. Returns the number of bytes read
- // or a net:: error code. EOF is indicated with a return value of zero.
- // The reader acquires a reference to the provided 'buf' until completion
- // at which time the callback is invoked with either a negative error code
- // or the number of bytes read. The 'callback' is a required parameter.
- // Should only be called where there is no Read operation in progress.
- // (virtual for testing)
- virtual void ReadData(net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback);
-
- // Returns true if there is a read operation, for data or info, pending.
- bool IsReadPending() { return IsIOPending(); }
-
- // Used to support range requests. If not called, the reader will
- // read the entire response body. If called, this must be called prior
- // to the first call to the ReadData method.
- void SetReadRange(int offset, int length);
-
- protected:
- friend class AppCacheStorageImpl;
- friend class content::MockAppCacheStorage;
-
- // Should only be constructed by the storage class and derivatives.
- AppCacheResponseReader(int64 response_id,
- int64 group_id,
- AppCacheDiskCacheInterface* disk_cache);
-
- virtual void OnIOComplete(int result) OVERRIDE;
- void ContinueReadInfo();
- void ContinueReadData();
- void OpenEntryIfNeededAndContinue();
- void OnOpenEntryComplete(AppCacheDiskCacheInterface::Entry** entry, int rv);
-
- int range_offset_;
- int range_length_;
- int read_position_;
- net::CompletionCallback open_callback_;
- base::WeakPtrFactory<AppCacheResponseReader> weak_factory_;
-};
-
-// Writes new response data to storage. If the object is deleted
-// and there is a write in progress, the implementation will return
-// immediately but will take care of any side effect of cancelling the
-// operation. In other words, instances are safe to delete at will.
-class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheResponseWriter
- : public AppCacheResponseIO {
- public:
- virtual ~AppCacheResponseWriter();
-
- // Writes the http info to storage. Always returns the result of the write
- // asynchronously through the 'callback'. Returns the number of bytes written
- // or a net:: error code. The writer acquires a reference to the 'info_buf'
- // until completion at which time the callback is invoked with either a
- // negative error code or the number of bytes written. The 'callback' is a
- // required parameter. The contents of 'info_buf' are not modified.
- // Should only be called where there is no Write operation in progress.
- void WriteInfo(HttpResponseInfoIOBuffer* info_buf,
- const net::CompletionCallback& callback);
-
- // Writes data to storage. Always returns the result of the write
- // asynchronously through the 'callback'. Returns the number of bytes written
- // or a net:: error code. Guaranteed to not perform partial writes.
- // The writer acquires a reference to the provided 'buf' until completion at
- // which time the callback is invoked with either a negative error code or
- // the number of bytes written. The 'callback' is a required parameter.
- // The contents of 'buf' are not modified.
- // Should only be called where there is no Write operation in progress.
- void WriteData(net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback);
-
- // Returns true if there is a write pending.
- bool IsWritePending() { return IsIOPending(); }
-
- // Returns the amount written, info and data.
- int64 amount_written() { return info_size_ + write_position_; }
-
- protected:
- // Should only be constructed by the storage class and derivatives.
- AppCacheResponseWriter(int64 response_id,
- int64 group_id,
- AppCacheDiskCacheInterface* disk_cache);
-
- private:
- friend class AppCacheStorageImpl;
- friend class content::MockAppCacheStorage;
-
- enum CreationPhase {
- NO_ATTEMPT,
- INITIAL_ATTEMPT,
- DOOM_EXISTING,
- SECOND_ATTEMPT
- };
-
- virtual void OnIOComplete(int result) OVERRIDE;
- void ContinueWriteInfo();
- void ContinueWriteData();
- void CreateEntryIfNeededAndContinue();
- void OnCreateEntryComplete(AppCacheDiskCacheInterface::Entry** entry, int rv);
-
- int info_size_;
- int write_position_;
- int write_amount_;
- CreationPhase creation_phase_;
- net::CompletionCallback create_callback_;
- base::WeakPtrFactory<AppCacheResponseWriter> weak_factory_;
-};
-
-} // namespace appcache
-
-#endif // WEBKIT_BROWSER_APPCACHE_APPCACHE_RESPONSE_H_

Powered by Google App Engine
This is Rietveld 408576698