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 |