blob: 2a93368363905a9d66fd85bd6fb38ee41d3a6020 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
// 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 CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_URL_REQUEST_JOB_H_
#define CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_URL_REQUEST_JOB_H_
#include <string>
#include "base/basictypes.h"
#include "base/callback.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "chrome/browser/chromeos/drive/file_errors.h"
#include "net/url_request/url_request_job.h"
namespace base {
class SequencedTaskRunner;
} // namespace
namespace net {
class IOBuffer;
class NetworkDelegate;
class URLRequest;
} // namespace net
namespace drive {
class DriveFileStreamReader;
class FileSystemInterface;
class ResourceEntry;
// DriveURLRequesetJob is the gateway between network-level drive:...
// requests for drive resources and DriveFileSytem. It exposes content URLs
// formatted as drive:<drive-file-path>.
// The methods should be run on IO thread, and the operations to communicate
// with a locally cached file will run on |file_task_runner|.
class DriveURLRequestJob : public net::URLRequestJob {
public:
// Callback to return the FileSystemInterface instance. This is an
// injecting point for testing.
// Note that the callback will be copied between threads (IO and UI), and
// will be called on UI thread.
typedef base::Callback<FileSystemInterface*()> FileSystemGetter;
DriveURLRequestJob(const FileSystemGetter& file_system_getter,
base::SequencedTaskRunner* file_task_runner,
net::URLRequest* request,
net::NetworkDelegate* network_delegate);
// net::URLRequestJob overrides:
virtual void Start() OVERRIDE;
virtual void Kill() OVERRIDE;
virtual bool GetMimeType(std::string* mime_type) const OVERRIDE;
virtual bool IsRedirectResponse(
GURL* location, int* http_status_code) OVERRIDE;
virtual bool ReadRawData(
net::IOBuffer* buf, int buf_size, int* bytes_read) OVERRIDE;
protected:
virtual ~DriveURLRequestJob();
private:
// Called when the initialization of DriveFileStreamReader is completed.
void OnDriveFileStreamReaderInitialized(
int error, scoped_ptr<ResourceEntry> entry);
// Called when DriveFileStreamReader::Read is completed.
void OnReadCompleted(int read_result);
const FileSystemGetter file_system_getter_;
scoped_refptr<base::SequencedTaskRunner> file_task_runner_;
scoped_ptr<DriveFileStreamReader> stream_reader_;
scoped_ptr<ResourceEntry> entry_;
// This should remain the last member so it'll be destroyed first and
// invalidate its weak pointers before other members are destroyed.
base::WeakPtrFactory<DriveURLRequestJob> weak_ptr_factory_;
DISALLOW_COPY_AND_ASSIGN(DriveURLRequestJob);
};
} // namespace drive
#endif // CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_URL_REQUEST_JOB_H_
|
