Index: net/test/url_request/url_request_slow_download_job.h |
diff --git a/net/test/url_request/url_request_slow_download_job.h b/net/test/url_request/url_request_slow_download_job.h |
new file mode 100644 |
index 0000000000000000000000000000000000000000..a264a84abdfe3ecc7649208ddcf7a657e2b8dbdd |
--- /dev/null |
+++ b/net/test/url_request/url_request_slow_download_job.h |
@@ -0,0 +1,99 @@ |
+// 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 class simulates a slow download. Requests to |kUnknownSizeUrl| and |
+// |kKnownSizeUrl| start downloads that pause after the first N bytes, to be |
+// completed by sending a request to |kFinishDownloadUrl|. |
+ |
+#ifndef NET_TEST_URL_REQUEST_URL_REQUEST_SLOW_DOWNLOAD_JOB_H_ |
+#define NET_TEST_URL_REQUEST_URL_REQUEST_SLOW_DOWNLOAD_JOB_H_ |
+ |
+#include <set> |
+#include <string> |
+ |
+#include "base/lazy_instance.h" |
+#include "base/memory/weak_ptr.h" |
+#include "net/url_request/url_request_job.h" |
+ |
+namespace net { |
+ |
+class URLRequestSlowDownloadJob : public URLRequestJob { |
+ public: |
+ // Test URLs. |
+ static const char kUnknownSizeUrl[]; |
+ static const char kKnownSizeUrl[]; |
+ static const char kFinishDownloadUrl[]; |
+ static const char kErrorDownloadUrl[]; |
+ |
+ // Download sizes. |
+ static const int kFirstDownloadSize; |
+ static const int kSecondDownloadSize; |
+ |
+ // Timer callback, used to check to see if we should finish our download and |
+ // send the second chunk. |
+ void CheckDoneStatus(); |
+ |
+ // URLRequestJob methods |
+ void Start() override; |
+ bool GetMimeType(std::string* mime_type) const override; |
+ void GetResponseInfo(HttpResponseInfo* info) override; |
+ bool ReadRawData(IOBuffer* buf, int buf_size, int* bytes_read) override; |
+ |
+ static URLRequestJob* Factory(URLRequest* request, |
+ NetworkDelegate* network_delegate, |
+ const std::string& scheme); |
+ |
+ // Returns the current number of URLRequestSlowDownloadJobs that have |
+ // not yet completed. |
+ static size_t NumberOutstandingRequests(); |
+ |
+ // Adds the testing URLs to the URLRequestFilter. |
+ static void AddUrlHandler(); |
+ |
+ private: |
+ URLRequestSlowDownloadJob(URLRequest* request, |
+ NetworkDelegate* network_delegate); |
+ ~URLRequestSlowDownloadJob() override; |
+ |
+ // Enum indicating where we are in the read after a call to |
+ // FillBufferHelper. |
+ enum ReadStatus { |
+ // The buffer was filled with data and may be returned. |
+ BUFFER_FILLED, |
+ |
+ // No data was added to the buffer because kFinishDownloadUrl has |
+ // not yet been seen and we've already returned the first chunk. |
+ REQUEST_BLOCKED, |
+ |
+ // No data was added to the buffer because we've already returned |
+ // all the data. |
+ REQUEST_COMPLETE |
+ }; |
+ ReadStatus FillBufferHelper(IOBuffer* buf, int buf_size, int* bytes_written); |
+ |
+ void GetResponseInfoConst(HttpResponseInfo* info) const; |
+ |
+ // Mark all pending requests to be finished. We keep track of pending |
+ // requests in |pending_requests_|. |
+ static void FinishPendingRequests(); |
+ static void ErrorPendingRequests(); |
+ typedef std::set<URLRequestSlowDownloadJob*> SlowJobsSet; |
+ static base::LazyInstance<SlowJobsSet>::Leaky pending_requests_; |
+ |
+ void StartAsync(); |
+ |
+ void set_should_finish_download() { should_finish_download_ = true; } |
+ void set_should_error_download() { should_error_download_ = true; } |
+ |
+ int bytes_already_sent_; |
+ bool should_error_download_; |
+ bool should_finish_download_; |
+ scoped_refptr<IOBuffer> buffer_; |
+ int buffer_size_; |
+ |
+ base::WeakPtrFactory<URLRequestSlowDownloadJob> weak_factory_; |
+}; |
+ |
+} // namespace content |
+ |
+#endif // NET_TEST_URL_REQUEST_URL_REQUEST_SLOW_DOWNLOAD_JOB_H_ |