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

Unified Diff: content/browser/download/download_request_model.h

Issue 23496076: WIP - Refactor programmatic downloads Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 3 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: content/browser/download/download_request_model.h
diff --git a/content/browser/download/download_request_model.h b/content/browser/download/download_request_model.h
new file mode 100644
index 0000000000000000000000000000000000000000..305d7d7b64f57b632f0805b5938ced2a72915d3c
--- /dev/null
+++ b/content/browser/download/download_request_model.h
@@ -0,0 +1,107 @@
+// Copyright 2013 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 CONTENT_BROWSER_DOWNLOAD_DOWNLOAD_REQUEST_MODEL_H_
+#define CONTENT_BROWSER_DOWNLOAD_DOWNLOAD_REQUEST_MODEL_H_
+
+#include "base/callback_forward.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/memory/weak_ptr.h"
+#include "base/timer/timer.h"
+#include "content/public/browser/download_interrupt_reasons.h"
+#include "content/public/browser/download_save_info.h"
+#include "content/public/common/page_transition_types.h"
+#include "net/url_request/url_request.h"
+
+class GURL;
+
+namespace net {
+class IOBuffer;
+class URLRequestStatus;
+}
+
+namespace content {
+
+class ByteStreamWriter;
+struct DownloadCreateInfo;
+struct DownloadSaveInfo;
+class DownloadUrlParameters;
+
+class DownloadRequestModel {
+ public:
+ enum ReadState {
+ READY_TO_READ,
+ WAIT_FOR_RESUME
+ };
+
+ // Size of the buffer used between the DownloadResourceHandler and the
+ // downstream receiver of its output.
+ static const int kDownloadByteStreamSize;
+
+ typedef base::Closure ResumeRequestCallback;
+
+ DownloadRequestModel(net::URLRequest* request,
+ scoped_ptr<DownloadSaveInfo> save_info);
+ ~DownloadRequestModel();
+
+ static scoped_ptr<net::URLRequest> CreateRequest(
+ const DownloadUrlParameters& parameters,
+ net::URLRequest::Delegate* delegate);
+
+ static bool IsRequestAllowed(const GURL& url, int child_process_id);
+
+ // Assumes that the request is allowed.
+ void OnRequestRedirected(const GURL& url);
+
+ // The response data for the request is available. Returns a
+ // DownloadCreateInfo which can be used to construct a DownloadItem.
+ // |resume_callback| is invoked when the internal ByteStream is ready to
+ // accept more data. See OnReadCompleted. |resume_callback| is guaranteed to
+ // not be invoked after DownloadRequestModel has been deleted.
+ scoped_ptr<DownloadCreateInfo> OnResponseStarted(
+ const std::string& sniffed_mime_type,
+ bool has_user_gesture,
+ PageTransition page_transition,
+ const ResumeRequestCallback& resume_callback);
+
+ void OnWillRead(net::IOBuffer** buf, int* buf_size, int min_size);
+ ReadState OnReadCompleted(int bytes_read);
+ DownloadInterruptReason OnResponseCompleted();
+ void OnPauseRequest();
+ ReadState OnResumeRequest();
+ void OnDownloadInterrupted(DownloadInterruptReason reason);
+
+ std::string DebugString() const;
+
+ net::URLRequest* request() { return request_; }
+
+ private:
+ ReadState read_state() const;
+
+ net::URLRequest* request_;
+
+ scoped_ptr<DownloadSaveInfo> save_info_;
+
+ // Data flow
+ scoped_refptr<net::IOBuffer> read_buffer_; // From URLRequest.
+ scoped_ptr<ByteStreamWriter> stream_writer_; // To rest of system.
+
+ // The following are used to collect stats.
+ base::TimeTicks download_start_time_;
+ base::TimeTicks last_read_time_;
+ base::TimeTicks last_stream_pause_time_;
+ base::TimeDelta total_pause_time_;
+ size_t last_buffer_size_;
+ int64 bytes_read_;
+
+ int pause_count_;
+ DownloadInterruptReason last_interrupt_reason_;
+
+ static const int kReadBufSize = 32768; // bytes
+ static const int kThrottleTimeMs = 200; // milliseconds
+};
+
+} // namespace content
+
+#endif
« no previous file with comments | « content/browser/download/download_request_handle.cc ('k') | content/browser/download/download_request_model.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698