OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "modules/fetch/FetchDataLoader.h" | 5 #include "modules/fetch/FetchDataLoader.h" |
6 | 6 |
7 #include "modules/fetch/DataConsumerHandleTestUtil.h" | 7 #include "modules/fetch/DataConsumerHandleTestUtil.h" |
8 #include "testing/gmock/include/gmock/gmock.h" | 8 #include "testing/gmock/include/gmock/gmock.h" |
9 #include "testing/gtest/include/gtest/gtest.h" | 9 #include "testing/gtest/include/gtest/gtest.h" |
10 #include <memory> | |
11 | 10 |
12 namespace blink { | 11 namespace blink { |
13 | 12 |
14 namespace { | 13 namespace { |
15 | 14 |
16 using ::testing::InSequence; | 15 using ::testing::InSequence; |
17 using ::testing::Return; | 16 using ::testing::Return; |
18 using ::testing::DoAll; | 17 using ::testing::DoAll; |
19 using ::testing::StrictMock; | 18 using ::testing::StrictMock; |
20 using ::testing::_; | 19 using ::testing::_; |
(...skipping 12 matching lines...) Expand all Loading... |
33 | 32 |
34 const char kQuickBrownFox[] = "Quick brown fox"; | 33 const char kQuickBrownFox[] = "Quick brown fox"; |
35 const size_t kQuickBrownFoxLength = 15; | 34 const size_t kQuickBrownFoxLength = 15; |
36 const size_t kQuickBrownFoxLengthWithTerminatingNull = 16; | 35 const size_t kQuickBrownFoxLengthWithTerminatingNull = 16; |
37 | 36 |
38 TEST(FetchDataLoaderTest, LoadAsBlob) | 37 TEST(FetchDataLoaderTest, LoadAsBlob) |
39 { | 38 { |
40 WebDataConsumerHandle::Client *client = nullptr; | 39 WebDataConsumerHandle::Client *client = nullptr; |
41 Checkpoint checkpoint; | 40 Checkpoint checkpoint; |
42 | 41 |
43 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 42 OwnPtr<MockHandle> handle = MockHandle::create(); |
44 std::unique_ptr<MockReader> reader = MockReader::create(); | 43 OwnPtr<MockReader> reader = MockReader::create(); |
45 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); | 44 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); |
46 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 45 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
47 RefPtr<BlobDataHandle> blobDataHandle; | 46 RefPtr<BlobDataHandle> blobDataHandle; |
48 | 47 |
49 InSequence s; | 48 InSequence s; |
50 EXPECT_CALL(checkpoint, Call(1)); | 49 EXPECT_CALL(checkpoint, Call(1)); |
51 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 50 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
52 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); | 51 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); |
53 EXPECT_CALL(checkpoint, Call(2)); | 52 EXPECT_CALL(checkpoint, Call(2)); |
54 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); | 53 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); |
55 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); | 54 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); |
56 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); | 55 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); |
57 EXPECT_CALL(*reader, destruct()); | 56 EXPECT_CALL(*reader, destruct()); |
58 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); | 57 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); |
59 EXPECT_CALL(checkpoint, Call(3)); | 58 EXPECT_CALL(checkpoint, Call(3)); |
60 EXPECT_CALL(checkpoint, Call(4)); | 59 EXPECT_CALL(checkpoint, Call(4)); |
61 | 60 |
62 // |reader| is adopted by |obtainReader|. | 61 // |reader| is adopted by |obtainReader|. |
63 ASSERT_TRUE(reader.release()); | 62 ASSERT_TRUE(reader.leakPtr()); |
64 | 63 |
65 checkpoint.Call(1); | 64 checkpoint.Call(1); |
66 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 65 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
67 checkpoint.Call(2); | 66 checkpoint.Call(2); |
68 ASSERT_TRUE(client); | 67 ASSERT_TRUE(client); |
69 client->didGetReadable(); | 68 client->didGetReadable(); |
70 checkpoint.Call(3); | 69 checkpoint.Call(3); |
71 fetchDataLoader->cancel(); | 70 fetchDataLoader->cancel(); |
72 checkpoint.Call(4); | 71 checkpoint.Call(4); |
73 | 72 |
74 ASSERT_TRUE(blobDataHandle); | 73 ASSERT_TRUE(blobDataHandle); |
75 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); | 74 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); |
76 EXPECT_EQ(String("text/test"), blobDataHandle->type()); | 75 EXPECT_EQ(String("text/test"), blobDataHandle->type()); |
77 } | 76 } |
78 | 77 |
79 TEST(FetchDataLoaderTest, LoadAsBlobFailed) | 78 TEST(FetchDataLoaderTest, LoadAsBlobFailed) |
80 { | 79 { |
81 WebDataConsumerHandle::Client *client = nullptr; | 80 WebDataConsumerHandle::Client *client = nullptr; |
82 Checkpoint checkpoint; | 81 Checkpoint checkpoint; |
83 | 82 |
84 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 83 OwnPtr<MockHandle> handle = MockHandle::create(); |
85 std::unique_ptr<MockReader> reader = MockReader::create(); | 84 OwnPtr<MockReader> reader = MockReader::create(); |
86 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); | 85 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); |
87 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 86 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
88 | 87 |
89 InSequence s; | 88 InSequence s; |
90 EXPECT_CALL(checkpoint, Call(1)); | 89 EXPECT_CALL(checkpoint, Call(1)); |
91 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 90 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
92 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); | 91 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); |
93 EXPECT_CALL(checkpoint, Call(2)); | 92 EXPECT_CALL(checkpoint, Call(2)); |
94 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); | 93 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); |
95 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); | 94 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); |
96 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); | 95 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); |
97 EXPECT_CALL(*reader, destruct()); | 96 EXPECT_CALL(*reader, destruct()); |
98 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); | 97 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); |
99 EXPECT_CALL(checkpoint, Call(3)); | 98 EXPECT_CALL(checkpoint, Call(3)); |
100 EXPECT_CALL(checkpoint, Call(4)); | 99 EXPECT_CALL(checkpoint, Call(4)); |
101 | 100 |
102 // |reader| is adopted by |obtainReader|. | 101 // |reader| is adopted by |obtainReader|. |
103 ASSERT_TRUE(reader.release()); | 102 ASSERT_TRUE(reader.leakPtr()); |
104 | 103 |
105 checkpoint.Call(1); | 104 checkpoint.Call(1); |
106 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 105 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
107 checkpoint.Call(2); | 106 checkpoint.Call(2); |
108 ASSERT_TRUE(client); | 107 ASSERT_TRUE(client); |
109 client->didGetReadable(); | 108 client->didGetReadable(); |
110 checkpoint.Call(3); | 109 checkpoint.Call(3); |
111 fetchDataLoader->cancel(); | 110 fetchDataLoader->cancel(); |
112 checkpoint.Call(4); | 111 checkpoint.Call(4); |
113 } | 112 } |
114 | 113 |
115 TEST(FetchDataLoaderTest, LoadAsBlobCancel) | 114 TEST(FetchDataLoaderTest, LoadAsBlobCancel) |
116 { | 115 { |
117 Checkpoint checkpoint; | 116 Checkpoint checkpoint; |
118 | 117 |
119 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 118 OwnPtr<MockHandle> handle = MockHandle::create(); |
120 std::unique_ptr<MockReader> reader = MockReader::create(); | 119 OwnPtr<MockReader> reader = MockReader::create(); |
121 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); | 120 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); |
122 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 121 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
123 | 122 |
124 InSequence s; | 123 InSequence s; |
125 EXPECT_CALL(checkpoint, Call(1)); | 124 EXPECT_CALL(checkpoint, Call(1)); |
126 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; | 125 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; |
127 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); | 126 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(nullptr)); |
128 EXPECT_CALL(checkpoint, Call(2)); | 127 EXPECT_CALL(checkpoint, Call(2)); |
129 EXPECT_CALL(*reader, destruct()); | 128 EXPECT_CALL(*reader, destruct()); |
130 EXPECT_CALL(checkpoint, Call(3)); | 129 EXPECT_CALL(checkpoint, Call(3)); |
131 | 130 |
132 // |reader| is adopted by |obtainReader|. | 131 // |reader| is adopted by |obtainReader|. |
133 ASSERT_TRUE(reader.release()); | 132 ASSERT_TRUE(reader.leakPtr()); |
134 | 133 |
135 checkpoint.Call(1); | 134 checkpoint.Call(1); |
136 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 135 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
137 checkpoint.Call(2); | 136 checkpoint.Call(2); |
138 fetchDataLoader->cancel(); | 137 fetchDataLoader->cancel(); |
139 checkpoint.Call(3); | 138 checkpoint.Call(3); |
140 } | 139 } |
141 | 140 |
142 TEST(FetchDataLoaderTest, LoadAsBlobViaDrainAsBlobDataHandleWithSameContentType) | 141 TEST(FetchDataLoaderTest, LoadAsBlobViaDrainAsBlobDataHandleWithSameContentType) |
143 { | 142 { |
144 std::unique_ptr<BlobData> blobData = BlobData::create(); | 143 OwnPtr<BlobData> blobData = BlobData::create(); |
145 blobData->appendBytes(kQuickBrownFox, kQuickBrownFoxLengthWithTerminatingNul
l); | 144 blobData->appendBytes(kQuickBrownFox, kQuickBrownFoxLengthWithTerminatingNul
l); |
146 blobData->setContentType("text/test"); | 145 blobData->setContentType("text/test"); |
147 RefPtr<BlobDataHandle> inputBlobDataHandle = BlobDataHandle::create(std::mov
e(blobData), kQuickBrownFoxLengthWithTerminatingNull); | 146 RefPtr<BlobDataHandle> inputBlobDataHandle = BlobDataHandle::create(std::mov
e(blobData), kQuickBrownFoxLengthWithTerminatingNull); |
148 | 147 |
149 Checkpoint checkpoint; | 148 Checkpoint checkpoint; |
150 | 149 |
151 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 150 OwnPtr<MockHandle> handle = MockHandle::create(); |
152 std::unique_ptr<MockReader> reader = MockReader::create(); | 151 OwnPtr<MockReader> reader = MockReader::create(); |
153 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); | 152 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); |
154 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 153 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
155 RefPtr<BlobDataHandle> blobDataHandle; | 154 RefPtr<BlobDataHandle> blobDataHandle; |
156 | 155 |
157 InSequence s; | 156 InSequence s; |
158 EXPECT_CALL(checkpoint, Call(1)); | 157 EXPECT_CALL(checkpoint, Call(1)); |
159 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; | 158 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; |
160 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(inputBlobDataHandle)); | 159 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(inputBlobDataHandle)); |
161 EXPECT_CALL(*reader, destruct()); | 160 EXPECT_CALL(*reader, destruct()); |
162 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); | 161 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); |
163 EXPECT_CALL(checkpoint, Call(2)); | 162 EXPECT_CALL(checkpoint, Call(2)); |
164 EXPECT_CALL(checkpoint, Call(3)); | 163 EXPECT_CALL(checkpoint, Call(3)); |
165 | 164 |
166 // |reader| is adopted by |obtainReader|. | 165 // |reader| is adopted by |obtainReader|. |
167 ASSERT_TRUE(reader.release()); | 166 ASSERT_TRUE(reader.leakPtr()); |
168 | 167 |
169 checkpoint.Call(1); | 168 checkpoint.Call(1); |
170 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 169 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
171 checkpoint.Call(2); | 170 checkpoint.Call(2); |
172 fetchDataLoader->cancel(); | 171 fetchDataLoader->cancel(); |
173 checkpoint.Call(3); | 172 checkpoint.Call(3); |
174 | 173 |
175 ASSERT_TRUE(blobDataHandle); | 174 ASSERT_TRUE(blobDataHandle); |
176 EXPECT_EQ(inputBlobDataHandle, blobDataHandle); | 175 EXPECT_EQ(inputBlobDataHandle, blobDataHandle); |
177 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); | 176 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); |
178 EXPECT_EQ(String("text/test"), blobDataHandle->type()); | 177 EXPECT_EQ(String("text/test"), blobDataHandle->type()); |
179 } | 178 } |
180 | 179 |
181 TEST(FetchDataLoaderTest, LoadAsBlobViaDrainAsBlobDataHandleWithDifferentContent
Type) | 180 TEST(FetchDataLoaderTest, LoadAsBlobViaDrainAsBlobDataHandleWithDifferentContent
Type) |
182 { | 181 { |
183 std::unique_ptr<BlobData> blobData = BlobData::create(); | 182 OwnPtr<BlobData> blobData = BlobData::create(); |
184 blobData->appendBytes(kQuickBrownFox, kQuickBrownFoxLengthWithTerminatingNul
l); | 183 blobData->appendBytes(kQuickBrownFox, kQuickBrownFoxLengthWithTerminatingNul
l); |
185 blobData->setContentType("text/different"); | 184 blobData->setContentType("text/different"); |
186 RefPtr<BlobDataHandle> inputBlobDataHandle = BlobDataHandle::create(std::mov
e(blobData), kQuickBrownFoxLengthWithTerminatingNull); | 185 RefPtr<BlobDataHandle> inputBlobDataHandle = BlobDataHandle::create(std::mov
e(blobData), kQuickBrownFoxLengthWithTerminatingNull); |
187 | 186 |
188 Checkpoint checkpoint; | 187 Checkpoint checkpoint; |
189 | 188 |
190 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 189 OwnPtr<MockHandle> handle = MockHandle::create(); |
191 std::unique_ptr<MockReader> reader = MockReader::create(); | 190 OwnPtr<MockReader> reader = MockReader::create(); |
192 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); | 191 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsBlobHandle
("text/test"); |
193 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 192 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
194 RefPtr<BlobDataHandle> blobDataHandle; | 193 RefPtr<BlobDataHandle> blobDataHandle; |
195 | 194 |
196 InSequence s; | 195 InSequence s; |
197 EXPECT_CALL(checkpoint, Call(1)); | 196 EXPECT_CALL(checkpoint, Call(1)); |
198 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; | 197 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; |
199 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(inputBlobDataHandle)); | 198 EXPECT_CALL(*reader, drainAsBlobDataHandle(kDisallowBlobWithInvalidSize)).Wi
llOnce(Return(inputBlobDataHandle)); |
200 EXPECT_CALL(*reader, destruct()); | 199 EXPECT_CALL(*reader, destruct()); |
201 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); | 200 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedBlobHandleMock(_)).Wil
lOnce(SaveArg<0>(&blobDataHandle)); |
202 EXPECT_CALL(checkpoint, Call(2)); | 201 EXPECT_CALL(checkpoint, Call(2)); |
203 EXPECT_CALL(checkpoint, Call(3)); | 202 EXPECT_CALL(checkpoint, Call(3)); |
204 | 203 |
205 // |reader| is adopted by |obtainReader|. | 204 // |reader| is adopted by |obtainReader|. |
206 ASSERT_TRUE(reader.release()); | 205 ASSERT_TRUE(reader.leakPtr()); |
207 | 206 |
208 checkpoint.Call(1); | 207 checkpoint.Call(1); |
209 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 208 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
210 checkpoint.Call(2); | 209 checkpoint.Call(2); |
211 fetchDataLoader->cancel(); | 210 fetchDataLoader->cancel(); |
212 checkpoint.Call(3); | 211 checkpoint.Call(3); |
213 | 212 |
214 ASSERT_TRUE(blobDataHandle); | 213 ASSERT_TRUE(blobDataHandle); |
215 EXPECT_NE(inputBlobDataHandle, blobDataHandle); | 214 EXPECT_NE(inputBlobDataHandle, blobDataHandle); |
216 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); | 215 EXPECT_EQ(kQuickBrownFoxLengthWithTerminatingNull, blobDataHandle->size()); |
217 EXPECT_EQ(String("text/test"), blobDataHandle->type()); | 216 EXPECT_EQ(String("text/test"), blobDataHandle->type()); |
218 } | 217 } |
219 | 218 |
220 TEST(FetchDataLoaderTest, LoadAsArrayBuffer) | 219 TEST(FetchDataLoaderTest, LoadAsArrayBuffer) |
221 { | 220 { |
222 WebDataConsumerHandle::Client *client = nullptr; | 221 WebDataConsumerHandle::Client *client = nullptr; |
223 Checkpoint checkpoint; | 222 Checkpoint checkpoint; |
224 | 223 |
225 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 224 OwnPtr<MockHandle> handle = MockHandle::create(); |
226 std::unique_ptr<MockReader> reader = MockReader::create(); | 225 OwnPtr<MockReader> reader = MockReader::create(); |
227 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); | 226 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); |
228 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 227 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
229 DOMArrayBuffer* arrayBuffer = nullptr; | 228 DOMArrayBuffer* arrayBuffer = nullptr; |
230 | 229 |
231 InSequence s; | 230 InSequence s; |
232 EXPECT_CALL(checkpoint, Call(1)); | 231 EXPECT_CALL(checkpoint, Call(1)); |
233 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 232 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
234 EXPECT_CALL(checkpoint, Call(2)); | 233 EXPECT_CALL(checkpoint, Call(2)); |
235 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); | 234 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); |
236 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); | 235 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); |
237 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); | 236 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); |
238 EXPECT_CALL(*reader, destruct()); | 237 EXPECT_CALL(*reader, destruct()); |
239 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedArrayBufferMock(_)).Wi
llOnce(SaveArg<0>(&arrayBuffer)); | 238 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedArrayBufferMock(_)).Wi
llOnce(SaveArg<0>(&arrayBuffer)); |
240 EXPECT_CALL(checkpoint, Call(3)); | 239 EXPECT_CALL(checkpoint, Call(3)); |
241 EXPECT_CALL(checkpoint, Call(4)); | 240 EXPECT_CALL(checkpoint, Call(4)); |
242 | 241 |
243 // |reader| is adopted by |obtainReader|. | 242 // |reader| is adopted by |obtainReader|. |
244 ASSERT_TRUE(reader.release()); | 243 ASSERT_TRUE(reader.leakPtr()); |
245 | 244 |
246 checkpoint.Call(1); | 245 checkpoint.Call(1); |
247 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 246 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
248 checkpoint.Call(2); | 247 checkpoint.Call(2); |
249 ASSERT_TRUE(client); | 248 ASSERT_TRUE(client); |
250 client->didGetReadable(); | 249 client->didGetReadable(); |
251 checkpoint.Call(3); | 250 checkpoint.Call(3); |
252 fetchDataLoader->cancel(); | 251 fetchDataLoader->cancel(); |
253 checkpoint.Call(4); | 252 checkpoint.Call(4); |
254 | 253 |
255 ASSERT_TRUE(arrayBuffer); | 254 ASSERT_TRUE(arrayBuffer); |
256 ASSERT_EQ(kQuickBrownFoxLengthWithTerminatingNull, arrayBuffer->byteLength()
); | 255 ASSERT_EQ(kQuickBrownFoxLengthWithTerminatingNull, arrayBuffer->byteLength()
); |
257 EXPECT_STREQ(kQuickBrownFox, static_cast<const char*>(arrayBuffer->data())); | 256 EXPECT_STREQ(kQuickBrownFox, static_cast<const char*>(arrayBuffer->data())); |
258 } | 257 } |
259 | 258 |
260 TEST(FetchDataLoaderTest, LoadAsArrayBufferFailed) | 259 TEST(FetchDataLoaderTest, LoadAsArrayBufferFailed) |
261 { | 260 { |
262 WebDataConsumerHandle::Client *client = nullptr; | 261 WebDataConsumerHandle::Client *client = nullptr; |
263 Checkpoint checkpoint; | 262 Checkpoint checkpoint; |
264 | 263 |
265 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 264 OwnPtr<MockHandle> handle = MockHandle::create(); |
266 std::unique_ptr<MockReader> reader = MockReader::create(); | 265 OwnPtr<MockReader> reader = MockReader::create(); |
267 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); | 266 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); |
268 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 267 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
269 | 268 |
270 InSequence s; | 269 InSequence s; |
271 EXPECT_CALL(checkpoint, Call(1)); | 270 EXPECT_CALL(checkpoint, Call(1)); |
272 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 271 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
273 EXPECT_CALL(checkpoint, Call(2)); | 272 EXPECT_CALL(checkpoint, Call(2)); |
274 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); | 273 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
hWithTerminatingNull), Return(kOk))); |
275 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); | 274 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); |
276 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); | 275 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); |
277 EXPECT_CALL(*reader, destruct()); | 276 EXPECT_CALL(*reader, destruct()); |
278 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); | 277 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); |
279 EXPECT_CALL(checkpoint, Call(3)); | 278 EXPECT_CALL(checkpoint, Call(3)); |
280 EXPECT_CALL(checkpoint, Call(4)); | 279 EXPECT_CALL(checkpoint, Call(4)); |
281 | 280 |
282 // |reader| is adopted by |obtainReader|. | 281 // |reader| is adopted by |obtainReader|. |
283 ASSERT_TRUE(reader.release()); | 282 ASSERT_TRUE(reader.leakPtr()); |
284 | 283 |
285 checkpoint.Call(1); | 284 checkpoint.Call(1); |
286 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 285 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
287 checkpoint.Call(2); | 286 checkpoint.Call(2); |
288 ASSERT_TRUE(client); | 287 ASSERT_TRUE(client); |
289 client->didGetReadable(); | 288 client->didGetReadable(); |
290 checkpoint.Call(3); | 289 checkpoint.Call(3); |
291 fetchDataLoader->cancel(); | 290 fetchDataLoader->cancel(); |
292 checkpoint.Call(4); | 291 checkpoint.Call(4); |
293 } | 292 } |
294 | 293 |
295 TEST(FetchDataLoaderTest, LoadAsArrayBufferCancel) | 294 TEST(FetchDataLoaderTest, LoadAsArrayBufferCancel) |
296 { | 295 { |
297 Checkpoint checkpoint; | 296 Checkpoint checkpoint; |
298 | 297 |
299 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 298 OwnPtr<MockHandle> handle = MockHandle::create(); |
300 std::unique_ptr<MockReader> reader = MockReader::create(); | 299 OwnPtr<MockReader> reader = MockReader::create(); |
301 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); | 300 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsArrayBuffe
r(); |
302 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 301 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
303 | 302 |
304 InSequence s; | 303 InSequence s; |
305 EXPECT_CALL(checkpoint, Call(1)); | 304 EXPECT_CALL(checkpoint, Call(1)); |
306 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; | 305 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; |
307 EXPECT_CALL(checkpoint, Call(2)); | 306 EXPECT_CALL(checkpoint, Call(2)); |
308 EXPECT_CALL(*reader, destruct()); | 307 EXPECT_CALL(*reader, destruct()); |
309 EXPECT_CALL(checkpoint, Call(3)); | 308 EXPECT_CALL(checkpoint, Call(3)); |
310 | 309 |
311 // |reader| is adopted by |obtainReader|. | 310 // |reader| is adopted by |obtainReader|. |
312 ASSERT_TRUE(reader.release()); | 311 ASSERT_TRUE(reader.leakPtr()); |
313 | 312 |
314 checkpoint.Call(1); | 313 checkpoint.Call(1); |
315 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 314 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
316 checkpoint.Call(2); | 315 checkpoint.Call(2); |
317 fetchDataLoader->cancel(); | 316 fetchDataLoader->cancel(); |
318 checkpoint.Call(3); | 317 checkpoint.Call(3); |
319 } | 318 } |
320 | 319 |
321 TEST(FetchDataLoaderTest, LoadAsString) | 320 TEST(FetchDataLoaderTest, LoadAsString) |
322 { | 321 { |
323 WebDataConsumerHandle::Client *client = nullptr; | 322 WebDataConsumerHandle::Client *client = nullptr; |
324 Checkpoint checkpoint; | 323 Checkpoint checkpoint; |
325 | 324 |
326 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 325 OwnPtr<MockHandle> handle = MockHandle::create(); |
327 std::unique_ptr<MockReader> reader = MockReader::create(); | 326 OwnPtr<MockReader> reader = MockReader::create(); |
328 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); | 327 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); |
329 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 328 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
330 | 329 |
331 InSequence s; | 330 InSequence s; |
332 EXPECT_CALL(checkpoint, Call(1)); | 331 EXPECT_CALL(checkpoint, Call(1)); |
333 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 332 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
334 EXPECT_CALL(checkpoint, Call(2)); | 333 EXPECT_CALL(checkpoint, Call(2)); |
335 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
h), Return(kOk))); | 334 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
h), Return(kOk))); |
336 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLength)).WillOnce(Return(kOk)); | 335 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLength)).WillOnce(Return(kOk)); |
337 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); | 336 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); |
338 EXPECT_CALL(*reader, destruct()); | 337 EXPECT_CALL(*reader, destruct()); |
339 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedString(String(kQuickBr
ownFox))); | 338 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedString(String(kQuickBr
ownFox))); |
340 EXPECT_CALL(checkpoint, Call(3)); | 339 EXPECT_CALL(checkpoint, Call(3)); |
341 EXPECT_CALL(checkpoint, Call(4)); | 340 EXPECT_CALL(checkpoint, Call(4)); |
342 | 341 |
343 // |reader| is adopted by |obtainReader|. | 342 // |reader| is adopted by |obtainReader|. |
344 ASSERT_TRUE(reader.release()); | 343 ASSERT_TRUE(reader.leakPtr()); |
345 | 344 |
346 checkpoint.Call(1); | 345 checkpoint.Call(1); |
347 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 346 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
348 checkpoint.Call(2); | 347 checkpoint.Call(2); |
349 ASSERT_TRUE(client); | 348 ASSERT_TRUE(client); |
350 client->didGetReadable(); | 349 client->didGetReadable(); |
351 checkpoint.Call(3); | 350 checkpoint.Call(3); |
352 fetchDataLoader->cancel(); | 351 fetchDataLoader->cancel(); |
353 checkpoint.Call(4); | 352 checkpoint.Call(4); |
354 } | 353 } |
355 | 354 |
356 TEST(FetchDataLoaderTest, LoadAsStringWithNullBytes) | 355 TEST(FetchDataLoaderTest, LoadAsStringWithNullBytes) |
357 { | 356 { |
358 WebDataConsumerHandle::Client *client = nullptr; | 357 WebDataConsumerHandle::Client *client = nullptr; |
359 Checkpoint checkpoint; | 358 Checkpoint checkpoint; |
360 | 359 |
361 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 360 OwnPtr<MockHandle> handle = MockHandle::create(); |
362 std::unique_ptr<MockReader> reader = MockReader::create(); | 361 OwnPtr<MockReader> reader = MockReader::create(); |
363 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); | 362 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); |
364 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 363 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
365 | 364 |
366 InSequence s; | 365 InSequence s; |
367 EXPECT_CALL(checkpoint, Call(1)); | 366 EXPECT_CALL(checkpoint, Call(1)); |
368 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 367 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
369 EXPECT_CALL(checkpoint, Call(2)); | 368 EXPECT_CALL(checkpoint, Call(2)); |
370 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>("Quick\0brown\0fox")), SetArgPointee<2>(16), Return(kO
k))); | 369 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>("Quick\0brown\0fox")), SetArgPointee<2>(16), Return(kO
k))); |
371 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); | 370 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLengthWithTerminatingNull)).WillO
nce(Return(kOk)); |
372 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); | 371 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kDone)); |
373 EXPECT_CALL(*reader, destruct()); | 372 EXPECT_CALL(*reader, destruct()); |
374 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedString(String("Quick\0
brown\0fox", 16))); | 373 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadedString(String("Quick\0
brown\0fox", 16))); |
375 EXPECT_CALL(checkpoint, Call(3)); | 374 EXPECT_CALL(checkpoint, Call(3)); |
376 EXPECT_CALL(checkpoint, Call(4)); | 375 EXPECT_CALL(checkpoint, Call(4)); |
377 | 376 |
378 // |reader| is adopted by |obtainReader|. | 377 // |reader| is adopted by |obtainReader|. |
379 ASSERT_TRUE(reader.release()); | 378 ASSERT_TRUE(reader.leakPtr()); |
380 | 379 |
381 checkpoint.Call(1); | 380 checkpoint.Call(1); |
382 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 381 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
383 checkpoint.Call(2); | 382 checkpoint.Call(2); |
384 ASSERT_TRUE(client); | 383 ASSERT_TRUE(client); |
385 client->didGetReadable(); | 384 client->didGetReadable(); |
386 checkpoint.Call(3); | 385 checkpoint.Call(3); |
387 fetchDataLoader->cancel(); | 386 fetchDataLoader->cancel(); |
388 checkpoint.Call(4); | 387 checkpoint.Call(4); |
389 } | 388 } |
390 | 389 |
391 TEST(FetchDataLoaderTest, LoadAsStringError) | 390 TEST(FetchDataLoaderTest, LoadAsStringError) |
392 { | 391 { |
393 WebDataConsumerHandle::Client *client = nullptr; | 392 WebDataConsumerHandle::Client *client = nullptr; |
394 Checkpoint checkpoint; | 393 Checkpoint checkpoint; |
395 | 394 |
396 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 395 OwnPtr<MockHandle> handle = MockHandle::create(); |
397 std::unique_ptr<MockReader> reader = MockReader::create(); | 396 OwnPtr<MockReader> reader = MockReader::create(); |
398 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); | 397 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); |
399 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 398 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
400 | 399 |
401 InSequence s; | 400 InSequence s; |
402 EXPECT_CALL(checkpoint, Call(1)); | 401 EXPECT_CALL(checkpoint, Call(1)); |
403 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); | 402 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(DoAll(SaveArg<0>(&cli
ent), Return(reader.get()))); |
404 EXPECT_CALL(checkpoint, Call(2)); | 403 EXPECT_CALL(checkpoint, Call(2)); |
405 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
h), Return(kOk))); | 404 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(DoAll(SetArgPointee<0>
(static_cast<const void*>(kQuickBrownFox)), SetArgPointee<2>(kQuickBrownFoxLengt
h), Return(kOk))); |
406 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLength)).WillOnce(Return(kOk)); | 405 EXPECT_CALL(*reader, endRead(kQuickBrownFoxLength)).WillOnce(Return(kOk)); |
407 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); | 406 EXPECT_CALL(*reader, beginRead(_, kNone, _)).WillOnce(Return(kUnexpectedErro
r)); |
408 EXPECT_CALL(*reader, destruct()); | 407 EXPECT_CALL(*reader, destruct()); |
409 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); | 408 EXPECT_CALL(*fetchDataLoaderClient, didFetchDataLoadFailed()); |
410 EXPECT_CALL(checkpoint, Call(3)); | 409 EXPECT_CALL(checkpoint, Call(3)); |
411 EXPECT_CALL(checkpoint, Call(4)); | 410 EXPECT_CALL(checkpoint, Call(4)); |
412 | 411 |
413 // |reader| is adopted by |obtainReader|. | 412 // |reader| is adopted by |obtainReader|. |
414 ASSERT_TRUE(reader.release()); | 413 ASSERT_TRUE(reader.leakPtr()); |
415 | 414 |
416 checkpoint.Call(1); | 415 checkpoint.Call(1); |
417 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 416 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
418 checkpoint.Call(2); | 417 checkpoint.Call(2); |
419 ASSERT_TRUE(client); | 418 ASSERT_TRUE(client); |
420 client->didGetReadable(); | 419 client->didGetReadable(); |
421 checkpoint.Call(3); | 420 checkpoint.Call(3); |
422 fetchDataLoader->cancel(); | 421 fetchDataLoader->cancel(); |
423 checkpoint.Call(4); | 422 checkpoint.Call(4); |
424 } | 423 } |
425 | 424 |
426 TEST(FetchDataLoaderTest, LoadAsStringCancel) | 425 TEST(FetchDataLoaderTest, LoadAsStringCancel) |
427 { | 426 { |
428 Checkpoint checkpoint; | 427 Checkpoint checkpoint; |
429 | 428 |
430 std::unique_ptr<MockHandle> handle = MockHandle::create(); | 429 OwnPtr<MockHandle> handle = MockHandle::create(); |
431 std::unique_ptr<MockReader> reader = MockReader::create(); | 430 OwnPtr<MockReader> reader = MockReader::create(); |
432 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); | 431 FetchDataLoader* fetchDataLoader = FetchDataLoader::createLoaderAsString(); |
433 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); | 432 MockFetchDataLoaderClient* fetchDataLoaderClient = MockFetchDataLoaderClient
::create(); |
434 | 433 |
435 InSequence s; | 434 InSequence s; |
436 EXPECT_CALL(checkpoint, Call(1)); | 435 EXPECT_CALL(checkpoint, Call(1)); |
437 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; | 436 EXPECT_CALL(*handle, obtainReaderInternal(_)).WillOnce(Return(reader.get()))
; |
438 EXPECT_CALL(checkpoint, Call(2)); | 437 EXPECT_CALL(checkpoint, Call(2)); |
439 EXPECT_CALL(*reader, destruct()); | 438 EXPECT_CALL(*reader, destruct()); |
440 EXPECT_CALL(checkpoint, Call(3)); | 439 EXPECT_CALL(checkpoint, Call(3)); |
441 | 440 |
442 // |reader| is adopted by |obtainReader|. | 441 // |reader| is adopted by |obtainReader|. |
443 ASSERT_TRUE(reader.release()); | 442 ASSERT_TRUE(reader.leakPtr()); |
444 | 443 |
445 checkpoint.Call(1); | 444 checkpoint.Call(1); |
446 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); | 445 fetchDataLoader->start(handle.get(), fetchDataLoaderClient); |
447 checkpoint.Call(2); | 446 checkpoint.Call(2); |
448 fetchDataLoader->cancel(); | 447 fetchDataLoader->cancel(); |
449 checkpoint.Call(3); | 448 checkpoint.Call(3); |
450 } | 449 } |
451 | 450 |
452 } // namespace | 451 } // namespace |
453 | 452 |
454 } // namespace blink | 453 } // namespace blink |
OLD | NEW |