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/awakable_list.h" | 5 #include "mojo/edk/system/awakable_list.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "mojo/edk/system/awakable.h" | 10 #include "mojo/edk/system/awakable.h" |
(...skipping 21 matching lines...) Expand all Loading... |
32 keep = it->awakable->Awake(MOJO_RESULT_FAILED_PRECONDITION, it->context); | 32 keep = it->awakable->Awake(MOJO_RESULT_FAILED_PRECONDITION, it->context); |
33 | 33 |
34 if (!keep) { | 34 if (!keep) { |
35 --last; | 35 --last; |
36 std::swap(*it, *last); | 36 std::swap(*it, *last); |
37 } else { | 37 } else { |
38 ++it; | 38 ++it; |
39 } | 39 } |
40 } | 40 } |
41 awakables_.erase(last, awakables_.end()); | 41 awakables_.erase(last, awakables_.end()); |
| 42 watchers_.NotifyForStateChange(state); |
42 } | 43 } |
43 | 44 |
44 void AwakableList::CancelAll() { | 45 void AwakableList::CancelAll() { |
45 for (AwakeInfoList::iterator it = awakables_.begin(); it != awakables_.end(); | 46 for (AwakeInfoList::iterator it = awakables_.begin(); it != awakables_.end(); |
46 ++it) { | 47 ++it) { |
47 it->awakable->Awake(MOJO_RESULT_CANCELLED, it->context); | 48 it->awakable->Awake(MOJO_RESULT_CANCELLED, it->context); |
48 } | 49 } |
49 awakables_.clear(); | 50 awakables_.clear(); |
| 51 watchers_.NotifyClosed(); |
50 } | 52 } |
51 | 53 |
52 void AwakableList::Add(Awakable* awakable, | 54 void AwakableList::Add(Awakable* awakable, |
53 MojoHandleSignals signals, | 55 MojoHandleSignals signals, |
54 uintptr_t context) { | 56 uintptr_t context) { |
55 awakables_.push_back(AwakeInfo(awakable, signals, context)); | 57 awakables_.push_back(AwakeInfo(awakable, signals, context)); |
56 } | 58 } |
57 | 59 |
58 void AwakableList::Remove(Awakable* awakable) { | 60 void AwakableList::Remove(Awakable* awakable) { |
59 // We allow a thread to wait on the same handle multiple times simultaneously, | 61 // We allow a thread to wait on the same handle multiple times simultaneously, |
60 // so we need to scan the entire list and remove all occurrences of |waiter|. | 62 // so we need to scan the entire list and remove all occurrences of |waiter|. |
61 auto last = awakables_.end(); | 63 auto last = awakables_.end(); |
62 for (AwakeInfoList::iterator it = awakables_.begin(); it != last;) { | 64 for (AwakeInfoList::iterator it = awakables_.begin(); it != last;) { |
63 if (it->awakable == awakable) { | 65 if (it->awakable == awakable) { |
64 --last; | 66 --last; |
65 std::swap(*it, *last); | 67 std::swap(*it, *last); |
66 } else { | 68 } else { |
67 ++it; | 69 ++it; |
68 } | 70 } |
69 } | 71 } |
70 awakables_.erase(last, awakables_.end()); | 72 awakables_.erase(last, awakables_.end()); |
71 } | 73 } |
72 | 74 |
| 75 MojoResult AwakableList::AddWatcher(MojoHandleSignals signals, |
| 76 const Watcher::WatchCallback& callback, |
| 77 uintptr_t context, |
| 78 const HandleSignalsState& current_state) { |
| 79 return watchers_.Add(signals, callback, context, current_state); |
| 80 } |
| 81 |
| 82 MojoResult AwakableList::RemoveWatcher(uintptr_t context) { |
| 83 return watchers_.Remove(context); |
| 84 } |
| 85 |
73 } // namespace edk | 86 } // namespace edk |
74 } // namespace mojo | 87 } // namespace mojo |
OLD | NEW |