| /external/libchrome/dbus/ |
| D | bus_unittest.cc | 74 scoped_refptr<Bus> bus = new Bus(options); in TEST() local
77 bus->GetObjectProxy("org.chromium.TestService", in TEST()
83 bus->GetObjectProxy("org.chromium.TestService", in TEST()
90 bus->GetObjectProxy( in TEST()
96 bus->ShutdownAndBlock(); in TEST()
101 scoped_refptr<Bus> bus = new Bus(options); in TEST() local
104 bus->GetObjectProxyWithOptions( in TEST()
112 bus->GetObjectProxyWithOptions( in TEST()
121 bus->GetObjectProxyWithOptions( in TEST()
128 bus->ShutdownAndBlock(); in TEST()
[all …]
|
| /external/crosvm/devices/src/ |
| D | bus.rs | 370 let mut bus = Bus::new(); in bus_insert() localVariable
372 assert!(bus.insert(dummy.clone(), 0x10, 0).is_err()); in bus_insert()
373 assert!(bus.insert(dummy.clone(), 0x10, 0x10).is_ok()); in bus_insert()
374 assert!(bus.insert(dummy.clone(), 0x0f, 0x10).is_err()); in bus_insert()
375 assert!(bus.insert(dummy.clone(), 0x10, 0x10).is_err()); in bus_insert()
376 assert!(bus.insert(dummy.clone(), 0x10, 0x15).is_err()); in bus_insert()
377 assert!(bus.insert(dummy.clone(), 0x12, 0x15).is_err()); in bus_insert()
378 assert!(bus.insert(dummy.clone(), 0x12, 0x01).is_err()); in bus_insert()
379 assert!(bus.insert(dummy.clone(), 0x0, 0x20).is_err()); in bus_insert()
380 assert!(bus.insert(dummy.clone(), 0x20, 0x05).is_ok()); in bus_insert()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | EventBusTest.java | 37 private EventBus bus; field in EventBusTest
42 bus = new EventBus(BUS_IDENTIFIER); in setUp()
47 bus.register(catcher); in testBasicCatcherDistribution()
48 bus.post(EVENT); in testBasicCatcherDistribution()
87 bus.register(stringCatcher); in testPolymorphicDistribution()
88 bus.register(objCatcher); in testPolymorphicDistribution()
89 bus.register(compCatcher); in testPolymorphicDistribution()
95 bus.post(EVENT); in testPolymorphicDistribution()
96 bus.post(objEvent); in testPolymorphicDistribution()
97 bus.post(compEvent); in testPolymorphicDistribution()
[all …]
|
| D | SubscriberTest.java | 36 private EventBus bus; field in SubscriberTest
42 bus = new EventBus(); in setUp()
48 Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); in testCreate()
52 Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); in testCreate()
58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough()
96 Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) in testEquals()
97 .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) in testEquals()
98 .addEqualityGroup(Subscriber.create(bus, "foo", concat)) in testEquals()
|
| D | ReentrantEventsTest.java | 33 final EventBus bus = new EventBus(); field in ReentrantEventsTest
37 bus.register(hater); in testNoReentrantEvents()
39 bus.post(FIRST); in testNoReentrantEvents()
56 bus.post(SECOND); in listenForStrings()
71 bus.register(processor); in testEventOrderingIsPredictable()
74 bus.register(recorder); in testEventOrderingIsPredictable()
76 bus.post(FIRST); in testEventOrderingIsPredictable()
87 bus.post(SECOND); in listenForStrings()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | EventBusTest.java | 37 private EventBus bus; field in EventBusTest
42 bus = new EventBus(BUS_IDENTIFIER); in setUp()
47 bus.register(catcher); in testBasicCatcherDistribution()
48 bus.post(EVENT); in testBasicCatcherDistribution()
87 bus.register(stringCatcher); in testPolymorphicDistribution()
88 bus.register(objCatcher); in testPolymorphicDistribution()
89 bus.register(compCatcher); in testPolymorphicDistribution()
95 bus.post(EVENT); in testPolymorphicDistribution()
96 bus.post(objEvent); in testPolymorphicDistribution()
97 bus.post(compEvent); in testPolymorphicDistribution()
[all …]
|
| D | SubscriberTest.java | 36 private EventBus bus; field in SubscriberTest
42 bus = new EventBus(); in setUp()
48 Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); in testCreate()
52 Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); in testCreate()
58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough()
96 Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) in testEquals()
97 .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) in testEquals()
98 .addEqualityGroup(Subscriber.create(bus, "foo", concat)) in testEquals()
|
| D | ReentrantEventsTest.java | 33 final EventBus bus = new EventBus(); field in ReentrantEventsTest
37 bus.register(hater); in testNoReentrantEvents()
39 bus.post(FIRST); in testNoReentrantEvents()
56 bus.post(SECOND); in listenForStrings()
71 bus.register(processor); in testEventOrderingIsPredictable()
74 bus.register(recorder); in testEventOrderingIsPredictable()
76 bus.post(FIRST); in testEventOrderingIsPredictable()
87 bus.post(SECOND); in listenForStrings()
|
| /external/autotest/client/common_lib/cros/cfm/usb/ |
| D | usb_port_manager.py | 17 PortId(bus=1, port_number=2): 56, # Front left USB 2
18 PortId(bus=2, port_number=1): 56, # Front left USB 3
19 PortId(bus=1, port_number=3): 57, # Front right USB 2
20 PortId(bus=2, port_number=2): 57, # Front right USB 3
22 PortId(bus=1, port_number=5): 47, # Back upper USB 2
23 PortId(bus=2, port_number=3): 47, # Back upper USB 3
24 PortId(bus=1, port_number=6): 47, # Back lower USB 2
25 PortId(bus=2, port_number=4): 47, # Back lower USB 3
32 PortId(bus=1, port_number=3): 4, # Front right USB 2
33 PortId(bus=1, port_number=4): 5, # Front left USB 2
[all …]
|
| /external/skqp/include/private/ |
| D | SkMessageBus.h | 66 static SkMessageBus<Message>* bus; \
67 once([] { bus = new SkMessageBus<Message>(); }); \
68 return bus; \
76 SkMessageBus<Message>* bus = SkMessageBus<Message>::Get(); in Inbox() local
77 SkAutoMutexAcquire lock(bus->fInboxesMutex); in Inbox()
78 bus->fInboxes.push_back(this); in Inbox()
84 SkMessageBus<Message>* bus = SkMessageBus<Message>::Get(); in ~Inbox() local
85 SkAutoMutexAcquire lock(bus->fInboxesMutex); in ~Inbox()
87 for (int i = 0; i < bus->fInboxes.count(); i++) { in ~Inbox()
88 if (this == bus->fInboxes[i]) { in ~Inbox()
[all …]
|
| /external/wpa_supplicant_8/wpa_supplicant/examples/ |
| D | wpas-dbus-new-signals.py | 32 if_obj = bus.get_object(WPAS_DBUS_SERVICE, path)
48 net_obj = bus.get_object(WPAS_DBUS_SERVICE, bss)
128 global bus
129 bus = dbus.SystemBus()
130 wpas_obj = bus.get_object(WPAS_DBUS_SERVICE, WPAS_DBUS_OPATH)
137 bus.add_signal_receiver(interfaceAdded,
140 bus.add_signal_receiver(interfaceRemoved,
143 bus.add_signal_receiver(propertiesChanged,
149 if_obj = bus.get_object(WPAS_DBUS_SERVICE, path)
154 bus.add_signal_receiver(scanDone,
[all …]
|
| D | wpas-dbus-new-wps.py | 38 global bus
39 bus = dbus.SystemBus()
40 wpas_obj = bus.get_object(WPAS_DBUS_SERVICE, WPAS_DBUS_OPATH)
47 bus.add_signal_receiver(scanDone,
50 bus.add_signal_receiver(bssAdded,
53 bus.add_signal_receiver(bssRemoved,
56 bus.add_signal_receiver(propertiesChanged,
59 bus.add_signal_receiver(wpsEvent,
62 bus.add_signal_receiver(credentials,
69 if_obj = bus.get_object(WPAS_DBUS_SERVICE, path)
|
| D | wpas-dbus-new.py | 31 if_obj = bus.get_object(WPAS_DBUS_SERVICE, path)
41 net_obj = bus.get_object(WPAS_DBUS_SERVICE, bss)
98 global bus
99 bus = dbus.SystemBus()
100 wpas_obj = bus.get_object(WPAS_DBUS_SERVICE, WPAS_DBUS_OPATH)
107 bus.add_signal_receiver(scanDone,
110 bus.add_signal_receiver(bssAdded,
113 bus.add_signal_receiver(bssRemoved,
116 bus.add_signal_receiver(propertiesChanged,
138 if_obj = bus.get_object(WPAS_DBUS_SERVICE, path)
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reset_usb.py | 34 def reset_usb(bus, device): argument
36 usb_file_path = '/dev/bus/usb/%03d/%03d' % (bus, device)
46 bus = None
51 bus = int(device_info.get('bus'))
54 if bus and device:
55 reset_usb(bus, device)
59 (bus, device, serial))
71 bus = int(device_info.get('bus'))
74 reset_usb(bus, device)
78 bus, device, serial)
[all …]
|
| /external/skia/src/core/ |
| D | SkMessageBus.h | 79 static SkMessageBus<Message, IDType, AllowCopyableMessage>* bus; \
80 once([] { bus = new SkMessageBus<Message, IDType, AllowCopyableMessage>(); }); \
81 return bus; \
90 auto* bus = SkMessageBus<Message, IDType, AllowCopyableMessage>::Get();
91 SkAutoMutexExclusive lock(bus->fInboxesMutex);
92 bus->fInboxes.push_back(this);
98 auto* bus = SkMessageBus<Message, IDType, AllowCopyableMessage>::Get();
99 SkAutoMutexExclusive lock(bus->fInboxesMutex);
101 for (int i = 0; i < bus->fInboxes.count(); i++) {
102 if (this == bus->fInboxes[i]) {
[all …]
|
| /external/toybox/toys/other/ |
| D | i2ctools.c | 87 static int i2c_open(int bus, int slave, int chip) in i2c_open() argument
91 snprintf(toybuf, sizeof(toybuf), "/dev/i2c-%d", bus); in i2c_open()
97 static unsigned long i2c_get_funcs(int bus) in i2c_get_funcs() argument
99 int fd = i2c_open(bus, 0, 0); in i2c_get_funcs()
122 static void i2cdetect_dash_F(int bus) in i2cdetect_dash_F() argument
143 unsigned long supported = i2c_get_funcs(bus); in i2cdetect_dash_F()
155 int bus; in i2cdetect_dash_l() local
161 if (sscanf(node->name, "i2c-%d", &bus) != 1) return 0; in i2cdetect_dash_l()
162 funcs = i2c_get_funcs(bus); in i2cdetect_dash_l()
188 int bus, first = 0x03, last = 0x77, fd, row, addr, byte; in i2cdetect_main() local
[all …]
|
| /external/ltp/testcases/kernel/device-drivers/pci/tpci_kernel/ |
| D | ltp_tpci.c | 87 struct pci_bus *bus; member
98 static int probe_pci_dev(unsigned int bus, unsigned int slot) in probe_pci_dev() argument
107 dev = pci_get_bus_and_slot(bus, slot); in probe_pci_dev()
112 pci_name(dev), bus, slot); in probe_pci_dev()
115 ltp_pci.bus = dev->bus; in probe_pci_dev()
116 prk_info("Bus number: %d", dev->bus->number); in probe_pci_dev()
186 int num = ltp_pci.bus->number; in test_find_bus()
191 temp = pci_find_bus(pci_domain_nr(ltp_pci.bus), num); in test_find_bus()
295 struct pci_bus *bus = ltp_pci.bus; in test_scan_bus() local
299 num = pci_rescan_bus(bus); in test_scan_bus()
[all …]
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Subscriber.java | 38 static Subscriber create(EventBus bus, Object listener, Method method) { in create() argument
40 ? new Subscriber(bus, listener, method) in create()
41 : new SynchronizedSubscriber(bus, listener, method); in create()
45 @Weak private EventBus bus; field in Subscriber
56 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() argument
57 this.bus = bus; in Subscriber()
62 this.executor = bus.executor(); in Subscriber()
74 bus.handleSubscriberException(e.getCause(), context(event)); in dispatchEvent()
102 return new SubscriberExceptionContext(bus, event, target, method); in context()
137 private SynchronizedSubscriber(EventBus bus, Object target, Method method) { in SynchronizedSubscriber() argument
[all …]
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | Subscriber.java | 38 static Subscriber create(EventBus bus, Object listener, Method method) { in create() argument
40 ? new Subscriber(bus, listener, method) in create()
41 : new SynchronizedSubscriber(bus, listener, method); in create()
45 @Weak private EventBus bus; field in Subscriber
56 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() argument
57 this.bus = bus; in Subscriber()
62 this.executor = bus.executor(); in Subscriber()
74 bus.handleSubscriberException(e.getCause(), context(event)); in dispatchEvent()
102 return new SubscriberExceptionContext(bus, event, target, method); in context()
137 private SynchronizedSubscriber(EventBus bus, Object target, Method method) { in SynchronizedSubscriber() argument
[all …]
|
| /external/autotest/client/site_tests/hardware_I2CProbe/ |
| D | hardware_I2CProbe.py | 19 def i2c_detect(bus, addr): argument
20 full_cmd = 'i2cdetect -y %d 0x%x 0x%x' % (bus, addr, addr)
26 def i2c_probe(bus, addr): argument
27 response = i2c_detect(bus, addr)
34 def run_once(self, bus, addr): argument
35 if not i2c_probe(bus, addr):
37 (bus, addr))
|
| /external/autotest/client/cros/networking/ |
| D | mm1_proxy.py | 37 def get_proxy(cls, bus=None, timeout_seconds=10): argument
54 def _connect_to_mm1(bus): argument
60 return cls(bus=bus)
69 lambda: _connect_to_mm1(bus) is not None,
74 connection = _connect_to_mm1(bus)
83 def __init__(self, bus=None): argument
84 if bus is None:
86 bus = dbus.SystemBus()
87 self._bus = bus
173 def __init__(self, bus, path): argument
[all …]
|
| /external/libchrome/libchrome_tools/patches/ |
| D | dbus-Make-Bus-is_connected-mockable.patch | 17 dbus/bus.cc | 4 ++++
18 dbus/bus.h | 2 +-
25 diff --git a/dbus/bus.cc b/dbus/bus.cc
27 --- a/dbus/bus.cc
28 +++ b/dbus/bus.cc
40 diff --git a/dbus/bus.h b/dbus/bus.h
42 --- a/dbus/bus.h
43 +++ b/dbus/bus.h
47 // Returns true if the bus is connected to D-Bus.
59 // Check if the bus is still connected. If the method takes long to
[all …]
|
| /external/autotest/client/cros/cellular/pseudomodem/ |
| D | dbus_std_ifaces.py | 56 def __init__(self, path, bus=None, config=None): argument
73 if bus:
74 dbus.service.Object.__init__(self, bus, path)
78 self.bus = bus
96 def SetBus(self, bus): argument
104 self.bus = bus
105 self.add_to_connection(bus, self.path)
121 self.add_to_connection(self.bus, path)
334 def __init__(self, bus, path): argument
335 dbus.service.Object.__init__(self, bus, path)
[all …]
|
| /external/selinux/restorecond/ |
| D | user.c | 85 DBusConnection *bus; in dbus_server() local
88 bus = dbus_bus_get (DBUS_BUS_SESSION, &error); in dbus_server()
89 if (bus) { in dbus_server()
90 dbus_connection_setup_with_g_main (bus, NULL); in dbus_server()
93 dbus_bus_add_match (bus, RULE, &error); // see signals from the given interfacey in dbus_server()
94 dbus_connection_add_filter (bus, signal_filter, loop, NULL); in dbus_server()
170 DBusConnection *bus; in start() local
176 bus = dbus_bus_get (DBUS_BUS_SESSION, &error); in start()
177 if (!bus) { in start()
190 dbus_connection_send (bus, message, NULL); in start()
|
| /external/autotest/client/common_lib/cros/ |
| D | power_cycle_usb_util_unittest.py | 42 bus, dev = power_cycle_usb_util.get_bus_dev_id(
44 self.assertEqual((bus, dev), want)
45 bus, dev = power_cycle_usb_util.get_bus_dev_id(
47 self.assertEqual((bus, dev), want_none)
48 bus, dev = power_cycle_usb_util.get_bus_dev_id(
50 self.assertEqual((bus, dev), want_multi)
|