OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/browser/chromeos/file_system_provider/fileapi/backend_delegate.
h" | 5 #include "chrome/browser/chromeos/file_system_provider/fileapi/backend_delegate.
h" |
6 | 6 |
7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "chrome/browser/chromeos/file_system_provider/fileapi/buffering_file_st
ream_reader.h" | 8 #include "chrome/browser/chromeos/file_system_provider/fileapi/buffering_file_st
ream_reader.h" |
9 #include "chrome/browser/chromeos/file_system_provider/fileapi/buffering_file_st
ream_writer.h" | 9 #include "chrome/browser/chromeos/file_system_provider/fileapi/buffering_file_st
ream_writer.h" |
10 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" | 10 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" |
11 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_write
r.h" | 11 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_write
r.h" |
12 #include "chrome/browser/chromeos/file_system_provider/fileapi/provider_async_fi
le_util.h" | 12 #include "chrome/browser/chromeos/file_system_provider/fileapi/provider_async_fi
le_util.h" |
| 13 #include "chrome/browser/chromeos/file_system_provider/fileapi/watcher_manager.h
" |
13 #include "content/public/browser/browser_thread.h" | 14 #include "content/public/browser/browser_thread.h" |
14 #include "storage/browser/blob/file_stream_reader.h" | 15 #include "storage/browser/blob/file_stream_reader.h" |
15 #include "storage/browser/fileapi/file_stream_writer.h" | 16 #include "storage/browser/fileapi/file_stream_writer.h" |
16 #include "storage/browser/fileapi/file_system_url.h" | 17 #include "storage/browser/fileapi/file_system_url.h" |
17 | 18 |
18 using content::BrowserThread; | 19 using content::BrowserThread; |
19 | 20 |
20 namespace chromeos { | 21 namespace chromeos { |
21 namespace file_system_provider { | 22 namespace file_system_provider { |
22 namespace { | 23 namespace { |
23 | 24 |
24 // Size of the stream reader internal buffer. At most this number of bytes will | 25 // Size of the stream reader internal buffer. At most this number of bytes will |
25 // be read ahead of the requested data. | 26 // be read ahead of the requested data. |
26 const int kReaderBufferSize = 512 * 1024; // 512KB. | 27 const int kReaderBufferSize = 512 * 1024; // 512KB. |
27 | 28 |
28 // Size of the stream writer internal buffer. At most this number of bytes will | 29 // Size of the stream writer internal buffer. At most this number of bytes will |
29 // be postponed for writing. | 30 // be postponed for writing. |
30 const int kWriterBufferSize = 512 * 1024; // 512KB. | 31 const int kWriterBufferSize = 512 * 1024; // 512KB. |
31 | 32 |
32 } // namespace | 33 } // namespace |
33 | 34 |
34 BackendDelegate::BackendDelegate() | 35 BackendDelegate::BackendDelegate() |
35 : async_file_util_(new internal::ProviderAsyncFileUtil) {} | 36 : async_file_util_(new internal::ProviderAsyncFileUtil), |
| 37 watcher_manager_(new WatcherManager) { |
| 38 } |
36 | 39 |
37 BackendDelegate::~BackendDelegate() {} | 40 BackendDelegate::~BackendDelegate() {} |
38 | 41 |
39 storage::AsyncFileUtil* BackendDelegate::GetAsyncFileUtil( | 42 storage::AsyncFileUtil* BackendDelegate::GetAsyncFileUtil( |
40 storage::FileSystemType type) { | 43 storage::FileSystemType type) { |
41 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 44 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
42 DCHECK_EQ(storage::kFileSystemTypeProvided, type); | 45 DCHECK_EQ(storage::kFileSystemTypeProvided, type); |
43 return async_file_util_.get(); | 46 return async_file_util_.get(); |
44 } | 47 } |
45 | 48 |
(...skipping 20 matching lines...) Expand all Loading... |
66 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 69 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
67 DCHECK_EQ(storage::kFileSystemTypeProvided, url.type()); | 70 DCHECK_EQ(storage::kFileSystemTypeProvided, url.type()); |
68 | 71 |
69 return scoped_ptr<storage::FileStreamWriter>(new BufferingFileStreamWriter( | 72 return scoped_ptr<storage::FileStreamWriter>(new BufferingFileStreamWriter( |
70 scoped_ptr<storage::FileStreamWriter>(new FileStreamWriter(url, offset)), | 73 scoped_ptr<storage::FileStreamWriter>(new FileStreamWriter(url, offset)), |
71 kWriterBufferSize)); | 74 kWriterBufferSize)); |
72 } | 75 } |
73 | 76 |
74 storage::WatcherManager* BackendDelegate::GetWatcherManager( | 77 storage::WatcherManager* BackendDelegate::GetWatcherManager( |
75 const storage::FileSystemURL& url) { | 78 const storage::FileSystemURL& url) { |
76 NOTIMPLEMENTED(); | 79 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
77 return NULL; | 80 DCHECK_EQ(storage::kFileSystemTypeProvided, url.type()); |
| 81 return watcher_manager_.get(); |
78 } | 82 } |
79 | 83 |
80 void BackendDelegate::GetRedirectURLForContents( | 84 void BackendDelegate::GetRedirectURLForContents( |
81 const storage::FileSystemURL& url, | 85 const storage::FileSystemURL& url, |
82 const storage::URLCallback& callback) { | 86 const storage::URLCallback& callback) { |
83 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 87 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
84 DCHECK_EQ(storage::kFileSystemTypeProvided, url.type()); | 88 DCHECK_EQ(storage::kFileSystemTypeProvided, url.type()); |
85 callback.Run(GURL()); | 89 callback.Run(GURL()); |
86 } | 90 } |
87 | 91 |
88 } // namespace file_system_provider | 92 } // namespace file_system_provider |
89 } // namespace chromeos | 93 } // namespace chromeos |
OLD | NEW |