Lines Matching refs:Handle
66 MojoHandle handle;
67 result = MojoCreateWaitSet(&handle);
69 wait_set_handle_.reset(Handle(handle));
94 const Handle& handle,
98 DCHECK(handle.is_valid());
99 // Assume it's an error if someone tries to reregister an existing handle.
100 CHECK_EQ(0u, handlers_.count(handle));
106 handlers_[handle] = handler_data;
108 bool inserted = deadline_handles_.insert(handle).second;
113 handle.value(), wait_signals);
115 // handle to no longer be open at this point.
119 void MessagePumpMojo::RemoveHandler(const Handle& handle) {
121 MojoRemoveHandle(wait_set_handle_.get().value(), handle.value());
122 // At this point, it's possible that the handle has been closed, which would
124 // possible for the handle to have already been removed, so all of the
129 handlers_.erase(handle);
130 deadline_handles_.erase(handle);
265 // percentile is 1 handle, and the long-term average is 1.1. However, this has
287 base::SmallMap<std::map<Handle, int>, kMaxServiced> ready_handles;
289 const Handle handle = Handle(handles[i]);
290 // Skip the control handle. It's special.
291 if (handle.value() == read_handle_.get().value())
293 DCHECK(handle.is_valid());
294 const auto it = handlers_.find(handle);
296 // RemoveHandler() can be called with a handle that has been closed. Because
297 // the handle is closed, the MojoRemoveHandle() call in RemoveHandler()
298 // would have failed, but the handle is still in the wait set. Once the
299 // handle is retrieved using MojoGetReadyHandles(), it is implicitly removed
301 // the handle was closed, or |MOJO_RESULT_CANCELLED| to indicate that the
302 // handle was closed.
305 ready_handles[handle] = it->second.id;
309 const Handle handle = Handle(handles[i]);
311 // If the handle has been removed, or it's ID has changed, skip over it.
312 // If the handle's ID has changed, and it still satisfies its signals,
314 const auto it = handlers_.find(handle);
315 if ((handle.value() != read_handle_.get().value()) &&
316 (it == handlers_.end() || it->second.id != ready_handles[handle])) {
324 << " handle: " << handle.value();
325 if (handle.value() == read_handle_.get().value()) {
333 // handle.
336 SignalHandleError(handle, handle_results[i]);
340 if (handle.value() == read_handle_.get().value()) {
346 DVLOG(1) << "Handle ready: " << handle.value();
347 SignalHandleReady(handle);
364 // map of <Handle, id>. Then, iterate over those expired handles and remove
367 std::map<Handle, int> expired_handles;
369 for (const Handle handle : deadline_handles_) {
370 const auto it = handlers_.find(handle);
371 // Expect any handle in |deadline_handles_| to also be in |handlers_| since
375 expired_handles[handle] = it->second.id;
409 for (const Handle handle : deadline_handles_) {
410 auto it = handlers_.find(handle);
418 void MessagePumpMojo::SignalHandleReady(Handle handle) {
419 auto it = handlers_.find(handle);
424 handler->OnHandleReady(handle);
428 void MessagePumpMojo::SignalHandleError(Handle handle, MojoResult result) {
429 auto it = handlers_.find(handle);
433 RemoveHandler(handle);
435 handler->OnHandleError(handle, result);
