| /external/chromium_org/device/serial/ |
| H A D | async_waiter.cc | 12 : waiter_(mojo::Environment::GetDefaultAsyncWaiter()),
15 id_ = waiter_->AsyncWait(handle.value(),
24 waiter_->CancelWait(id_);
|
| H A D | async_waiter.h | 31 const MojoAsyncWaiter* waiter_; member in class:device::AsyncWaiter
|
| H A D | data_sink_receiver.cc | 84 if (waiter_)
85 waiter_.reset();
126 waiter_.reset();
135 DCHECK(!waiter_ && !shut_down_);
136 waiter_.reset(
143 DCHECK(waiter_ && !shut_down_);
144 waiter_.reset();
220 if (!waiter_)
|
| H A D | data_receiver.cc | 161 waiter_.reset();
181 DCHECK(pending_receive_ && !shut_down_ && waiter_);
182 waiter_.reset();
197 waiter_.reset();
215 waiter_.reset(new AsyncWaiter(
258 waiter_.reset();
|
| H A D | data_source_sender.cc | 82 waiter_.reset();
118 DCHECK(pending_send_ && !waiter_);
119 waiter_.reset(
126 DCHECK(pending_send_ && !shut_down_ && waiter_);
127 waiter_.reset();
|
| H A D | data_receiver.h | 66 // |waiter_| is used to wait until it is ready. If an error occurs in reading
97 scoped_ptr<AsyncWaiter> waiter_; member in class:device::DataReceiver
|
| H A D | data_sender.h | 65 // Copies data from |pending_sends_| into the data pipe and starts |waiter_|
90 scoped_ptr<AsyncWaiter> waiter_; member in class:device::DataSender
|
| H A D | data_sink_receiver.h | 98 scoped_ptr<AsyncWaiter> waiter_; member in class:device::DataSinkReceiver
|
| H A D | data_source_sender.h | 81 scoped_ptr<AsyncWaiter> waiter_; member in class:device::DataSourceSender
|
| H A D | data_sender.cc | 171 waiter_.reset(new AsyncWaiter(
184 waiter_.reset();
203 waiter_.reset();
|
| /external/chromium_org/mojo/system/ |
| H A D | waiter_test_utils.cc | 13 waiter_.Init();
23 *result_ = waiter_.Wait(MOJO_DEADLINE_INDEFINITE, context_);
56 waiter_.Init();
59 &waiter_, handle_signals_, context_, signals_state_out_);
64 *result_out_ = waiter_.Wait(deadline_, context_out_);
65 dispatcher_->RemoveWaiter(&waiter_, signals_state_out_);
|
| H A D | waiter_test_utils.h | 54 Waiter* waiter() { return &waiter_; }
61 Waiter waiter_; member in class:mojo::system::test::SimpleWaiterThread
96 Waiter waiter_; member in class:mojo::system::test::WaiterThread
|
| H A D | dispatcher_unittest.cc | 166 waiter_.Init();
235 dispatcher_->AddWaiter(&waiter_, ~MOJO_HANDLE_SIGNAL_NONE, 0, &hss);
244 dispatcher_->RemoveWaiter(&waiter_, &hss);
256 dispatcher_->RemoveWaiter(&waiter_, &hss);
265 Waiter waiter_; member in class:mojo::system::__anon8849::ThreadSafetyStressThread
|
| H A D | waiter_unittest.cc | 37 waiter_.Init();
61 Waiter* waiter() { return &waiter_; }
71 result = waiter_.Wait(deadline_, &context);
84 Waiter waiter_; // Thread-safe. member in class:mojo::system::__anon8869::WaitingThread
|
| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| H A D | interface_ptr_internal.h | 23 InterfacePtrState() : proxy_(NULL), router_(NULL), waiter_(NULL) {}
44 std::swap(other->waiter_, waiter_);
51 MOJO_DCHECK(!waiter_);
54 waiter_ = waiter;
68 waiter_ = NULL;
117 if (!waiter_) {
127 router_ = new Router(handle_.Pass(), filters.Pass(), waiter_);
128 waiter_ = NULL;
140 // message pipe handle is needed. Before that, |handle_| and |waiter_| stor
143 const MojoAsyncWaiter* waiter_; member in class:mojo::internal::InterfacePtrState
[all...] |
| H A D | connector.cc | 20 waiter_(waiter),
137 async_wait_id_ = waiter_->AsyncWait(message_pipe_.get().value(),
195 waiter_->CancelWait(async_wait_id_);
|
| H A D | connector.h | 88 // Cancels any calls made to |waiter_|.
92 const MojoAsyncWaiter* waiter_; member in class:mojo::internal::Connector
|
| /external/chromium_org/base/synchronization/ |
| H A D | waitable_event_watcher_posix.cc | 114 waiter_(NULL),
171 waiter_ = new AsyncWaiter(current_ml, internal_callback_, cancel_flag_.get());
172 event->Enqueue(waiter_);
225 if (kernel_->Dequeue(waiter_, cancel_flag_.get())) {
230 delete waiter_;
|
| H A D | waitable_event_watcher.h | 103 AsyncWaiter* waiter_; member in class:base::WaitableEventWatcher
|
| /external/chromium_org/extensions/renderer/resources/ |
| H A D | data_receiver.js | 120 this.waiter_.stop();
183 this.waiter_ = new asyncWaiter.AsyncWaiter(this.receivePipe_,
223 this.waiter_.stop();
296 this.waiter_.start();
319 this.waiter_.start();
341 this.waiter_.stop();
|
| H A D | data_sender.js | 194 this.waiter_.stop();
253 this.waiter_ = new asyncWaiter.AsyncWaiter(
306 this.waiter_.stop();
358 if (!this.waiter_.isWaiting())
359 this.waiter_.start();
404 this.waiter_.start();
|
| /external/chromium_org/chrome/browser/extensions/ |
| H A D | extension_gcm_app_handler_unittest.cc | 138 waiter_(waiter),
162 waiter_->SignalCompleted();
179 Waiter* waiter_; member in class:extensions::FakeExtensionGCMAppHandler
258 gcm_app_handler_.reset(new FakeExtensionGCMAppHandler(profile(), &waiter_));
266 waiter_.PumpUILoop();
348 waiter_.PumpIOLoop();
353 waiter_.PumpIOLoop();
368 waiter_.SignalCompleted();
380 Waiter* waiter() { return &waiter_; }
407 Waiter waiter_; member in class:extensions::ExtensionGCMAppHandlerTest
[all...] |