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_use_counter_id) { |
| 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 use_counter_id = std::get<0>(params); |
| 363 EXPECT_EQ(expected_use_counter_id, use_counter_id); |
| 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_use_counter) { |
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> use_counter = std::get<0>(params); |
| 408 EXPECT_EQ(expected_use_counter, use_counter); |
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 use_counter_id1 = 124; |
| 509 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 510 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id1))); |
| 511 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
| 512 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 513 CheckViewMsgCountFeature(renderer_host.get(), connector.get(), |
| 514 use_counter_id1); |
| 515 // A message should be sent only one time per use_counter_id. |
| 516 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 517 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id1))); |
| 518 EXPECT_EQ(0U, renderer_host->QueuedMessageCount()); |
| 519 |
| 520 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 521 // EmbeddedSharedWorkerStub::CountFeature() for another use_counter_id use. |
| 522 uint32_t use_counter_id2 = 901; |
| 523 EXPECT_TRUE(renderer_host->OnMessageReceived( |
| 524 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id2))); |
| 525 EXPECT_EQ(1U, renderer_host->QueuedMessageCount()); |
| 526 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 527 CheckViewMsgCountFeature(renderer_host.get(), connector.get(), |
| 528 use_counter_id2); |
| 529 |
488 // UpdateWorkerDependency should not be called. | 530 // UpdateWorkerDependency should not be called. |
489 EXPECT_EQ(0, s_update_worker_dependency_call_count_); | 531 EXPECT_EQ(0, s_update_worker_dependency_call_count_); |
490 } | 532 } |
491 | 533 |
492 TEST_F(SharedWorkerServiceImplTest, TwoRendererTest) { | 534 TEST_F(SharedWorkerServiceImplTest, TwoRendererTest) { |
493 // The first renderer host. | 535 // The first renderer host. |
494 std::unique_ptr<MockRendererProcessHost> renderer_host0( | 536 std::unique_ptr<MockRendererProcessHost> renderer_host0( |
495 new MockRendererProcessHost(kProcessIDs[0], | 537 new MockRendererProcessHost(kProcessIDs[0], |
496 browser_context_->GetResourceContext(), | 538 browser_context_->GetResourceContext(), |
497 *partition_.get())); | 539 *partition_.get())); |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
555 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); | 597 new WorkerHostMsg_WorkerScriptLoaded(worker_route_id))); |
556 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); | 598 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); |
557 | 599 |
558 // SharedWorker sends WorkerHostMsg_WorkerConnected in | 600 // SharedWorker sends WorkerHostMsg_WorkerConnected in |
559 // EmbeddedSharedWorkerStub::workerScriptLoaded(). | 601 // EmbeddedSharedWorkerStub::workerScriptLoaded(). |
560 EXPECT_TRUE( | 602 EXPECT_TRUE( |
561 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( | 603 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( |
562 connector0->remote_port_id(), worker_route_id))); | 604 connector0->remote_port_id(), worker_route_id))); |
563 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 605 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
564 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. | 606 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. |
565 CheckViewMsgWorkerConnected(renderer_host0.get(), connector0.get()); | 607 CheckViewMsgWorkerConnected(renderer_host0.get(), connector0.get(), |
| 608 std::set<uint32_t>()); |
566 | 609 |
567 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, | 610 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, |
568 // SharedWorker side shuold receive MessagePortMsg_Message. | 611 // SharedWorker side shuold receive MessagePortMsg_Message. |
569 connector0->SendPostMessage("test1"); | 612 connector0->SendPostMessage("test1"); |
570 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 613 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
571 CheckMessagePortMsgMessage( | 614 CheckMessagePortMsgMessage( |
572 renderer_host0.get(), worker_msg_port_route_id1, "test1"); | 615 renderer_host0.get(), worker_msg_port_route_id1, "test1"); |
573 | 616 |
574 // When SharedWorker side sends MessagePortHostMsg_PostMessage, | 617 // When SharedWorker side sends MessagePortHostMsg_PostMessage, |
575 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. | 618 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. |
576 const std::vector<int> empty_ports; | 619 const std::vector<int> empty_ports; |
577 EXPECT_TRUE( | 620 EXPECT_TRUE( |
578 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( | 621 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( |
579 connector0->remote_port_id(), | 622 connector0->remote_port_id(), |
580 base::ASCIIToUTF16("test2"), empty_ports))); | 623 base::ASCIIToUTF16("test2"), empty_ports))); |
581 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 624 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
582 CheckMessagePortMsgMessage( | 625 CheckMessagePortMsgMessage( |
583 renderer_host0.get(), connector0->local_port_route_id(), "test2"); | 626 renderer_host0.get(), connector0->local_port_route_id(), "test2"); |
584 | 627 |
| 628 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 629 // EmbeddedSharedWorkerStub::CountFeature(). |
| 630 uint32_t use_counter_id1 = 124; |
| 631 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 632 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id1))); |
| 633 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 634 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 635 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), |
| 636 use_counter_id1); |
| 637 uint32_t use_counter_id2 = 901; |
| 638 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 639 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id2))); |
| 640 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 641 // ViewMsg_CountFeature should be sent to SharedWorkerConnector side. |
| 642 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), |
| 643 use_counter_id2); |
| 644 |
585 // The second renderer host. | 645 // The second renderer host. |
586 std::unique_ptr<MockRendererProcessHost> renderer_host1( | 646 std::unique_ptr<MockRendererProcessHost> renderer_host1( |
587 new MockRendererProcessHost(kProcessIDs[1], | 647 new MockRendererProcessHost(kProcessIDs[1], |
588 browser_context_->GetResourceContext(), | 648 browser_context_->GetResourceContext(), |
589 *partition_.get())); | 649 *partition_.get())); |
590 std::unique_ptr<MockSharedWorkerConnector> connector1( | 650 std::unique_ptr<MockSharedWorkerConnector> connector1( |
591 new MockSharedWorkerConnector(renderer_host1.get())); | 651 new MockSharedWorkerConnector(renderer_host1.get())); |
592 int worker_msg_port_route_id2; | 652 int worker_msg_port_route_id2; |
593 | 653 |
594 // UpdateWorkerDependency should not be called yet. | 654 // UpdateWorkerDependency should not be called yet. |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
635 connector1->SendSendQueuedMessages(empty_messages); | 695 connector1->SendSendQueuedMessages(empty_messages); |
636 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); | 696 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); |
637 | 697 |
638 // SharedWorker sends WorkerHostMsg_WorkerConnected in | 698 // SharedWorker sends WorkerHostMsg_WorkerConnected in |
639 // EmbeddedSharedWorkerStub::OnConnect(). | 699 // EmbeddedSharedWorkerStub::OnConnect(). |
640 EXPECT_TRUE( | 700 EXPECT_TRUE( |
641 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( | 701 renderer_host0->OnMessageReceived(new WorkerHostMsg_WorkerConnected( |
642 connector1->remote_port_id(), worker_route_id))); | 702 connector1->remote_port_id(), worker_route_id))); |
643 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); | 703 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
644 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. | 704 // ViewMsg_WorkerConnected should be sent to SharedWorkerConnector side. |
645 CheckViewMsgWorkerConnected(renderer_host1.get(), connector1.get()); | 705 CheckViewMsgWorkerConnected(renderer_host1.get(), connector1.get(), |
| 706 {use_counter_id1, use_counter_id2}); |
646 | 707 |
647 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, | 708 // When SharedWorkerConnector side sends MessagePortHostMsg_PostMessage, |
648 // SharedWorker side shuold receive MessagePortMsg_Message. | 709 // SharedWorker side shuold receive MessagePortMsg_Message. |
649 connector1->SendPostMessage("test3"); | 710 connector1->SendPostMessage("test3"); |
650 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); | 711 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
651 CheckMessagePortMsgMessage( | 712 CheckMessagePortMsgMessage( |
652 renderer_host0.get(), worker_msg_port_route_id2, "test3"); | 713 renderer_host0.get(), worker_msg_port_route_id2, "test3"); |
653 | 714 |
654 // When SharedWorker side sends MessagePortHostMsg_PostMessage, | 715 // When SharedWorker side sends MessagePortHostMsg_PostMessage, |
655 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. | 716 // SharedWorkerConnector side shuold receive MessagePortMsg_Message. |
656 EXPECT_TRUE( | 717 EXPECT_TRUE( |
657 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( | 718 renderer_host0->OnMessageReceived(new MessagePortHostMsg_PostMessage( |
658 connector1->remote_port_id(), | 719 connector1->remote_port_id(), |
659 base::ASCIIToUTF16("test4"), empty_ports))); | 720 base::ASCIIToUTF16("test4"), empty_ports))); |
660 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); | 721 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
661 CheckMessagePortMsgMessage( | 722 CheckMessagePortMsgMessage( |
662 renderer_host1.get(), connector1->local_port_route_id(), "test4"); | 723 renderer_host1.get(), connector1->local_port_route_id(), "test4"); |
663 | 724 |
| 725 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 726 // EmbeddedSharedWorkerStub::CountFeature(). These use_counter are already |
| 727 // counted in the browser-side, so messages should not be sent to |
| 728 // SharedWorkerConnectors. |
| 729 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 730 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id1))); |
| 731 EXPECT_EQ(0U, renderer_host0->QueuedMessageCount()); |
| 732 EXPECT_EQ(0U, renderer_host1->QueuedMessageCount()); |
| 733 |
| 734 // SharedWorker sends WorkerHostMsg_CountFeature in |
| 735 // EmbeddedSharedWorkerStub::CountFeature() for another use_counter_id use. |
| 736 uint32_t use_counter_id3 = 1019; |
| 737 EXPECT_TRUE(renderer_host0->OnMessageReceived( |
| 738 new WorkerHostMsg_CountFeature(worker_route_id, use_counter_id3))); |
| 739 // ViewMsg_CountFeature should be sent to all SharedWorkerConnectors |
| 740 // connecting to this worker. |
| 741 EXPECT_EQ(1U, renderer_host0->QueuedMessageCount()); |
| 742 CheckViewMsgCountFeature(renderer_host0.get(), connector0.get(), |
| 743 use_counter_id3); |
| 744 EXPECT_EQ(1U, renderer_host1->QueuedMessageCount()); |
| 745 CheckViewMsgCountFeature(renderer_host1.get(), connector1.get(), |
| 746 use_counter_id3); |
| 747 |
664 EXPECT_EQ(1, s_update_worker_dependency_call_count_); | 748 EXPECT_EQ(1, s_update_worker_dependency_call_count_); |
665 renderer_host1.reset(); | 749 renderer_host1.reset(); |
666 // UpdateWorkerDependency should be called. | 750 // UpdateWorkerDependency should be called. |
667 EXPECT_EQ(2, s_update_worker_dependency_call_count_); | 751 EXPECT_EQ(2, s_update_worker_dependency_call_count_); |
668 EXPECT_EQ(0U, s_worker_dependency_added_ids_.size()); | 752 EXPECT_EQ(0U, s_worker_dependency_added_ids_.size()); |
669 EXPECT_EQ(1U, s_worker_dependency_removed_ids_.size()); | 753 EXPECT_EQ(1U, s_worker_dependency_removed_ids_.size()); |
670 EXPECT_EQ(kProcessIDs[0], s_worker_dependency_removed_ids_[0]); | 754 EXPECT_EQ(kProcessIDs[0], s_worker_dependency_removed_ids_[0]); |
671 } | 755 } |
672 | 756 |
673 TEST_F(SharedWorkerServiceImplTest, CreateWorkerTest) { | 757 TEST_F(SharedWorkerServiceImplTest, CreateWorkerTest) { |
(...skipping 303 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
977 kDocumentIDs[2], | 1061 kDocumentIDs[2], |
978 kRenderFrameRouteIDs[2]); | 1062 kRenderFrameRouteIDs[2]); |
979 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); | 1063 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); |
980 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); | 1064 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); |
981 RunAllPendingInMessageLoop(); | 1065 RunAllPendingInMessageLoop(); |
982 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); | 1066 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); |
983 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); | 1067 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); |
984 } | 1068 } |
985 | 1069 |
986 } // namespace content | 1070 } // namespace content |
OLD | NEW |