| OLD | NEW | 
|---|
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "mojo/edk/system/dispatcher.h" | 5 #include "mojo/edk/system/dispatcher.h" | 
| 6 | 6 | 
| 7 #include "base/memory/ref_counted.h" | 7 #include "base/memory/ref_counted.h" | 
| 8 #include "base/memory/scoped_vector.h" | 8 #include "base/memory/scoped_vector.h" | 
| 9 #include "base/synchronization/waitable_event.h" | 9 #include "base/synchronization/waitable_event.h" | 
| 10 #include "base/threading/simple_thread.h" | 10 #include "base/threading/simple_thread.h" | 
| (...skipping 13 matching lines...) Expand all  Loading... | 
| 24   TrivialDispatcher() {} | 24   TrivialDispatcher() {} | 
| 25 | 25 | 
| 26   Type GetType() const override { return Type::UNKNOWN; } | 26   Type GetType() const override { return Type::UNKNOWN; } | 
| 27 | 27 | 
| 28  private: | 28  private: | 
| 29   friend class base::RefCountedThreadSafe<TrivialDispatcher>; | 29   friend class base::RefCountedThreadSafe<TrivialDispatcher>; | 
| 30   ~TrivialDispatcher() override {} | 30   ~TrivialDispatcher() override {} | 
| 31 | 31 | 
| 32   scoped_refptr<Dispatcher> CreateEquivalentDispatcherAndCloseImplNoLock() | 32   scoped_refptr<Dispatcher> CreateEquivalentDispatcherAndCloseImplNoLock() | 
| 33       override { | 33       override { | 
| 34     mutex().AssertHeld(); | 34     lock().AssertAcquired(); | 
| 35     return scoped_refptr<Dispatcher>(new TrivialDispatcher()); | 35     return scoped_refptr<Dispatcher>(new TrivialDispatcher()); | 
| 36   } | 36   } | 
| 37 | 37 | 
| 38   MOJO_DISALLOW_COPY_AND_ASSIGN(TrivialDispatcher); | 38   MOJO_DISALLOW_COPY_AND_ASSIGN(TrivialDispatcher); | 
| 39 }; | 39 }; | 
| 40 | 40 | 
| 41 TEST(DispatcherTest, Basic) { | 41 TEST(DispatcherTest, Basic) { | 
| 42   scoped_refptr<Dispatcher> d(new TrivialDispatcher()); | 42   scoped_refptr<Dispatcher> d(new TrivialDispatcher()); | 
| 43 | 43 | 
| 44   EXPECT_EQ(Dispatcher::Type::UNKNOWN, d->GetType()); | 44   EXPECT_EQ(Dispatcher::Type::UNKNOWN, d->GetType()); | 
| (...skipping 253 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
| 298       event.Signal(); | 298       event.Signal(); | 
| 299     }  // Joins all the threads. | 299     }  // Joins all the threads. | 
| 300 | 300 | 
| 301     EXPECT_EQ(MOJO_RESULT_OK, d->Close()); | 301     EXPECT_EQ(MOJO_RESULT_OK, d->Close()); | 
| 302   } | 302   } | 
| 303 } | 303 } | 
| 304 | 304 | 
| 305 }  // namespace | 305 }  // namespace | 
| 306 }  // namespace system | 306 }  // namespace system | 
| 307 }  // namespace mojo | 307 }  // namespace mojo | 
| OLD | NEW | 
|---|