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