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

Unified Diff: net/http/http_cache_transaction.h

Issue 992733002: Remove //net (except for Android test stuff) and sdch (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 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
« no previous file with comments | « net/http/http_cache.cc ('k') | net/http/http_cache_transaction.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « net/http/http_cache.cc ('k') | net/http/http_cache_transaction.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698