Searched refs:handles (Results 1 - 25 of 217) sorted by relevance

123456789

/external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/system/impl/
H A DCoreImplTest.java98 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 Dbindings_serialization.h48 // 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 Dbindings_serialization.cc64 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 Darray_internal.cc41 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 Dw32_CancelableWait.c60 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 Dfunctions.h65 // 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 Dmessage_pipe.h80 // 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 Dhandle_table.h65 // 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 Dhandle_table.cc80 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 Dcore_unittest.cc151 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 Dentrypoints.cc48 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 Draw_channel_unittest.cc78 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 Doom_priority_manager_unittest.cc147 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 Dmessage_pump_mojo.cc22 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 Drun_loop.cc28 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 DMessagePipeHandleImpl.java36 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 Dwrite_transaction.cc86 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 DMessagePipeHandle.java12 * 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 Dsyncable_util.cc22 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 Dsync_socket_posix.cc72 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 Dcore.cc40 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 Dconnector.js42 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 Dsystem_thunks.cc30 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 Dwaitable_event_win.cc81 HANDLE handles[MAXIMUM_WAIT_OBJECTS]; local
86 handles[i] = events[i]->handle();
91 handles,
/external/chromium_org/content/common/
H A Dgamepad_seqlock_unittest.cc71 PlatformThreadHandle handles[kNumReaderThreads]; local
76 ASSERT_TRUE(PlatformThread::Create(0, &threads[i], &handles[i]));
95 PlatformThread::Join(handles[i]);

Completed in 501 milliseconds

123456789