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 "content/browser/shared_worker/shared_worker_service_impl.h" | 5 #include "content/browser/shared_worker/shared_worker_service_impl.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include <map> | 9 #include <map> |
10 #include <memory> | 10 #include <memory> |
(...skipping 333 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
344 *route_id = std::get<0>(param).route_id; | 344 *route_id = std::get<0>(param).route_id; |
345 } | 345 } |
346 | 346 |
347 void CheckViewMsgWorkerCreated(MockRendererProcessHost* renderer_host, | 347 void CheckViewMsgWorkerCreated(MockRendererProcessHost* renderer_host, |
348 MockSharedWorkerConnector* connector) { | 348 MockSharedWorkerConnector* connector) { |
349 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 349 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
350 EXPECT_EQ(ViewMsg_WorkerCreated::ID, msg->type()); | 350 EXPECT_EQ(ViewMsg_WorkerCreated::ID, msg->type()); |
351 EXPECT_EQ(connector->route_id(), msg->routing_id()); | 351 EXPECT_EQ(connector->route_id(), msg->routing_id()); |
352 } | 352 } |
353 | 353 |
| 354 void CheckViewMsgCountFeature(MockRendererProcessHost* renderer_host, |
| 355 MockSharedWorkerConnector* connector, |
| 356 uint32_t expected_feature) { |
| 357 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
| 358 EXPECT_EQ(ViewMsg_CountFeatureOnSharedWorker::ID, msg->type()); |
| 359 EXPECT_EQ(connector->route_id(), msg->routing_id()); |
| 360 ViewMsg_CountFeatureOnSharedWorker::Param params; |
| 361 EXPECT_TRUE(ViewMsg_CountFeatureOnSharedWorker::Read(msg.get(), ¶ms)); |
| 362 uint32_t feature = std::get<0>(params); |
| 363 EXPECT_EQ(expected_feature, feature); |
| 364 } |
| 365 |
354 void CheckMessagePortMsgMessagesQueued(MockRendererProcessHost* renderer_host, | 366 void CheckMessagePortMsgMessagesQueued(MockRendererProcessHost* renderer_host, |
355 MockSharedWorkerConnector* connector) { | 367 MockSharedWorkerConnector* connector) { |
356 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 368 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
357 EXPECT_EQ(MessagePortMsg_MessagesQueued::ID, msg->type()); | 369 EXPECT_EQ(MessagePortMsg_MessagesQueued::ID, msg->type()); |
358 EXPECT_EQ(connector->temporary_remote_port_route_id(), msg->routing_id()); | 370 EXPECT_EQ(connector->temporary_remote_port_route_id(), msg->routing_id()); |
359 } | 371 } |
360 | 372 |
361 void CheckWorkerMsgConnect(MockRendererProcessHost* renderer_host, | 373 void CheckWorkerMsgConnect(MockRendererProcessHost* renderer_host, |
362 int expected_msg_route_id, | 374 int expected_msg_route_id, |
363 int expected_sent_message_port_id, | 375 int expected_sent_message_port_id, |
(...skipping 14 matching lines...) Expand all Loading... |
378 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 390 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
379 EXPECT_EQ(MessagePortMsg_Message::ID, msg->type()); | 391 EXPECT_EQ(MessagePortMsg_Message::ID, msg->type()); |
380 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); | 392 EXPECT_EQ(expected_msg_route_id, msg->routing_id()); |
381 MessagePortMsg_Message::Param params; | 393 MessagePortMsg_Message::Param params; |
382 EXPECT_TRUE(MessagePortMsg_Message::Read(msg.get(), ¶ms)); | 394 EXPECT_TRUE(MessagePortMsg_Message::Read(msg.get(), ¶ms)); |
383 base::string16 data = std::get<0>(params); | 395 base::string16 data = std::get<0>(params); |
384 EXPECT_EQ(base::ASCIIToUTF16(expected_data), data); | 396 EXPECT_EQ(base::ASCIIToUTF16(expected_data), data); |
385 } | 397 } |
386 | 398 |
387 void CheckViewMsgWorkerConnected(MockRendererProcessHost* renderer_host, | 399 void CheckViewMsgWorkerConnected(MockRendererProcessHost* renderer_host, |
388 MockSharedWorkerConnector* connector) { | 400 MockSharedWorkerConnector* connector, |
| 401 std::set<uint32_t> expected_features) { |
389 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); | 402 std::unique_ptr<IPC::Message> msg(renderer_host->PopMessage()); |
390 EXPECT_EQ(ViewMsg_WorkerConnected::ID, msg->type()); | 403 EXPECT_EQ(ViewMsg_WorkerConnected::ID, msg->type()); |
391 EXPECT_EQ(connector->route_id(), msg->routing_id()); | 404 EXPECT_EQ(connector->route_id(), msg->routing_id()); |
| 405 ViewMsg_WorkerConnected::Param params; |
| 406 EXPECT_TRUE(ViewMsg_WorkerConnected::Read(msg.get(), ¶ms)); |
| 407 std::set<uint32_t> features = std::get<0>(params); |
| 408 EXPECT_EQ(expected_features, features); |
392 } | 409 } |
393 | 410 |
394 } // namespace | 411 } // namespace |
395 | 412 |
396 TEST_F(SharedWorkerServiceImplTest, BasicTest) { | 413 TEST_F(SharedWorkerServiceImplTest, BasicTest) { |
397 std::unique_ptr<MockRendererProcessHost> renderer_host( | 414 std::unique_ptr<MockRendererProcessHost> renderer_host( |
398 new MockRendererProcessHost(kProcessIDs[0], | 415 new MockRendererProcessHost(kProcessIDs[0], |
399 browser_context_->GetResourceContext(), | 416 browser_context_->GetResourceContext(), |
400 *partition_.get())); | 417 *partition_.get())); |
401 std::unique_ptr<MockSharedWorkerConnector> connector( | 418 std::unique_ptr<MockSharedWorkerConnector> connector( |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
458 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); | 475 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); |
459 EXPECT_EQ(0U, renderer_host->QueuedMessageCount()); | 476 EXPECT_EQ(0U, renderer_host->QueuedMessageCount()); |
460 | 477 |
461 // SharedWorker sends WorkerHostMsg_WorkerConnected in | 478 // SharedWorker sends WorkerHostMsg_WorkerConnected in |
462 // EmbeddedSharedWorkerStub::workerScriptLoaded(). | 479 // EmbeddedSharedWorkerStub::workerScriptLoaded(). |
463 EXPECT_TRUE( | 480 EXPECT_TRUE( |
464 renderer_host->OnMessageReceived(new WorkerHostMsg_WorkerConnected( | 481 renderer_host->OnMessageReceived(new WorkerHostMsg_WorkerConnected( |
465 connector->remote_port_id(), worker_route_id))); | 482 connector->remote_port_id(), worker_route_id))); |
466 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); | 483 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
467 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. | 484 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. |
468 CheckViewMsgWorkerConnected(renderer_host.get(), connector.get()); | 485 CheckViewMsgWorkerConnected(renderer_host.get(), connector.get(), |
| 486 std::set<uint32_t>()); |
469 | 487 |
470 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, | 488 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, |
471 // SharedWorker side shuold receive MessagePortMsg_Message. | 489 // SharedWorker side shuold receive MessagePortMsg_Message. |
472 connector->SendPostMessage("test1"); | 490 connector->SendPostMessage("test1"); |
473 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); | 491 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
474 CheckMessagePortMsgMessage( | 492 CheckMessagePortMsgMessage( |
475 renderer_host.get(), worker_msg_port_route_id, "test1"); | 493 renderer_host.get(), worker_msg_port_route_id, "test1"); |
476 | 494 |
477 // When SharedWorker side sends MessagePortHostMsg_PostMessage, | 495 // When SharedWorker side sends MessagePortHostMsg_PostMessage, |
478 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. | 496 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. |
479 const std::vector<int> empty_ports; | 497 const std::vector<int> empty_ports; |
480 EXPECT_TRUE( | 498 EXPECT_TRUE( |
481 renderer_host->OnMessageReceived(new MessagePortHostMsg_PostMessage( | 499 renderer_host->OnMessageReceived(new MessagePortHostMsg_PostMessage( |
482 connector->remote_port_id(), | 500 connector->remote_port_id(), |
483 base::ASCIIToUTF16("test2"), empty_ports))); | 501 base::ASCIIToUTF16("test2"), empty_ports))); |
484 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); | 502 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
485 CheckMessagePortMsgMessage( | 503 CheckMessagePortMsgMessage( |
486 renderer_host.get(), connector->local_port_route_id(), "test2"); | 504 renderer_host.get(), connector->local_port_route_id(), "test2"); |
487 | 505 |
| 506 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 507 // EmbeddedSharedWorkerStub::CountFeature(). |
| 508 uint32_t feature1 = 124; |
| 509 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 510 new WorkerHostMsg_CountFeature(worker_route_id, feature1))); |
| 511 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
| 512 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 513 CheckViewMsgCountFeature(renderer_host.get(), connector.get(), feature1); |
| 514 // A message should be sent only one time per feature. |
| 515 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 516 new WorkerHostMsg_CountFeature(worker_route_id, feature1))); |
| 517 EXPECT_EQ(0U, renderer_host->QueuedMessageCount()); |
| 518 |
| 519 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 520 // EmbeddedSharedWorkerStub::CountFeature() for another feature use. |
| 521 uint32_t feature2 = 901; |
| 522 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 523 new WorkerHostMsg_CountFeature(worker_route_id, feature2))); |
| 524 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
| 525 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 526 CheckViewMsgCountFeature(renderer_host.get(), connector.get(), feature2); |
| 527 |
488 // UpdateWorkerDependency should not be called. | 528 // UpdateWorkerDependency should not be called. |
489 EXPECT_EQ(0, s_update_worker_dependency_call_count_); | 529 EXPECT_EQ(0, s_update_worker_dependency_call_count_); |
490 } | 530 } |
491 | 531 |
492 TEST_F(SharedWorkerServiceImplTest, TwoRendererTest) { | 532 TEST_F(SharedWorkerServiceImplTest, TwoRendererTest) { |
493 // The first renderer host. | 533 // The first renderer host. |
494 std::unique_ptr<MockRendererProcessHost> renderer_host0( | 534 std::unique_ptr<MockRendererProcessHost> renderer_host0( |
495 new MockRendererProcessHost(kProcessIDs[0], | 535 new MockRendererProcessHost(kProcessIDs[0], |
496 browser_context_->GetResourceContext(), | 536 browser_context_->GetResourceContext(), |
497 *partition_.get())); | 537 *partition_.get())); |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
555 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); | 595 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); |
556 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); | 596 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); |
557 | 597 |
558 // SharedWorker sends WorkerHostMsg_WorkerConnected in | 598 // SharedWorker sends WorkerHostMsg_WorkerConnected in |
559 // EmbeddedSharedWorkerStub::workerScriptLoaded(). | 599 // EmbeddedSharedWorkerStub::workerScriptLoaded(). |
560 EXPECT_TRUE( | 600 EXPECT_TRUE( |
561 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( | 601 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( |
562 connector0->remote_port_id(), worker_route_id))); | 602 connector0->remote_port_id(), worker_route_id))); |
563 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 603 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
564 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. | 604 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. |
565 CheckViewMsgWorkerConnected(renderer_host0.get(), connector0.get()); | 605 CheckViewMsgWorkerConnected(renderer_host0.get(), connector0.get(), |
| 606 std::set<uint32_t>()); |
566 | 607 |
567 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, | 608 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, |
568 // SharedWorker side shuold receive MessagePortMsg_Message. | 609 // SharedWorker side shuold receive MessagePortMsg_Message. |
569 connector0->SendPostMessage("test1"); | 610 connector0->SendPostMessage("test1"); |
570 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 611 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
571 CheckMessagePortMsgMessage( | 612 CheckMessagePortMsgMessage( |
572 renderer_host0.get(), worker_msg_port_route_id1, "test1"); | 613 renderer_host0.get(), worker_msg_port_route_id1, "test1"); |
573 | 614 |
574 // When SharedWorker side sends MessagePortHostMsg_PostMessage, | 615 // When SharedWorker side sends MessagePortHostMsg_PostMessage, |
575 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. | 616 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. |
576 const std::vector<int> empty_ports; | 617 const std::vector<int> empty_ports; |
577 EXPECT_TRUE( | 618 EXPECT_TRUE( |
578 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( | 619 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( |
579 connector0->remote_port_id(), | 620 connector0->remote_port_id(), |
580 base::ASCIIToUTF16("test2"), empty_ports))); | 621 base::ASCIIToUTF16("test2"), empty_ports))); |
581 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 622 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
582 CheckMessagePortMsgMessage( | 623 CheckMessagePortMsgMessage( |
583 renderer_host0.get(), connector0->local_port_route_id(), "test2"); | 624 renderer_host0.get(), connector0->local_port_route_id(), "test2"); |
584 | 625 |
| 626 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 627 // EmbeddedSharedWorkerStub::CountFeature(). |
| 628 uint32_t feature1 = 124; |
| 629 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 630 new WorkerHostMsg_CountFeature(worker_route_id, feature1))); |
| 631 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 632 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 633 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), feature1); |
| 634 uint32_t feature2 = 901; |
| 635 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 636 new WorkerHostMsg_CountFeature(worker_route_id, feature2))); |
| 637 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 638 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 639 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), feature2); |
| 640 |
585 // The second renderer host. | 641 // The second renderer host. |
586 std::unique_ptr<MockRendererProcessHost> renderer_host1( | 642 std::unique_ptr<MockRendererProcessHost> renderer_host1( |
587 new MockRendererProcessHost(kProcessIDs[1], | 643 new MockRendererProcessHost(kProcessIDs[1], |
588 browser_context_->GetResourceContext(), | 644 browser_context_->GetResourceContext(), |
589 *partition_.get())); | 645 *partition_.get())); |
590 std::unique_ptr<MockSharedWorkerConnector> connector1( | 646 std::unique_ptr<MockSharedWorkerConnector> connector1( |
591 new MockSharedWorkerConnector(renderer_host1.get())); | 647 new MockSharedWorkerConnector(renderer_host1.get())); |
592 int worker_msg_port_route_id2; | 648 int worker_msg_port_route_id2; |
593 | 649 |
594 // UpdateWorkerDependency should not be called yet. | 650 // UpdateWorkerDependency should not be called yet. |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
635 connector1->SendSendQueuedMessages(empty_messages); | 691 connector1->SendSendQueuedMessages(empty_messages); |
636 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); | 692 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); |
637 | 693 |
638 // SharedWorker sends WorkerHostMsg_WorkerConnected in | 694 // SharedWorker sends WorkerHostMsg_WorkerConnected in |
639 // EmbeddedSharedWorkerStub::OnConnect(). | 695 // EmbeddedSharedWorkerStub::OnConnect(). |
640 EXPECT_TRUE( | 696 EXPECT_TRUE( |
641 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( | 697 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( |
642 connector1->remote_port_id(), worker_route_id))); | 698 connector1->remote_port_id(), worker_route_id))); |
643 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); | 699 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
644 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. | 700 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. |
645 CheckViewMsgWorkerConnected(renderer_host1.get(), connector1.get()); | 701 CheckViewMsgWorkerConnected(renderer_host1.get(), connector1.get(), |
| 702 {feature1, feature2}); |
646 | 703 |
647 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, | 704 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, |
648 // SharedWorker side shuold receive MessagePortMsg_Message. | 705 // SharedWorker side shuold receive MessagePortMsg_Message. |
649 connector1->SendPostMessage("test3"); | 706 connector1->SendPostMessage("test3"); |
650 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 707 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
651 CheckMessagePortMsgMessage( | 708 CheckMessagePortMsgMessage( |
652 renderer_host0.get(), worker_msg_port_route_id2, "test3"); | 709 renderer_host0.get(), worker_msg_port_route_id2, "test3"); |
653 | 710 |
654 // When SharedWorker side sends MessagePortHostMsg_PostMessage, | 711 // When SharedWorker side sends MessagePortHostMsg_PostMessage, |
655 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. | 712 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. |
656 EXPECT_TRUE( | 713 EXPECT_TRUE( |
657 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( | 714 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( |
658 connector1->remote_port_id(), | 715 connector1->remote_port_id(), |
659 base::ASCIIToUTF16("test4"), empty_ports))); | 716 base::ASCIIToUTF16("test4"), empty_ports))); |
660 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); | 717 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
661 CheckMessagePortMsgMessage( | 718 CheckMessagePortMsgMessage( |
662 renderer_host1.get(), connector1->local_port_route_id(), "test4"); | 719 renderer_host1.get(), connector1->local_port_route_id(), "test4"); |
663 | 720 |
| 721 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 722 // EmbeddedSharedWorkerStub::CountFeature(). These features are already |
| 723 // counted in the browser-side, so messages should not be sent to |
| 724 // SharedWorkerConnectors. |
| 725 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 726 new WorkerHostMsg_CountFeature(worker_route_id, feature1))); |
| 727 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); |
| 728 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); |
| 729 |
| 730 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 731 // EmbeddedSharedWorkerStub::CountFeature() for another feature use. |
| 732 uint32_t feature3 = 1019; |
| 733 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 734 new WorkerHostMsg_CountFeature(worker_route_id, feature3))); |
| 735 // ViewMsg_CountFeature should be sent to all SharedWorkerConnectors |
| 736 // connecting to this worker. |
| 737 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 738 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), feature3); |
| 739 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
| 740 CheckViewMsgCountFeature(renderer_host1.get(), connector1.get(), feature3); |
| 741 |
664 EXPECT_EQ(1, s_update_worker_dependency_call_count_); | 742 EXPECT_EQ(1, s_update_worker_dependency_call_count_); |
665 renderer_host1.reset(); | 743 renderer_host1.reset(); |
666 // UpdateWorkerDependency should be called. | 744 // UpdateWorkerDependency should be called. |
667 EXPECT_EQ(2, s_update_worker_dependency_call_count_); | 745 EXPECT_EQ(2, s_update_worker_dependency_call_count_); |
668 EXPECT_EQ(0U, s_worker_dependency_added_ids_.size()); | 746 EXPECT_EQ(0U, s_worker_dependency_added_ids_.size()); |
669 EXPECT_EQ(1U, s_worker_dependency_removed_ids_.size()); | 747 EXPECT_EQ(1U, s_worker_dependency_removed_ids_.size()); |
670 EXPECT_EQ(kProcessIDs[0], s_worker_dependency_removed_ids_[0]); | 748 EXPECT_EQ(kProcessIDs[0], s_worker_dependency_removed_ids_[0]); |
671 } | 749 } |
672 | 750 |
673 TEST_F(SharedWorkerServiceImplTest, CreateWorkerTest) { | 751 TEST_F(SharedWorkerServiceImplTest, CreateWorkerTest) { |
(...skipping 303 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
977 kDocumentIDs[2], | 1055 kDocumentIDs[2], |
978 kRenderFrameRouteIDs[2]); | 1056 kRenderFrameRouteIDs[2]); |
979 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); | 1057 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); |
980 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); | 1058 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); |
981 RunAllPendingInMessageLoop(); | 1059 RunAllPendingInMessageLoop(); |
982 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); | 1060 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); |
983 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); | 1061 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); |
984 } | 1062 } |
985 | 1063 |
986 } // namespace content | 1064 } // namespace content |
OLD | NEW |