| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/bind.h" | 5 #include "base/bind.h" |
| 6 #include "base/compiler_specific.h" | 6 #include "base/compiler_specific.h" |
| 7 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
| 8 #include "base/threading/thread.h" | 8 #include "base/threading/thread.h" |
| 9 #include "jingle/glue/thread_wrapper.h" | 9 #include "jingle/glue/thread_wrapper.h" |
| 10 #include "testing/gmock/include/gmock/gmock.h" | 10 #include "testing/gmock/include/gmock/gmock.h" |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 140 EXPECT_CALL(handler1_, OnMessage( | 140 EXPECT_CALL(handler1_, OnMessage( |
| 141 MatchMessage(&handler1_, kTestMessage2, data2))) | 141 MatchMessage(&handler1_, kTestMessage2, data2))) |
| 142 .WillOnce(DeleteMessageData()); | 142 .WillOnce(DeleteMessageData()); |
| 143 EXPECT_CALL(handler2_, OnMessage( | 143 EXPECT_CALL(handler2_, OnMessage( |
| 144 MatchMessage(&handler2_, kTestMessage1, data3))) | 144 MatchMessage(&handler2_, kTestMessage1, data3))) |
| 145 .WillOnce(DeleteMessageData()); | 145 .WillOnce(DeleteMessageData()); |
| 146 EXPECT_CALL(handler2_, OnMessage( | 146 EXPECT_CALL(handler2_, OnMessage( |
| 147 MatchMessage(&handler2_, kTestMessage1, data4))) | 147 MatchMessage(&handler2_, kTestMessage1, data4))) |
| 148 .WillOnce(DeleteMessageData()); | 148 .WillOnce(DeleteMessageData()); |
| 149 | 149 |
| 150 message_loop_.PostDelayedTask(FROM_HERE, new MessageLoop::QuitTask(), | 150 message_loop_.PostDelayedTask(FROM_HERE, MessageLoop::QuitClosure(), |
| 151 kMaxTestDelay); | 151 kMaxTestDelay); |
| 152 message_loop_.Run(); | 152 message_loop_.Run(); |
| 153 } | 153 } |
| 154 | 154 |
| 155 TEST_F(ThreadWrapperTest, Clear) { | 155 TEST_F(ThreadWrapperTest, Clear) { |
| 156 thread_->Post(&handler1_, kTestMessage1, NULL); | 156 thread_->Post(&handler1_, kTestMessage1, NULL); |
| 157 thread_->Post(&handler1_, kTestMessage2, NULL); | 157 thread_->Post(&handler1_, kTestMessage2, NULL); |
| 158 thread_->Post(&handler2_, kTestMessage1, NULL); | 158 thread_->Post(&handler2_, kTestMessage1, NULL); |
| 159 thread_->Post(&handler2_, kTestMessage2, NULL); | 159 thread_->Post(&handler2_, kTestMessage2, NULL); |
| 160 | 160 |
| (...skipping 29 matching lines...) Expand all Loading... |
| 190 EXPECT_CALL(handler1_, OnMessage( | 190 EXPECT_CALL(handler1_, OnMessage( |
| 191 MatchMessage(&handler1_, kTestMessage1, null_data))) | 191 MatchMessage(&handler1_, kTestMessage1, null_data))) |
| 192 .WillOnce(DeleteMessageData()); | 192 .WillOnce(DeleteMessageData()); |
| 193 EXPECT_CALL(handler2_, OnMessage( | 193 EXPECT_CALL(handler2_, OnMessage( |
| 194 MatchMessage(&handler2_, kTestMessage1, null_data))) | 194 MatchMessage(&handler2_, kTestMessage1, null_data))) |
| 195 .WillOnce(DeleteMessageData()); | 195 .WillOnce(DeleteMessageData()); |
| 196 EXPECT_CALL(handler2_, OnMessage( | 196 EXPECT_CALL(handler2_, OnMessage( |
| 197 MatchMessage(&handler2_, kTestMessage1, null_data))) | 197 MatchMessage(&handler2_, kTestMessage1, null_data))) |
| 198 .WillOnce(DeleteMessageData()); | 198 .WillOnce(DeleteMessageData()); |
| 199 | 199 |
| 200 message_loop_.PostDelayedTask(FROM_HERE, new MessageLoop::QuitTask(), | 200 message_loop_.PostDelayedTask(FROM_HERE, MessageLoop::QuitClosure(), |
| 201 kMaxTestDelay); | 201 kMaxTestDelay); |
| 202 message_loop_.Run(); | 202 message_loop_.Run(); |
| 203 } | 203 } |
| 204 | 204 |
| 205 // Verify that the queue is cleared when a handler is destroyed. | 205 // Verify that the queue is cleared when a handler is destroyed. |
| 206 TEST_F(ThreadWrapperTest, ClearDestoroyed) { | 206 TEST_F(ThreadWrapperTest, ClearDestoroyed) { |
| 207 MockMessageHandler* handler_ptr; | 207 MockMessageHandler* handler_ptr; |
| 208 { | 208 { |
| 209 MockMessageHandler handler; | 209 MockMessageHandler handler; |
| 210 handler_ptr = &handler; | 210 handler_ptr = &handler; |
| (...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 295 | 295 |
| 296 TEST_F(ThreadWrapperTest, Dispose) { | 296 TEST_F(ThreadWrapperTest, Dispose) { |
| 297 bool deleted_; | 297 bool deleted_; |
| 298 thread_->Dispose(new DeletableObject(&deleted_)); | 298 thread_->Dispose(new DeletableObject(&deleted_)); |
| 299 EXPECT_FALSE(deleted_); | 299 EXPECT_FALSE(deleted_); |
| 300 message_loop_.RunAllPending(); | 300 message_loop_.RunAllPending(); |
| 301 EXPECT_TRUE(deleted_); | 301 EXPECT_TRUE(deleted_); |
| 302 } | 302 } |
| 303 | 303 |
| 304 } // namespace jingle_glue | 304 } // namespace jingle_glue |
| OLD | NEW |