| /third_party/FreeBSD/sys/dev/usb/controller/ |
| D | usb_controller.c | 98 usb_root_mount_rel(struct usb_bus *bus) in usb_root_mount_rel() argument
100 if (bus->bus_roothold != NULL) { in usb_root_mount_rel()
101 DPRINTF("Releasing root mount hold %p\n", bus->bus_roothold); in usb_root_mount_rel()
102 root_mount_rel(bus->bus_roothold); in usb_root_mount_rel()
103 bus->bus_roothold = NULL; in usb_root_mount_rel()
118 struct usb_bus *bus = (struct usb_bus *)device_get_ivars(dev); in usb_attach() local
124 if (bus == NULL) { in usb_attach()
132 bus->bus_roothold = root_mount_hold(device_get_nameunit(dev)); in usb_attach()
144 usb_attach_sub(dev, bus); in usb_attach()
154 struct usb_bus *bus = (struct usb_bus *)device_get_softc(dev); in usb_detach() local
[all …]
|
| /third_party/gstreamer/gstreamer/gst/ |
| D | gstbus.c | 164 GstBus *bus = GST_BUS_CAST (object); in gst_bus_set_property() local
168 bus->priv->enable_async = g_value_get_boolean (value); in gst_bus_set_property()
179 GstBus *bus = GST_BUS_CAST (object); in gst_bus_constructed() local
181 if (bus->priv->enable_async) { in gst_bus_constructed()
182 bus->priv->poll = gst_poll_new_timer (); in gst_bus_constructed()
183 gst_poll_get_read_gpollfd (bus->priv->poll, &bus->priv->pollfd); in gst_bus_constructed()
249 gst_bus_init (GstBus * bus) in gst_bus_init() argument
251 bus->priv = gst_bus_get_instance_private (bus); in gst_bus_init()
252 bus->priv->enable_async = DEFAULT_ENABLE_ASYNC; in gst_bus_init()
253 g_mutex_init (&bus->priv->queue_lock); in gst_bus_init()
[all …]
|
| D | gstbus.h | 36 #define GST_BUS(bus) (G_TYPE_CHECK_INSTANCE_CAST ((bus), GST_TYPE_BUS, GstBus)) argument
37 #define GST_IS_BUS(bus) (G_TYPE_CHECK_INSTANCE_TYPE ((bus), GST_TYPE_BUS)) argument
40 #define GST_BUS_GET_CLASS(bus) (G_TYPE_INSTANCE_GET_CLASS ((bus), GST_TYPE_BUS, GstBusClass)) argument
41 #define GST_BUS_CAST(bus) ((GstBus*)(bus)) argument
86 typedef GstBusSyncReply (*GstBusSyncHandler) (GstBus * bus, GstMessage * message, gpointer user_…
106 typedef gboolean (*GstBusFunc) (GstBus * bus, GstMessage * message, gpointer user_…
143 void (*message) (GstBus *bus, GstMessage *message);
152 void (*sync_message) (GstBus *bus, GstMessage *message);
165 gboolean gst_bus_post (GstBus * bus, GstMessage * message);
168 gboolean gst_bus_have_pending (GstBus * bus);
[all …]
|
| /third_party/FreeBSD/sys/dev/usb/ |
| D | usb_bus.h | 39 struct usb_bus *bus; member
52 #define USB_BUS_TT_PROC(bus) USB_BUS_NON_GIANT_ISOC_PROC(bus) argument
53 #define USB_BUS_CS_PROC(bus) USB_BUS_NON_GIANT_ISOC_PROC(bus) argument
56 #define USB_BUS_GIANT_PROC(bus) (&(bus)->giant_callback_proc) argument
57 #define USB_BUS_NON_GIANT_ISOC_PROC(bus) (&(bus)->non_giant_isoc_callback_proc) argument
58 #define USB_BUS_NON_GIANT_BULK_PROC(bus) (&(bus)->non_giant_bulk_callback_proc) argument
59 #define USB_BUS_EXPLORE_PROC(bus) (&(bus)->explore_proc) argument
60 #define USB_BUS_CONTROL_XFER_PROC(bus) (&(bus)->control_xfer_proc) argument
|
| D | usb_hub.c | 193 usb_needs_explore(sc->sc_udev->bus, 0); in uhub_intr_callback()
237 USB_BUS_UNLOCK(udev->bus); in uhub_reset_tt_proc()
243 USB_BUS_LOCK(udev->bus); in uhub_reset_tt_proc()
283 USB_BUS_LOCK_ASSERT(udev->bus, MA_OWNED); in uhub_tt_buffer_reset_async_locked()
314 (void)usb_proc_msignal(USB_BUS_TT_PROC(udev->bus), in uhub_tt_buffer_reset_async_locked()
337 USB_BUS_LOCK(udev->bus); in uhub_reset_tt_callback()
354 USB_BUS_UNLOCK(udev->bus); in uhub_reset_tt_callback()
359 USB_BUS_UNLOCK(udev->bus); in uhub_reset_tt_callback()
398 child = usb_bus_port_get_device(udev->bus, up); in uhub_count_active_host_ports()
503 struct usb_bus *bus; in uhub_explore_sub() local
[all …]
|
| D | usb_transfer.c | 160 mtod = udev->bus->methods; in usbd_get_dma_delay()
968 parm->dma_tag_p, udev->bus->dma_parent_tag[0].tag, in usbd_transfer_setup()
969 xfer_mtx, &usb_bdma_done_event, udev->bus->dma_bits, parm->dma_tag_max); in usbd_transfer_setup()
972 info->bus = udev->bus; in usbd_transfer_setup()
995 USB_BUS_CONTROL_XFER_PROC(udev->bus); in usbd_transfer_setup()
998 USB_BUS_GIANT_PROC(udev->bus); in usbd_transfer_setup()
1001 USB_BUS_NON_GIANT_BULK_PROC(udev->bus); in usbd_transfer_setup()
1004 USB_BUS_NON_GIANT_ISOC_PROC(udev->bus); in usbd_transfer_setup()
1063 &udev->bus->bus_mtx, 0); in usbd_transfer_setup()
1091 (udev->bus->methods->xfer_setup) (parm); in usbd_transfer_setup()
[all …]
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstbin.c | 30 pop_async_done (GstBus * bus) in pop_async_done() argument
35 message = gst_bus_poll (bus, GST_MESSAGE_ASYNC_DONE, -1); in pop_async_done()
45 pop_latency (GstBus * bus) in pop_latency() argument
50 message = gst_bus_poll (bus, GST_MESSAGE_LATENCY, -1); in pop_latency()
60 pop_state_changed (GstBus * bus, int count) in pop_state_changed() argument
68 message = gst_bus_poll (bus, GST_MESSAGE_STATE_CHANGED, -1); in pop_state_changed()
249 GstBus *bus; in GST_START_TEST() local
256 bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline)); in GST_START_TEST()
277 gst_bus_poll (bus, GST_MESSAGE_ERROR | GST_MESSAGE_EOS, 2 * GST_SECOND); in GST_START_TEST()
284 message = gst_bus_poll (bus, GST_MESSAGE_ERROR | GST_MESSAGE_EOS, -1); in GST_START_TEST()
[all …]
|
| D | gstcontext.c | 155 GstBus *bus; in GST_START_TEST() local
161 bus = gst_bus_new (); in GST_START_TEST()
162 gst_element_set_bus (element, bus); in GST_START_TEST()
168 fail_if (gst_bus_pop (bus) != NULL); in GST_START_TEST()
175 gst_bus_pop_filtered (bus, GST_MESSAGE_STATE_CHANGED)) != NULL); in GST_START_TEST()
177 fail_if (gst_bus_pop (bus) != NULL); in GST_START_TEST()
187 gst_object_unref (bus); in GST_START_TEST()
194 sync_handler (GstBus * bus, GstMessage * message, gpointer user_data) in sync_handler() argument
213 GstBus *bus; in GST_START_TEST() local
218 bus = gst_bus_new (); in GST_START_TEST()
[all …]
|
| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | level.c | 149 GstBus *bus; in GST_START_TEST() local
159 bus = gst_bus_new (); in GST_START_TEST()
160 ASSERT_OBJECT_REFCOUNT (bus, "bus", 1); in GST_START_TEST()
161 gst_element_set_bus (level, bus); in GST_START_TEST()
162 ASSERT_OBJECT_REFCOUNT (bus, "bus", 2); in GST_START_TEST()
176 message = gst_bus_poll (bus, GST_MESSAGE_ELEMENT, -1); in GST_START_TEST()
185 gst_bus_set_flushing (bus, TRUE); in GST_START_TEST()
193 ASSERT_OBJECT_REFCOUNT (bus, "bus", 1); in GST_START_TEST()
194 gst_object_unref (bus); in GST_START_TEST()
207 GstBus *bus; in GST_START_TEST() local
[all …]
|
| D | spectrum.c | 127 GstBus *bus; in GST_START_TEST() local
163 bus = gst_bus_new (); in GST_START_TEST()
164 ASSERT_OBJECT_REFCOUNT (bus, "bus", 1); in GST_START_TEST()
165 gst_element_set_bus (spectrum, bus); in GST_START_TEST()
166 ASSERT_OBJECT_REFCOUNT (bus, "bus", 2); in GST_START_TEST()
176 message = gst_bus_poll (bus, GST_MESSAGE_ELEMENT, -1); in GST_START_TEST()
205 gst_bus_set_flushing (bus, TRUE); in GST_START_TEST()
213 ASSERT_OBJECT_REFCOUNT (bus, "bus", 1); in GST_START_TEST()
214 gst_object_unref (bus); in GST_START_TEST()
227 GstBus *bus; in GST_START_TEST() local
[all …]
|
| D | videomixer.c | 85 message_received (GstBus * bus, GstMessage * message, GstPipeline * bin) in message_received() argument
125 test_event_message_received (GstBus * bus, GstMessage * message, in test_event_message_received() argument
147 GstBus *bus; in GST_START_TEST() local
158 bus = gst_element_get_bus (bin); in GST_START_TEST()
159 gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH); in GST_START_TEST()
202 g_signal_connect (bus, "message::segment-done", in GST_START_TEST()
204 g_signal_connect (bus, "message::error", (GCallback) message_received, bin); in GST_START_TEST()
205 g_signal_connect (bus, "message::warning", (GCallback) message_received, bin); in GST_START_TEST()
206 g_signal_connect (bus, "message::eos", (GCallback) message_received, bin); in GST_START_TEST()
238 gst_bus_remove_signal_watch (bus); in GST_START_TEST()
[all …]
|
| D | wavpackdec.c | 117 GstBus *bus; in GST_START_TEST() local
122 bus = gst_bus_new (); in GST_START_TEST()
129 gst_element_set_bus (wavpackdec, bus); in GST_START_TEST()
156 gst_bus_set_flushing (bus, TRUE); in GST_START_TEST()
158 gst_object_unref (GST_OBJECT (bus)); in GST_START_TEST()
168 GstBus *bus; in GST_START_TEST() local
172 bus = gst_bus_new (); in GST_START_TEST()
181 gst_element_set_bus (wavpackdec, bus); in GST_START_TEST()
186 fail_if ((message = gst_bus_pop (bus)) == NULL); in GST_START_TEST()
191 gst_object_unref (GST_OBJECT (bus)); in GST_START_TEST()
[all …]
|
| /third_party/flutter/skia/src/core/ |
| 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 SkAutoMutexExclusive lock(bus->fInboxesMutex); in Inbox()
78 bus->fInboxes.push_back(this); in Inbox()
84 SkMessageBus<Message>* bus = SkMessageBus<Message>::Get(); in ~Inbox() local
85 SkAutoMutexExclusive 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 …]
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | adder.c | 126 message_received (GstBus * bus, GstMessage * message, GstPipeline * bin) in message_received() argument
233 test_event_message_received (GstBus * bus, GstMessage * message, in test_event_message_received() argument
254 GstBus *bus; in GST_START_TEST() local
264 bus = gst_element_get_bus (bin); in GST_START_TEST()
265 gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH); in GST_START_TEST()
309 g_signal_connect (bus, "message::segment-done", in GST_START_TEST()
311 g_signal_connect (bus, "message::error", (GCallback) message_received, bin); in GST_START_TEST()
312 g_signal_connect (bus, "message::warning", (GCallback) message_received, bin); in GST_START_TEST()
313 g_signal_connect (bus, "message::eos", (GCallback) message_received, bin); in GST_START_TEST()
332 gst_bus_remove_signal_watch (bus); in GST_START_TEST()
[all …]
|
| D | audiomixer.c | 147 message_received (GstBus * bus, GstMessage * message, GstPipeline * bin) in message_received() argument
264 test_event_message_received (GstBus * bus, GstMessage * message, in test_event_message_received() argument
286 GstBus *bus; in GST_START_TEST() local
296 bus = gst_element_get_bus (bin); in GST_START_TEST()
297 gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH); in GST_START_TEST()
341 g_signal_connect (bus, "message::segment-done", in GST_START_TEST()
343 g_signal_connect (bus, "message::error", (GCallback) message_received, bin); in GST_START_TEST()
344 g_signal_connect (bus, "message::warning", (GCallback) message_received, bin); in GST_START_TEST()
345 g_signal_connect (bus, "message::eos", (GCallback) message_received, bin); in GST_START_TEST()
364 gst_bus_remove_signal_watch (bus); in GST_START_TEST()
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/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)
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/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)
|
| /third_party/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 …]
|
| /third_party/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 …]
|
| /third_party/gstreamer/gstplugins_base/tests/icles/playback/ |
| D | test7.c | 57 warning_cb (GstBus * bus, GstMessage * msg, gpointer foo) in warning_cb() argument
71 error_cb (GstBus * bus, GstMessage * msg, GMainLoop * main_loop) in error_cb() argument
87 eos_cb (GstBus * bus, GstMessage * msg, GMainLoop * main_loop) in eos_cb() argument
94 new_clock_cb (GstBus * bus, GstMessage * msg, gpointer nothing) in new_clock_cb() argument
103 clock_lost_cb (GstBus * bus, GstMessage * msg, GstElement * playbin) in clock_lost_cb() argument
129 GstBus *bus; in main() local
143 bus = gst_pipeline_get_bus (GST_PIPELINE (player)); in main()
144 gst_bus_add_signal_watch (bus); in main()
146 g_signal_connect (bus, "message::eos", G_CALLBACK (eos_cb), loop); in main()
147 g_signal_connect (bus, "message::error", G_CALLBACK (error_cb), loop); in main()
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/check/pipelines/ |
| D | vorbisdec.c | 35 element_message_cb (GstBus * bus, GstMessage * message, gpointer user_data) in element_message_cb() argument
47 eos_message_cb (GstBus * bus, GstMessage * message, gpointer user_data) in eos_message_cb() argument
57 GstBus *bus; in GST_START_TEST() local
72 bus = gst_element_get_bus (pipeline); in GST_START_TEST()
73 fail_if (bus == NULL); in GST_START_TEST()
74 gst_bus_add_signal_watch (bus); in GST_START_TEST()
75 g_signal_connect (bus, "message::element", (GCallback) element_message_cb, in GST_START_TEST()
77 g_signal_connect (bus, "message::eos", (GCallback) eos_message_cb, NULL); in GST_START_TEST()
89 gst_bus_remove_signal_watch (bus); in GST_START_TEST()
90 gst_object_unref (bus); in GST_START_TEST()
|
| /third_party/gstreamer/gstplugins_bad/tests/check/elements/ |
| D | kate.c | 295 GstBus *bus; in GST_START_TEST() local
299 bus = gst_bus_new (); in GST_START_TEST()
313 gst_element_set_bus (katedec, bus); in GST_START_TEST()
322 gst_object_unref (GST_OBJECT (bus)); in GST_START_TEST()
333 GstBus *bus; in GST_START_TEST() local
340 bus = gst_bus_new (); in GST_START_TEST()
351 gst_element_set_bus (katedec, bus); in GST_START_TEST()
404 gst_bus_set_flushing (bus, TRUE); in GST_START_TEST()
406 gst_object_unref (GST_OBJECT (bus)); in GST_START_TEST()
437 GstBus *bus; in GST_START_TEST() local
[all …]
|
| /third_party/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_domain_bus_and_slot(0, 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()
294 struct pci_bus *bus = ltp_pci.bus; in test_scan_bus() local
298 num = pci_rescan_bus(bus); in test_scan_bus()
[all …]
|