| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBasedArrayBlockingQueue.java | 76 final Monitor monitor; field in MonitorBasedArrayBlockingQueue
164 monitor = new Monitor(fair); in MonitorBasedArrayBlockingQueue()
166 new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
173 new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
232 final Monitor monitor = this.monitor; in offer() local
233 if (monitor.enterIf(notFull)) { in offer()
238 monitor.leave(); in offer()
256 final Monitor monitor = this.monitor; in offer() local
257 if (monitor.enterWhen(notFull, timeout, unit)) { in offer()
262 monitor.leave(); in offer()
[all …]
|
| D | MonitorBasedPriorityBlockingQueue.java | 89 final Monitor monitor = new Monitor(true); field in MonitorBasedPriorityBlockingQueue
91 new Monitor.Guard(monitor) {
171 final Monitor monitor = this.monitor; in offer() local
172 monitor.enter(); in offer()
180 monitor.leave(); in offer()
218 final Monitor monitor = this.monitor; in poll() local
219 monitor.enter(); in poll()
223 monitor.leave(); in poll()
229 final Monitor monitor = this.monitor; in poll() local
230 if (monitor.enterWhen(notEmpty, timeout, unit)) { in poll()
[all …]
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MonitorBasedArrayBlockingQueue.java | 76 final Monitor monitor; field in MonitorBasedArrayBlockingQueue
164 monitor = new Monitor(fair); in MonitorBasedArrayBlockingQueue()
166 new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
173 new Monitor.Guard(monitor) { in MonitorBasedArrayBlockingQueue()
232 final Monitor monitor = this.monitor; in offer() local
233 if (monitor.enterIf(notFull)) { in offer()
238 monitor.leave(); in offer()
256 final Monitor monitor = this.monitor; in offer() local
257 if (monitor.enterWhen(notFull, timeout, unit)) { in offer()
262 monitor.leave(); in offer()
[all …]
|
| D | MonitorBasedPriorityBlockingQueue.java | 89 final Monitor monitor = new Monitor(true); field in MonitorBasedPriorityBlockingQueue
91 new Monitor.Guard(monitor) {
171 final Monitor monitor = this.monitor; in offer() local
172 monitor.enter(); in offer()
180 monitor.leave(); in offer()
218 final Monitor monitor = this.monitor; in poll() local
219 monitor.enter(); in poll()
223 monitor.leave(); in poll()
229 final Monitor monitor = this.monitor; in poll() local
230 if (monitor.enterWhen(notEmpty, timeout, unit)) { in poll()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | dbus_unittest.cc | 54 rtc::scoped_ptr<rtc::DBusMonitor> monitor; in TEST() local
55 monitor.reset(rtc::DBusMonitor::Create(DBUS_BUS_SYSTEM)); in TEST()
56 if (monitor) { in TEST()
57 EXPECT_TRUE(monitor->AddFilter(&filter)); in TEST()
59 EXPECT_TRUE(monitor->StopMonitoring()); in TEST()
60 EXPECT_EQ(monitor->GetStatus(), DBusMonitor::DMS_NOT_INITIALIZED); in TEST()
62 EXPECT_TRUE(monitor->StartMonitoring()); in TEST()
63 EXPECT_EQ_WAIT(DBusMonitor::DMS_RUNNING, monitor->GetStatus(), kTimeoutMs); in TEST()
64 EXPECT_TRUE(monitor->StopMonitoring()); in TEST()
65 EXPECT_EQ(monitor->GetStatus(), DBusMonitor::DMS_STOPPED); in TEST()
[all …]
|
| D | httpserver_unittest.cc | 59 HttpServerMonitor& monitor, in CreateClientConnection() argument
64 EXPECT_FALSE(monitor.server_closed); in CreateClientConnection()
65 EXPECT_FALSE(monitor.transaction); in CreateClientConnection()
70 EXPECT_FALSE(monitor.server_closed); in CreateClientConnection()
77 HttpServerMonitor monitor(&server); in TEST() local
79 CreateClientConnection(server, monitor, true); in TEST()
81 ASSERT_TRUE(NULL != monitor.transaction); in TEST()
82 server.Respond(monitor.transaction); in TEST()
83 EXPECT_FALSE(monitor.transaction); in TEST()
85 EXPECT_FALSE(monitor.server_closed); in TEST()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | SupplementalMonitorTest.java | 40 Monitor monitor = new Monitor(); in testLeaveWithoutEnterThrowsIMSE() local
42 monitor.leave(); in testLeaveWithoutEnterThrowsIMSE()
84 Monitor monitor = new Monitor(); in testOccupiedMethods() local
85 verifyOccupiedMethodsInCurrentThread(monitor, false, false, 0); in testOccupiedMethods()
86 verifyOccupiedMethodsInAnotherThread(monitor, false, false, 0); in testOccupiedMethods()
87 monitor.enter(); in testOccupiedMethods()
89 verifyOccupiedMethodsInCurrentThread(monitor, true, true, 1); in testOccupiedMethods()
90 verifyOccupiedMethodsInAnotherThread(monitor, true, false, 0); in testOccupiedMethods()
91 monitor.enter(); in testOccupiedMethods()
93 verifyOccupiedMethodsInCurrentThread(monitor, true, true, 2); in testOccupiedMethods()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SupplementalMonitorTest.java | 40 Monitor monitor = new Monitor(); in testLeaveWithoutEnterThrowsIMSE() local
42 monitor.leave(); in testLeaveWithoutEnterThrowsIMSE()
84 Monitor monitor = new Monitor(); in testOccupiedMethods() local
85 verifyOccupiedMethodsInCurrentThread(monitor, false, false, 0); in testOccupiedMethods()
86 verifyOccupiedMethodsInAnotherThread(monitor, false, false, 0); in testOccupiedMethods()
87 monitor.enter(); in testOccupiedMethods()
89 verifyOccupiedMethodsInCurrentThread(monitor, true, true, 1); in testOccupiedMethods()
90 verifyOccupiedMethodsInAnotherThread(monitor, true, false, 0); in testOccupiedMethods()
91 monitor.enter(); in testOccupiedMethods()
93 verifyOccupiedMethodsInCurrentThread(monitor, true, true, 2); in testOccupiedMethods()
[all …]
|
| D | MonitorTestCase.java | 36 super(MonitorTestCase.this.monitor); in TestGuard()
51 private Monitor monitor; field in MonitorTestCase
63 monitor = new Monitor(fair); in setUp()
64 tearDownStack.addTearDown(thread1 = new TestThread<>(monitor, "TestThread #1")); in setUp()
65 tearDownStack.addTearDown(thread2 = new TestThread<>(monitor, "TestThread #2")); in setUp()
145 thread1.callAndAssertReturns(enterWhen(), monitor.newGuard(() -> true)); in testEnterWhen_initiallyTrue()
151 monitor.enter(); in testEnterWhen_initiallyFalse()
153 monitor.leave(); in testEnterWhen_initiallyFalse()
213 monitor.enter(); in testWaitFor_initiallyFalse()
215 monitor.leave(); in testWaitFor_initiallyFalse()
[all …]
|
| /external/mesa3d/src/gallium/drivers/iris/ |
| D | iris_monitor.c | 185 struct iris_monitor_object *monitor = in iris_create_monitor_object() local
187 if (unlikely(!monitor)) in iris_create_monitor_object()
190 monitor->num_active_counters = num_queries; in iris_create_monitor_object()
191 monitor->active_counters = calloc(num_queries, sizeof(int)); in iris_create_monitor_object()
192 if (unlikely(!monitor->active_counters)) in iris_create_monitor_object()
202 monitor->active_counters[i] = in iris_create_monitor_object()
211 monitor->query = query_obj; in iris_create_monitor_object()
212 monitor->result_size = perf_cfg->queries[group].data_size; in iris_create_monitor_object()
213 monitor->result_buffer = calloc(1, monitor->result_size); in iris_create_monitor_object()
214 if (unlikely(!monitor->result_buffer)) in iris_create_monitor_object()
[all …]
|
| /external/dagger2/javatests/dagger/producers/internal/ |
| D | AbstractProducesMethodProducerTest.java | 51 private ProducerMonitor monitor; field in AbstractProducesMethodProducerTest
57 monitor = Mockito.mock(ProducerMonitor.class, Mockito.CALLS_REAL_METHODS); in initMocks()
58 when(componentMonitor.producerMonitorFor(any(ProducerToken.class))).thenReturn(monitor); in initMocks()
75 verify(monitor).ready(); in monitor_success()
76 verify(monitor).requested(); in monitor_success()
77 verify(monitor).addCallbackTo(anyListenableFuture()); in monitor_success()
78 verify(monitor).methodStarting(); in monitor_success()
79 verify(monitor).methodFinished(); in monitor_success()
82 verify(monitor).succeeded(-42); in monitor_success()
83 verifyNoMoreInteractions(monitor); in monitor_success()
[all …]
|
| /external/libcups/filter/ |
| D | testclient.c | 54 static void *monitor_printer(_client_monitor_t *monitor);
86 _client_monitor_t monitor; /* Monitoring data */ in main() local
283 memset(&monitor, 0, sizeof(monitor)); in main()
285 monitor.uri = uri; in main()
286 monitor.hostname = hostname; in main()
287 monitor.resource = resource; in main()
288 monitor.port = port; in main()
289 monitor.encryption = encryption; in main()
291 _cupsThreadCreate((_cups_thread_func_t)monitor_printer, &monitor); in main()
320 monitor.job_state = IPP_JSTATE_ABORTED; in main()
[all …]
|
| /external/junit/src/main/java/org/junit/runner/notification/ |
| D | SynchronizedRunListener.java | 25 private final Object monitor; field in SynchronizedRunListener
27 SynchronizedRunListener(RunListener listener, Object monitor) { in SynchronizedRunListener() argument
29 this.monitor = monitor; in SynchronizedRunListener()
34 synchronized (monitor) { in testRunStarted()
41 synchronized (monitor) { in testRunFinished()
48 synchronized (monitor) { in testStarted()
55 synchronized (monitor) { in testFinished()
62 synchronized (monitor) { in testFailure()
69 synchronized (monitor) { in testAssumptionFailure()
76 synchronized (monitor) { in testIgnored()
|
| /external/dagger2/javatests/dagger/functional/producers/ |
| D | ProducerFactoryTest.java | 49 private ProducerMonitor monitor; field in ProducerFactoryTest
56 monitor = Mockito.mock(ProducerMonitor.class, Mockito.CALLS_REAL_METHODS); in setUpMocks()
57 when(componentMonitor.producerMonitorFor(any(ProducerToken.class))).thenReturn(monitor); in setUpMocks()
81 InOrder order = inOrder(componentMonitor, monitor); in noArgMethod()
83 order.verify(monitor).methodStarting(); in noArgMethod()
84 order.verify(monitor).methodFinished(); in noArgMethod()
85 order.verify(monitor).succeeded("str"); in noArgMethod()
115 InOrder order = inOrder(componentMonitor, monitor); in successMonitor()
119 order.verify(monitor).methodStarting(); in successMonitor()
120 order.verify(monitor).methodFinished(); in successMonitor()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 119 private final Monitor monitor = new Monitor();
126 super(AbstractService.this.monitor);
140 super(AbstractService.this.monitor);
154 super(AbstractService.this.monitor);
168 super(AbstractService.this.monitor);
244 if (monitor.enterIf(isStartable)) {
252 monitor.leave();
264 if (monitor.enterIf(isStoppable)) {
291 monitor.leave();
300 monitor.enterWhenUninterruptibly(hasReachedRunning);
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 119 private final Monitor monitor = new Monitor();
126 super(AbstractService.this.monitor);
140 super(AbstractService.this.monitor);
154 super(AbstractService.this.monitor);
168 super(AbstractService.this.monitor);
244 if (monitor.enterIf(isStartable)) {
252 monitor.leave();
264 if (monitor.enterIf(isStoppable)) {
291 monitor.leave();
300 monitor.enterWhenUninterruptibly(hasReachedRunning);
[all …]
|
| /external/vogar/src/vogar/target/ |
| D | MainTargetRunner.java | 21 import vogar.monitor.TargetMonitor;
28 private final TargetMonitor monitor; field in MainTargetRunner
33 public MainTargetRunner(TargetMonitor monitor, Class<?> mainClass, String[] args) { in MainTargetRunner() argument
34 this.monitor = monitor; in MainTargetRunner()
46 monitor.outcomeStarted(mainClass.getName() + "#main"); in run()
49 monitor.outcomeFinished(Result.SUCCESS); in run()
52 monitor.outcomeFinished(Result.EXEC_FAILED); in run()
|
| D | TestRunner.java | 36 import vogar.monitor.TargetMonitor;
142 final TargetMonitor monitor = useSocketMonitor in run() local
148 monitor.output(str != null ? str : "null"); in run()
155 run(monitor); in run()
159 monitor.close(); in run()
163 private void run(final TargetMonitor monitor) { in run() argument
200 targetRunner = runnerFactory.newRunner(monitor, qualification, klass, in run()
203 monitor.outcomeStarted(klass.getName()); in run()
205 monitor.outcomeFinished(Result.ERROR); in run()
210 monitor.outcomeStarted(klass.getName()); in run()
[all …]
|
| D | TargetMonitorRunListener.java | 24 import vogar.monitor.TargetMonitor;
32 private final TargetMonitor monitor; field in TargetMonitorRunListener
35 public TargetMonitorRunListener(TargetMonitor monitor) { in TargetMonitorRunListener() argument
36 this.monitor = monitor; in TargetMonitorRunListener()
42 monitor.outcomeStarted(JUnitUtils.getTestName(description)); in testStarted()
53 monitor.outcomeFinished(Result.SUCCESS); in testFinished()
59 monitor.outcomeFinished(Result.EXEC_FAILED); in testFinished()
|
| D | CaliperTargetRunner.java | 23 import vogar.monitor.TargetMonitor;
30 private final TargetMonitor monitor; field in CaliperTargetRunner
34 public CaliperTargetRunner(TargetMonitor monitor, Class<?> testClass, String[] args) { in CaliperTargetRunner() argument
35 this.monitor = monitor; in CaliperTargetRunner()
41 monitor.outcomeStarted(testClass.getName()); in run()
68 monitor.outcomeFinished(result); in run()
|
| /external/u-boot/common/ |
| D | edid.c | 49 struct edid_monitor_descriptor *monitor; in edid_get_ranges() local
56 monitor = &edid->monitor_details.descriptor[i]; in edid_get_ranges()
57 if (monitor->type == EDID_MONITOR_DESCRIPTOR_RANGE) { in edid_get_ranges()
58 *hmin = monitor->data.range_data.horizontal_min; in edid_get_ranges()
59 *hmax = monitor->data.range_data.horizontal_max; in edid_get_ranges()
60 *vmin = monitor->data.range_data.vertical_min; in edid_get_ranges()
61 *vmax = monitor->data.range_data.vertical_max; in edid_get_ranges()
276 static void edid_print_dtd(struct edid_monitor_descriptor *monitor, in edid_print_dtd() argument
279 unsigned char *bytes = (unsigned char *)monitor; in edid_print_dtd()
281 (struct edid_detailed_timing *)monitor; in edid_print_dtd()
[all …]
|
| /external/dagger2/java/dagger/producers/monitoring/internal/ |
| D | Monitors.java | 88 ProducerMonitor monitor = delegate.producerMonitorFor(token); in producerMonitorFor() local
89 return monitor == null ? ProducerMonitor.noOp() : new NonThrowingProducerMonitor(monitor); in producerMonitorFor()
106 ProductionComponentMonitor monitor = delegate.create(component); in create() local
107 return monitor == null in create()
109 : new NonThrowingProductionComponentMonitor(monitor); in create()
201 ProducerMonitor monitor = delegate.producerMonitorFor(token); in producerMonitorFor() local
202 if (monitor != null) { in producerMonitorFor()
203 monitorsBuilder.add(monitor); in producerMonitorFor()
231 ProductionComponentMonitor monitor = delegate.create(component); in create() local
232 if (monitor != null) { in create()
[all …]
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | debug_events_monitors_test.py | 208 monitor = debug_events_monitors.InfNanMonitor(mock_reader)
209 self.assertEmpty(monitor.alerts())
213 monitor = debug_events_monitors.InfNanMonitor(mock_reader)
224 monitor.on_execution(50, execution)
226 self.assertLen(monitor.alerts(), 1)
227 alert = monitor.alerts()[0]
241 monitor = debug_events_monitors.InfNanMonitor(mock_reader)
254 monitor.on_execution(60, execution)
256 self.assertLen(monitor.alerts(), 1)
257 alert = monitor.alerts()[0]
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | CoroutinesDumpTest.kt | 13 private val monitor = Any() in <lambda>() constant
16 fun testSuspendedCoroutine() = synchronized(monitor) { in <lambda>()
38 fun testRunningCoroutine() = synchronized(monitor) { in <lambda>()
61 fun testRunningCoroutineWithSuspensionPoint() = synchronized(monitor) { in <lambda>()
89 fun testCreationStackTrace() = synchronized(monitor) { in <lambda>()
116 fun testFinishedCoroutineRemoved() = synchronized(monitor) { in <lambda>()
151 (monitor as Object).wait() in <lambda>()
155 synchronized(monitor) { in <lambda>()
156 (monitor as Object).notify() in <lambda>()
|
| /external/openssh/ |
| D | sandbox-capsicum.c | 46 struct monitor *monitor; member
51 ssh_sandbox_init(struct monitor *monitor) in ssh_sandbox_init() argument
61 box->monitor = monitor; in ssh_sandbox_init()
97 if (cap_rights_limit(box->monitor->m_recvfd, &rights) < 0 && in ssh_sandbox_child()
101 if (cap_rights_limit(box->monitor->m_log_sendfd, &rights) < 0 && in ssh_sandbox_child()
|