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

Side by Side Diff: chrome/browser/chromeos/drive/file_system/open_file_operation_unittest.cc

Issue 408143014: Rename OperationObserver to OperationDelegate (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 5 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 unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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/drive/file_system/open_file_operation.h" 5 #include "chrome/browser/chromeos/drive/file_system/open_file_operation.h"
6 6
7 #include <map> 7 #include <map>
8 8
9 #include "base/file_util.h" 9 #include "base/file_util.h"
10 #include "base/files/file_path.h" 10 #include "base/files/file_path.h"
(...skipping 10 matching lines...) Expand all
21 21
22 namespace drive { 22 namespace drive {
23 namespace file_system { 23 namespace file_system {
24 24
25 class OpenFileOperationTest : public OperationTestBase { 25 class OpenFileOperationTest : public OperationTestBase {
26 protected: 26 protected:
27 virtual void SetUp() OVERRIDE { 27 virtual void SetUp() OVERRIDE {
28 OperationTestBase::SetUp(); 28 OperationTestBase::SetUp();
29 29
30 operation_.reset(new OpenFileOperation( 30 operation_.reset(new OpenFileOperation(
31 blocking_task_runner(), observer(), scheduler(), metadata(), cache(), 31 blocking_task_runner(), delegate(), scheduler(), metadata(), cache(),
32 temp_dir())); 32 temp_dir()));
33 } 33 }
34 34
35 scoped_ptr<OpenFileOperation> operation_; 35 scoped_ptr<OpenFileOperation> operation_;
36 }; 36 };
37 37
38 TEST_F(OpenFileOperationTest, OpenExistingFile) { 38 TEST_F(OpenFileOperationTest, OpenExistingFile) {
39 const base::FilePath file_in_root( 39 const base::FilePath file_in_root(
40 FILE_PATH_LITERAL("drive/root/File 1.txt")); 40 FILE_PATH_LITERAL("drive/root/File 1.txt"));
41 ResourceEntry src_entry; 41 ResourceEntry src_entry;
(...skipping 12 matching lines...) Expand all
54 content::RunAllBlockingPoolTasksUntilIdle(); 54 content::RunAllBlockingPoolTasksUntilIdle();
55 55
56 EXPECT_EQ(FILE_ERROR_OK, error); 56 EXPECT_EQ(FILE_ERROR_OK, error);
57 ASSERT_TRUE(base::PathExists(file_path)); 57 ASSERT_TRUE(base::PathExists(file_path));
58 int64 local_file_size; 58 int64 local_file_size;
59 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size)); 59 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size));
60 EXPECT_EQ(file_size, local_file_size); 60 EXPECT_EQ(file_size, local_file_size);
61 61
62 ASSERT_FALSE(close_callback.is_null()); 62 ASSERT_FALSE(close_callback.is_null());
63 close_callback.Run(); 63 close_callback.Run();
64 EXPECT_EQ(1U, observer()->updated_local_ids().count(src_entry.local_id())); 64 EXPECT_EQ(1U, delegate()->updated_local_ids().count(src_entry.local_id()));
65 } 65 }
66 66
67 TEST_F(OpenFileOperationTest, OpenNonExistingFile) { 67 TEST_F(OpenFileOperationTest, OpenNonExistingFile) {
68 const base::FilePath file_in_root( 68 const base::FilePath file_in_root(
69 FILE_PATH_LITERAL("drive/root/not-exist.txt")); 69 FILE_PATH_LITERAL("drive/root/not-exist.txt"));
70 70
71 FileError error = FILE_ERROR_FAILED; 71 FileError error = FILE_ERROR_FAILED;
72 base::FilePath file_path; 72 base::FilePath file_path;
73 base::Closure close_callback; 73 base::Closure close_callback;
74 operation_->OpenFile( 74 operation_->OpenFile(
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after
111 base::FilePath file_path; 111 base::FilePath file_path;
112 base::Closure close_callback; 112 base::Closure close_callback;
113 operation_->OpenFile( 113 operation_->OpenFile(
114 file_in_root, 114 file_in_root,
115 CREATE_FILE, 115 CREATE_FILE,
116 std::string(), // mime_type 116 std::string(), // mime_type
117 google_apis::test_util::CreateCopyResultCallback( 117 google_apis::test_util::CreateCopyResultCallback(
118 &error, &file_path, &close_callback)); 118 &error, &file_path, &close_callback));
119 content::RunAllBlockingPoolTasksUntilIdle(); 119 content::RunAllBlockingPoolTasksUntilIdle();
120 120
121 EXPECT_EQ(1U, observer()->get_changed_files().size()); 121 EXPECT_EQ(1U, delegate()->get_changed_files().size());
122 EXPECT_TRUE(observer()->get_changed_files().count(file_in_root)); 122 EXPECT_TRUE(delegate()->get_changed_files().count(file_in_root));
123 123
124 EXPECT_EQ(FILE_ERROR_OK, error); 124 EXPECT_EQ(FILE_ERROR_OK, error);
125 ASSERT_TRUE(base::PathExists(file_path)); 125 ASSERT_TRUE(base::PathExists(file_path));
126 int64 local_file_size; 126 int64 local_file_size;
127 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size)); 127 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size));
128 EXPECT_EQ(0, local_file_size); // Should be an empty file. 128 EXPECT_EQ(0, local_file_size); // Should be an empty file.
129 129
130 ASSERT_FALSE(close_callback.is_null()); 130 ASSERT_FALSE(close_callback.is_null());
131 close_callback.Run(); 131 close_callback.Run();
132 EXPECT_EQ(1U, 132 EXPECT_EQ(1U,
133 observer()->updated_local_ids().count(GetLocalId(file_in_root))); 133 delegate()->updated_local_ids().count(GetLocalId(file_in_root)));
134 } 134 }
135 135
136 TEST_F(OpenFileOperationTest, OpenOrCreateExistingFile) { 136 TEST_F(OpenFileOperationTest, OpenOrCreateExistingFile) {
137 const base::FilePath file_in_root( 137 const base::FilePath file_in_root(
138 FILE_PATH_LITERAL("drive/root/File 1.txt")); 138 FILE_PATH_LITERAL("drive/root/File 1.txt"));
139 ResourceEntry src_entry; 139 ResourceEntry src_entry;
140 ASSERT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &src_entry)); 140 ASSERT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &src_entry));
141 const int64 file_size = src_entry.file_info().size(); 141 const int64 file_size = src_entry.file_info().size();
142 142
143 FileError error = FILE_ERROR_FAILED; 143 FileError error = FILE_ERROR_FAILED;
144 base::FilePath file_path; 144 base::FilePath file_path;
145 base::Closure close_callback; 145 base::Closure close_callback;
146 operation_->OpenFile( 146 operation_->OpenFile(
147 file_in_root, 147 file_in_root,
148 OPEN_OR_CREATE_FILE, 148 OPEN_OR_CREATE_FILE,
149 std::string(), // mime_type 149 std::string(), // mime_type
150 google_apis::test_util::CreateCopyResultCallback( 150 google_apis::test_util::CreateCopyResultCallback(
151 &error, &file_path, &close_callback)); 151 &error, &file_path, &close_callback));
152 content::RunAllBlockingPoolTasksUntilIdle(); 152 content::RunAllBlockingPoolTasksUntilIdle();
153 153
154 // Notified because 'available offline' status of the existing file changes. 154 // Notified because 'available offline' status of the existing file changes.
155 EXPECT_EQ(1U, observer()->get_changed_files().size()); 155 EXPECT_EQ(1U, delegate()->get_changed_files().size());
156 EXPECT_TRUE(observer()->get_changed_files().count(file_in_root)); 156 EXPECT_TRUE(delegate()->get_changed_files().count(file_in_root));
157 157
158 EXPECT_EQ(FILE_ERROR_OK, error); 158 EXPECT_EQ(FILE_ERROR_OK, error);
159 ASSERT_TRUE(base::PathExists(file_path)); 159 ASSERT_TRUE(base::PathExists(file_path));
160 int64 local_file_size; 160 int64 local_file_size;
161 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size)); 161 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size));
162 EXPECT_EQ(file_size, local_file_size); 162 EXPECT_EQ(file_size, local_file_size);
163 163
164 ASSERT_FALSE(close_callback.is_null()); 164 ASSERT_FALSE(close_callback.is_null());
165 close_callback.Run(); 165 close_callback.Run();
166 EXPECT_EQ(1U, observer()->updated_local_ids().count(src_entry.local_id())); 166 EXPECT_EQ(1U, delegate()->updated_local_ids().count(src_entry.local_id()));
167 167
168 ResourceEntry result_entry; 168 ResourceEntry result_entry;
169 EXPECT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &result_entry)); 169 EXPECT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &result_entry));
170 EXPECT_TRUE(result_entry.file_specific_info().cache_state().is_present()); 170 EXPECT_TRUE(result_entry.file_specific_info().cache_state().is_present());
171 EXPECT_TRUE(result_entry.file_specific_info().cache_state().is_dirty()); 171 EXPECT_TRUE(result_entry.file_specific_info().cache_state().is_dirty());
172 } 172 }
173 173
174 TEST_F(OpenFileOperationTest, OpenOrCreateNonExistingFile) { 174 TEST_F(OpenFileOperationTest, OpenOrCreateNonExistingFile) {
175 const base::FilePath file_in_root( 175 const base::FilePath file_in_root(
176 FILE_PATH_LITERAL("drive/root/not-exist.txt")); 176 FILE_PATH_LITERAL("drive/root/not-exist.txt"));
(...skipping 11 matching lines...) Expand all
188 188
189 EXPECT_EQ(FILE_ERROR_OK, error); 189 EXPECT_EQ(FILE_ERROR_OK, error);
190 ASSERT_TRUE(base::PathExists(file_path)); 190 ASSERT_TRUE(base::PathExists(file_path));
191 int64 local_file_size; 191 int64 local_file_size;
192 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size)); 192 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size));
193 EXPECT_EQ(0, local_file_size); // Should be an empty file. 193 EXPECT_EQ(0, local_file_size); // Should be an empty file.
194 194
195 ASSERT_FALSE(close_callback.is_null()); 195 ASSERT_FALSE(close_callback.is_null());
196 close_callback.Run(); 196 close_callback.Run();
197 EXPECT_EQ(1U, 197 EXPECT_EQ(1U,
198 observer()->updated_local_ids().count(GetLocalId(file_in_root))); 198 delegate()->updated_local_ids().count(GetLocalId(file_in_root)));
199 } 199 }
200 200
201 TEST_F(OpenFileOperationTest, OpenFileTwice) { 201 TEST_F(OpenFileOperationTest, OpenFileTwice) {
202 const base::FilePath file_in_root( 202 const base::FilePath file_in_root(
203 FILE_PATH_LITERAL("drive/root/File 1.txt")); 203 FILE_PATH_LITERAL("drive/root/File 1.txt"));
204 ResourceEntry src_entry; 204 ResourceEntry src_entry;
205 ASSERT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &src_entry)); 205 ASSERT_EQ(FILE_ERROR_OK, GetLocalResourceEntry(file_in_root, &src_entry));
206 const int64 file_size = src_entry.file_info().size(); 206 const int64 file_size = src_entry.file_info().size();
207 207
208 FileError error = FILE_ERROR_FAILED; 208 FileError error = FILE_ERROR_FAILED;
(...skipping 29 matching lines...) Expand all
238 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size)); 238 ASSERT_TRUE(base::GetFileSize(file_path, &local_file_size));
239 EXPECT_EQ(file_size, local_file_size); 239 EXPECT_EQ(file_size, local_file_size);
240 240
241 ASSERT_FALSE(close_callback.is_null()); 241 ASSERT_FALSE(close_callback.is_null());
242 ASSERT_FALSE(close_callback2.is_null()); 242 ASSERT_FALSE(close_callback2.is_null());
243 243
244 close_callback.Run(); 244 close_callback.Run();
245 245
246 // There still remains a client opening the file, so it shouldn't be 246 // There still remains a client opening the file, so it shouldn't be
247 // uploaded yet. 247 // uploaded yet.
248 EXPECT_TRUE(observer()->updated_local_ids().empty()); 248 EXPECT_TRUE(delegate()->updated_local_ids().empty());
249 249
250 close_callback2.Run(); 250 close_callback2.Run();
251 251
252 // Here, all the clients close the file, so it should be uploaded then. 252 // Here, all the clients close the file, so it should be uploaded then.
253 EXPECT_EQ(1U, observer()->updated_local_ids().count(src_entry.local_id())); 253 EXPECT_EQ(1U, delegate()->updated_local_ids().count(src_entry.local_id()));
254 } 254 }
255 255
256 } // namespace file_system 256 } // namespace file_system
257 } // namespace drive 257 } // namespace drive
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698