Home
last modified time | relevance | path

Searched refs:handles (Results 1 – 25 of 1037) sorted by relevance

12345678910>>...42

/external/libmojo/mojo/android/javatests/src/org/chromium/mojo/system/impl/
DCoreImplTest.java77 private void addHandlePairToClose(Pair<? extends Handle, ? extends Handle> handles) { in addHandlePairToClose() argument
78 mHandlesToClose.add(handles.first); in addHandlePairToClose()
79 mHandlesToClose.add(handles.second); in addHandlePairToClose()
195 Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null); in testWaitMany() local
196 addHandlePairToClose(handles); in testWaitMany()
203 new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); in testWaitMany()
205 new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); in testWaitMany()
217 new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); in testWaitMany()
219 new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); in testWaitMany()
236 Pair<? extends Handle, ? extends Handle> handles = core.createMessagePipe(null); in testGetCore() local
[all …]
/external/libmojo/mojo/edk/system/
Dnode_channel.cc288 ScopedPlatformHandleVectorPtr handles(new PlatformHandleVector()); in AddBrokerClient() local
290 handles->push_back(PlatformHandle(process_handle)); in AddBrokerClient()
294 handles->size(), &data); in AddBrokerClient()
295 message->SetHandles(std::move(handles)); in AddBrokerClient()
307 ScopedPlatformHandleVectorPtr handles(new PlatformHandleVector()); in BrokerClientAdded() local
309 handles->push_back(broker_channel.release()); in BrokerClientAdded()
312 handles->size(), &data); in BrokerClientAdded()
313 message->SetHandles(std::move(handles)); in BrokerClientAdded()
321 ScopedPlatformHandleVectorPtr handles(new PlatformHandleVector()); in AcceptBrokerClient() local
323 handles->push_back(broker_channel.release()); in AcceptBrokerClient()
[all …]
Dbroker_host_posix.cc55 ScopedPlatformHandleVectorPtr handles; in SendChannel() local
56 handles.reset(new PlatformHandleVector(1)); in SendChannel()
57 handles->at(0) = handle.release(); in SendChannel()
58 message->SetHandles(std::move(handles)); in SendChannel()
79 ScopedPlatformHandleVectorPtr handles; in OnBufferRequest() local
80 handles.reset(new PlatformHandleVector(2)); in OnBufferRequest()
81 handles->at(0) = buffer->PassPlatformHandle().release(); in OnBufferRequest()
82 handles->at(1) = read_only_buffer->PassPlatformHandle().release(); in OnBufferRequest()
83 message->SetHandles(std::move(handles)); in OnBufferRequest()
91 ScopedPlatformHandleVectorPtr handles) { in OnChannelMessage() argument
Dchannel_posix.cc74 void SetHandles(ScopedPlatformHandleVectorPtr handles) { in SetHandles() argument
75 handles_ = std::move(handles); in SetHandles()
149 ScopedPlatformHandleVectorPtr* handles) override { in GetReadPlatformHandles() argument
164 handles->reset(); in GetReadPlatformHandles()
168 handles->reset(new PlatformHandleVector(num_handles)); in GetReadPlatformHandles()
173 (*handles)->at(i) = PlatformHandle( in GetReadPlatformHandles()
175 CHECK((*handles)->at(i).type == PlatformHandle::Type::MACH); in GetReadPlatformHandles()
178 (*handles)->at(i).type = PlatformHandle::Type::MACH_NAME; in GetReadPlatformHandles()
182 (*handles)->at(i) = incoming_platform_handles_.front(); in GetReadPlatformHandles()
188 handles->reset(); in GetReadPlatformHandles()
[all …]
Dcore_unittest.cc215 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; in TEST_F() local
220 core()->WaitMany(handles, signals, 0, MOJO_DEADLINE_INDEFINITE, in TEST_F()
240 core()->WaitMany(handles, nullptr, 0, MOJO_DEADLINE_INDEFINITE, in TEST_F()
244 core()->WaitMany(handles, signals, 1, MOJO_DEADLINE_INDEFINITE, nullptr, in TEST_F()
252 handles, signals, 1, MOJO_DEADLINE_INDEFINITE, &result_index, in TEST_F()
261 handles[0] = CreateMockHandle(&info[0]); in TEST_F()
267 handles, signals, 1, MOJO_DEADLINE_INDEFINITE, &result_index, in TEST_F()
278 handles, signals, 2, MOJO_DEADLINE_INDEFINITE, &result_index, in TEST_F()
285 handles[1] = handles[0] + 1; // Invalid handle. in TEST_F()
288 core()->WaitMany(handles, signals, 2, MOJO_DEADLINE_INDEFINITE, nullptr, in TEST_F()
[all …]
Dmultiprocess_message_pipe_unittest.cc223 MojoHandle handles[10]; in DEFINE_TEST_CLIENT_WITH_PIPE() local
224 uint32_t num_handlers = arraysize(handles); // Maximum number to receive in DEFINE_TEST_CLIENT_WITH_PIPE()
226 &num_bytes, &handles[0], in DEFINE_TEST_CLIENT_WITH_PIPE()
235 CHECK_EQ(MojoMapBuffer(handles[0], 0, 100, &buffer, in DEFINE_TEST_CLIENT_WITH_PIPE()
244 MojoClose(handles[0]); in DEFINE_TEST_CLIENT_WITH_PIPE()
301 MojoHandle handles[1]; in TEST_F() local
302 handles[0] = duplicated_shared_buffer; in TEST_F()
305 static_cast<uint32_t>(go1.size()), &handles[0], in TEST_F()
306 arraysize(handles), in TEST_F()
370 MojoHandle handles[255]; // Maximum number to receive. in DEFINE_TEST_CLIENT_WITH_PIPE() local
[all …]
Dchannel.cc192 ScopedPlatformHandleVectorPtr handles( in Deserialize() local
195 (*handles)[i].handle = reinterpret_cast<HANDLE>( in Deserialize()
198 message->SetHandles(std::move(handles)); in Deserialize()
320 PlatformHandleVector* handles) { in RewriteHandles() argument
322 for (size_t i = 0; i < handles->size(); ++i) { in RewriteHandles()
323 if (!(*handles)[i].is_valid()) { in RewriteHandles()
327 DCHECK_EQ((*handles)[i].owning_process, from_process); in RewriteHandles()
329 from_process, (*handles)[i].handle, to_process, in RewriteHandles()
330 &(*handles)[i].handle, 0, FALSE, in RewriteHandles()
333 (*handles)[i].owning_process = to_process; in RewriteHandles()
[all …]
Dhandle_table.cc32 MojoHandle* handles) { in AddDispatchersFromTransit() argument
47 handles[i] = handle; in AddDispatchersFromTransit()
75 const MojoHandle* handles, in BeginTransit() argument
81 auto it = handles_.find(handles[i]); in BeginTransit()
88 d.local_handle = handles[i]; in BeginTransit()
118 void HandleTable::GetActiveHandlesForTest(std::vector<MojoHandle>* handles) { in GetActiveHandlesForTest() argument
119 handles->clear(); in GetActiveHandlesForTest()
121 handles->push_back(entry.first); in GetActiveHandlesForTest()
/external/libmojo/mojo/message_pump/
Dmessage_pump_mojo_unittest.cc90 MessagePipe handles; in TEST() local
92 handles.handle0.get(), in TEST()
96 handles.handle1.get(), NULL, 0, NULL, 0, MOJO_WRITE_MESSAGE_FLAG_NONE); in TEST()
98 handles.handle1.get(), NULL, 0, NULL, 0, MOJO_WRITE_MESSAGE_FLAG_NONE); in TEST()
101 MojoWait(handles.handle0.get().value(), MOJO_HANDLE_SIGNAL_READABLE, in TEST()
116 MessagePipe handles; in TEST() local
118 handles.handle0.get(), in TEST()
122 handles.handle1.get(), NULL, 0, NULL, 0, MOJO_WRITE_MESSAGE_FLAG_NONE); in TEST()
126 MojoWait(handles.handle0.get().value(), MOJO_HANDLE_SIGNAL_READABLE, in TEST()
137 handles.handle1.get(), NULL, 0, NULL, 0, MOJO_WRITE_MESSAGE_FLAG_NONE); in TEST()
[all …]
/external/python/cpython2/Python/
Ddynload_shlib.c65 } handles[128]; variable
92 if (statb.st_dev == handles[i].dev && in _PyImport_GetDynLoadFunc()
93 statb.st_ino == handles[i].ino) { in _PyImport_GetDynLoadFunc()
94 p = (dl_funcptr) dlsym(handles[i].handle, in _PyImport_GetDynLoadFunc()
100 handles[nhandles].dev = statb.st_dev; in _PyImport_GetDynLoadFunc()
102 handles[nhandles].ino[0] = statb.st_ino[0]; in _PyImport_GetDynLoadFunc()
103 handles[nhandles].ino[1] = statb.st_ino[1]; in _PyImport_GetDynLoadFunc()
104 handles[nhandles].ino[2] = statb.st_ino[2]; in _PyImport_GetDynLoadFunc()
106 handles[nhandles].ino = statb.st_ino; in _PyImport_GetDynLoadFunc()
140 handles[nhandles++].handle = handle; in _PyImport_GetDynLoadFunc()
/external/curl/tests/libtest/
Dlib1900.c34 CURL *handles[MAX_URLS]; variable
107 handles[i] = curl_easy_init(); in create_handles()
117 curl_easy_setopt(handles[handlenum], CURLOPT_URL, urlbuf); in setup_handle()
118 curl_easy_setopt(handles[handlenum], CURLOPT_VERBOSE, 1L); in setup_handle()
119 curl_easy_setopt(handles[handlenum], CURLOPT_FAILONERROR, 1L); in setup_handle()
120 curl_easy_setopt(handles[handlenum], CURLOPT_WRITEFUNCTION, write_callback); in setup_handle()
121 curl_easy_setopt(handles[handlenum], CURLOPT_WRITEDATA, NULL); in setup_handle()
122 curl_multi_add_handle(m, handles[handlenum]); in setup_handle()
130 if(handles[i]) in remove_handles()
131 curl_easy_cleanup(handles[i]); in remove_handles()
[all …]
/external/curl/docs/examples/
Dmulti-app.c48 CURL *handles[HANDLECOUNT]; in main() local
59 handles[i] = curl_easy_init(); in main()
62 curl_easy_setopt(handles[HTTP_HANDLE], CURLOPT_URL, "http://example.com"); in main()
64 curl_easy_setopt(handles[FTP_HANDLE], CURLOPT_URL, "ftp://example.com"); in main()
65 curl_easy_setopt(handles[FTP_HANDLE], CURLOPT_UPLOAD, 1L); in main()
72 curl_multi_add_handle(multi_handle, handles[i]); in main()
154 found = (msg->easy_handle == handles[idx]); in main()
174 curl_easy_cleanup(handles[i]); in main()
/external/libmojo/mojo/public/cpp/system/
Dhandle.h230 inline WaitManyResult WaitMany(const HandleVectorType& handles, in WaitMany() argument
234 if (signals.size() != handles.size() || in WaitMany()
237 if (handles.size() >= kInvalidWaitManyIndexValue) in WaitMany()
240 if (handles.size() == 0) { in WaitMany()
246 const Handle& first_handle = handles[0]; in WaitMany()
252 &first_signals, static_cast<uint32_t>(handles.size()), in WaitMany()
261 inline WaitManyResult WaitMany(const HandleVectorType& handles, in WaitMany() argument
265 if (signals.size() != handles.size()) in WaitMany()
267 if (handles.size() >= kInvalidWaitManyIndexValue) in WaitMany()
270 if (handles.size() == 0) { in WaitMany()
[all …]
Dmessage_pipe.h73 const MojoHandle* handles, in WriteMessageRaw() argument
77 message_pipe.value(), bytes, num_bytes, handles, num_handles, flags); in WriteMessageRaw()
85 MojoHandle* handles, in ReadMessageRaw() argument
89 message_pipe.value(), bytes, num_bytes, handles, num_handles, flags); in ReadMessageRaw()
106 MojoHandle* handles, in ReadMessageNew() argument
111 num_bytes, handles, num_handles, flags); in ReadMessageNew()
/external/libmojo/mojo/public/interfaces/bindings/tests/
Dregression_tests.mojom56 // Previously, a field or parameter called |handles| would be shadowed by a
59 EmptyStruct handles;
63 handle handles;
67 int32 handles;
71 HandlesNameCollisionUnion handles;
75 Method(EmptyStruct handles) => (handle handles);
/external/libchrome/base/
Dsync_socket_posix.cc75 Handle handles[2] = { kInvalidHandle, kInvalidHandle }; in CreatePair() local
76 if (socketpair(AF_UNIX, SOCK_STREAM, 0, handles) != 0) { in CreatePair()
77 CloseHandle(handles[0]); in CreatePair()
78 CloseHandle(handles[1]); in CreatePair()
85 if (0 != setsockopt(handles[0], SOL_SOCKET, SO_NOSIGPIPE, in CreatePair()
87 0 != setsockopt(handles[1], SOL_SOCKET, SO_NOSIGPIPE, in CreatePair()
89 CloseHandle(handles[0]); in CreatePair()
90 CloseHandle(handles[1]); in CreatePair()
96 socket_a->handle_ = handles[0]; in CreatePair()
97 socket_b->handle_ = handles[1]; in CreatePair()
/external/libmojo/mojo/edk/embedder/
Dentrypoints.cc38 MojoResult MojoWaitManyImpl(const MojoHandle* handles, in MojoWaitManyImpl() argument
44 return g_core->WaitMany(handles, signals, num_handles, deadline, result_index, in MojoWaitManyImpl()
60 const MojoHandle* handles, in MojoAllocMessageImpl() argument
64 return g_core->AllocMessage(num_bytes, handles, num_handles, flags, message); in MojoAllocMessageImpl()
92 MojoHandle* handles, in MojoGetReadyHandlesImpl() argument
95 return g_core->GetReadyHandles(wait_set_handle, count, handles, results, in MojoGetReadyHandlesImpl()
110 const MojoHandle* handles, in MojoWriteMessageImpl() argument
113 return g_core->WriteMessage(message_pipe_handle, bytes, num_bytes, handles, in MojoWriteMessageImpl()
126 MojoHandle* handles, in MojoReadMessageImpl() argument
130 message_pipe_handle, bytes, num_bytes, handles, num_handles, flags); in MojoReadMessageImpl()
[all …]
/external/syslinux/efi/
Dconsole.c76 EFI_HANDLE *handles = NULL; in setup_gop() local
96 NULL, &nr_handles, &handles); in setup_gop()
99 handles = AllocatePool(nr_handles); in setup_gop()
100 if (!handles) in setup_gop()
104 NULL, &nr_handles, &handles); in setup_gop()
113 EFI_HANDLE *h = handles[i]; in setup_gop()
211 if (handles) FreePool(handles); in setup_gop()
246 EFI_HANDLE *handles; in setup_uga() local
251 NULL, &nr_handles, &handles); in setup_uga()
257 EFI_HANDLE *handle = handles[i]; in setup_uga()
[all …]
/external/libmojo/mojo/public/c/system/
Dthunks.cc33 MojoResult MojoWaitMany(const MojoHandle* handles, in MojoWaitMany() argument
40 return g_thunks.WaitMany(handles, signals, num_handles, deadline, in MojoWaitMany()
55 const MojoHandle* handles, in MojoWriteMessage() argument
59 return g_thunks.WriteMessage(message_pipe_handle, bytes, num_bytes, handles, in MojoWriteMessage()
66 MojoHandle* handles, in MojoReadMessage() argument
70 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles, in MojoReadMessage()
180 MojoHandle* handles, in MojoGetReadyHandles() argument
184 return g_thunks.GetReadyHandles(wait_set, count, handles, results, in MojoGetReadyHandles()
216 MojoHandle* handles, in MojoReadMessageNew() argument
221 handles, num_handles, flags); in MojoReadMessageNew()
[all …]
/external/tpm2/
DGetCapability.c43 &out->capabilityData.data.handles); in TPM2_GetCapability()
49 &out->capabilityData.data.handles); in TPM2_GetCapability()
55 &out->capabilityData.data.handles); in TPM2_GetCapability()
61 &out->capabilityData.data.handles); in TPM2_GetCapability()
67 &out->capabilityData.data.handles); in TPM2_GetCapability()
73 &out->capabilityData.data.handles); in TPM2_GetCapability()
80 &out->capabilityData.data.handles); in TPM2_GetCapability()
/external/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/
DCoreImpl.java97 public WaitManyResult waitMany(List<Pair<Handle, HandleSignals>> handles, long deadline) { in waitMany() argument
106 ByteBuffer buffer = allocateDirectBuffer(handles.size() * 16 + 4); in waitMany()
108 for (Pair<Handle, HandleSignals> handle : handles) { in waitMany()
111 HANDLE_SIZE * handles.size() + FLAG_SIZE * index, handle.second.getFlags()); in waitMany()
117 result.setHandleIndex(buffer.getInt(handles.size() * 16)); in waitMany()
120 HandleSignalsState[] states = new HandleSignalsState[handles.size()]; in waitMany()
121 for (int i = 0; i < handles.size(); ++i) { in waitMany()
123 new HandleSignals(buffer.getInt(8 * (handles.size() + i))), in waitMany()
124 new HandleSignals(buffer.getInt(8 * (handles.size() + i) + 4))); in waitMany()
278 List<? extends Handle> handles, MessagePipeHandle.WriteFlags flags) { in writeMessage() argument
[all …]
/external/libmojo/mojo/public/cpp/bindings/lib/
Dmessage.cc33 std::vector<Handle>* handles) { in InitializeFromMojoMessage() argument
36 handles_.swap(*handles); in InitializeFromMojoMessage()
97 std::vector<Handle> handles; in ReadMessage() local
108 handles.resize(num_handles); in ReadMessage()
112 reinterpret_cast<MojoHandle*>(handles.data()), in ReadMessage()
121 std::move(mojo_message), num_bytes, &handles); in ReadMessage()
/external/mesa3d/src/amd/vulkan/winsys/amdgpu/
Dradv_amdgpu_cs.c47 amdgpu_bo_handle *handles; member
144 free(cs->handles); in radv_amdgpu_cs_destroy()
313 unsigned hash = ((uintptr_t)cs->handles[i] >> 6) & in radv_amdgpu_cs_reset()
342 if (cs->handles[index] == bo) in radv_amdgpu_cs_find_buffer()
346 if (cs->handles[i] == bo) { in radv_amdgpu_cs_find_buffer()
369 cs->handles = realloc(cs->handles, new_count * sizeof(amdgpu_bo_handle)); in radv_amdgpu_cs_add_buffer_internal()
374 cs->handles[cs->num_buffers] = bo; in radv_amdgpu_cs_add_buffer_internal()
400 radv_amdgpu_cs_add_buffer_internal(parent, child->handles[i], in radv_amdgpu_cs_execute_secondary()
430 amdgpu_bo_handle *handles; in radv_amdgpu_create_bo_list() local
435 handles = malloc(sizeof(handles[0]) * ws->num_buffers); in radv_amdgpu_create_bo_list()
[all …]
/external/libmojo/mojo/public/cpp/system/tests/
Dcore_unittest.cc285 MojoHandle handles[5]; in TEST() local
286 handles[0] = mp.handle1.release().value(); in TEST()
287 EXPECT_NE(kInvalidHandleValue, handles[0]); in TEST()
294 handles, in TEST()
298 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, MojoClose(handles[0])); in TEST()
308 for (size_t i = 0; i < arraysize(handles); i++) in TEST()
309 handles[i] = kInvalidHandleValue; in TEST()
310 handles_count = static_cast<uint32_t>(arraysize(handles)); in TEST()
315 handles, in TEST()
321 EXPECT_NE(kInvalidHandleValue, handles[0]); in TEST()
[all …]
/external/libmojo/mojo/edk/js/
Dcore.cc64 const std::vector<mojo::Handle>& handles, in WaitMany() argument
72 mojo::WaitMany(handles, signals, deadline, &signals_states); in WaitMany()
81 for (size_t i = 0; i < handles.size(); ++i) { in WaitMany()
137 const std::vector<gin::Handle<HandleWrapper> >& handles, in WriteMessage()
139 std::vector<MojoHandle> raw_handles(handles.size()); in WriteMessage()
140 for (size_t i = 0; i < handles.size(); ++i) in WriteMessage()
141 raw_handles[i] = handles[i]->get().value(); in WriteMessage()
149 for (size_t i = 0; i < handles.size(); ++i) in WriteMessage()
150 ignore_result(handles[i]->release()); in WriteMessage()
170 std::vector<mojo::Handle> handles(num_handles); in ReadMessage() local
[all …]

12345678910>>...42