/external/chromium_org/mojo/bindings/js/ |
H A D | core.cc | 41 const std::vector<mojo::Handle>& handles, 44 return mojo::WaitMany(handles, signals, deadline); 87 const std::vector<gin::Handle<gin::HandleWrapper> >& handles, 89 std::vector<MojoHandle> raw_handles(handles.size()); 90 for (size_t i = 0; i < handles.size(); ++i) 91 raw_handles[i] = handles[i]->get().value(); 98 // MojoWriteMessage takes ownership of the handles upon success, so 101 for (size_t i = 0; i < handles.size(); ++i) 102 ignore_result(handles[i]->release()); 122 std::vector<mojo::Handle> handles(num_handle 40 WaitMany( const std::vector<mojo::Handle>& handles, const std::vector<MojoHandleSignals>& signals, MojoDeadline deadline) argument 84 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/java/system/src/org/chromium/mojo/system/ |
H A D | MessagePipeHandle.java | 12 * can contain plain data and/or Mojo handles. 144 * If a message was read, the number of handles contained in the message, otherwise the 145 * number of handles contained in the next message. 149 * If a message was read, the handles contained in the message, undefined otherwise. 196 * @return the handles 203 * @param handles the handles to set 205 public void setHandles(List<UntypedHandle> handles) { argument 206 mHandles = handles; 218 * attached handles specifie 226 writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) argument [all...] |
/external/chromium_org/mojo/system/ |
H A D | core_unittest.cc | 250 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; local 254 core()->WaitMany(MakeUserPointer(handles), 286 core()->WaitMany(MakeUserPointer(handles), 293 core()->WaitMany(MakeUserPointer(handles), 304 core()->WaitMany(MakeUserPointer(handles), 317 handles[0] = CreateMockHandle(&info[0]); 322 core()->WaitMany(MakeUserPointer(handles), 336 core()->WaitMany(MakeUserPointer(handles), 347 handles[1] = handles[ 388 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; local 853 MojoHandle handles[10]; local 1209 MojoHandle handles[10]; local [all...] |
H A D | handle_table.cc | 77 MojoHandle* handles) { 79 DCHECK(handles); 93 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]); 96 handles[i] = MOJO_HANDLE_INVALID; 104 const MojoHandle* handles, 108 DCHECK(handles); 115 // First verify all the handles and get their dispatchers. 121 if (handles[i] == disallowed_handle) { 126 HandleToEntryMap::iterator it = handle_to_entry_map_.find(handles[i]); 149 "to transfer handle " << handles[ 76 AddDispatcherVector(const DispatcherVector& dispatchers, MojoHandle* handles) argument 102 MarkBusyAndStartTransport( MojoHandle disallowed_handle, const MojoHandle* handles, uint32_t num_handles, std::vector<DispatcherTransport>* transports) argument 212 RemoveBusyHandles(const MojoHandle* handles, uint32_t num_handles) argument 226 RestoreBusyHandles(const MojoHandle* handles, uint32_t num_handles) argument [all...] |
/external/chromium_org/ppapi/proxy/ |
H A D | resource_message_params.h | 27 // Note that the caller doesn't take ownership of the returned handles. 28 const std::vector<SerializedHandle>& handles() const { function in class:ppapi::proxy::ResourceMessageParams 32 // Makes ResourceMessageParams leave its handles open, even if they weren't 46 // Helper functions to return shared memory, socket or file handles passed in 65 std::vector<base::SharedMemoryHandle>* handles) const; 67 // Appends the given handle to the list of handles sent with the call or 78 // Writes everything except the handles to |msg|. 80 // Writes the handles to |msg|. 99 // Whether the handles stored in |data_| should be closed when this object 105 // ResourceMessageReplyParams) will close those handles whic [all...] |
/external/chromium_org/sync/engine/ |
H A D | apply_control_data_updates_unittest.cc | 122 Syncer::UnsyncedMetaHandles handles; local 123 GetUnsyncedEntries(&trans, &handles); 124 EXPECT_TRUE(handles.empty()); 165 Syncer::UnsyncedMetaHandles handles; local 166 GetUnsyncedEntries(&trans, &handles); 167 EXPECT_EQ(2*batch_s+1, handles.size()); 183 Syncer::UnsyncedMetaHandles handles; local 184 GetUnsyncedEntries(&trans, &handles); 185 EXPECT_EQ(2*batch_s+1, handles.size()); 209 Syncer::UnsyncedMetaHandles handles; local 234 Syncer::UnsyncedMetaHandles handles; local 279 Syncer::UnsyncedMetaHandles handles; local 299 Syncer::UnsyncedMetaHandles handles; local [all...] |
H A D | directory_update_handler.cc | 113 std::vector<int64> handles; local 117 &handles); 121 applicator.AttemptApplications(&trans, handles); 148 handles.clear(); 152 &handles); 155 conflict_applicator.AttemptApplications(&trans, handles);
|
H A D | process_updates_util.cc | 313 syncable::Directory::Metahandles handles; local 314 dir->GetMetaHandlesOfType(trans, type, &handles); 315 for (size_t i = 0; i < handles.size(); ++i) { 317 handles[i]);
|
/external/chromium_org/sync/syncable/ |
H A D | nigori_util.cc | 36 std::vector<int64> handles; local 37 GetUnsyncedEntries(trans, &handles); 38 for (size_t i = 0; i < handles.size(); ++i) { 39 MutableEntry entry(trans, GET_BY_HANDLE, handles[i]); 54 std::vector<int64> handles; local 55 GetUnsyncedEntries(trans, &handles); 56 for (size_t i = 0; i < handles.size(); ++i) { 57 Entry entry(trans, GET_BY_HANDLE, handles[i]);
|
/external/chromium_org/third_party/protobuf/src/google/protobuf/compiler/ |
H A D | subprocess.cc | 101 // Setup STARTUPINFO to redirect handles. 125 TRUE, // inherit handles? 161 HANDLE handles[2]; local 165 handles[handle_count++] = child_stdin_; 168 handles[handle_count++] = child_stdout_; 172 WaitForMultipleObjects(handle_count, handles, FALSE, INFINITE); 177 signaled_handle = handles[wait_result - WAIT_OBJECT_0];
|
/external/protobuf/src/google/protobuf/compiler/ |
H A D | subprocess.cc | 98 // Setup STARTUPINFO to redirect handles. 122 TRUE, // inherit handles? 158 HANDLE handles[2]; local 162 handles[handle_count++] = child_stdin_; 165 handles[handle_count++] = child_stdout_; 169 WaitForMultipleObjects(handle_count, handles, FALSE, INFINITE); 174 signaled_handle = handles[wait_result - WAIT_OBJECT_0];
|
/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/cloud_print/service/win/ |
H A D | chrome_launcher.cc | 227 HANDLE handles[] = { stop_event_.handle(), chrome_handle.Get() }; local 231 wait_result = ::WaitForMultipleObjects(arraysize(handles), handles,
|
/external/chromium_org/components/nacl/loader/ |
H A D | nacl_listener.cc | 210 // On Windows, valid handles are 32 bit unsigned integers so this is safe. 370 std::vector<nacl::FileDescriptor> handles = params.handles; local 381 CHECK(handles.size() >= 1); 382 g_shm_fd = nacl::ToNativeHandle(handles[handles.size() - 1]); 383 handles.pop_back(); 388 CHECK(handles.size() >= 1); 389 NaClHandle irt_handle = nacl::ToNativeHandle(handles[handles [all...] |
/external/chromium_org/content/browser/indexed_db/ |
H A D | indexed_db_fake_backing_store.cc | 86 ScopedVector<storage::BlobDataHandle>* handles, 80 PutRecord( IndexedDBBackingStore::Transaction* transaction, int64 database_id, int64 object_store_id, const IndexedDBKey& key, IndexedDBValue* value, ScopedVector<storage::BlobDataHandle>* handles, RecordIdentifier* record) argument
|
/external/chromium_org/device/usb/ |
H A D | usb_device_impl.cc | 420 HandlesVector handles; local 421 swap(handles, handles_); 422 for (HandlesVector::iterator it = handles.begin(); it != handles.end(); ++it)
|
/external/chromium_org/ipc/mojo/ |
H A D | ipc_channel_mojo.cc | 232 DLOG(WARNING) << "Pipe failed to covert handles. Closing: " 248 std::vector<MojoHandle>* handles) { 249 // We dup() the handles in IPC::Message to transmit. 270 DLOG(WARNING) << "Pipe failed to wrap handles. Closing: " 276 handles->push_back(wrapped_handle); 246 ReadFromFileDescriptorSet( Message* message, std::vector<MojoHandle>* handles) argument
|
H A D | ipc_channel_mojo_readers.cc | 138 std::vector<MojoHandle> handles; local 141 ChannelMojo::ReadFromFileDescriptorSet(message.get(), &handles); 143 std::for_each(handles.begin(), handles.end(), &MojoClose); 152 handles.empty() ? NULL : &handles[0], 153 static_cast<uint32>(handles.size()), 156 std::for_each(handles.begin(), handles.end(), &MojoClose);
|
/external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/system/impl/ |
H A D | CoreImplTest.java | 71 private void addHandlePairToClose(Pair<? extends Handle, ? extends Handle> handles) { argument 72 mHandlesToClose.add(handles.first); 73 mHandlesToClose.add(handles.second); 177 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); 178 addHandlePairToClose(handles); 183 new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); 185 new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); 192 new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); 194 new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); 207 Pair<? extends Handle, ? extends Handle> handles [all...] |
/external/chromium_org/mojo/common/ |
H A D | message_pump_mojo.cc | 41 std::vector<Handle> handles; member in struct:mojo::common::MessagePumpMojo::WaitState 144 // There isn't a good way to know if there are more handles ready, we assume 173 WaitMany(wait_state.handles, wait_state.wait_signals, deadline); 181 DCHECK(handlers_.find(wait_state.handles[index]) != handlers_.end()); 182 handlers_[wait_state.handles[index]].handler->OnHandleReady( 183 wait_state.handles[index]); 217 for (size_t i = 0; i < wait_state.handles.size(); ++i) { 219 Wait(wait_state.handles[i], wait_state.wait_signals[i], 0); 231 CHECK(handlers_.find(wait_state.handles[i]) != handlers_.end()); 233 handlers_[wait_state.handles[ [all...] |
/external/chromium_org/mojo/embedder/ |
H A D | embedder_unittest.cc | 230 MojoHandle handles[10] = {}; local 231 uint32_t num_handles = arraysize(handles); 236 handles, 242 EXPECT_NE(handles[0], MOJO_HANDLE_INVALID); 243 h1 = handles[0]; 253 memset(handles, 0, sizeof(handles)); 254 num_handles = arraysize(handles); 259 handles, 535 // TODO(vtl): If the scope were to end here (and the two handles close [all...] |
/external/chromium_org/mojo/public/cpp/bindings/lib/ |
H A D | array_internal.h | 175 std::vector<Handle>* handles) { 180 std::vector<Handle>* handles) { 202 std::vector<Handle>* handles); 206 std::vector<Handle>* handles); 222 "invalid handle in array expecting valid handles", 241 std::vector<Handle>* handles) { 243 header, elements, handles); 248 std::vector<Handle>* handles) { 250 header, elements, handles); 269 std::vector<Handle>* handles) { 173 EncodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 178 DecodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 239 EncodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 246 DecodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 267 EncodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument 274 DecodePointersAndHandles(const ArrayHeader* header, ElementType* elements, std::vector<Handle>* handles) argument [all...] |
/external/chromium_org/mojo/public/cpp/system/ |
H A D | handle.h | 73 // provide the desired level of flexibility/safety: a vector of handles would 208 inline MojoResult WaitMany(const HandleVectorType& handles, argument 211 if (signals.size() != handles.size()) 213 if (handles.size() > std::numeric_limits<uint32_t>::max()) 216 if (handles.size() == 0) 219 const Handle& first_handle = handles[0]; 224 static_cast<uint32_t>(handles.size()),
|
/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 146 if (wait_state.handles.empty() && delayed_tasks_.empty()) { 151 const MojoResult result = WaitMany(wait_state.handles, 156 assert(handler_data_.find(wait_state.handles[index]) != 158 handler_data_[wait_state.handles[index]].handler->OnHandleReady( 159 wait_state.handles[index]); 207 for (size_t i = 0; i < wait_state.handles.size(); ++i) { 209 mojo::Wait(wait_state.handles[i], wait_state.handle_signals[i], 215 assert(handler_data_.find(wait_state.handles[i]) != handler_data_.end()); 217 handler_data_[wait_state.handles[ [all...] |
/external/chromium_org/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
H A D | Encoder.java | 21 * It also keeps track of the associated handles, and the offset of the current data section. 42 * The list of encountered handles. 44 public final List<Handle> handles = new ArrayList<Handle>(); field in class:Encoder.EncoderState 52 * @param core the |Core| implementation used to generate handles. Only used if the |Struct| 115 return new Message(mEncoderState.byteBuffer, mEncoderState.handles); 121 * @param core the |Core| implementation used to generate handles. Only used if the |Struct| 242 encode(mEncoderState.handles.size(), offset); 243 mEncoderState.handles.add(v); 270 Pair<MessagePipeHandle, MessagePipeHandle> handles = 272 manager.bind(v, handles [all...] |