| 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 <map> | 5 #include <map> |
| 6 #include <set> | 6 #include <set> |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/atomic_sequence_num.h" | 9 #include "base/atomic_sequence_num.h" |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 309 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 320 }; | 320 }; |
| 321 | 321 |
| 322 void CheckWorkerProcessMsgCreateWorker( | 322 void CheckWorkerProcessMsgCreateWorker( |
| 323 MockRendererProcessHost* renderer_host, | 323 MockRendererProcessHost* renderer_host, |
| 324 const std::string& expected_url, | 324 const std::string& expected_url, |
| 325 const std::string& expected_name, | 325 const std::string& expected_name, |
| 326 blink::WebContentSecurityPolicyType expected_security_policy_type, | 326 blink::WebContentSecurityPolicyType expected_security_policy_type, |
| 327 int* route_id) { | 327 int* route_id) { |
| 328 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 328 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 329 EXPECT_EQ(WorkerProcessMsg_CreateWorker::ID, msg->type()); | 329 EXPECT_EQ(WorkerProcessMsg_CreateWorker::ID, msg->type()); |
| 330 Tuple<WorkerProcessMsg_CreateWorker_Params> param; | 330 base::Tuple<WorkerProcessMsg_CreateWorker_Params> param; |
| 331 EXPECT_TRUE(WorkerProcessMsg_CreateWorker::Read(msg.get(), ¶m)); | 331 EXPECT_TRUE(WorkerProcessMsg_CreateWorker::Read(msg.get(), ¶m)); |
| 332 EXPECT_EQ(GURL(expected_url), get<0>(param).url); | 332 EXPECT_EQ(GURL(expected_url), base::get<0>(param).url); |
| 333 EXPECT_EQ(base::ASCIIToUTF16(expected_name), get<0>(param).name); | 333 EXPECT_EQ(base::ASCIIToUTF16(expected_name), base::get<0>(param).name); |
| 334 EXPECT_EQ(expected_security_policy_type, get<0>(param).security_policy_type); | 334 EXPECT_EQ(expected_security_policy_type, |
| 335 *route_id = get<0>(param).route_id; | 335 base::get<0>(param).security_policy_type); |
| 336 *route_id = base::get<0>(param).route_id; |
| 336 } | 337 } |
| 337 | 338 |
| 338 void CheckViewMsgWorkerCreated(MockRendererProcessHost* renderer_host, | 339 void CheckViewMsgWorkerCreated(MockRendererProcessHost* renderer_host, |
| 339 MockSharedWorkerConnector* connector) { | 340 MockSharedWorkerConnector* connector) { |
| 340 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 341 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 341 EXPECT_EQ(ViewMsg_WorkerCreated::ID, msg->type()); | 342 EXPECT_EQ(ViewMsg_WorkerCreated::ID, msg->type()); |
| 342 EXPECT_EQ(connector->route_id(), msg->routing_id()); | 343 EXPECT_EQ(connector->route_id(), msg->routing_id()); |
| 343 } | 344 } |
| 344 | 345 |
| 345 void CheckMessagePortMsgMessagesQueued(MockRendererProcessHost* renderer_host, | 346 void CheckMessagePortMsgMessagesQueued(MockRendererProcessHost* renderer_host, |
| 346 MockSharedWorkerConnector* connector) { | 347 MockSharedWorkerConnector* connector) { |
| 347 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 348 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 348 EXPECT_EQ(MessagePortMsg_MessagesQueued::ID, msg->type()); | 349 EXPECT_EQ(MessagePortMsg_MessagesQueued::ID, msg->type()); |
| 349 EXPECT_EQ(connector->temporary_remote_port_route_id(), msg->routing_id()); | 350 EXPECT_EQ(connector->temporary_remote_port_route_id(), msg->routing_id()); |
| 350 } | 351 } |
| 351 | 352 |
| 352 void CheckWorkerMsgConnect(MockRendererProcessHost* renderer_host, | 353 void CheckWorkerMsgConnect(MockRendererProcessHost* renderer_host, |
| 353 int expected_msg_route_id, | 354 int expected_msg_route_id, |
| 354 int expected_sent_message_port_id, | 355 int expected_sent_message_port_id, |
| 355 int* routing_id) { | 356 int* routing_id) { |
| 356 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 357 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 357 EXPECT_EQ(WorkerMsg_Connect::ID, msg->type()); | 358 EXPECT_EQ(WorkerMsg_Connect::ID, msg->type()); |
| 358 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); | 359 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); |
| 359 WorkerMsg_Connect::Param params; | 360 WorkerMsg_Connect::Param params; |
| 360 EXPECT_TRUE(WorkerMsg_Connect::Read(msg.get(), ¶ms)); | 361 EXPECT_TRUE(WorkerMsg_Connect::Read(msg.get(), ¶ms)); |
| 361 int port_id = get<0>(params); | 362 int port_id = base::get<0>(params); |
| 362 *routing_id = get<1>(params); | 363 *routing_id = base::get<1>(params); |
| 363 EXPECT_EQ(expected_sent_message_port_id, port_id); | 364 EXPECT_EQ(expected_sent_message_port_id, port_id); |
| 364 } | 365 } |
| 365 | 366 |
| 366 void CheckMessagePortMsgMessage(MockRendererProcessHost* renderer_host, | 367 void CheckMessagePortMsgMessage(MockRendererProcessHost* renderer_host, |
| 367 int expected_msg_route_id, | 368 int expected_msg_route_id, |
| 368 std::string expected_data) { | 369 std::string expected_data) { |
| 369 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 370 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 370 EXPECT_EQ(MessagePortMsg_Message::ID, msg->type()); | 371 EXPECT_EQ(MessagePortMsg_Message::ID, msg->type()); |
| 371 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); | 372 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); |
| 372 MessagePortMsg_Message::Param params; | 373 MessagePortMsg_Message::Param params; |
| 373 EXPECT_TRUE(MessagePortMsg_Message::Read(msg.get(), ¶ms)); | 374 EXPECT_TRUE(MessagePortMsg_Message::Read(msg.get(), ¶ms)); |
| 374 base::string16 data = get<0>(params).message_as_string; | 375 base::string16 data = base::get<0>(params).message_as_string; |
| 375 EXPECT_EQ(base::ASCIIToUTF16(expected_data), data); | 376 EXPECT_EQ(base::ASCIIToUTF16(expected_data), data); |
| 376 } | 377 } |
| 377 | 378 |
| 378 void CheckViewMsgWorkerConnected(MockRendererProcessHost* renderer_host, | 379 void CheckViewMsgWorkerConnected(MockRendererProcessHost* renderer_host, |
| 379 MockSharedWorkerConnector* connector) { | 380 MockSharedWorkerConnector* connector) { |
| 380 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 381 scoped_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 381 EXPECT_EQ(ViewMsg_WorkerConnected::ID, msg->type()); | 382 EXPECT_EQ(ViewMsg_WorkerConnected::ID, msg->type()); |
| 382 EXPECT_EQ(connector->route_id(), msg->routing_id()); | 383 EXPECT_EQ(connector->route_id(), msg->routing_id()); |
| 383 } | 384 } |
| 384 | 385 |
| (...skipping 524 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 909 kDocumentIDs[2], | 910 kDocumentIDs[2], |
| 910 kRenderFrameRouteIDs[2]); | 911 kRenderFrameRouteIDs[2]); |
| 911 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); | 912 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); |
| 912 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); | 913 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); |
| 913 RunAllPendingInMessageLoop(); | 914 RunAllPendingInMessageLoop(); |
| 914 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); | 915 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); |
| 915 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); | 916 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); |
| 916 } | 917 } |
| 917 | 918 |
| 918 } // namespace content | 919 } // namespace content |
| OLD | NEW |