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 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a | 5 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a |
6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to | 6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to |
7 // increase tolerance and reduce observed flakiness (though doing so reduces the | 7 // increase tolerance and reduce observed flakiness (though doing so reduces the |
8 // meaningfulness of the test). | 8 // meaningfulness of the test). |
9 | 9 |
10 #include "mojo/system/simple_dispatcher.h" | 10 #include "mojo/system/simple_dispatcher.h" |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
53 CHECK_EQ(new_satisfiable_signals & state_.satisfied_signals, | 53 CHECK_EQ(new_satisfiable_signals & state_.satisfied_signals, |
54 state_.satisfied_signals); | 54 state_.satisfied_signals); |
55 | 55 |
56 if (new_satisfiable_signals == state_.satisfiable_signals) | 56 if (new_satisfiable_signals == state_.satisfiable_signals) |
57 return; | 57 return; |
58 | 58 |
59 state_.satisfiable_signals = new_satisfiable_signals; | 59 state_.satisfiable_signals = new_satisfiable_signals; |
60 HandleSignalsStateChangedNoLock(); | 60 HandleSignalsStateChangedNoLock(); |
61 } | 61 } |
62 | 62 |
63 virtual Type GetType() const OVERRIDE { return kTypeUnknown; } | 63 virtual Type GetType() const override { return kTypeUnknown; } |
64 | 64 |
65 private: | 65 private: |
66 friend class base::RefCountedThreadSafe<MockSimpleDispatcher>; | 66 friend class base::RefCountedThreadSafe<MockSimpleDispatcher>; |
67 virtual ~MockSimpleDispatcher() {} | 67 virtual ~MockSimpleDispatcher() {} |
68 | 68 |
69 virtual scoped_refptr<Dispatcher> | 69 virtual scoped_refptr<Dispatcher> |
70 CreateEquivalentDispatcherAndCloseImplNoLock() OVERRIDE { | 70 CreateEquivalentDispatcherAndCloseImplNoLock() override { |
71 scoped_refptr<MockSimpleDispatcher> rv(new MockSimpleDispatcher()); | 71 scoped_refptr<MockSimpleDispatcher> rv(new MockSimpleDispatcher()); |
72 rv->state_ = state_; | 72 rv->state_ = state_; |
73 return scoped_refptr<Dispatcher>(rv.get()); | 73 return scoped_refptr<Dispatcher>(rv.get()); |
74 } | 74 } |
75 | 75 |
76 // |Dispatcher| override: | 76 // |Dispatcher| override: |
77 virtual HandleSignalsState GetHandleSignalsStateImplNoLock() const OVERRIDE { | 77 virtual HandleSignalsState GetHandleSignalsStateImplNoLock() const override { |
78 lock().AssertAcquired(); | 78 lock().AssertAcquired(); |
79 return state_; | 79 return state_; |
80 } | 80 } |
81 | 81 |
82 // Protected by |lock()|: | 82 // Protected by |lock()|: |
83 HandleSignalsState state_; | 83 HandleSignalsState state_; |
84 | 84 |
85 DISALLOW_COPY_AND_ASSIGN(MockSimpleDispatcher); | 85 DISALLOW_COPY_AND_ASSIGN(MockSimpleDispatcher); |
86 }; | 86 }; |
87 | 87 |
(...skipping 572 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
660 // Since we closed before joining, we can't say much about what each thread | 660 // Since we closed before joining, we can't say much about what each thread |
661 // saw as the state. | 661 // saw as the state. |
662 } | 662 } |
663 } | 663 } |
664 | 664 |
665 // TODO(vtl): Stress test? | 665 // TODO(vtl): Stress test? |
666 | 666 |
667 } // namespace | 667 } // namespace |
668 } // namespace system | 668 } // namespace system |
669 } // namespace mojo | 669 } // namespace mojo |
OLD | NEW |