/external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/system/impl/ |
H A D | CoreImplTest.java | 98 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(); 105 new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE)); 107 new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE)); 114 new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE)); 116 new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE)); 121 handles.first.close(); 122 handles.second.close(); 133 Pair<? extends Handle, ? extends Handle> handles = core.createMessagePipe(); 135 assertEquals(core, handles.first.getCore()); 136 assertEquals(core, handles [all...] |
/external/chromium_org/mojo/public/cpp/bindings/lib/ |
H A D | bindings_serialization.h | 48 // Handles are encoded as indices into a vector of handles. These functions 50 void EncodeHandle(Handle* handle, std::vector<Handle>* handles); 52 void DecodeHandle(Handle* handle, std::vector<Handle>* handles); 58 inline void Encode(T* obj, std::vector<Handle>* handles) { argument 60 obj->ptr->EncodePointersAndHandles(handles); 66 inline void Decode(T* obj, std::vector<Handle>* handles) { argument 69 obj->ptr->DecodePointersAndHandles(handles);
|
H A D | bindings_serialization.cc | 64 void EncodeHandle(Handle* handle, std::vector<Handle>* handles) { argument 66 handles->push_back(*handle); 67 handle->set_value(static_cast<MojoHandle>(handles->size() - 1)); 73 void DecodeHandle(Handle* handle, std::vector<Handle>* handles) { argument 78 assert(handle->value() < handles->size()); 80 *handle = FetchAndReset(&handles->at(handle->value()));
|
H A D | array_internal.cc | 41 std::vector<Handle>* handles) { 43 EncodeHandle(&elements[i], handles); 50 std::vector<Handle>* handles) { 52 DecodeHandle(&elements[i], handles); 38 EncodePointersAndHandles( const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 47 DecodePointersAndHandles( const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument
|
/external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
H A D | w32_CancelableWait.c | 60 HANDLE handles[2]; local 64 handles[0] = waitHandle; 77 if ((handles[1] = sp->cancelEvent) != NULL) 85 handles[1] = NULL; 88 status = WaitForMultipleObjects (nHandles, handles, PTW32_FALSE, timeout); 95 * In the event that both handles are signalled, the smallest index 106 * In the event that both handles are signaled, the cancel will 109 ResetEvent (handles[1]);
|
/external/chromium_org/mojo/public/c/system/ |
H A D | functions.h | 65 // Waits on |handles[0]|, ..., |handles[num_handles-1]| for at least one of them 75 // handles satisfying any of its signals. 78 MOJO_SYSTEM_EXPORT MojoResult MojoWaitMany(const MojoHandle* handles,
|
H A D | message_pipe.h | 80 // handles. 85 // handles for the two endpoints (ports) for the message pipe. 102 // handles specified by |handles| of count |num_handles|, and options specified 104 // |num_bytes| must be zero. If there are no attached handles, |handles| may be 107 // If handles are attached, on success the handles will no longer be valid (the 108 // receiver will receive equivalent, but logically different, handles). Handles 117 // the number of handles t [all...] |
/external/chromium_org/mojo/system/ |
H A D | handle_table.h | 65 // Adds a pair of dispatchers (which must be valid), return a pair of handles 67 // handles will be |MOJO_HANDLE_INVALID|, and neither dispatcher will be 74 // |kMaxMessageNumHandles|). |handles| must point to an array of size at least 78 // |handles[...]| untouched (and all dispatchers unadded). 80 MojoHandle* handles); 82 // Tries to mark the given handles as busy and start transport on them (i.e., 88 const MojoHandle* handles, 92 // Remove the given handles, which must all be present and which should have 94 void RemoveBusyHandles(const MojoHandle* handles, uint32_t num_handles); 96 // Restores the given handles, whic [all...] |
H A D | handle_table.cc | 80 MojoHandle* handles) { 82 DCHECK(handles); 96 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]); 99 handles[i] = MOJO_HANDLE_INVALID; 107 const MojoHandle* handles, 111 DCHECK(handles); 118 // First verify all the handles and get their dispatchers. 124 if (handles[i] == disallowed_handle) { 129 HandleToEntryMap::iterator it = handle_to_entry_map_.find(handles[i]); 209 void HandleTable::RemoveBusyHandles(const MojoHandle* handles, argument 79 AddDispatcherVector(const DispatcherVector& dispatchers, MojoHandle* handles) argument 105 MarkBusyAndStartTransport( MojoHandle disallowed_handle, const MojoHandle* handles, uint32_t num_handles, std::vector<DispatcherTransport>* transports) argument 223 RestoreBusyHandles(const MojoHandle* handles, uint32_t num_handles) argument [all...] |
H A D | core_unittest.cc | 151 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; local 155 core()->WaitMany(handles, signals, 0, MOJO_DEADLINE_INDEFINITE)); 159 core()->WaitMany(handles, NULL, 0, MOJO_DEADLINE_INDEFINITE)); 164 core()->WaitMany(handles, NULL, 1, MOJO_DEADLINE_INDEFINITE)); 166 core()->WaitMany(handles, signals, 1, MOJO_DEADLINE_INDEFINITE)); 169 handles[0] = CreateMockHandle(&info[0]); 172 core()->WaitMany(handles, signals, 1, MOJO_DEADLINE_INDEFINITE)); 174 core()->WaitMany(handles, signals, 2, MOJO_DEADLINE_INDEFINITE)); 175 handles[1] = handles[ 207 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; local 436 MojoHandle handles[10]; local 687 MojoHandle handles[10]; local [all...] |
H A D | entrypoints.cc | 48 MojoResult MojoWaitMany(const MojoHandle* handles, argument 52 return g_core->WaitMany(handles, signals, num_handles, deadline); 65 const MojoHandle* handles, 69 message_pipe_handle, bytes, num_bytes, handles, num_handles, flags); 75 MojoHandle* handles, 79 message_pipe_handle, bytes, num_bytes, handles, num_handles, flags); 62 MojoWriteMessage(MojoHandle message_pipe_handle, const void* bytes, uint32_t num_bytes, const MojoHandle* handles, uint32_t num_handles, MojoWriteMessageFlags flags) argument 72 MojoReadMessage(MojoHandle message_pipe_handle, void* bytes, uint32_t* num_bytes, MojoHandle* handles, uint32_t* num_handles, MojoReadMessageFlags flags) argument
|
H A D | raw_channel_unittest.cc | 78 handles[0] = channel_pair.PassServerHandle(); 79 handles[1] = channel_pair.PassClientHandle(); 85 handles[0].reset(); 86 handles[1].reset(); 92 embedder::ScopedPlatformHandle handles[2]; member in class:mojo::system::__anon8275::RawChannelTest 195 scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass())); 196 TestMessageReaderAndChecker checker(handles[1].get()); 285 scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass())); 294 EXPECT_TRUE(WriteTestMessageToHandle(handles[1].get(), size)); 306 EXPECT_TRUE(WriteTestMessageToHandle(handles[ [all...] |
/external/chromium_org/chrome/browser/chromeos/memory/ |
H A D | oom_priority_manager_unittest.cc | 147 std::vector<base::ProcessHandle> handles; local 149 // Empty stats list gives empty handles list. 151 handles = OomPriorityManager::GetProcessHandles(empty_list); 152 EXPECT_EQ(0u, handles.size()); 154 // Two tabs in two different processes generates two handles out. 160 handles = OomPriorityManager::GetProcessHandles(two_list); 161 EXPECT_EQ(2u, handles.size()); 162 EXPECT_EQ(100, handles[0]); 163 EXPECT_EQ(101, handles[1]); 165 // Zero handles ar [all...] |
/external/chromium_org/mojo/common/ |
H A D | message_pump_mojo.cc | 22 std::vector<Handle> handles; member in struct:mojo::common::MessagePumpMojo::WaitState 116 // There isn't a good way to know if there are more handles ready, we assume 145 WaitMany(wait_state.handles, wait_state.wait_signals, deadline); 153 DCHECK(handlers_.find(wait_state.handles[index]) != handlers_.end()); 154 handlers_[wait_state.handles[index]].handler->OnHandleReady( 155 wait_state.handles[index]); 190 for (size_t i = 1; i < wait_state.handles.size(); ++i) { 192 Wait(wait_state.handles[i], wait_state.wait_signals[i], 0); 198 DCHECK(handlers_.find(wait_state.handles[i]) != handlers_.end()); 200 handlers_[wait_state.handles[ [all...] |
/external/chromium_org/mojo/public/cpp/utility/lib/ |
H A D | run_loop.cc | 28 std::vector<Handle> handles; member in struct:mojo::RunLoop::WaitState 123 if (wait_state.handles.empty()) { 128 const MojoResult result = WaitMany(wait_state.handles, 133 assert(handler_data_.find(wait_state.handles[index]) != 135 handler_data_[wait_state.handles[index]].handler->OnHandleReady( 136 wait_state.handles[index]); 177 for (size_t i = 0; i < wait_state.handles.size(); ++i) { 179 mojo::Wait(wait_state.handles[i], wait_state.handle_signals[i], 185 assert(handler_data_.find(wait_state.handles[i]) != handler_data_.end()); 187 handler_data_[wait_state.handles[ [all...] |
/external/chromium_org/mojo/android/system/src/org/chromium/mojo/system/impl/ |
H A D | MessagePipeHandleImpl.java | 36 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) { argument 37 mCore.writeMessage(this, bytes, handles, flags);
|
/external/chromium_org/sync/internal_api/ |
H A D | write_transaction.cc | 86 syncable::Directory::Metahandles handles; local 88 transaction_, attachment_id.GetProto(), &handles); 89 for (syncable::Directory::Metahandles::iterator iter = handles.begin(); 90 iter != handles.end();
|
/external/chromium_org/mojo/public/java/src/org/chromium/mojo/system/ |
H A D | MessagePipeHandle.java | 12 * can contain plain data and/or Mojo handles. 87 * attached handles specified by |handles|, and options specified by |flags|. If there is no 89 * attached handles, |handles| may be null. 91 * If handles are attached, on success the handles will no longer be valid (the receiver will 92 * receive equivalent, but logically different, handles). Handles to be sent should not be in 95 void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags); argument 111 * If a message was read, the number of handles containe 172 setHandles(List<UntypedHandle> handles) argument [all...] |
/external/chromium_org/sync/syncable/ |
H A D | syncable_util.cc | 22 std::vector<int64> *handles) { 23 trans->directory()->GetUnsyncedMetaHandles(trans, handles); 24 DVLOG_IF(1, !handles->empty()) << "Have " << handles->size() 26 return handles->size(); 21 GetUnsyncedEntries(BaseTransaction* trans, std::vector<int64> *handles) argument
|
/external/chromium_org/base/ |
H A D | sync_socket_posix.cc | 72 Handle handles[2] = { kInvalidHandle, kInvalidHandle }; local 73 if (socketpair(AF_UNIX, SOCK_STREAM, 0, handles) != 0) { 74 CloseHandle(handles[0]); 75 CloseHandle(handles[1]); 82 if (0 != setsockopt(handles[0], SOL_SOCKET, SO_NOSIGPIPE, 84 0 != setsockopt(handles[1], SOL_SOCKET, SO_NOSIGPIPE, 86 CloseHandle(handles[0]); 87 CloseHandle(handles[1]); 92 // Copy the handles out for successful return. 93 socket_a->handle_ = handles[ [all...] |
/external/chromium_org/mojo/bindings/js/ |
H A D | core.cc | 40 const std::vector<mojo::Handle>& handles, 43 return mojo::WaitMany(handles, signals, deadline); 62 const std::vector<gin::Handle<gin::HandleWrapper> >& handles, 64 std::vector<MojoHandle> raw_handles(handles.size()); 65 for (size_t i = 0; i < handles.size(); ++i) 66 raw_handles[i] = handles[i]->get().value(); 73 // MojoWriteMessage takes ownership of the handles upon success, so 76 for (size_t i = 0; i < handles.size(); ++i) 77 ignore_result(handles[i]->release()); 97 std::vector<mojo::Handle> handles(num_handle 39 WaitMany( const std::vector<mojo::Handle>& handles, const std::vector<MojoHandleSignals>& signals, MojoDeadline deadline) argument 59 WriteMessage( mojo::Handle handle, const gin::ArrayBufferView& buffer, const std::vector<gin::Handle<gin::HandleWrapper> >& handles, MojoWriteMessageFlags flags) argument [all...] |
/external/chromium_org/mojo/public/js/bindings/ |
H A D | connector.js | 42 message.handles, 46 // The handles were successfully transferred, so we don't own them 48 message.handles = []; 99 var message = new codec.Message(buffer, read.handles);
|
/external/chromium_org/mojo/public/platform/native/ |
H A D | system_thunks.cc | 30 MojoResult MojoWaitMany(const MojoHandle* handles, argument 35 return g_thunks.WaitMany(handles, signals, num_handles, deadline); 49 const MojoHandle* handles, 53 return g_thunks.WriteMessage(message_pipe_handle, bytes, num_bytes, handles, 60 MojoHandle* handles, 64 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles, 46 MojoWriteMessage(MojoHandle message_pipe_handle, const void* bytes, uint32_t num_bytes, const MojoHandle* handles, uint32_t num_handles, MojoWriteMessageFlags flags) argument 57 MojoReadMessage(MojoHandle message_pipe_handle, void* bytes, uint32_t* num_bytes, MojoHandle* handles, uint32_t* num_handles, MojoReadMessageFlags flags) argument
|
/external/chromium_org/base/synchronization/ |
H A D | waitable_event_win.cc | 81 HANDLE handles[MAXIMUM_WAIT_OBJECTS]; local 86 handles[i] = events[i]->handle(); 91 handles,
|
/external/chromium_org/content/common/ |
H A D | gamepad_seqlock_unittest.cc | 71 PlatformThreadHandle handles[kNumReaderThreads]; local 76 ASSERT_TRUE(PlatformThread::Create(0, &threads[i], &handles[i])); 95 PlatformThread::Join(handles[i]);
|