Home
last modified time | relevance | path

Searched refs:EventStream (Results 1 – 24 of 24) sorted by relevance

/system/bt/gd/cert/
Dcert_self_test_lib.py27 from cert.event_stream import EventStream, FilteringEventStream
133 with EventStream(FetchEvents(events=[1, 2, 3, 1, 2, 3], delay_ms=40)) as event_stream:
139 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
145 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
154 with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
161 with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
265 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
270 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
276 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
286 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
[all …]
Dpy_le_security.py23 from cert.event_stream import EventStream
51 … self._ui_event_stream = EventStream(self._device.security.FetchUiEvents(empty_proto.Empty()))
52 … self._bond_event_stream = EventStream(self._device.security.FetchBondEvents(empty_proto.Empty()))
53 …self._helper_event_stream = EventStream(self._device.security.FetchHelperEvents(empty_proto.Empty(…
Dpy_acl_manager.py18 from cert.event_stream import EventStream
35 …self.acl_stream = EventStream(self.acl_manager.FetchAclData(acl_manager_facade.HandleMsg(handle=se…
70 self.incoming_connection_event_stream = EventStream(
76 self.outgoing_connection_event_stream = EventStream(
Dpy_le_acl_manager.py19 from cert.event_stream import EventStream
45 self.acl_stream = EventStream(
90 self.incoming_connection_event_stream = EventStream(
109 self.outgoing_connection_event_streams[self.next_token] = EventStream(
Dpy_security.py22 from cert.event_stream import EventStream
70 … self._ui_event_stream = EventStream(self._device.security.FetchUiEvents(empty_proto.Empty()))
71 … self._bond_event_stream = EventStream(self._device.security.FetchBondEvents(empty_proto.Empty()))
72 self._enforce_security_policy_stream = EventStream(
74 …self._disconnect_event_stream = EventStream(self._device.security.FetchDisconnectEvents(empty_prot…
75 self._oob_data_event_stream = EventStream(
Dpy_hci.py18 from cert.event_stream import EventStream
121 self.event_stream = EventStream(self.device.hci.StreamEvents(empty_proto.Empty()))
122 self.le_event_stream = EventStream(self.device.hci.StreamLeSubevents(empty_proto.Empty()))
127 self.acl_stream = EventStream(self.device.hci.StreamAcl(empty_proto.Empty()))
Dpy_le_iso.py24 from cert.event_stream import EventStream, IEventStream
77 self._iso_event_stream = EventStream(self._device.iso.FetchIsoEvents(empty_proto.Empty()))
78 self._iso_data_stream = EventStream(self._device.iso.FetchIsoData(empty_proto.Empty()))
Dpy_l2cap.py26 from cert.event_stream import EventStream, IEventStream
80 self._l2cap_stream = EventStream(self._device.l2cap.FetchL2capData(empty_proto.Empty()))
81 self._security_connection_event_stream = EventStream(
225 … self._le_l2cap_stream = EventStream(self._device.l2cap_le.FetchL2capData(empty_proto.Empty()))
Dpy_hal.py18 from cert.event_stream import EventStream
119 self.hci_event_stream = EventStream(self.device.hal.StreamEvents(empty_proto.Empty()))
120 self.acl_stream = EventStream(self.device.hal.StreamAcl(empty_proto.Empty()))
Devent_stream.py65 class EventStream(IEventStream, Closable): class
80 self.future = self.executor.submit(EventStream.__event_loop, self)
Dcert_self_test.py30 from cert.event_stream import EventStream, FilteringEventStream
/system/bt/gd/neighbor/cert/
Dpy_neighbor.py20 from cert.event_stream import EventStream
33 self.inquiry_event_stream = EventStream(device.neighbor.SetInquiryMode(inquiry_msg))
45 … self.remote_name_stream = EventStream(device.neighbor.GetRemoteNameEvents(empty_proto.Empty()))
/system/bt/gd/hci/cert/
Dle_scanning_with_security_test.py18 from cert.event_stream import EventStream
62 with EventStream(
Dle_scanning_manager_test.py22 from cert.event_stream import EventStream
73 with EventStream(
Dle_acl_manager_test.py19 from cert.event_stream import EventStream
41 … self.cert_hci_le_event_stream = EventStream(self.cert.hci.StreamLeSubevents(empty_proto.Empty()))
42 self.cert_acl_data_stream = EventStream(self.cert.hci.StreamAcl(empty_proto.Empty()))
Dle_advertising_manager_test.py22 from cert.event_stream import EventStream
/system/bt/gd/shim/cert/
Dshim_test.py21 from cert.event_stream import EventStream
/system/bt/gd/hal/cert/
Dsimple_hal_test.py20 from cert.event_stream import EventStream
/system/bt/gd/l2cap/classic/cert/
Dpts_l2cap_test.py20 from cert.event_stream import EventStream
52 return EventStream(self.device_under_test.l2cap.FetchConnectionComplete(empty_pb2.Empty()))
55 return EventStream(self.device_under_test.l2cap.FetchConnectionClose(empty_pb2.Empty()))
Dl2cap_test.py28 from cert.event_stream import EventStream
/system/bt/gd/iso/cert/
Dle_iso_test.py20 from cert.event_stream import EventStream
/system/bt/gd/security/cert/
Dcert_security.py22 from cert.event_stream import EventStream
Dsecurity_test.py20 from cert.event_stream import EventStream
Dle_security_test.py20 from cert.event_stream import EventStream