1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "mojo/edk/system/awakable_list.h"
#include <algorithm>
#include "base/logging.h"
#include "mojo/edk/system/awakable.h"
#include "mojo/edk/system/handle_signals_state.h"
namespace mojo {
namespace edk {
AwakableList::AwakableList() {
}
AwakableList::~AwakableList() {
DCHECK(awakables_.empty());
}
void AwakableList::AwakeForStateChange(const HandleSignalsState& state) {
// Instead of deleting elements in-place, swap them with the last element and
// erase the elements from the end.
auto last = awakables_.end();
for (AwakeInfoList::iterator it = awakables_.begin(); it != last;) {
bool keep = true;
if (state.satisfies(it->signals))
keep = it->awakable->Awake(MOJO_RESULT_OK, it->context);
else if (!state.can_satisfy(it->signals))
keep = it->awakable->Awake(MOJO_RESULT_FAILED_PRECONDITION, it->context);
if (!keep) {
--last;
std::swap(*it, *last);
} else {
++it;
}
}
awakables_.erase(last, awakables_.end());
watchers_.NotifyForStateChange(state);
}
void AwakableList::CancelAll() {
for (AwakeInfoList::iterator it = awakables_.begin(); it != awakables_.end();
++it) {
it->awakable->Awake(MOJO_RESULT_CANCELLED, it->context);
}
awakables_.clear();
watchers_.NotifyClosed();
}
void AwakableList::Add(Awakable* awakable,
MojoHandleSignals signals,
uintptr_t context) {
awakables_.push_back(AwakeInfo(awakable, signals, context));
}
void AwakableList::Remove(Awakable* awakable) {
// We allow a thread to wait on the same handle multiple times simultaneously,
// so we need to scan the entire list and remove all occurrences of |waiter|.
auto last = awakables_.end();
for (AwakeInfoList::iterator it = awakables_.begin(); it != last;) {
if (it->awakable == awakable) {
--last;
std::swap(*it, *last);
} else {
++it;
}
}
awakables_.erase(last, awakables_.end());
}
MojoResult AwakableList::AddWatcher(MojoHandleSignals signals,
const Watcher::WatchCallback& callback,
uintptr_t context,
const HandleSignalsState& current_state) {
return watchers_.Add(signals, callback, context, current_state);
}
MojoResult AwakableList::RemoveWatcher(uintptr_t context) {
return watchers_.Remove(context);
}
} // namespace edk
} // namespace mojo
|
