| 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 <stddef.h> | 5 #include <stddef.h> |
| 6 | 6 |
| 7 #include <map> | 7 #include <map> |
| 8 #include <set> | 8 #include <set> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| (...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 203 } | 203 } |
| 204 return ret; | 204 return ret; |
| 205 } | 205 } |
| 206 | 206 |
| 207 size_t QueuedMessageCount() const { return queued_messages_.size(); } | 207 size_t QueuedMessageCount() const { return queued_messages_.size(); } |
| 208 | 208 |
| 209 scoped_ptr<IPC::Message> PopMessage() { | 209 scoped_ptr<IPC::Message> PopMessage() { |
| 210 CHECK(queued_messages_.size()); | 210 CHECK(queued_messages_.size()); |
| 211 scoped_ptr<IPC::Message> msg(*queued_messages_.begin()); | 211 scoped_ptr<IPC::Message> msg(*queued_messages_.begin()); |
| 212 queued_messages_.weak_erase(queued_messages_.begin()); | 212 queued_messages_.weak_erase(queued_messages_.begin()); |
| 213 return msg.Pass(); | 213 return msg; |
| 214 } | 214 } |
| 215 | 215 |
| 216 void FastShutdownIfPossible() { | 216 void FastShutdownIfPossible() { |
| 217 SharedWorkerServiceImplTest::UnregisterRunningProcessID(process_id_); | 217 SharedWorkerServiceImplTest::UnregisterRunningProcessID(process_id_); |
| 218 } | 218 } |
| 219 | 219 |
| 220 private: | 220 private: |
| 221 const int process_id_; | 221 const int process_id_; |
| 222 ScopedVector<IPC::Message> queued_messages_; | 222 ScopedVector<IPC::Message> queued_messages_; |
| 223 base::AtomicSequenceNumber next_routing_id_; | 223 base::AtomicSequenceNumber next_routing_id_; |
| (...skipping 691 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 915 kDocumentIDs[2], | 915 kDocumentIDs[2], |
| 916 kRenderFrameRouteIDs[2]); | 916 kRenderFrameRouteIDs[2]); |
| 917 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); | 917 EXPECT_NE(MSG_ROUTING_NONE, connector2->route_id()); |
| 918 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); | 918 EXPECT_EQ(0U, renderer_host2->QueuedMessageCount()); |
| 919 RunAllPendingInMessageLoop(); | 919 RunAllPendingInMessageLoop(); |
| 920 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); | 920 EXPECT_EQ(1U, renderer_host2->QueuedMessageCount()); |
| 921 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); | 921 CheckViewMsgWorkerCreated(renderer_host2.get(), connector2.get()); |
| 922 } | 922 } |
| 923 | 923 |
| 924 } // namespace content | 924 } // namespace content |
| OLD | NEW |