| Index: net/http/http_cache_transaction.h
|
| diff --git a/net/http/http_cache_transaction.h b/net/http/http_cache_transaction.h
|
| deleted file mode 100644
|
| index f230f42e8a1430b17340aa5112470fa721368ccb..0000000000000000000000000000000000000000
|
| --- a/net/http/http_cache_transaction.h
|
| +++ /dev/null
|
| @@ -1,490 +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.
|
| -
|
| -// This file declares HttpCache::Transaction, a private class of HttpCache so
|
| -// it should only be included by http_cache.cc
|
| -
|
| -#ifndef NET_HTTP_HTTP_CACHE_TRANSACTION_H_
|
| -#define NET_HTTP_HTTP_CACHE_TRANSACTION_H_
|
| -
|
| -#include <string>
|
| -
|
| -#include "base/time/time.h"
|
| -#include "net/base/completion_callback.h"
|
| -#include "net/base/net_log.h"
|
| -#include "net/base/request_priority.h"
|
| -#include "net/http/http_cache.h"
|
| -#include "net/http/http_request_headers.h"
|
| -#include "net/http/http_response_headers.h"
|
| -#include "net/http/http_response_info.h"
|
| -#include "net/http/http_transaction.h"
|
| -
|
| -namespace net {
|
| -
|
| -class PartialData;
|
| -struct HttpRequestInfo;
|
| -struct LoadTimingInfo;
|
| -
|
| -// This is the transaction that is returned by the HttpCache transaction
|
| -// factory.
|
| -class HttpCache::Transaction : public HttpTransaction {
|
| - public:
|
| - // The transaction has the following modes, which apply to how it may access
|
| - // its cache entry.
|
| - //
|
| - // o If the mode of the transaction is NONE, then it is in "pass through"
|
| - // mode and all methods just forward to the inner network transaction.
|
| - //
|
| - // o If the mode of the transaction is only READ, then it may only read from
|
| - // the cache entry.
|
| - //
|
| - // o If the mode of the transaction is only WRITE, then it may only write to
|
| - // the cache entry.
|
| - //
|
| - // o If the mode of the transaction is READ_WRITE, then the transaction may
|
| - // optionally modify the cache entry (e.g., possibly corresponding to
|
| - // cache validation).
|
| - //
|
| - // o If the mode of the transaction is UPDATE, then the transaction may
|
| - // update existing cache entries, but will never create a new entry or
|
| - // respond using the entry read from the cache.
|
| - enum Mode {
|
| - NONE = 0,
|
| - READ_META = 1 << 0,
|
| - READ_DATA = 1 << 1,
|
| - READ = READ_META | READ_DATA,
|
| - WRITE = 1 << 2,
|
| - READ_WRITE = READ | WRITE,
|
| - UPDATE = READ_META | WRITE, // READ_WRITE & ~READ_DATA
|
| - };
|
| -
|
| - Transaction(RequestPriority priority,
|
| - HttpCache* cache);
|
| - ~Transaction() override;
|
| -
|
| - Mode mode() const { return mode_; }
|
| -
|
| - const std::string& key() const { return cache_key_; }
|
| -
|
| - // Writes |buf_len| bytes of meta-data from the provided buffer |buf|. to the
|
| - // HTTP cache entry that backs this transaction (if any).
|
| - // Returns the number of bytes actually written, or a net error code. If the
|
| - // operation cannot complete immediately, returns ERR_IO_PENDING, grabs a
|
| - // reference to the buffer (until completion), and notifies the caller using
|
| - // the provided |callback| when the operation finishes.
|
| - //
|
| - // The first time this method is called for a given transaction, previous
|
| - // meta-data will be overwritten with the provided data, and subsequent
|
| - // invocations will keep appending to the cached entry.
|
| - //
|
| - // In order to guarantee that the metadata is set to the correct entry, the
|
| - // response (or response info) must be evaluated by the caller, for instance
|
| - // to make sure that the response_time is as expected, before calling this
|
| - // method.
|
| - int WriteMetadata(IOBuffer* buf,
|
| - int buf_len,
|
| - const CompletionCallback& callback);
|
| -
|
| - // This transaction is being deleted and we are not done writing to the cache.
|
| - // We need to indicate that the response data was truncated. Returns true on
|
| - // success. Keep in mind that this operation may have side effects, such as
|
| - // deleting the active entry.
|
| - bool AddTruncatedFlag();
|
| -
|
| - HttpCache::ActiveEntry* entry() { return entry_; }
|
| -
|
| - // Returns the LoadState of the writer transaction of a given ActiveEntry. In
|
| - // other words, returns the LoadState of this transaction without asking the
|
| - // http cache, because this transaction should be the one currently writing
|
| - // to the cache entry.
|
| - LoadState GetWriterLoadState() const;
|
| -
|
| - const CompletionCallback& io_callback() { return io_callback_; }
|
| -
|
| - const BoundNetLog& net_log() const;
|
| -
|
| - // Bypasses the cache lock whenever there is lock contention.
|
| - void BypassLockForTest() {
|
| - bypass_lock_for_test_ = true;
|
| - }
|
| -
|
| - // Generates a failure when attempting to conditionalize a network request.
|
| - void FailConditionalizationForTest() {
|
| - fail_conditionalization_for_test_ = true;
|
| - }
|
| -
|
| - // HttpTransaction methods:
|
| - int Start(const HttpRequestInfo* request_info,
|
| - const CompletionCallback& callback,
|
| - const BoundNetLog& net_log) override;
|
| - int RestartIgnoringLastError(const CompletionCallback& callback) override;
|
| - int RestartWithCertificate(X509Certificate* client_cert,
|
| - const CompletionCallback& callback) override;
|
| - int RestartWithAuth(const AuthCredentials& credentials,
|
| - const CompletionCallback& callback) override;
|
| - bool IsReadyToRestartForAuth() override;
|
| - int Read(IOBuffer* buf,
|
| - int buf_len,
|
| - const CompletionCallback& callback) override;
|
| - void StopCaching() override;
|
| - bool GetFullRequestHeaders(HttpRequestHeaders* headers) const override;
|
| - int64 GetTotalReceivedBytes() const override;
|
| - void DoneReading() override;
|
| - const HttpResponseInfo* GetResponseInfo() const override;
|
| - LoadState GetLoadState() const override;
|
| - UploadProgress GetUploadProgress(void) const override;
|
| - void SetQuicServerInfo(QuicServerInfo* quic_server_info) override;
|
| - bool GetLoadTimingInfo(LoadTimingInfo* load_timing_info) const override;
|
| - void SetPriority(RequestPriority priority) override;
|
| - void SetWebSocketHandshakeStreamCreateHelper(
|
| - net::WebSocketHandshakeStreamBase::CreateHelper* create_helper) override;
|
| - void SetBeforeNetworkStartCallback(
|
| - const BeforeNetworkStartCallback& callback) override;
|
| - void SetBeforeProxyHeadersSentCallback(
|
| - const BeforeProxyHeadersSentCallback& callback) override;
|
| - int ResumeNetworkStart() override;
|
| -
|
| - private:
|
| - static const size_t kNumValidationHeaders = 2;
|
| - // Helper struct to pair a header name with its value, for
|
| - // headers used to validate cache entries.
|
| - struct ValidationHeaders {
|
| - ValidationHeaders() : initialized(false) {}
|
| -
|
| - std::string values[kNumValidationHeaders];
|
| - bool initialized;
|
| - };
|
| -
|
| - enum State {
|
| - STATE_NONE,
|
| - STATE_GET_BACKEND,
|
| - STATE_GET_BACKEND_COMPLETE,
|
| - STATE_SEND_REQUEST,
|
| - STATE_SEND_REQUEST_COMPLETE,
|
| - STATE_SUCCESSFUL_SEND_REQUEST,
|
| - STATE_NETWORK_READ,
|
| - STATE_NETWORK_READ_COMPLETE,
|
| - STATE_INIT_ENTRY,
|
| - STATE_OPEN_ENTRY,
|
| - STATE_OPEN_ENTRY_COMPLETE,
|
| - STATE_CREATE_ENTRY,
|
| - STATE_CREATE_ENTRY_COMPLETE,
|
| - STATE_DOOM_ENTRY,
|
| - STATE_DOOM_ENTRY_COMPLETE,
|
| - STATE_ADD_TO_ENTRY,
|
| - STATE_ADD_TO_ENTRY_COMPLETE,
|
| - STATE_START_PARTIAL_CACHE_VALIDATION,
|
| - STATE_COMPLETE_PARTIAL_CACHE_VALIDATION,
|
| - STATE_UPDATE_CACHED_RESPONSE,
|
| - STATE_UPDATE_CACHED_RESPONSE_COMPLETE,
|
| - STATE_OVERWRITE_CACHED_RESPONSE,
|
| - STATE_TRUNCATE_CACHED_DATA,
|
| - STATE_TRUNCATE_CACHED_DATA_COMPLETE,
|
| - STATE_TRUNCATE_CACHED_METADATA,
|
| - STATE_TRUNCATE_CACHED_METADATA_COMPLETE,
|
| - STATE_PARTIAL_HEADERS_RECEIVED,
|
| - STATE_CACHE_READ_RESPONSE,
|
| - STATE_CACHE_READ_RESPONSE_COMPLETE,
|
| - STATE_CACHE_DISPATCH_VALIDATION,
|
| - STATE_TOGGLE_UNUSED_SINCE_PREFETCH,
|
| - STATE_TOGGLE_UNUSED_SINCE_PREFETCH_COMPLETE,
|
| - STATE_CACHE_WRITE_RESPONSE,
|
| - STATE_CACHE_WRITE_TRUNCATED_RESPONSE,
|
| - STATE_CACHE_WRITE_RESPONSE_COMPLETE,
|
| - STATE_CACHE_READ_METADATA,
|
| - STATE_CACHE_READ_METADATA_COMPLETE,
|
| - STATE_CACHE_QUERY_DATA,
|
| - STATE_CACHE_QUERY_DATA_COMPLETE,
|
| - STATE_CACHE_READ_DATA,
|
| - STATE_CACHE_READ_DATA_COMPLETE,
|
| - STATE_CACHE_WRITE_DATA,
|
| - STATE_CACHE_WRITE_DATA_COMPLETE
|
| - };
|
| -
|
| - // Used for categorizing transactions for reporting in histograms. Patterns
|
| - // cover relatively common use cases being measured and considered for
|
| - // optimization. Many use cases that are more complex or uncommon are binned
|
| - // as PATTERN_NOT_COVERED, and details are not reported.
|
| - // NOTE: This enumeration is used in histograms, so please do not add entries
|
| - // in the middle.
|
| - enum TransactionPattern {
|
| - PATTERN_UNDEFINED,
|
| - PATTERN_NOT_COVERED,
|
| - PATTERN_ENTRY_NOT_CACHED,
|
| - PATTERN_ENTRY_USED,
|
| - PATTERN_ENTRY_VALIDATED,
|
| - PATTERN_ENTRY_UPDATED,
|
| - PATTERN_ENTRY_CANT_CONDITIONALIZE,
|
| - PATTERN_MAX,
|
| - };
|
| -
|
| - // This is a helper function used to trigger a completion callback. It may
|
| - // only be called if callback_ is non-null.
|
| - void DoCallback(int rv);
|
| -
|
| - // This will trigger the completion callback if appropriate.
|
| - int HandleResult(int rv);
|
| -
|
| - // Runs the state transition loop.
|
| - int DoLoop(int result);
|
| -
|
| - // Each of these methods corresponds to a State value. If there is an
|
| - // argument, the value corresponds to the return of the previous state or
|
| - // corresponding callback.
|
| - int DoGetBackend();
|
| - int DoGetBackendComplete(int result);
|
| - int DoSendRequest();
|
| - int DoSendRequestComplete(int result);
|
| - int DoSuccessfulSendRequest();
|
| - int DoNetworkRead();
|
| - int DoNetworkReadComplete(int result);
|
| - int DoInitEntry();
|
| - int DoOpenEntry();
|
| - int DoOpenEntryComplete(int result);
|
| - int DoCreateEntry();
|
| - int DoCreateEntryComplete(int result);
|
| - int DoDoomEntry();
|
| - int DoDoomEntryComplete(int result);
|
| - int DoAddToEntry();
|
| - int DoAddToEntryComplete(int result);
|
| - int DoStartPartialCacheValidation();
|
| - int DoCompletePartialCacheValidation(int result);
|
| - int DoUpdateCachedResponse();
|
| - int DoUpdateCachedResponseComplete(int result);
|
| - int DoOverwriteCachedResponse();
|
| - int DoTruncateCachedData();
|
| - int DoTruncateCachedDataComplete(int result);
|
| - int DoTruncateCachedMetadata();
|
| - int DoTruncateCachedMetadataComplete(int result);
|
| - int DoPartialHeadersReceived();
|
| - int DoCacheReadResponse();
|
| - int DoCacheReadResponseComplete(int result);
|
| - int DoCacheDispatchValidation();
|
| - int DoCacheToggleUnusedSincePrefetch();
|
| - int DoCacheToggleUnusedSincePrefetchComplete(int result);
|
| - int DoCacheWriteResponse();
|
| - int DoCacheWriteTruncatedResponse();
|
| - int DoCacheWriteResponseComplete(int result);
|
| - int DoCacheReadMetadata();
|
| - int DoCacheReadMetadataComplete(int result);
|
| - int DoCacheQueryData();
|
| - int DoCacheQueryDataComplete(int result);
|
| - int DoCacheReadData();
|
| - int DoCacheReadDataComplete(int result);
|
| - int DoCacheWriteData(int num_bytes);
|
| - int DoCacheWriteDataComplete(int result);
|
| -
|
| - // These functions are involved in a field trial testing storing certificates
|
| - // in seperate entries from the HttpResponseInfo.
|
| - void ReadCertChain();
|
| - void WriteCertChain();
|
| -
|
| - // Sets request_ and fields derived from it.
|
| - void SetRequest(const BoundNetLog& net_log, const HttpRequestInfo* request);
|
| -
|
| - // Returns true if the request should be handled exclusively by the network
|
| - // layer (skipping the cache entirely).
|
| - bool ShouldPassThrough();
|
| -
|
| - // Called to begin reading from the cache. Returns network error code.
|
| - int BeginCacheRead();
|
| -
|
| - // Called to begin validating the cache entry. Returns network error code.
|
| - int BeginCacheValidation();
|
| -
|
| - // Called to begin validating an entry that stores partial content. Returns
|
| - // a network error code.
|
| - int BeginPartialCacheValidation();
|
| -
|
| - // Validates the entry headers against the requested range and continues with
|
| - // the validation of the rest of the entry. Returns a network error code.
|
| - int ValidateEntryHeadersAndContinue();
|
| -
|
| - // Called to start requests which were given an "if-modified-since" or
|
| - // "if-none-match" validation header by the caller (NOT when the request was
|
| - // conditionalized internally in response to LOAD_VALIDATE_CACHE).
|
| - // Returns a network error code.
|
| - int BeginExternallyConditionalizedRequest();
|
| -
|
| - // Called to restart a network transaction after an error. Returns network
|
| - // error code.
|
| - int RestartNetworkRequest();
|
| -
|
| - // Called to restart a network transaction with a client certificate.
|
| - // Returns network error code.
|
| - int RestartNetworkRequestWithCertificate(X509Certificate* client_cert);
|
| -
|
| - // Called to restart a network transaction with authentication credentials.
|
| - // Returns network error code.
|
| - int RestartNetworkRequestWithAuth(const AuthCredentials& credentials);
|
| -
|
| - // Called to determine if we need to validate the cache entry before using it,
|
| - // and whether the validation should be synchronous or asynchronous.
|
| - ValidationType RequiresValidation();
|
| -
|
| - // Called to make the request conditional (to ask the server if the cached
|
| - // copy is valid). Returns true if able to make the request conditional.
|
| - bool ConditionalizeRequest();
|
| -
|
| - // Makes sure that a 206 response is expected. Returns true on success.
|
| - // On success, handling_206_ will be set to true if we are processing a
|
| - // partial entry.
|
| - bool ValidatePartialResponse();
|
| -
|
| - // Handles a response validation error by bypassing the cache.
|
| - void IgnoreRangeRequest();
|
| -
|
| - // Fixes the response headers to match expectations for a HEAD request.
|
| - void FixHeadersForHead();
|
| -
|
| - // Launches an asynchronous revalidation based on this transaction.
|
| - void TriggerAsyncValidation();
|
| -
|
| - // Changes the response code of a range request to be 416 (Requested range not
|
| - // satisfiable).
|
| - void FailRangeRequest();
|
| -
|
| - // Setups the transaction for reading from the cache entry.
|
| - int SetupEntryForRead();
|
| -
|
| - // Reads data from the network.
|
| - int ReadFromNetwork(IOBuffer* data, int data_len);
|
| -
|
| - // Reads data from the cache entry.
|
| - int ReadFromEntry(IOBuffer* data, int data_len);
|
| -
|
| - // Called to write data to the cache entry. If the write fails, then the
|
| - // cache entry is destroyed. Future calls to this function will just do
|
| - // nothing without side-effect. Returns a network error code.
|
| - int WriteToEntry(int index, int offset, IOBuffer* data, int data_len,
|
| - const CompletionCallback& callback);
|
| -
|
| - // Called to write response_ to the cache entry. |truncated| indicates if the
|
| - // entry should be marked as incomplete.
|
| - int WriteResponseInfoToEntry(bool truncated);
|
| -
|
| - // Called to append response data to the cache entry. Returns a network error
|
| - // code.
|
| - int AppendResponseDataToEntry(IOBuffer* data, int data_len,
|
| - const CompletionCallback& callback);
|
| -
|
| - // Called when we are done writing to the cache entry.
|
| - void DoneWritingToEntry(bool success);
|
| -
|
| - // Returns an error to signal the caller that the current read failed. The
|
| - // current operation |result| is also logged. If |restart| is true, the
|
| - // transaction should be restarted.
|
| - int OnCacheReadError(int result, bool restart);
|
| -
|
| - // Called when the cache lock timeout fires.
|
| - void OnAddToEntryTimeout(base::TimeTicks start_time);
|
| -
|
| - // Deletes the current partial cache entry (sparse), and optionally removes
|
| - // the control object (partial_).
|
| - void DoomPartialEntry(bool delete_object);
|
| -
|
| - // Performs the needed work after receiving data from the network, when
|
| - // working with range requests.
|
| - int DoPartialNetworkReadCompleted(int result);
|
| -
|
| - // Performs the needed work after receiving data from the cache, when
|
| - // working with range requests.
|
| - int DoPartialCacheReadCompleted(int result);
|
| -
|
| - // Restarts this transaction after deleting the cached data. It is meant to
|
| - // be used when the current request cannot be fulfilled due to conflicts
|
| - // between the byte range request and the cached entry.
|
| - int DoRestartPartialRequest();
|
| -
|
| - // Resets the relavant internal state to remove traces of internal processing
|
| - // related to range requests. Deletes |partial_| if |delete_object| is true.
|
| - void ResetPartialState(bool delete_object);
|
| -
|
| - // Resets |network_trans_|, which must be non-NULL. Also updates
|
| - // |old_network_trans_load_timing_|, which must be NULL when this is called.
|
| - void ResetNetworkTransaction();
|
| -
|
| - // Returns true if we should bother attempting to resume this request if it
|
| - // is aborted while in progress. If |has_data| is true, the size of the stored
|
| - // data is considered for the result.
|
| - bool CanResume(bool has_data);
|
| -
|
| - void UpdateTransactionPattern(TransactionPattern new_transaction_pattern);
|
| - void RecordHistograms();
|
| -
|
| - // Called to signal completion of asynchronous IO.
|
| - void OnIOComplete(int result);
|
| -
|
| - State next_state_;
|
| - const HttpRequestInfo* request_;
|
| - RequestPriority priority_;
|
| - BoundNetLog net_log_;
|
| - scoped_ptr<HttpRequestInfo> custom_request_;
|
| - HttpRequestHeaders request_headers_copy_;
|
| - // If extra_headers specified a "if-modified-since" or "if-none-match",
|
| - // |external_validation_| contains the value of those headers.
|
| - ValidationHeaders external_validation_;
|
| - base::WeakPtr<HttpCache> cache_;
|
| - HttpCache::ActiveEntry* entry_;
|
| - HttpCache::ActiveEntry* new_entry_;
|
| - scoped_ptr<HttpTransaction> network_trans_;
|
| - CompletionCallback callback_; // Consumer's callback.
|
| - HttpResponseInfo response_;
|
| - HttpResponseInfo auth_response_;
|
| - const HttpResponseInfo* new_response_;
|
| - std::string cache_key_;
|
| - Mode mode_;
|
| - State target_state_;
|
| - bool reading_; // We are already reading. Never reverts to false once set.
|
| - bool invalid_range_; // We may bypass the cache for this request.
|
| - bool truncated_; // We don't have all the response data.
|
| - bool is_sparse_; // The data is stored in sparse byte ranges.
|
| - bool range_requested_; // The user requested a byte range.
|
| - bool handling_206_; // We must deal with this 206 response.
|
| - bool cache_pending_; // We are waiting for the HttpCache.
|
| - bool done_reading_; // All available data was read.
|
| - bool vary_mismatch_; // The request doesn't match the stored vary data.
|
| - bool couldnt_conditionalize_request_;
|
| - bool bypass_lock_for_test_; // A test is exercising the cache lock.
|
| - bool fail_conditionalization_for_test_; // Fail ConditionalizeRequest.
|
| - scoped_refptr<IOBuffer> read_buf_;
|
| - int io_buf_len_;
|
| - int read_offset_;
|
| - int effective_load_flags_;
|
| - int write_len_;
|
| - scoped_ptr<PartialData> partial_; // We are dealing with range requests.
|
| - UploadProgress final_upload_progress_;
|
| - CompletionCallback io_callback_;
|
| -
|
| - // Members used to track data for histograms.
|
| - TransactionPattern transaction_pattern_;
|
| - base::TimeTicks entry_lock_waiting_since_;
|
| - base::TimeTicks first_cache_access_since_;
|
| - base::TimeTicks send_request_since_;
|
| -
|
| - int64 total_received_bytes_;
|
| -
|
| - // Load timing information for the last network request, if any. Set in the
|
| - // 304 and 206 response cases, as the network transaction may be destroyed
|
| - // before the caller requests load timing information.
|
| - scoped_ptr<LoadTimingInfo> old_network_trans_load_timing_;
|
| -
|
| - // The helper object to use to create WebSocketHandshakeStreamBase
|
| - // objects. Only relevant when establishing a WebSocket connection.
|
| - // This is passed to the underlying network transaction. It is stored here in
|
| - // case the transaction does not exist yet.
|
| - WebSocketHandshakeStreamBase::CreateHelper*
|
| - websocket_handshake_stream_base_create_helper_;
|
| -
|
| - BeforeNetworkStartCallback before_network_start_callback_;
|
| - BeforeProxyHeadersSentCallback before_proxy_headers_sent_callback_;
|
| -
|
| - base::WeakPtrFactory<Transaction> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(Transaction);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_HTTP_HTTP_CACHE_TRANSACTION_H_
|
|
|