| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 // Unit test for SyncChannel. | 5 // Unit test for SyncChannel. |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 163 base::Thread* ListenerThread() { | 163 base::Thread* ListenerThread() { |
| 164 return overrided_thread_ ? overrided_thread_ : &listener_thread_; | 164 return overrided_thread_ ? overrided_thread_ : &listener_thread_; |
| 165 } | 165 } |
| 166 | 166 |
| 167 private: | 167 private: |
| 168 // Called on the listener thread to create the sync channel. | 168 // Called on the listener thread to create the sync channel. |
| 169 void OnStart() { | 169 void OnStart() { |
| 170 // Link ipc_thread_, listener_thread_ and channel_ altogether. | 170 // Link ipc_thread_, listener_thread_ and channel_ altogether. |
| 171 StartThread(&ipc_thread_, MessageLoop::TYPE_IO); | 171 StartThread(&ipc_thread_, MessageLoop::TYPE_IO); |
| 172 channel_.reset(new SyncChannel( | 172 channel_.reset(new SyncChannel( |
| 173 channel_name_, mode_, this, NULL, ipc_thread_.message_loop(), true, | 173 channel_name_, mode_, this, ipc_thread_.message_loop(), true, |
| 174 &shutdown_event_)); | 174 &shutdown_event_)); |
| 175 channel_created_->Signal(); | 175 channel_created_->Signal(); |
| 176 Run(); | 176 Run(); |
| 177 } | 177 } |
| 178 | 178 |
| 179 void OnListenerThreadShutdown1(WaitableEvent* listener_event, | 179 void OnListenerThreadShutdown1(WaitableEvent* listener_event, |
| 180 WaitableEvent* ipc_event) { | 180 WaitableEvent* ipc_event) { |
| 181 // SyncChannel needs to be destructed on the thread that it was created on. | 181 // SyncChannel needs to be destructed on the thread that it was created on. |
| 182 channel_.reset(); | 182 channel_.reset(); |
| 183 | 183 |
| (...skipping 978 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1162 server.done_event()->Wait(); | 1162 server.done_event()->Wait(); |
| 1163 server.done_event()->Reset(); | 1163 server.done_event()->Reset(); |
| 1164 | 1164 |
| 1165 server.SendDummy(); | 1165 server.SendDummy(); |
| 1166 server.done_event()->Wait(); | 1166 server.done_event()->Wait(); |
| 1167 | 1167 |
| 1168 EXPECT_FALSE(server.send_result()); | 1168 EXPECT_FALSE(server.send_result()); |
| 1169 } | 1169 } |
| 1170 | 1170 |
| 1171 | 1171 |
| OLD | NEW |