| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBasedArrayBlockingQueue.java | 83 final Monitor monitor;
86 private final Monitor.Guard notEmpty;
89 private final Monitor.Guard notFull;
175 monitor = new Monitor(fair); in MonitorBasedArrayBlockingQueue()
176 notEmpty = new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
181 notFull = new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
246 final Monitor monitor = this.monitor; in offer()
269 final Monitor monitor = this.monitor; in put()
291 final Monitor monitor = this.monitor; in offer()
306 final Monitor monitor = this.monitor; in poll()
[all …]
|
| D | MonitorBasedPriorityBlockingQueue.java | 96 final Monitor monitor = new Monitor(true);
97 private final Monitor.Guard notEmpty =
98 new Monitor.Guard(monitor) {
189 final Monitor monitor = this.monitor; in offer()
238 final Monitor monitor = this.monitor; in poll()
249 final Monitor monitor = this.monitor; in take()
260 final Monitor monitor = this.monitor; in poll()
274 final Monitor monitor = this.monitor; in peek()
297 final Monitor monitor = this.monitor; in size()
328 final Monitor monitor = this.monitor; in remove()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MonitorTestCase.java | 35 public class TestGuard extends Monitor.Guard {
53 private Monitor monitor;
55 private TestThread<Monitor> thread1;
56 private TestThread<Monitor> thread2;
64 monitor = new Monitor(fair); in setUp()
65 tearDownStack.addTearDown(thread1 = new TestThread<Monitor>(monitor, "TestThread #1")); in setUp()
66 tearDownStack.addTearDown(thread2 = new TestThread<Monitor>(monitor, "TestThread #2")); in setUp()
226 .setDefault(Monitor.Guard.class, new TestGuard(true)) in testNulls()
|
| /external/webrtc/webrtc/base/ |
| D | socket_unittest.cc | 199 sink.Monitor(client.get()); in ConnectInternal()
206 sink.Monitor(server.get()); in ConnectInternal()
254 sink.Monitor(client.get()); in ConnectWithDnsLookupInternal()
259 sink.Monitor(server.get()); in ConnectWithDnsLookupInternal()
302 sink.Monitor(client.get()); in ConnectFailInternal()
307 sink.Monitor(server.get()); in ConnectFailInternal()
335 sink.Monitor(client.get()); in ConnectWithDnsLookupFailInternal()
340 sink.Monitor(server.get()); in ConnectWithDnsLookupFailInternal()
392 sink.Monitor(server.get()); in ConnectWhileNotClosedInternal()
436 sink.Monitor(client.get()); in ServerCloseDuringConnectInternal()
[all …]
|
| D | virtualsocket_unittest.cc | 248 sink.Monitor(client); in ConnectTest()
255 sink.Monitor(server); in ConnectTest()
316 sink.Monitor(client); in ConnectToNonListenerTest()
321 sink.Monitor(server); in ConnectToNonListenerTest()
350 sink.Monitor(client.get()); in CloseDuringConnectTest()
353 sink.Monitor(server.get()); in CloseDuringConnectTest()
373 sink.Monitor(server.get()); in CloseDuringConnectTest()
396 sink.Monitor(server.get()); in CloseDuringConnectTest()
411 sink.Monitor(accepted.get()); in CloseDuringConnectTest()
434 sink.Monitor(a); in CloseTest()
[all …]
|
| D | physicalsocketserver_unittest.cc | 133 sink.Monitor(client1.get()); in ConnectInternalAcceptError()
139 sink.Monitor(client2.get()); in ConnectInternalAcceptError()
146 sink.Monitor(server.get()); in ConnectInternalAcceptError()
|
| /external/tensorflow/tensorflow/contrib/distribute/python/ |
| D | monitor_test.py | 46 monitor = monitor_lib.Monitor(single_loss_step, None)
49 monitor = monitor_lib.Monitor(single_loss_step, sess)
71 _ = monitor_lib.Monitor(step_function, sess)
81 _ = monitor_lib.Monitor(step_function, session=None)
|
| D | monitor.py | 26 class Monitor(object): class
|
| /external/lzma/CS/7zip/Compress/LzmaAlone/Properties/ |
| D | Settings.cs | 25 System.Threading.Monitor.Enter(Settings.m_SyncObject);
34 System.Threading.Monitor.Exit(Settings.m_SyncObject);
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 202 public final class Monitor { class
293 final Monitor monitor;
303 protected Guard(Monitor monitor) { in Guard()
338 public Monitor() { in Monitor() method in Monitor
348 public Monitor(boolean fair) { in Monitor() method in Monitor
|
| D | ServiceManager.java | 401 final Monitor monitor = new Monitor();
441 final Monitor.Guard awaitHealthGuard = new Monitor.Guard(monitor) {
454 final Monitor.Guard stoppedGuard = new Monitor.Guard(monitor) {
|
| D | AbstractService.java | 31 import com.google.common.util.concurrent.Monitor.Guard;
97 private final Monitor monitor = new Monitor();
|
| /external/vulkan-validation-layers/ |
| D | GOVERNANCE.md | 16 - Google: Monitor for Android
17 - LunarG: Monitor for desktop (Windows and Linux)
32 - Monitor github issues and drive timely resolution
|
| /external/libbrillo/brillo/glib/ |
| D | dbus.h | 273 MonitorConnection<void(A1)>* Monitor(const Proxy& proxy, in Monitor() function
289 MonitorConnection<void(A1, A2)>* Monitor(const Proxy& proxy, in Monitor() function
308 MonitorConnection<void(A1, A2, A3)>* Monitor(const Proxy& proxy, in Monitor() function
328 MonitorConnection<void(A1, A2, A3, A4)>* Monitor( in Monitor() function
|
| /external/python/cpython3/Tools/clinic/ |
| D | cpp.py | 12 class Monitor: class
187 cpp = Monitor(filename, verbose=True)
|
| /external/libkmsxx/py/tests/ |
| D | hpd.py | 14 monitor = pyudev.Monitor.from_netlink(context)
|
| /external/tensorflow/tensorflow/contrib/distribute/ |
| D | __init__.py | 29 from tensorflow.contrib.distribute.python.monitor import Monitor
|
| /external/autotest/client/site_tests/video_VideoCapability/ |
| D | control | 7 PURPOSE = "Monitor the capabilities on device"
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-api-index.rst | 40 - Monitor for completion.
55 - Monitor for completion with a ``for`` loop.
|
| /external/autotest/client/site_tests/camera_HAL3Perf/ |
| D | control | 7 PURPOSE = "Monitor the performance of the camera HAL3."
|
| /external/autotest/client/site_tests/video_JEAPerf/ |
| D | control | 7 PURPOSE = "Monitor the performance of the Chromium JEA."
|
| /external/tensorflow/tensorflow/core/profiler/rpc/ |
| D | profiler_service_impl.cc | 32 ::grpc::Status Monitor(::grpc::ServerContext* ctx, const MonitorRequest* req, in Monitor() function in tensorflow::__anona088a3940111::ProfilerServiceImpl
|
| /external/u-boot/arch/arm/lib/ |
| D | vectors_m.S | 50 .long __invalid_entry @ 12 - Debug Monitor
|
| /external/autotest/client/site_tests/video_VEAPerf/ |
| D | control.vp8.bvt | 7 PURPOSE = "Monitor the performance of the Chromium VEA."
|
| D | control.h264.bvt | 7 PURPOSE = "Monitor the performance of the Chromium VEA."
|