Searched refs:Waiter (Results 1 - 25 of 46) sorted by relevance

12

/external/chromium_org/mojo/system/
H A Dwaiter.h19 // IMPORTANT (all-caps gets your attention, right?): |Waiter| methods are called
20 // under other locks, in particular, |Dispatcher::lock_|s, so |Waiter| methods
23 class MOJO_SYSTEM_IMPL_EXPORT Waiter { class in namespace:mojo::system
25 Waiter();
26 ~Waiter();
28 // A |Waiter| can be used multiple times; |Init()| should be called before
75 DISALLOW_COPY_AND_ASSIGN(Waiter);
H A Dwaiter_list.h19 class Waiter;
22 // |WaiterList| tracks all the |Waiter|s that are waiting on a given
36 void AddWaiter(Waiter* waiter, MojoHandleSignals signals, uint32_t context);
37 void RemoveWaiter(Waiter* waiter);
41 WaiterInfo(Waiter* waiter, MojoHandleSignals signals, uint32_t context)
44 Waiter* waiter;
H A Dwaiter.cc15 Waiter::Waiter() function in class:mojo::system::Waiter
25 Waiter::~Waiter() {
28 void Waiter::Init() {
39 MojoResult Waiter::Wait(MojoDeadline deadline, uint32_t* context) {
85 void Waiter::Awake(MojoResult result, uint32_t context) {
H A Dmessage_pipe_endpoint.h26 class Waiter;
68 virtual MojoResult AddWaiter(Waiter* waiter,
72 virtual void RemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state);
H A Dmessage_pipe_endpoint.cc34 MojoResult MessagePipeEndpoint::AddWaiter(Waiter* /*waiter*/,
44 void MessagePipeEndpoint::RemoveWaiter(Waiter* /*waiter*/,
H A Dsimple_dispatcher.h35 Waiter* waiter,
40 Waiter* waiter,
H A Dsimple_dispatcher.cc29 Waiter* waiter,
52 Waiter* waiter,
H A Dwaiter_test_utils.h23 // This is a very simple thread that has a |Waiter|, on which it waits
25 // |Waiter| on creation, but the caller must start the thread with |Start()|. It
42 // |Waiter::Init()|, |AddWaiter()|, and |RemoveWaiter()| are done in the main
54 Waiter* waiter() { return &waiter_; }
61 Waiter waiter_;
66 // This is a more complex and realistic thread that has a |Waiter|, on which it
96 Waiter waiter_;
H A Dmessage_pipe.h29 class Waiter;
80 Waiter* waiter,
85 Waiter* waiter,
H A Ddata_pipe_consumer_dispatcher.h49 Waiter* waiter,
54 Waiter* waiter,
H A Ddata_pipe_producer_dispatcher.h50 Waiter* waiter,
55 Waiter* waiter,
H A Dlocal_message_pipe_endpoint.h40 virtual MojoResult AddWaiter(Waiter* waiter,
44 virtual void RemoveWaiter(Waiter* waiter,
H A Dwaiter_list.cc39 void WaiterList::AddWaiter(Waiter* waiter,
45 void WaiterList::RemoveWaiter(Waiter* waiter) {
H A Ddata_pipe.h23 class Waiter;
61 MojoResult ProducerAddWaiter(Waiter* waiter,
65 void ProducerRemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state);
85 MojoResult ConsumerAddWaiter(Waiter* waiter,
89 void ConsumerRemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state);
H A Ddata_pipe_producer_dispatcher.cc86 Waiter* waiter,
95 Waiter* waiter,
H A Ddispatcher.h43 class Waiter;
146 MojoResult AddWaiter(Waiter* waiter,
154 void RemoveWaiter(Waiter* waiter, HandleSignalsState* signals_state);
270 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
274 virtual void RemoveWaiterImplNoLock(Waiter* waiter,
H A Ddata_pipe_consumer_dispatcher.cc109 Waiter* waiter,
118 Waiter* waiter,
/external/chromium_org/base/synchronization/
H A Dwaitable_event.h113 class Waiter { class in class:base::WaitableEvent
117 // Consider the case of a Waiter which is in multiple WaitableEvent's
125 // Because of this, a Waiter may "reject" a wake by returning false. In
137 virtual ~Waiter() {}
159 bool Dequeue(Waiter* waiter, void* tag);
164 std::list<Waiter*> waiters_;
179 size_t count, Waiter* waiter);
183 void Enqueue(Waiter* waiter);
H A Dwaitable_event_posix.cc85 class SyncWaiter : public WaitableEvent::Waiter {
312 // The locks of the WaitableEvents have been taken in order and the Waiter has
316 // None of the WaitableEvent locks are held. The Waiter has not been enqueued
323 size_t count, Waiter* waiter) {
366 for (std::list<Waiter*>::iterator
395 void WaitableEvent::Enqueue(Waiter* waiter) {
403 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) {
404 for (std::list<Waiter*>::iterator
/external/chromium_org/extensions/browser/
H A Dtest_extension_registry_observer.cc12 class TestExtensionRegistryObserver::Waiter { class in class:extensions::TestExtensionRegistryObserver
14 explicit Waiter(const std::string& extension_id) function in class:extensions::TestExtensionRegistryObserver::Waiter
38 DISALLOW_COPY_AND_ASSIGN(Waiter);
44 : will_be_installed_waiter_(new Waiter(extension_id)),
45 uninstalled_waiter_(new Waiter(extension_id)),
46 loaded_waiter_(new Waiter(extension_id)),
47 unloaded_waiter_(new Waiter(extension_id)),
H A Dtest_extension_registry_observer.h27 class Waiter;
47 scoped_ptr<Waiter> will_be_installed_waiter_;
48 scoped_ptr<Waiter> uninstalled_waiter_;
49 scoped_ptr<Waiter> loaded_waiter_;
50 scoped_ptr<Waiter> unloaded_waiter_;
/external/chromium_org/net/socket/
H A Dwebsocket_endpoint_lock_manager.h24 class NET_EXPORT_PRIVATE Waiter : public base::LinkNode<Waiter> { class in class:net::WebSocketEndpointLockManager
27 virtual ~Waiter();
36 // it is. A Waiter automatically removes itself from the list of waiters when
38 int LockEndpoint(const IPEndPoint& endpoint, Waiter* waiter);
66 typedef base::LinkedList<Waiter> WaiterQueue;
H A Dwebsocket_endpoint_lock_manager.cc15 WebSocketEndpointLockManager::Waiter::~Waiter() {
27 Waiter* waiter) {
116 Waiter* next_job = queue->head()->value();
/external/chromium_org/chrome/browser/chromeos/login/lock/
H A Dscreen_locker_browsertest.cc43 class Waiter : public content::NotificationObserver { class in namespace:__anon3291
45 explicit Waiter(Browser* browser) function in class:__anon3291::Waiter
56 virtual ~Waiter() {
89 DISALLOW_COPY_AND_ASSIGN(Waiter);
188 Waiter waiter(browser());
196 Waiter waiter(browser());
211 Waiter waiter(browser());
221 Waiter waiter(browser());
232 Waiter waiter(browser());
/external/chromium_org/chrome/browser/extensions/
H A Dextension_gcm_app_handler_unittest.cc72 class Waiter { class in namespace:extensions
74 Waiter() {} function in class:extensions::Waiter
75 ~Waiter() {}
99 base::Bind(&Waiter::OnIOLoopPump, base::Unretained(this)));
117 base::Bind(&Waiter::OnIOLoopPumpCompleted, base::Unretained(this)));
126 base::Bind(&Waiter::PumpIOLoopCompleted, base::Unretained(this)));
131 DISALLOW_COPY_AND_ASSIGN(Waiter);
136 FakeExtensionGCMAppHandler(Profile* profile, Waiter* waiter)
179 Waiter* waiter_;
380 Waiter* waite
[all...]

Completed in 876 milliseconds

12