Home
last modified time | relevance | path

Searched defs:acquire (Results 1 – 25 of 186) sorted by relevance

12345678

/external/pytorch/test/cpp_extensions/open_registration_extension/pytorch_openreg/csrc/
DOpenRegHooks.cpp52 py::gil_scoped_acquire acquire; in exchangeDevice() local
61 py::gil_scoped_acquire acquire; in getDevice() local
71 py::gil_scoped_acquire acquire; in setDevice() local
80 py::gil_scoped_acquire acquire; in uncheckedSetDevice() local
88 py::gil_scoped_acquire acquire; in getStream() local
96 py::gil_scoped_acquire acquire; in getDefaultStream() local
104 py::gil_scoped_acquire acquire; in getStreamFromGlobalPool() local
114 py::gil_scoped_acquire acquire; in getNewStream() local
124 py::gil_scoped_acquire acquire; in exchangeStream() local
133 py::gil_scoped_acquire acquire; in destroyEvent() local
[all …]
DOpenRegMem.cpp23 py::gil_scoped_acquire acquire; in allocate() local
38 py::gil_scoped_acquire acquire; in ReportAndDelete() local
50 py::gil_scoped_acquire acquire; in copy_data() local
/external/pytorch/torch/csrc/utils/
Dpython_symnode.h41 py::gil_scoped_acquire acquire; in wrap_int() local
47 py::gil_scoped_acquire acquire; in wrap_float() local
53 py::gil_scoped_acquire acquire; in wrap_bool() local
79 py::gil_scoped_acquire acquire; in TORCH_SYMNODE_SIZES_STRIDES() local
84 py::gil_scoped_acquire acquire; in is_int() local
89 py::gil_scoped_acquire acquire; in is_float() local
94 py::gil_scoped_acquire acquire; in is_bool() local
99 py::gil_scoped_acquire acquire; in is_nested_int() local
104 py::gil_scoped_acquire acquire; in has_hint() local
109 py::gil_scoped_acquire acquire; in guard_int() local
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
DHealthCheckedChannelPoolTest.java84 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeJustOneCall() local
100 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeManyCalls() local
116 Future<Channel> acquire = channelPool.acquire(); in acquireActiveAndKeepAliveTrue_shouldAcquireOnce() local
133 Future<Channel> acquire = channelPool.acquire(); in acquire_firstChannelKeepAliveFalse_shouldAcquireAnother() local
149 Future<Channel> acquire = channelPool.acquire(); in badDownstreamAcquiresCausesException() local
171 Future<Channel> acquire = channelPool.acquire(); in slowAcquireTimesOut() local
/external/tensorflow/tensorflow/python/lib/io/
Dfile_io_wrapper.cc86 pybind11::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
109 pybind11::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
121 pybind11::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
229 py::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
240 pybind11::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
255 py::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
300 py::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
315 py::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
322 py::gil_scoped_acquire acquire; in PYBIND11_MODULE() local
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
DReleaseOnceChannelPool.java51 public Future<Channel> acquire() { in acquire() method in ReleaseOnceChannelPool
56 public Future<Channel> acquire(Promise<Channel> promise) { in acquire() method in ReleaseOnceChannelPool
DHonorCloseOnReleaseChannelPool.java44 public Future<Channel> acquire() { in acquire() method in HonorCloseOnReleaseChannelPool
49 public Future<Channel> acquire(Promise<Channel> promise) { in acquire() method in HonorCloseOnReleaseChannelPool
DSimpleChannelPoolAwareChannelPool.java36 public Future<Channel> acquire() { in acquire() method in SimpleChannelPoolAwareChannelPool
41 public Future<Channel> acquire(Promise<Channel> promise) { in acquire() method in SimpleChannelPoolAwareChannelPool
DCancellableAcquireChannelPool.java44 public Future<Channel> acquire() { in acquire() method in CancellableAcquireChannelPool
49 public Future<Channel> acquire(Promise<Channel> acquirePromise) { in acquire() method in CancellableAcquireChannelPool
DListenerInvokingChannelPool.java91 public Future<Channel> acquire() { in acquire() method in ListenerInvokingChannelPool
96 public Future<Channel> acquire(Promise<Channel> returnFuture) { in acquire() method in ListenerInvokingChannelPool
DHealthCheckedChannelPool.java59 public Future<Channel> acquire() { in acquire() method in HealthCheckedChannelPool
64 public Future<Channel> acquire(Promise<Channel> resultFuture) { in acquire() method in HealthCheckedChannelPool
DIdleConnectionCountingChannelPool.java72 public Future<Channel> acquire() { in acquire() method in IdleConnectionCountingChannelPool
77 public Future<Channel> acquire(Promise<Channel> promise) { in acquire() method in IdleConnectionCountingChannelPool
/external/rust/android-crates-io/crates/tokio/src/sync/tests/
Dsemaphore_batch.rs164 let mut acquire = task::spawn(s.acquire(1)); in poll_acquire_one_zero_permits() localVariable
202 let mut acquire = task::spawn(s.acquire(1)); in close_semaphore_notifies_permit1() localVariable
252 let mut acquire = task::spawn(s.acquire(8)); in cancel_acquire_releases_permits() localVariable
303 let mut acquire = task::spawn(s.acquire(7)); in update_permits_many_times() localVariable
/external/lottie/snapshot-tests/src/androidTest/java/com/airbnb/lottie/snapshots/utils/
DSuspendingSemaphore.kt17 fun acquire() { in acquire() method
DObjectPool.kt16 fun acquire(): T { in acquire() method
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/util/
DCapacityManager.java50 public boolean acquire() { in acquire() method in CapacityManager
62 public boolean acquire(int capacity) { in acquire() method in CapacityManager
/external/pytorch/torch/csrc/autograd/
Dpython_saved_variable_hooks.cpp21 py::gil_scoped_acquire acquire; in call_pack_hook() local
35 py::gil_scoped_acquire acquire; in call_unpack_hook() local
/external/swiftshader/third_party/llvm-subzero/lib/Support/
DMutex.cpp28 bool MutexImpl::acquire() { return true; } in acquire() function in llvm::MutexImpl
84 MutexImpl::acquire() in acquire() function in llvm::MutexImpl
/external/llvm/lib/Support/
DMutex.cpp28 bool MutexImpl::acquire() { return true; } in acquire() function in llvm::MutexImpl
84 MutexImpl::acquire() in acquire() function in llvm::MutexImpl
/external/pytorch/torch/csrc/distributed/rpc/
Drequest_callback_impl.cpp91 py::gil_scoped_acquire acquire; in serializePyObject() local
111 py::gil_scoped_acquire acquire; in runPythonFunction() local
244 py::gil_scoped_acquire acquire; in handleRRefDelete() local
261 py::gil_scoped_acquire acquire; in processRpcWithErrors() local
/external/tensorflow/tensorflow/python/lib/core/
Dpybind11_status.h106 pybind11::gil_scoped_acquire acquire; in MaybeRaiseRegisteredFromStatusWithGIL() local
132 pybind11::gil_scoped_acquire acquire; in MaybeRaiseRegisteredFromTFStatusWithGIL() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/
DSemaphore.kt44 public suspend fun acquire() in <lambda>() method
170 suspend fun acquire() { in acquire() method
192 protected fun acquire(waiter: CancellableContinuation<Unit>) = acquire( in acquire() method
199 …private inline fun <W> acquire(waiter: W, suspend: (waiter: W) -> Boolean, onAcquired: (waiter: W)… in acquire() method
/external/pigweed/pw_sync_zephyr/public/pw_sync_zephyr/
Dthread_notification_inline.h30 inline void ThreadNotification::acquire() { native_type_.acquire(); } in acquire() function
/external/jetpack-camera-app/core/common/src/main/java/com/google/jetpackcamera/core/common/
DRefCounted.kt69 fun acquire(): T? { in <lambda>() method in com.google.jetpackcamera.core.common.RefCounted
/external/pigweed/pw_sync/public/pw_sync/backends/
Dbinary_semaphore_thread_notification_inline.h24 inline void ThreadNotification::acquire() { native_type_.acquire(); } in acquire() function

12345678