| /external/v8/src/handles/ |
| D | local-handles-inl.h | 18 LocalHandles* handles = local_heap->handles(); in GetHandle() local
19 Address* result = handles->scope_.next; in GetHandle()
20 if (result == handles->scope_.limit) { in GetHandle()
21 result = handles->AddBlock(); in GetHandle()
23 DCHECK_LT(result, handles->scope_.limit); in GetHandle()
24 handles->scope_.next++; in GetHandle()
33 LocalHandles* handles = local_heap->handles(); in LocalHandleScope() local
35 prev_next_ = handles->scope_.next; in LocalHandleScope()
36 prev_limit_ = handles->scope_.limit; in LocalHandleScope()
37 handles->scope_.level++; in LocalHandleScope()
[all …]
|
| /external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/system/impl/ |
| D | CoreImplTest.java | 80 private void addHandlePairToClose(Pair<? extends Handle, ? extends Handle> handles) { in addHandlePairToClose() argument
81 mHandlesToClose.add(handles.first); in addHandlePairToClose()
82 mHandlesToClose.add(handles.second); in addHandlePairToClose()
171 Pair<? extends Handle, ? extends Handle> handles = core.createMessagePipe(null); in testGetCore() local
172 addHandlePairToClose(handles); in testGetCore()
173 Assert.assertEquals(core, handles.first.getCore()); in testGetCore()
174 Assert.assertEquals(core, handles.second.getCore()); in testGetCore()
176 handles = core.createDataPipe(null); in testGetCore()
177 addHandlePairToClose(handles); in testGetCore()
178 Assert.assertEquals(core, handles.first.getCore()); in testGetCore()
[all …]
|
| D | WatcherImplTest.java | 74 private void addHandlePairToClose(Pair<? extends Handle, ? extends Handle> handles) { in addHandlePairToClose() argument
75 mHandlesToClose.add(handles.first); in addHandlePairToClose()
76 mHandlesToClose.add(handles.second); in addHandlePairToClose()
120 Pair<MessagePipeHandle, MessagePipeHandle> handles = mCore.createMessagePipe(null); in testCorrectResult() local
121 addHandlePairToClose(handles); in testCorrectResult()
122 final WatcherResult watcherResult = new WatcherResult(handles.first); in testCorrectResult()
125 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testCorrectResult()
128 handles.second.writeMessage( in testCorrectResult()
141 Pair<MessagePipeHandle, MessagePipeHandle> handles = mCore.createMessagePipe(null); in testClosingPeerHandle() local
142 addHandlePairToClose(handles); in testClosingPeerHandle()
[all …]
|
| /external/libchrome/mojo/core/ |
| D | broker_host.cc | 52 std::vector<PlatformHandleInTransit>* handles) { in PrepareHandlesForClient() argument
55 for (auto& handle : *handles) { in PrepareHandlesForClient()
78 std::vector<PlatformHandleInTransit> handles(1); in SendChannel() local
79 handles[0] = PlatformHandleInTransit(std::move(handle)); in SendChannel()
83 if (!PrepareHandlesForClient(&handles)) in SendChannel()
86 message->SetHandles(std::move(handles)); in SendChannel()
110 std::vector<PlatformHandleInTransit> handles(2); in OnBufferRequest() local
115 handles[0] = PlatformHandleInTransit(std::move(h[0])); in OnBufferRequest()
116 handles[1] = PlatformHandleInTransit(std::move(h[1])); in OnBufferRequest()
121 DCHECK(!handles[1].handle().is_valid()); in OnBufferRequest()
[all …]
|
| D | message_unittest.cc | 65 virtual void SerializeHandles(MojoHandle* handles) = 0;
75 std::vector<MojoHandle> handles(num_handles); in SerializeMessageContext() local
77 message->SerializeHandles(handles.data()); in SerializeMessageContext()
85 message_handle, base::checked_cast<uint32_t>(num_bytes), handles.data(), in SerializeMessageContext()
114 void SerializeHandles(MojoHandle* handles) override { NOTREACHED(); } in SerializeHandles() argument
137 std::vector<mojo::ScopedMessagePipeHandle>& handles() { return handles_; } in handles() function in mojo::core::__anonff00f8140111::SimpleMessage
146 void SerializeHandles(MojoHandle* handles) override { in SerializeHandles() argument
149 handles[i] = handles_[i].release().value(); in SerializeHandles()
291 MojoHandle handles[4]; in DEFINE_TEST_CLIENT_TEST_WITH_PIPE() local
292 auto m = MojoTestBase::ReadMessageWithHandles(h, handles, 4); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
|
| D | node_channel.cc | 285 std::vector<PlatformHandle> handles; in AddBrokerClient() local
287 handles.emplace_back(base::win::ScopedHandle(process_handle.release())); in AddBrokerClient()
291 handles.size(), &data); in AddBrokerClient()
292 message->SetHandles(std::move(handles)); in AddBrokerClient()
304 std::vector<PlatformHandle> handles; in BrokerClientAdded() local
306 handles.emplace_back(std::move(broker_channel)); in BrokerClientAdded()
309 sizeof(BrokerClientAddedData), handles.size(), &data); in BrokerClientAdded()
310 message->SetHandles(std::move(handles)); in BrokerClientAdded()
318 std::vector<PlatformHandle> handles; in AcceptBrokerClient() local
320 handles.emplace_back(std::move(broker_channel)); in AcceptBrokerClient()
[all …]
|
| D | channel_fuchsia.cc | 54 zx_handle_t handles[FDIO_MAX_HANDLES] = {}; in UnwrapPlatformHandle() local
57 fdio_transfer_fd(handle.handle().GetFD().get(), 0, handles, info); in UnwrapPlatformHandle()
65 result = fdio_clone_fd(handle.handle().GetFD().get(), 0, handles, info); in UnwrapPlatformHandle()
82 PlatformHandleInTransit(PlatformHandle(zx::handle(handles[i])))); in UnwrapPlatformHandle()
89 base::circular_deque<zx::handle>* handles) { in WrapPlatformHandles() argument
92 out_handle = PlatformHandle(std::move(handles->front())); in WrapPlatformHandles()
93 handles->pop_front(); in WrapPlatformHandles()
102 fd_handles[i] = (*handles)[i].get(); in WrapPlatformHandles()
118 ignore_result(handles->front().release()); in WrapPlatformHandles()
119 handles->pop_front(); in WrapPlatformHandles()
[all …]
|
| D | multiprocess_message_pipe_unittest.cc | 54 std::vector<ScopedHandle> handles; in MojoReadMessage() local
56 ReadMessageRaw(MessagePipeHandle(pipe), &bytes, &handles, flags); in MojoReadMessage()
68 *num_handles = static_cast<uint32_t>(handles.size()); in MojoReadMessage()
69 if (!handles.empty()) { in MojoReadMessage()
70 CHECK(out_handles && num_handles && *num_handles >= handles.size()); in MojoReadMessage()
71 for (size_t i = 0; i < handles.size(); ++i) in MojoReadMessage()
72 out_handles[i] = handles[i].release().value(); in MojoReadMessage()
80 const MojoHandle* handles, in MojoWriteMessage() argument
83 return WriteMessageRaw(MessagePipeHandle(pipe), bytes, num_bytes, handles, in MojoWriteMessage()
272 MojoHandle handles[10]; in DEFINE_TEST_CLIENT_WITH_PIPE() local
[all …]
|
| D | channel_posix.cc | 82 void SetHandles(std::vector<PlatformHandleInTransit> handles) { in SetHandles() argument
83 handles_ = std::move(handles); in SetHandles()
193 std::vector<PlatformHandle>* handles, in GetReadPlatformHandles() argument
269 handles->resize(handles_in_transit.size()); in GetReadPlatformHandles()
270 for (size_t i = 0; i < handles->size(); ++i) in GetReadPlatformHandles()
271 handles->at(i) = handles_in_transit[i].TakeHandle(); in GetReadPlatformHandles()
276 handles->resize(num_handles); in GetReadPlatformHandles()
278 handles->at(i) = PlatformHandle(std::move(incoming_fds_.front())); in GetReadPlatformHandles()
394 std::vector<PlatformHandle> handles(message.handles.size()); in FlushPendingMessagesWithMachPortsOnIOThread() local
395 for (size_t i = 0; i < message.handles.size(); ++i) { in FlushPendingMessagesWithMachPortsOnIOThread()
[all …]
|
| /external/igt-gpu-tools/lib/ |
| D | igt_syncobj.c | 182 syncobj_wait_err(int fd, uint32_t *handles, uint32_t count, in syncobj_wait_err() argument
187 wait.handles = to_user_pointer(handles); in syncobj_wait_err()
211 syncobj_wait(int fd, uint32_t *handles, uint32_t count, in syncobj_wait() argument
218 wait.handles = to_user_pointer(handles); in syncobj_wait()
237 __syncobj_reset(int fd, uint32_t *handles, uint32_t count) in __syncobj_reset() argument
242 array.handles = to_user_pointer(handles); in __syncobj_reset()
258 syncobj_reset(int fd, uint32_t *handles, uint32_t count) in syncobj_reset() argument
260 igt_assert_eq(__syncobj_reset(fd, handles, count), 0); in syncobj_reset()
264 __syncobj_signal(int fd, uint32_t *handles, uint32_t count) in __syncobj_signal() argument
269 array.handles = to_user_pointer(handles); in __syncobj_signal()
[all …]
|
| D | igt_syncobj.h | 36 __u64 handles; member
46 __u64 handles; member
63 int syncobj_wait_err(int fd, uint32_t *handles, uint32_t count,
65 bool syncobj_wait(int fd, uint32_t *handles, uint32_t count,
68 void syncobj_reset(int fd, uint32_t *handles, uint32_t count);
69 void syncobj_signal(int fd, uint32_t *handles, uint32_t count);
|
| /external/tensorflow/tensorflow/compiler/xla/tests/ |
| D | deconstruct_tuple_test.cc | 66 auto handles = result_status.ConsumeValueOrDie(); in TEST_F() local
68 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[0])); in TEST_F()
70 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[1])); in TEST_F()
117 auto handles = result_status.ConsumeValueOrDie(); in XLA_TEST_F() local
120 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[0])); in XLA_TEST_F()
122 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[1])); in XLA_TEST_F()
124 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[2])); in XLA_TEST_F()
126 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[3])); in XLA_TEST_F()
139 auto handles = result_status.ConsumeValueOrDie(); in TEST_F() local
146 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[0])); in TEST_F()
[all …]
|
| /external/python/cpython2/Python/ |
| D | dynload_shlib.c | 65 } 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/perfetto/src/tracing/consumer_api_deprecated/ |
| D | consumer_api_deprecated_test.cc | 125 std::array<Handle, 5> handles{}; in TestMany() local
126 for (size_t i = 0; i < handles.size(); i++) { in TestMany()
128 handles[i] = handle; in TestMany()
136 for (size_t i = 0; i < handles.size(); i++) { in TestMany()
137 if (PollState(handles[i]) != State::kConfigured) { in TestMany()
145 for (size_t i = 0; i < handles.size(); i++) { in TestMany()
147 StartTracing(handles[i]); in TestMany()
155 for (size_t i = 0; i < handles.size(); i++) { in TestMany()
156 if (PollState(handles[i]) == State::kTraceEnded) { in TestMany()
164 for (size_t i = 0; i < handles.size(); i++) { in TestMany()
[all …]
|
| /external/minigbm/cros_gralloc/gralloc4/ |
| D | CrosGralloc4Allocator.cc | 83 hidl_vec<hidl_handle> handles; in allocate() local
87 hidlCb(Error::NO_RESOURCES, 0, handles); in allocate()
96 hidlCb(Error::BAD_DESCRIPTOR, 0, handles); in allocate()
100 handles.resize(count); in allocate()
103 for (int i = 0; i < handles.size(); i++) { in allocate()
104 Error err = allocate(description, &stride, &(handles[i])); in allocate()
107 mDriver->release(handles[j].getNativeHandle()); in allocate()
109 handles.resize(0); in allocate()
110 hidlCb(err, 0, handles); in allocate()
115 hidlCb(Error::NONE, stride, handles); in allocate()
[all …]
|
| /external/igt-gpu-tools/tests/ |
| D | kms_getfb.c | 102 add.handles[0] = gem_create(fd, size); in get_ccs_fb()
103 igt_require(add.handles[0] != 0); in get_ccs_fb()
104 add.handles[1] = add.handles[0]; in get_ccs_fb()
109 gem_close(fd, add.handles[0]); in get_ccs_fb()
138 add.handles[0] = igt_create_bo_with_dimensions(fd, 1024, 1024, in test_handle_input()
140 igt_require(add.handles[0] != 0); in test_handle_input()
174 gem_close(fd, add.handles[0]); in test_handle_input()
186 add.handles[0] = igt_create_bo_with_dimensions(fd, 1024, 1024, in test_duplicate_handles()
188 igt_assert(add.handles[0]); in test_duplicate_handles()
196 igt_assert_neq_u32(get.handle, add.handles[0]); in test_duplicate_handles()
[all …]
|
| /external/skqp/src/compute/skc/platforms/cl_12/ |
| D | handle_pool_cl_12.c | 119 skc_uint const handles = blocks * width; in skc_handle_pool_create() local
123 skc_extent_pdrw_alloc(runtime,&handle_pool->map,handles * sizeof(skc_block_id_t)); in skc_handle_pool_create()
126 …refcnts = skc_runtime_host_perm_alloc(runtime,SKC_MEM_FLAGS_READ_WRITE,handles * sizeof(*… in skc_handle_pool_create()
131 for (skc_uint ii=0; ii<handles; ii++) in skc_handle_pool_create()
134 for (skc_uint ii=0; ii<handles; ii++) in skc_handle_pool_create()
137 handle_pool->handle.count = handles; in skc_handle_pool_create()
206 skc_handle_t * handles = handle_pool->handle.indices + (index + 1) * handle_pool->block.width; in skc_handle_pool_block_readable_pop()
208 printf("R-: %u\n",*--handles); in skc_handle_pool_block_readable_pop()
222 skc_handle_t * handles = handle_pool->handle.indices + (index + 1) * handle_pool->block.width; in skc_handle_pool_block_readable_push()
224 printf("R+: %u\n",*--handles); in skc_handle_pool_block_readable_push()
[all …]
|
| /external/curl/tests/libtest/ |
| D | lib1900.c | 34 static 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/libchrome/mojo/core/test/ |
| D | mojo_test_base.cc | 110 const MojoHandle* handles, in WriteMessageWithHandles() argument
113 static_cast<uint32_t>(message.size()), handles, in WriteMessageWithHandles()
131 std::vector<ScopedHandle> handles; in ReadMessageWithHandles() local
133 ReadMessageRaw(MessagePipeHandle(mp), &bytes, &handles, in ReadMessageWithHandles()
135 CHECK_EQ(expected_num_handles, handles.size()); in ReadMessageWithHandles()
136 for (size_t i = 0; i < handles.size(); ++i) in ReadMessageWithHandles()
137 out_handles[i] = handles[i].release().value(); in ReadMessageWithHandles()
148 std::vector<ScopedHandle> handles; in ReadMessageWithOptionalHandle() local
150 ReadMessageRaw(MessagePipeHandle(mp), &bytes, &handles, in ReadMessageWithOptionalHandle()
152 CHECK(handles.size() == 0 || handles.size() == 1); in ReadMessageWithOptionalHandle()
[all …]
|
| /external/curl/docs/examples/ |
| D | multi-app.c | 48 CURL *handles[HANDLECOUNT]; in main() local
59 handles[i] = curl_easy_init(); in main()
62 curl_easy_setopt(handles[HTTP_HANDLE], CURLOPT_URL, "https://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 int found = (msg->easy_handle == handles[idx]); in main()
174 curl_easy_cleanup(handles[i]); in main()
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | message_pipe.cc | 14 const MojoHandle* handles, in WriteMessageRaw() argument
27 base::checked_cast<uint32_t>(num_bytes), handles, in WriteMessageRaw()
46 std::vector<ScopedHandle>* handles, in ReadMessageRaw() argument
63 DCHECK(handles); in ReadMessageRaw()
64 handles->resize(num_handles); in ReadMessageRaw()
67 reinterpret_cast<MojoHandle*>(handles->data()), &num_handles); in ReadMessageRaw()
79 if (handles && !num_handles) in ReadMessageRaw()
80 handles->clear(); in ReadMessageRaw()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | pending_counts_test.cc | 80 PendingCounts::Handle handles[2]; in TEST() local
81 handles[0] = layout.CreateHandle(5, 4); in TEST()
82 handles[1] = layout.CreateHandle(15, 4); in TEST()
84 PendingCounts::Handle h = handles[id]; in TEST()
115 std::vector<PendingCounts::Handle> handles(C); in TEST() local
117 handles[id] = layout.CreateHandle(id, id); in TEST()
121 c.set_initial_count(handles[id], id); in TEST()
125 PendingCounts::Handle h = handles[id]; in TEST()
140 PendingCounts::Handle handles[2]; in TEST() local
141 handles[0] = layout.CreateHandle(5, 4); in TEST()
[all …]
|
| /external/python/cpython3/Python/ |
| D | dynload_shlib.c | 54 } handles[128]; variable
84 if (status.st_dev == handles[i].dev && in _PyImport_FindSharedFuncptr()
85 status.st_ino == handles[i].ino) { in _PyImport_FindSharedFuncptr()
86 p = (dl_funcptr) dlsym(handles[i].handle, in _PyImport_FindSharedFuncptr()
92 handles[nhandles].dev = status.st_dev; in _PyImport_FindSharedFuncptr()
93 handles[nhandles].ino = status.st_ino; in _PyImport_FindSharedFuncptr()
129 handles[nhandles++].handle = handle; in _PyImport_FindSharedFuncptr()
|
| /external/libchrome/mojo/public/interfaces/bindings/tests/ |
| D | regression_tests.mojom | 56 // 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/ |
| D | sync_socket_posix.cc | 76 Handle handles[2] = { kInvalidHandle, kInvalidHandle }; in CreatePair() local
77 if (socketpair(AF_UNIX, SOCK_STREAM, 0, handles) != 0) { in CreatePair()
78 CloseHandle(handles[0]); in CreatePair()
79 CloseHandle(handles[1]); in CreatePair()
86 if (0 != setsockopt(handles[0], SOL_SOCKET, SO_NOSIGPIPE, in CreatePair()
88 0 != setsockopt(handles[1], SOL_SOCKET, SO_NOSIGPIPE, in CreatePair()
90 CloseHandle(handles[0]); in CreatePair()
91 CloseHandle(handles[1]); in CreatePair()
97 socket_a->handle_ = handles[0]; in CreatePair()
98 socket_b->handle_ = handles[1]; in CreatePair()
|