| /external/grpc-grpc/src/ruby/pb/grpc/health/ |
| D | checker.rb | 37 @status_mutex.synchronize do
48 @status_mutex.synchronize { @statuses["#{service}"] = status }
53 @status_mutex.synchronize do
60 @status_mutex.synchronize do
67 @status_mutex.synchronize { @statuses.delete("#{service}") }
72 @status_mutex.synchronize { @statuses = {} }
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 60 @stop_mutex.synchronize do
76 @stop_mutex.synchronize do
95 @stop_mutex.synchronize do # wait @keep_alive seconds for workers to stop
128 @stop_mutex.synchronize do
145 @stop_mutex.synchronize do
243 @run_mutex.synchronize do
254 @run_mutex.synchronize do
288 @run_mutex.synchronize do
327 @run_mutex.synchronize do
345 @run_mutex.synchronize do
[all …]
|
| D | active_call.rb | 120 @send_initial_md_mutex.synchronize do
230 @send_initial_md_mutex.synchronize do
359 @send_initial_md_mutex.synchronize do
442 @send_initial_md_mutex.synchronize do
573 @send_initial_md_mutex.synchronize do
589 @call_finished_mu.synchronize do
599 @call_finished_mu.synchronize do
621 @client_call_executed_mu.synchronize do
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | __init__.py | 175 from multiprocessing.synchronize import Lock
182 from multiprocessing.synchronize import RLock
189 from multiprocessing.synchronize import Condition
196 from multiprocessing.synchronize import Semaphore
203 from multiprocessing.synchronize import BoundedSemaphore
210 from multiprocessing.synchronize import Event
|
| /external/webrtc/examples/objc/AppRTCMobile/ |
| D | ARDSettingsStore.m | 66 [self.storage synchronize];
75 [self.storage synchronize];
84 [self.storage synchronize];
93 [self.storage synchronize];
102 [self.storage synchronize];
111 [self.storage synchronize];
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | context.py | 67 from .synchronize import Lock
72 from .synchronize import RLock
77 from .synchronize import Condition
82 from .synchronize import Semaphore
87 from .synchronize import BoundedSemaphore
92 from .synchronize import Event
97 from .synchronize import Barrier
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | rpc_server_pool_spec.rb | 49 wait_mu.synchronize do
61 wait_mu.synchronize do
104 wait_forever_mu.synchronize do
|
| /external/grpc-grpc/src/ruby/lib/grpc/ |
| D | notifier.rb | 30 @mutex.synchronize do
36 @mutex.synchronize do
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | sig_handling_driver.rb | 43 client_started_mu.synchronize do
55 client_started_mu.synchronize do
|
| D | killed_client_thread_driver.rb | 42 client_started_mu.synchronize do
58 client_started_mu.synchronize do
|
| /external/llvm-project/openmp/libomptarget/src/ |
| D | device.cpp | 433 if (!AsyncInfoPtr || !RTL->data_submit_async || !RTL->synchronize) in submitData()
443 if (!AsyncInfoPtr || !RTL->data_retrieve_async || !RTL->synchronize) in retrieveData()
453 if (!AsyncInfo || !RTL->data_exchange_async || !RTL->synchronize) { in dataExchange()
466 if (!AsyncInfoPtr || !RTL->run_region || !RTL->synchronize) in runRegion()
480 if (!AsyncInfoPtr || !RTL->run_team_region_async || !RTL->synchronize) in runTeamRegion()
502 int32_t DeviceTy::synchronize(__tgt_async_info *AsyncInfoPtr) { in synchronize() function in DeviceTy
503 if (RTL->synchronize) in synchronize()
504 return RTL->synchronize(RTLDeviceID, AsyncInfoPtr); in synchronize()
|
| D | rtl.h | 88 synchronize_ty *synchronize = nullptr; member
128 synchronize = r.synchronize; in RTLInfoTy()
|
| /external/angle/src/libANGLE/renderer/cl/ |
| D | CLContextCL.h | 107 const auto data = mData.synchronize(); in hasMemory()
113 const auto data = mData.synchronize(); in hasSampler()
119 const auto data = mData.synchronize(); in hasDeviceQueue()
|
| /external/ImageMagick/MagickCore/ |
| D | matrix.c | 77 synchronize; member
192 if (matrix_info->synchronize != MagickFalse) in SetMatrixExtent()
205 *synchronize; in AcquireMatrixInfo() local
222 synchronize=GetEnvironmentValue("MAGICK_SYNCHRONIZE"); in AcquireMatrixInfo()
223 if (synchronize != (const char *) NULL) in AcquireMatrixInfo()
225 matrix_info->synchronize=IsStringTrue(synchronize); in AcquireMatrixInfo()
226 synchronize=DestroyString(synchronize); in AcquireMatrixInfo()
|
| /external/eigen/unsupported/test/ |
| D | cxx11_tensor_reduction_cuda.cu | 50 gpu_device.synchronize(); in test_full_reductions()
88 dev.synchronize(); in test_first_dim_reductions()
128 dev.synchronize(); in test_last_dim_reductions()
|
| D | cxx11_tensor_of_float16_cuda.cu | 49 gpu_device.synchronize(); in test_cuda_numext()
124 gpu_device.synchronize(); in test_cuda_unary()
165 gpu_device.synchronize(); in test_cuda_elementwise()
238 gpu_device.synchronize(); in test_cuda_trancendental()
300 gpu_device.synchronize(); in test_cuda_contractions()
353 gpu_device.synchronize(); in test_cuda_reductions()
409 gpu_device.synchronize(); in test_cuda_full_reductions()
417 gpu_device.synchronize(); in test_cuda_full_reductions()
462 gpu_device.synchronize(); in test_cuda_forced_evals()
|
| /external/grpc-grpc/src/ruby/stress/ |
| D | stress_client.rb | 35 @query_mutex.synchronize { @query_count += 1}
47 (@query_mutex.synchronize { @query_count / (Time.now - @start_time) }).to_i
|
| /external/llvm/examples/ParallelJIT/ |
| D | ParallelJIT.cpp | 242 static WaitForThreads synchronize; variable
252 synchronize.block(); // wait until other threads are at this point in callFunc()
301 synchronize.releaseThreads(3); // wait until other threads are at this point in main()
|
| /external/llvm-project/llvm/examples/ParallelJIT/ |
| D | ParallelJIT.cpp | 241 static WaitForThreads synchronize; variable
251 synchronize.block(); // wait until other threads are at this point in callFunc()
300 synchronize.releaseThreads(3); // wait until other threads are at this point in main()
|
| /external/skia/site/docs/dev/chrome/ |
| D | changes.md | 11 The strategy you use to synchronize changes in the Skia and Chromium
40 how to synchronize the changes between Skia, Blink, and Chromium [here](../blink).
|
| /external/skqp/site/dev/chrome/ |
| D | changes.md | 6 The strategy you use to synchronize changes in the Skia and Chromium
35 how to synchronize the changes between Skia, Blink, and Chromium [here](./blink).
|
| /external/webrtc/system_wrappers/source/ |
| D | clock.cc | 250 ReadLockScoped synchronize(*lock_); in CurrentTime() local
275 WriteLockScoped synchronize(*lock_); in AdvanceTime() local
|
| /external/deqp-deps/SPIRV-Tools/utils/vscode/ |
| D | extension.js | 39 synchronize: { property
|
| /external/angle/third_party/vulkan-deps/spirv-tools/src/utils/vscode/ |
| D | extension.js | 39 synchronize: { property
|
| /external/swiftshader/third_party/SPIRV-Tools/utils/vscode/ |
| D | extension.js | 39 synchronize: { property
|