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

Side by Side Diff: webkit/glue/resource_request_body_unittest.cc

Issue 11778016: net: Stop using base::WorkerPool from UploadFileElementReader (Closed) Base URL: http://git.chromium.org/chromium/src.git@master
Patch Set: _ Created 7 years, 11 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
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "webkit/glue/resource_request_body.h" 5 #include "webkit/glue/resource_request_body.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 8
9 #include "base/file_path.h" 9 #include "base/file_path.h"
10 #include "base/file_util.h" 10 #include "base/file_util.h"
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
61 const uint64 kFileLength = 100U; 61 const uint64 kFileLength = 100U;
62 const base::Time kFileTime = base::Time::FromDoubleT(999); 62 const base::Time kFileTime = base::Time::FromDoubleT(999);
63 const int64 kIdentifier = 12345; 63 const int64 kIdentifier = 12345;
64 64
65 request_body->AppendBytes(kData, arraysize(kData) - 1); 65 request_body->AppendBytes(kData, arraysize(kData) - 1);
66 request_body->AppendFileRange(FilePath(kFilePath), 66 request_body->AppendFileRange(FilePath(kFilePath),
67 kFileOffset, kFileLength, kFileTime); 67 kFileOffset, kFileLength, kFileTime);
68 request_body->set_identifier(kIdentifier); 68 request_body->set_identifier(kIdentifier);
69 69
70 scoped_ptr<net::UploadDataStream> upload( 70 scoped_ptr<net::UploadDataStream> upload(
71 request_body->ResolveElementsAndCreateUploadDataStream(NULL)); 71 request_body->ResolveElementsAndCreateUploadDataStream(NULL, NULL));
72 72
73 EXPECT_EQ(kIdentifier, upload->identifier()); 73 EXPECT_EQ(kIdentifier, upload->identifier());
74 ASSERT_EQ(request_body->elements()->size(), upload->element_readers().size()); 74 ASSERT_EQ(request_body->elements()->size(), upload->element_readers().size());
75 75
76 const net::UploadBytesElementReader* r1 = 76 const net::UploadBytesElementReader* r1 =
77 upload->element_readers()[0]->AsBytesReader(); 77 upload->element_readers()[0]->AsBytesReader();
78 ASSERT_TRUE(r1); 78 ASSERT_TRUE(r1);
79 EXPECT_EQ(kData, std::string(r1->bytes(), r1->length())); 79 EXPECT_EQ(kData, std::string(r1->bytes(), r1->length()));
80 80
81 const net::UploadFileElementReader* r2 = 81 const net::UploadFileElementReader* r2 =
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
132 // Test no blob reference. 132 // Test no blob reference.
133 scoped_refptr<ResourceRequestBody> request_body(new ResourceRequestBody()); 133 scoped_refptr<ResourceRequestBody> request_body(new ResourceRequestBody());
134 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length()); 134 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length());
135 request_body->AppendFileRange(upload_element2.path(), 135 request_body->AppendFileRange(upload_element2.path(),
136 upload_element2.offset(), 136 upload_element2.offset(),
137 upload_element2.length(), 137 upload_element2.length(),
138 upload_element2.expected_modification_time()); 138 upload_element2.expected_modification_time());
139 139
140 scoped_ptr<net::UploadDataStream> upload( 140 scoped_ptr<net::UploadDataStream> upload(
141 request_body->ResolveElementsAndCreateUploadDataStream( 141 request_body->ResolveElementsAndCreateUploadDataStream(
142 &blob_storage_controller)); 142 &blob_storage_controller, NULL));
143 143
144 ASSERT_EQ(2U, upload->element_readers().size()); 144 ASSERT_EQ(2U, upload->element_readers().size());
145 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1)); 145 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1));
146 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], upload_element2)); 146 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], upload_element2));
147 147
148 // Test having only one blob reference that refers to empty blob data. 148 // Test having only one blob reference that refers to empty blob data.
149 request_body = new ResourceRequestBody(); 149 request_body = new ResourceRequestBody();
150 request_body->AppendBlob(blob_url0); 150 request_body->AppendBlob(blob_url0);
151 151
152 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 152 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
153 &blob_storage_controller)); 153 &blob_storage_controller, NULL));
154 ASSERT_EQ(0U, upload->element_readers().size()); 154 ASSERT_EQ(0U, upload->element_readers().size());
155 155
156 // Test having only one blob reference. 156 // Test having only one blob reference.
157 request_body = new ResourceRequestBody(); 157 request_body = new ResourceRequestBody();
158 request_body->AppendBlob(blob_url1); 158 request_body->AppendBlob(blob_url1);
159 159
160 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 160 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
161 &blob_storage_controller)); 161 &blob_storage_controller, NULL));
162 ASSERT_EQ(2U, upload->element_readers().size()); 162 ASSERT_EQ(2U, upload->element_readers().size());
163 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1)); 163 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1));
164 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2)); 164 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2));
165 165
166 // Test having one blob reference at the beginning. 166 // Test having one blob reference at the beginning.
167 request_body = new ResourceRequestBody(); 167 request_body = new ResourceRequestBody();
168 request_body->AppendBlob(blob_url1); 168 request_body->AppendBlob(blob_url1);
169 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length()); 169 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length());
170 request_body->AppendFileRange(upload_element2.path(), 170 request_body->AppendFileRange(upload_element2.path(),
171 upload_element2.offset(), 171 upload_element2.offset(),
172 upload_element2.length(), 172 upload_element2.length(),
173 upload_element2.expected_modification_time()); 173 upload_element2.expected_modification_time());
174 174
175 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 175 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
176 &blob_storage_controller)); 176 &blob_storage_controller, NULL));
177 ASSERT_EQ(4U, upload->element_readers().size()); 177 ASSERT_EQ(4U, upload->element_readers().size());
178 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1)); 178 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1));
179 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2)); 179 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2));
180 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], upload_element1)); 180 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], upload_element1));
181 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], upload_element2)); 181 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], upload_element2));
182 182
183 // Test having one blob reference at the end. 183 // Test having one blob reference at the end.
184 request_body = new ResourceRequestBody(); 184 request_body = new ResourceRequestBody();
185 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length()); 185 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length());
186 request_body->AppendFileRange(upload_element2.path(), 186 request_body->AppendFileRange(upload_element2.path(),
187 upload_element2.offset(), 187 upload_element2.offset(),
188 upload_element2.length(), 188 upload_element2.length(),
189 upload_element2.expected_modification_time()); 189 upload_element2.expected_modification_time());
190 request_body->AppendBlob(blob_url1); 190 request_body->AppendBlob(blob_url1);
191 191
192 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 192 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
193 &blob_storage_controller)); 193 &blob_storage_controller, NULL));
194 ASSERT_EQ(4U, upload->element_readers().size()); 194 ASSERT_EQ(4U, upload->element_readers().size());
195 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1)); 195 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1));
196 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], upload_element2)); 196 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], upload_element2));
197 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], blob_element1)); 197 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], blob_element1));
198 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], blob_element2)); 198 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], blob_element2));
199 199
200 // Test having one blob reference in the middle. 200 // Test having one blob reference in the middle.
201 request_body = new ResourceRequestBody(); 201 request_body = new ResourceRequestBody();
202 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length()); 202 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length());
203 request_body->AppendBlob(blob_url1); 203 request_body->AppendBlob(blob_url1);
204 request_body->AppendFileRange(upload_element2.path(), 204 request_body->AppendFileRange(upload_element2.path(),
205 upload_element2.offset(), 205 upload_element2.offset(),
206 upload_element2.length(), 206 upload_element2.length(),
207 upload_element2.expected_modification_time()); 207 upload_element2.expected_modification_time());
208 208
209 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 209 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
210 &blob_storage_controller)); 210 &blob_storage_controller, NULL));
211 ASSERT_EQ(4U, upload->element_readers().size()); 211 ASSERT_EQ(4U, upload->element_readers().size());
212 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1)); 212 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], upload_element1));
213 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element1)); 213 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element1));
214 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], blob_element2)); 214 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], blob_element2));
215 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], upload_element2)); 215 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], upload_element2));
216 216
217 // Test having multiple blob references. 217 // Test having multiple blob references.
218 request_body = new ResourceRequestBody(); 218 request_body = new ResourceRequestBody();
219 request_body->AppendBlob(blob_url1); 219 request_body->AppendBlob(blob_url1);
220 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length()); 220 request_body->AppendBytes(upload_element1.bytes(), upload_element1.length());
221 request_body->AppendBlob(blob_url2); 221 request_body->AppendBlob(blob_url2);
222 request_body->AppendBlob(blob_url3); 222 request_body->AppendBlob(blob_url3);
223 request_body->AppendFileRange(upload_element2.path(), 223 request_body->AppendFileRange(upload_element2.path(),
224 upload_element2.offset(), 224 upload_element2.offset(),
225 upload_element2.length(), 225 upload_element2.length(),
226 upload_element2.expected_modification_time()); 226 upload_element2.expected_modification_time());
227 227
228 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream( 228 upload.reset(request_body->ResolveElementsAndCreateUploadDataStream(
229 &blob_storage_controller)); 229 &blob_storage_controller, NULL));
230 ASSERT_EQ(8U, upload->element_readers().size()); 230 ASSERT_EQ(8U, upload->element_readers().size());
231 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1)); 231 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[0], blob_element1));
232 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2)); 232 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[1], blob_element2));
233 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], upload_element1)); 233 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[2], upload_element1));
234 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], blob_element1)); 234 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[3], blob_element1));
235 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[4], blob_element2)); 235 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[4], blob_element2));
236 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[5], blob_element1)); 236 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[5], blob_element1));
237 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[6], blob_element2)); 237 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[6], blob_element2));
238 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[7], upload_element2)); 238 EXPECT_TRUE(AreElementsEqual(*upload->element_readers()[7], upload_element2));
239 } 239 }
240 240
241 } // namespace webkit_glue 241 } // namespace webkit_glue
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698