OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "mojo/system/simple_dispatcher.h" | |
6 | |
7 #include "base/logging.h" | |
8 | |
9 namespace mojo { | |
10 namespace system { | |
11 | |
12 SimpleDispatcher::SimpleDispatcher() { | |
13 } | |
14 | |
15 SimpleDispatcher::~SimpleDispatcher() { | |
16 } | |
17 | |
18 void SimpleDispatcher::HandleSignalsStateChangedNoLock() { | |
19 lock().AssertAcquired(); | |
20 waiter_list_.AwakeWaitersForStateChange(GetHandleSignalsStateImplNoLock()); | |
21 } | |
22 | |
23 void SimpleDispatcher::CancelAllWaitersNoLock() { | |
24 lock().AssertAcquired(); | |
25 waiter_list_.CancelAllWaiters(); | |
26 } | |
27 | |
28 MojoResult SimpleDispatcher::AddWaiterImplNoLock( | |
29 Waiter* waiter, | |
30 MojoHandleSignals signals, | |
31 uint32_t context, | |
32 HandleSignalsState* signals_state) { | |
33 lock().AssertAcquired(); | |
34 | |
35 HandleSignalsState state(GetHandleSignalsStateImplNoLock()); | |
36 if (state.satisfies(signals)) { | |
37 if (signals_state) | |
38 *signals_state = state; | |
39 return MOJO_RESULT_ALREADY_EXISTS; | |
40 } | |
41 if (!state.can_satisfy(signals)) { | |
42 if (signals_state) | |
43 *signals_state = state; | |
44 return MOJO_RESULT_FAILED_PRECONDITION; | |
45 } | |
46 | |
47 waiter_list_.AddWaiter(waiter, signals, context); | |
48 return MOJO_RESULT_OK; | |
49 } | |
50 | |
51 void SimpleDispatcher::RemoveWaiterImplNoLock( | |
52 Waiter* waiter, | |
53 HandleSignalsState* signals_state) { | |
54 lock().AssertAcquired(); | |
55 waiter_list_.RemoveWaiter(waiter); | |
56 if (signals_state) | |
57 *signals_state = GetHandleSignalsStateImplNoLock(); | |
58 } | |
59 | |
60 } // namespace system | |
61 } // namespace mojo | |
OLD | NEW |