| /external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/system/impl/ |
| CoreImplTest.java | 71 private void addHandlePairToClose(Pair<? extends Handle, ? extends Handle> handles) {
72 mHandlesToClose.add(handles.first);
73 mHandlesToClose.add(handles.second);
177 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
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 = core.createMessagePipe(null) local
227 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(options); local
249 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
290 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
304 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
328 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
350 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe( local
382 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe(null); local
395 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe(null); local
425 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe(null); local
516 List<Pair<Handle, Core.HandleSignals>> handles = new ArrayList< local
530 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
588 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
614 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
644 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
675 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
700 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
736 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
761 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
781 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe(null); local
826 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); local
[all...] |
| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| 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) {
60 obj->ptr->EncodePointersAndHandles(handles);
66 inline void Decode(T* obj, std::vector<Handle>* handles) {
69 obj->ptr->DecodePointersAndHandles(handles);
|
| bindings_serialization.cc | 63 void EncodeHandle(Handle* handle, std::vector<Handle>* handles) {
65 handles->push_back(*handle);
66 handle->set_value(static_cast<MojoHandle>(handles->size() - 1));
72 void DecodeHandle(Handle* handle, std::vector<Handle>* handles) {
77 MOJO_DCHECK(handle->value() < handles->size());
79 *handle = FetchAndReset(&handles->at(handle->value()));
|
| array_internal.cc | 60 std::vector<Handle>* handles) {
62 EncodeHandle(&elements[i], handles);
69 std::vector<Handle>* handles) {
71 DecodeHandle(&elements[i], handles);
|
| /external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
| 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/java/bindings/src/org/chromium/mojo/bindings/ |
| Message.java | 25 * The handles of the message.
38 * @param handles The list of handles to send.
40 public Message(ByteBuffer buffer, List<? extends Handle> handles) {
43 mHandle = handles;
54 * The handles of the message.
|
| /external/chromium_org/mojo/public/c/system/ |
| functions.h | 77 // Waits on |handles[0]|, ..., |handles[num_handles-1]| until (at least) one
96 // handles satisfying any of its signals.
99 MOJO_SYSTEM_EXPORT MojoResult MojoWaitMany(const MojoHandle* handles,
|
| 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
[all...] |
| /external/chromium_org/mojo/python/tests/ |
| async_wait_unittest.py | 18 self.handles = system.MessagePipe()
19 self.cancel = self.handles.handle0.AsyncWait(system.HANDLE_SIGNAL_READABLE,
25 self.handles = None
33 self.handles.handle1.WriteMessage()
|
| system_unittest.py | 82 def _TestMessageHandleCreation(self, handles):
83 self._testHandlesCreation(handles.handle0, handles.handle1)
96 handles = system.MessagePipe()
97 handle = handles.handle0
104 handles.handle1.WriteMessage()
113 handles = system.MessagePipe()
114 handle0 = handles.handle0
115 handle1 = handles.handle1
139 handles = system.MessagePipe(
[all...] |
| /external/chromium_org/mojo/system/ |
| 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, which must all be present and which should hav
[all...] |
| 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[i
[all...] |
| 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[0] + 1; // Invalid handle
388 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; local
853 MojoHandle handles[10]; local
1209 MojoHandle handles[10]; local
[all...] |
| /external/chromium_org/chrome/browser/chromeos/memory/ |
| 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 are removed
[all...] |
| /external/chromium_org/mojo/common/ |
| 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[i]].handler
[all...] |
| /external/chromium_org/mojo/public/cpp/utility/lib/ |
| 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[i]].handler
[all...] |
| /external/chromium_org/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| MessagePipeHandleImpl.java | 44 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) {
45 mCore.writeMessage(this, bytes, handles, flags);
|
| /external/chromium_org/mojo/public/cpp/system/ |
| message_pipe.h | 52 // ownership of handles (especially when writing messages).
57 const MojoHandle* handles,
60 return MojoWriteMessage(message_pipe.value(), bytes, num_bytes, handles,
67 MojoHandle* handles,
70 return MojoReadMessage(message_pipe.value(), bytes, num_bytes, handles,
75 // handles.
|
| handle.h | 73 // provide the desired level of flexibility/safety: a vector of handles would
208 inline MojoResult WaitMany(const HandleVectorType& handles,
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/sync/internal_api/ |
| sync_rollback_manager.h | 31 SyncerError DeleteOnWorkerThread(ModelType type, std::vector<int64> handles);
|
| 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/system/src/org/chromium/mojo/system/ |
| 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) {
206 mHandles = handles;
218 * attached handles specified by |handles|, and options specified by |flags|. If there is n
[all...] |
| /external/chromium_org/sync/syncable/ |
| 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();
|
| /external/chromium_org/base/ |
| 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[0]
[all...] |
| /external/chromium_org/mojo/public/platform/native/ |
| system_thunks.cc | 32 MojoResult MojoWaitMany(const MojoHandle* handles,
37 return g_thunks.WaitMany(handles, signals, num_handles, deadline);
51 const MojoHandle* handles,
55 return g_thunks.WriteMessage(message_pipe_handle, bytes, num_bytes, handles,
62 MojoHandle* handles,
66 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles,
|
