Home
last modified time | relevance | path

Searched refs:monitor (Results 1 – 25 of 332) sorted by relevance

12345678910>>...14

/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DMonitorBasedArrayBlockingQueue.java83 final Monitor monitor; field in MonitorBasedArrayBlockingQueue
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() local
247 if (monitor.enterIf(notFull)) { in offer()
252 monitor.leave(); in offer()
269 final Monitor monitor = this.monitor; in put() local
270 monitor.enterWhen(notFull); in put()
274 monitor.leave(); in put()
[all …]
DMonitorBasedPriorityBlockingQueue.java96 final Monitor monitor = new Monitor(true); field in MonitorBasedPriorityBlockingQueue
98 new Monitor.Guard(monitor) {
189 final Monitor monitor = this.monitor; in offer() local
190 monitor.enter(); in offer()
198 monitor.leave(); in offer()
238 final Monitor monitor = this.monitor; in poll() local
239 monitor.enter(); in poll()
243 monitor.leave(); in poll()
249 final Monitor monitor = this.monitor; in take() local
250 monitor.enterWhen(notEmpty); in take()
[all …]
/external/webrtc/webrtc/base/
Ddbus_unittest.cc54 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 …]
Dhttpserver_unittest.cc59 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/autotest/client/tests/kvm/tests/
Dqmp_basic.py145 def greeting_suite(monitor): argument
152 greeting = monitor.get_greeting()
157 def json_parsing_errors_suite(monitor): argument
192 resp = monitor.cmd_raw(cmd)
196 def test_id_key(monitor): argument
202 resp = monitor.cmd_qmp("eject", { "foobar": True }, id=id_key)
207 resp = monitor.cmd_qmp("query-status", id=id_key)
214 resp = monitor.cmd_qmp("query-status", id=id_key)
221 def test_invalid_arg_key(monitor): argument
227 resp = monitor.cmd_obj({ "execute": "eject", "foobar": True })
[all …]
Dqmp_basic_rhel6.py145 def greeting_suite(monitor): argument
152 greeting = monitor.get_greeting()
157 def json_parsing_errors_suite(monitor): argument
192 resp = monitor.cmd_raw(cmd)
196 def test_id_key(monitor): argument
202 resp = monitor.cmd_qmp("eject", { "foobar": True }, id=id_key)
207 resp = monitor.cmd_qmp("query-status", id=id_key)
214 resp = monitor.cmd_qmp("query-status", id=id_key)
221 def test_invalid_arg_key(monitor): argument
227 resp = monitor.cmd_obj({ "execute": "eject", "foobar": True })
[all …]
Dcdrom.py43 blocks = vm.monitor.info("block")
72 blocks = vm.monitor.info("block")
86 def eject_cdrom(device, monitor): argument
87 if isinstance(monitor, kvm_monitor.HumanMonitor):
88 monitor.cmd("eject %s" % device)
89 elif isinstance(monitor, kvm_monitor.QMPMonitor):
90 monitor.cmd("eject", args={'device': device})
93 def change_cdrom(device, target, monitor): argument
94 if isinstance(monitor, kvm_monitor.HumanMonitor):
95 monitor.cmd("change %s %s" % (device, target))
[all …]
Dnic_hotplug.py45 vm.monitor.cmd(attach_cmd)
47 network = vm.monitor.info("network")
55 vm.monitor.cmd("netdev_del %s" % n_id)
57 network = vm.monitor.info("network")
81 vm.monitor.cmd(device_add_cmd)
83 qdev = vm.monitor.info("qtree")
100 vm.monitor.cmd(nic_del_cmd)
104 vm.monitor.info("qtree"),
106 logging.error(vm.monitor.info("qtree"))
123 vm.monitor.cmd("set_link %s down" % vm.netdev_id[0])
[all …]
Dpci_hotplug.py33 info_pci_ref = vm.monitor.info("pci")
43 cmd_output = vm.monitor.cmd("?")
62 devices_support = vm.monitor.cmd("%s ?" % cmd_type)
74 add_output = vm.monitor.cmd(pci_add_cmd)
79 after_add = vm.monitor.info("pci")
110 vm.monitor.cmd(controller_add_cmd)
123 vm.monitor.cmd(driver_add_cmd)
127 add_output = vm.monitor.cmd(pci_add_cmd)
131 after_add = vm.monitor.info("pci")
149 vm.monitor.cmd(cmd)
[all …]
/external/valgrind/gdbserver_tests/
Dmcvabits.stdinB.gdb4 monitor v.set vgdb-error 999999
23 eval "monitor check_memory addressable 0x%lx 10", $0xundefined
24 eval "monitor check_memory defined 0x%lx 10", $0xundefined
25 eval "monitor get_vbits 0x%lx 10", $0xundefined
26 eval "monitor xb 0x%lx 10", $0xundefined
32 eval "monitor check_memory addressable 0x%lx 10", $0xundefined
33 eval "monitor check_memory defined 0x%lx 10", $0xundefined
34 eval "monitor get_vbits 0x%lx 10", $0xundefined
38 eval "monitor make_memory defined 0x%lx 3", $0xundefined_2
40 eval "monitor check_memory addressable 0x%lx 10", $0xundefined
[all …]
Dmcleak.stdinB.gdb4 monitor v.set vgdb-error 999999
16 monitor leak_check full reachable any
22 monitor leak_check full reachable increased
30 monitor leak_check full reachable increased
38 monitor leak_check full reachable increased
44 monitor leak_check full reachable increased
51 monitor leak_check full reachable increased
58 monitor leak_check full reachable changed
65 monitor leak_check full reachable changed
72 monitor leak_check full reachable changed
[all …]
Dmssnapshot.stdinB.gdb4 monitor v.set vgdb-error 999999
14 monitor help
17 monitor snapshot
18 monitor detailed_snapshot
19 monitor all_snapshots
22 monitor v.kill
/external/vogar/test/vogar/target/
DJUnitRunnerTest.java28 import vogar.monitor.TargetMonitor;
44 private TargetMonitor monitor; field in JUnitRunnerTest
49 monitor = mock(TargetMonitor.class); in setUp()
55 Runner runner = new JUnitRunner(monitor, skipPastReference, testEnvironment, 0, tests); in test_run_for_SimpleTest_should_perform_test()
58 verify(monitor).outcomeStarted(JUnitRunner.class, in test_run_for_SimpleTest_should_perform_test()
60 verify(monitor).outcomeFinished(Result.SUCCESS); in test_run_for_SimpleTest_should_perform_test()
66 Runner runner = new JUnitRunner(monitor, skipPastReference, testEnvironment, 0, tests); in test_run_for_SuiteTest_should_perform_tests()
69 verify(monitor).outcomeStarted(JUnitRunner.class, in test_run_for_SuiteTest_should_perform_tests()
71 verify(monitor).outcomeStarted(JUnitRunner.class, in test_run_for_SuiteTest_should_perform_tests()
73 verify(monitor).outcomeStarted(JUnitRunner.class, in test_run_for_SuiteTest_should_perform_tests()
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractService.java97 private final Monitor monitor = new Monitor();
99 private final Guard isStartable = new Guard(monitor) {
105 private final Guard isStoppable = new Guard(monitor) {
111 private final Guard hasReachedRunning = new Guard(monitor) {
117 private final Guard isStopped = new Guard(monitor) {
170 if (monitor.enterIf(isStartable)) {
179 monitor.leave();
189 if (monitor.enterIf(isStoppable)) {
219 monitor.leave();
227 monitor.enterWhenUninterruptibly(hasReachedRunning);
[all …]
DMonitor.java293 final Monitor monitor; field in Monitor.Guard
303 protected Guard(Monitor monitor) { in Guard() argument
304 this.monitor = checkNotNull(monitor, "monitor"); in Guard()
305 this.condition = monitor.lock.newCondition(); in Guard()
420 if (guard.monitor != this) { in enterWhen()
444 if (guard.monitor != this) { in enterWhenUninterruptibly()
473 if (guard.monitor != this) { in enterWhen()
514 if (guard.monitor != this) { in enterWhenUninterruptibly()
568 if (guard.monitor != this) { in enterIf()
591 if (guard.monitor != this) { in enterIfInterruptibly()
[all …]
DServiceManager.java401 final Monitor monitor = new Monitor(); field in ServiceManager.ServiceManagerState
441 final Monitor.Guard awaitHealthGuard = new Monitor.Guard(monitor) {
454 final Monitor.Guard stoppedGuard = new Monitor.Guard(monitor) {
481 monitor.enter(); in tryStartTiming()
488 monitor.leave(); in tryStartTiming()
497 monitor.enter(); in markReady()
514 monitor.leave(); in markReady()
521 monitor.enter(); in addListener()
528 monitor.leave(); in addListener()
533 monitor.enterWhenUninterruptibly(awaitHealthGuard); in awaitHealthy()
[all …]
/external/chromium-trace/catapult/telemetry/telemetry/internal/platform/power_monitor/
Dandroid_temperature_monitor_unittest.py20 monitor = android_temperature_monitor.AndroidTemperatureMonitor(
22 self.assertTrue(monitor.CanMonitorPower())
23 monitor.StartMonitoringPower(None)
24 measurements = monitor.StopMonitoringPower()
36 monitor = android_temperature_monitor.AndroidTemperatureMonitor(
38 self.assertTrue(monitor.CanMonitorPower())
39 monitor.StartMonitoringPower(None)
40 measurements = monitor.StopMonitoringPower()
48 monitor = android_temperature_monitor.AndroidTemperatureMonitor(
50 self.assertFalse(monitor.CanMonitorPower())
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/
DProducerFactoryTest.java45 private ProducerMonitor monitor; field in ProducerFactoryTest
51 monitor = Mockito.mock(ProducerMonitor.class, Mockito.CALLS_REAL_METHODS); in setUpMocks()
52 when(componentMonitor.producerMonitorFor(any(ProducerToken.class))).thenReturn(monitor); in setUpMocks()
69 InOrder order = inOrder(componentMonitor, monitor); in noArgMethod()
71 order.verify(monitor).methodStarting(); in noArgMethod()
72 order.verify(monitor).methodFinished(); in noArgMethod()
73 order.verify(monitor).succeeded("str"); in noArgMethod()
100 InOrder order = inOrder(componentMonitor, monitor); in successMonitor()
104 order.verify(monitor).methodStarting(); in successMonitor()
105 order.verify(monitor).methodFinished(); in successMonitor()
[all …]
/external/dhcpcd-6.8.2/dev/
Dudev.c45 static struct udev_monitor *monitor; variable
53 return monitor ? 1 : 0; in udev_listening()
81 device = udev_monitor_receive_device(monitor); in udev_handle_device()
108 if (monitor) { in udev_stop()
109 udev_monitor_unref(monitor); in udev_stop()
110 monitor = NULL; in udev_stop()
135 monitor = udev_monitor_new_from_netlink(udev, "udev"); in udev_start()
136 if (monitor == NULL) { in udev_start()
141 if (udev_monitor_filter_add_match_subsystem_devtype(monitor, in udev_start()
149 if (udev_monitor_enable_receiving(monitor) != 0) { in udev_start()
[all …]
/external/vogar/src/vogar/target/
DMainRunner.java21 import vogar.monitor.TargetMonitor;
28 private final TargetMonitor monitor; field in MainRunner
33 public MainRunner(TargetMonitor monitor, Class<?> mainClass, String[] args) { in MainRunner() argument
34 this.monitor = monitor; in MainRunner()
46 monitor.outcomeStarted(getClass(), mainClass.getName()); in run()
52 monitor.outcomeFinished(Result.SUCCESS); in run()
55 monitor.outcomeFinished(Result.EXEC_FAILED); in run()
DTestRunner.java35 import vogar.monitor.TargetMonitor;
155 final TargetMonitor monitor = useSocketMonitor in run() local
161 monitor.output(str != null ? str : "null"); in run()
168 run(monitor); in run()
172 monitor.close(); in run()
176 private void run(final TargetMonitor monitor) { in run() argument
224 runner = runnerFactory.newRunner(monitor, qualification, klass, in run()
227 monitor.outcomeStarted(null, qualifiedName); in run()
229 monitor.outcomeFinished(Result.ERROR); in run()
234 monitor.outcomeStarted(null, klass.getName()); in run()
[all …]
DCaliperRunner.java23 import vogar.monitor.TargetMonitor;
30 private final TargetMonitor monitor; field in CaliperRunner
35 public CaliperRunner(TargetMonitor monitor, boolean profile, Class<?> testClass, in CaliperRunner() argument
37 this.monitor = monitor; in CaliperRunner()
44 monitor.outcomeStarted(getClass(), testClass.getName()); in run()
84 monitor.outcomeFinished(Result.SUCCESS); in run()
/external/dagger2/producers/src/main/java/dagger/producers/monitoring/internal/
DMonitors.java72 ProducerMonitor monitor = delegate.producerMonitorFor(token); in producerMonitorFor() local
73 return monitor == null ? noOpProducerMonitor() : new NonThrowingProducerMonitor(monitor); in producerMonitorFor()
90 ProductionComponentMonitor monitor = delegate.create(component); in create() local
91 return monitor == null in create()
93 : new NonThrowingProductionComponentMonitor(monitor); in create()
167 ProducerMonitor monitor = delegate.producerMonitorFor(token); in producerMonitorFor() local
168 if (monitor != null) { in producerMonitorFor()
169 monitorsBuilder.add(monitor); in producerMonitorFor()
197 ProductionComponentMonitor monitor = delegate.create(component); in create() local
198 if (monitor != null) { in create()
[all …]
DMonitorCache.java32 private volatile ProductionComponentMonitor monitor; field in MonitorCache
40 public ProductionComponentMonitor monitor( in monitor() method in MonitorCache
43 ProductionComponentMonitor result = monitor; in monitor()
46 result = monitor; in monitor()
52 result = monitor = factory.create(componentProvider.get()); in monitor()
55 result = monitor = Monitors.noOpProductionComponentMonitor(); in monitor()
/external/autotest/client/site_tests/graphics_GpuReset/src/
Dgpureset.c169 struct udev_monitor* monitor = udev_monitor_new_from_netlink(udev, "udev"); in udev_init() local
170 if (!monitor) { in udev_init()
176 udev_monitor_filter_add_match_subsystem_devtype(monitor, in udev_init()
179 udev_monitor_enable_receiving(monitor); in udev_init()
181 return monitor; in udev_init()
184 int udev_wait(struct udev_monitor* monitor) in udev_wait() argument
190 int fd = udev_monitor_get_fd(monitor); in udev_wait()
203 struct udev_device* dev = udev_monitor_receive_device(monitor); in udev_wait()
283 struct udev_monitor* monitor = udev_init(); in main() local
284 if (!monitor) { in main()
[all …]

12345678910>>...14