Index: content/browser/loader/resource_dispatcher_host_unittest.cc |
=================================================================== |
--- content/browser/loader/resource_dispatcher_host_unittest.cc (revision 271040) |
+++ content/browser/loader/resource_dispatcher_host_unittest.cc (working copy) |
@@ -78,9 +78,8 @@ |
void GenerateIPCMessage( |
scoped_refptr<ResourceMessageFilter> filter, |
scoped_ptr<IPC::Message> message) { |
- bool msg_is_ok; |
ResourceDispatcherHostImpl::Get()->OnMessageReceived( |
- *message, filter.get(), &msg_is_ok); |
+ *message, filter.get()); |
} |
// On Windows, ResourceMsg_SetDataBuffer supplies a HANDLE which is not |
@@ -927,8 +926,7 @@ |
ResourceHostMsg_Request request = |
CreateResourceRequest("GET", type, url); |
ResourceHostMsg_RequestResource msg(render_view_id, request_id, request); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter, &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter); |
KickOffRequest(); |
} |
@@ -1068,8 +1066,7 @@ |
// Finish the redirection |
ResourceHostMsg_FollowRedirect redirect_msg(5); |
- bool msg_was_ok; |
- host_.OnMessageReceived(redirect_msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg, filter_.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// flush all the pending requests |
@@ -1195,11 +1192,10 @@ |
ResourceHostMsg_Request request_ping = CreateResourceRequest( |
"GET", ResourceType::PING, net::URLRequestTestJob::test_url_3()); |
- bool msg_was_ok; |
ResourceHostMsg_RequestResource msg_prefetch(0, 1, request_prefetch); |
- host_.OnMessageReceived(msg_prefetch, filter_, &msg_was_ok); |
+ host_.OnMessageReceived(msg_prefetch, filter_); |
ResourceHostMsg_RequestResource msg_ping(0, 2, request_ping); |
- host_.OnMessageReceived(msg_ping, filter_, &msg_was_ok); |
+ host_.OnMessageReceived(msg_ping, filter_); |
// Remove the filter before processing the requests by simulating channel |
// closure. |
@@ -1247,8 +1243,7 @@ |
net::URLRequestTestJob::test_url_redirect_to_url_2()); |
ResourceHostMsg_RequestResource msg(0, 1, request); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_, &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_); |
// Remove the filter before processing the request by simulating channel |
// closure. |
@@ -2123,8 +2118,7 @@ |
// And now simulate a cancellation coming from the renderer. |
ResourceHostMsg_CancelRequest msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
// Since the request had already started processing as a download, |
// the cancellation above should have been ignored and the request |
@@ -2159,8 +2153,7 @@ |
// And now simulate a cancellation coming from the renderer. |
ResourceHostMsg_CancelRequest msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
// Since the request had already started processing as a download, |
// the cancellation above should have been ignored and the request |
@@ -2228,8 +2221,7 @@ |
// And now simulate a cancellation coming from the renderer. |
ResourceHostMsg_CancelRequest msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
// Since the request is marked as being transferred, |
// the cancellation above should have been ignored and the request |
@@ -2279,8 +2271,7 @@ |
"Content-Type: text/html\n\n", |
kResponseBody); |
ResourceHostMsg_FollowRedirect redirect_msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(redirect_msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg, filter_.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Flush all the pending requests to get the response through the |
@@ -2304,8 +2295,7 @@ |
ResourceHostMsg_RequestResource transfer_request_msg( |
new_render_view_id, new_request_id, request); |
- host_.OnMessageReceived( |
- transfer_request_msg, second_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(transfer_request_msg, second_filter.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Check generated messages. |
@@ -2354,8 +2344,7 @@ |
"Content-Type: text/plain\n\n", |
kResponseBody); |
ResourceHostMsg_FollowRedirect redirect_msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(redirect_msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg, filter_.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Flush all the pending requests to get the response through the |
@@ -2379,8 +2368,7 @@ |
ResourceHostMsg_RequestResource transfer_request_msg( |
new_render_view_id, new_request_id, request); |
- host_.OnMessageReceived( |
- transfer_request_msg, second_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(transfer_request_msg, second_filter.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Check generated messages. |
@@ -2426,9 +2414,7 @@ |
ResourceHostMsg_RequestResource first_request_msg( |
render_view_id, request_id, first_request); |
- bool msg_was_ok; |
- host_.OnMessageReceived( |
- first_request_msg, first_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(first_request_msg, first_filter.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Now that we're blocked on the redirect, update the response and unblock |
@@ -2437,7 +2423,7 @@ |
"Content-Type: text/html\n\n", |
kResponseBody); |
ResourceHostMsg_FollowRedirect redirect_msg(request_id); |
- host_.OnMessageReceived(redirect_msg, first_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg, first_filter.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Flush all the pending requests to get the response through the |
@@ -2468,9 +2454,7 @@ |
child_ids_.insert(second_filter->child_id()); |
ResourceHostMsg_RequestResource transfer_request_msg( |
new_render_view_id, new_request_id, request); |
- bool msg_was_ok; |
- host_.OnMessageReceived( |
- transfer_request_msg, second_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(transfer_request_msg, second_filter.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Check generated messages. |
@@ -2511,8 +2495,7 @@ |
SetResponse("HTTP/1.1 302 Found\n" |
"Location: http://other.com/blerg\n\n"); |
ResourceHostMsg_FollowRedirect redirect_msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(redirect_msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg, filter_.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Now that we're blocked on the second redirect, update the response and |
@@ -2524,7 +2507,7 @@ |
"Content-Type: text/plain\n\n", |
kResponseBody); |
ResourceHostMsg_FollowRedirect redirect_msg2(request_id); |
- host_.OnMessageReceived(redirect_msg2, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(redirect_msg2, filter_.get()); |
base::MessageLoop::current()->RunUntilIdle(); |
// Flush all the pending requests to get the response through the |
@@ -2550,8 +2533,7 @@ |
child_ids_.insert(second_filter->child_id()); |
ResourceHostMsg_RequestResource transfer_request_msg( |
new_render_view_id, new_request_id, request); |
- host_.OnMessageReceived( |
- transfer_request_msg, second_filter.get(), &msg_was_ok); |
+ host_.OnMessageReceived(transfer_request_msg, second_filter.get()); |
// Verify that we update the ResourceRequestInfo. |
GlobalRequestID global_request_id(second_filter->child_id(), new_request_id); |
@@ -2649,8 +2631,7 @@ |
// Simulate a cancellation coming from the renderer. |
ResourceHostMsg_CancelRequest msg(request_id); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
EXPECT_EQ(1, host_.pending_requests()); |
@@ -2713,8 +2694,7 @@ |
EXPECT_EQ(ResourceMsg_DataReceived::ID, msgs[0][i].type()); |
ResourceHostMsg_DataReceived_ACK msg(1); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
} |
base::MessageLoop::current()->RunUntilIdle(); |
@@ -2748,8 +2728,7 @@ |
// Send some unexpected ACKs. |
for (size_t i = 0; i < 128; ++i) { |
ResourceHostMsg_DataReceived_ACK msg(1); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
} |
msgs[0].erase(msgs[0].begin()); |
@@ -2767,8 +2746,7 @@ |
EXPECT_EQ(ResourceMsg_DataReceived::ID, msgs[0][i].type()); |
ResourceHostMsg_DataReceived_ACK msg(1); |
- bool msg_was_ok; |
- host_.OnMessageReceived(msg, filter_.get(), &msg_was_ok); |
+ host_.OnMessageReceived(msg, filter_.get()); |
} |
base::MessageLoop::current()->RunUntilIdle(); |
@@ -2804,10 +2782,8 @@ |
filter_->child_id(), file_path)); |
// The child releases from the request. |
- bool msg_was_ok = true; |
ResourceHostMsg_ReleaseDownloadedFile release_msg(kRequestID); |
- host_.OnMessageReceived(release_msg, filter_, &msg_was_ok); |
- ASSERT_TRUE(msg_was_ok); |
+ host_.OnMessageReceived(release_msg, filter_); |
// Still readable because there is another reference to the file. (The child |
// may take additional blob references.) |
@@ -2865,9 +2841,7 @@ |
"GET", ResourceType::SUB_RESOURCE, net::URLRequestTestJob::test_url_1()); |
request.download_to_file = true; |
ResourceHostMsg_RequestResource request_msg(0, 1, request); |
- bool msg_was_ok; |
- host_.OnMessageReceived(request_msg, filter_, &msg_was_ok); |
- ASSERT_TRUE(msg_was_ok); |
+ host_.OnMessageReceived(request_msg, filter_); |
// Running the message loop until idle does not work because |
// RedirectToFileResourceHandler posts things to base::WorkerPool. Instead, |
@@ -2922,8 +2896,7 @@ |
// RunUntilIdle doesn't work because base::WorkerPool is involved. |
ShareableFileReleaseWaiter waiter(response_head.download_file_path); |
ResourceHostMsg_ReleaseDownloadedFile release_msg(1); |
- host_.OnMessageReceived(release_msg, filter_, &msg_was_ok); |
- ASSERT_TRUE(msg_was_ok); |
+ host_.OnMessageReceived(release_msg, filter_); |
waiter.Wait(); |
// The release callback runs before the delete is scheduled, so pump the |
// message loop for the delete itself. (This relies on the delete happening on |