Home
last modified time | relevance | path

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

/system/bt/gd/cert/
Dpy_hal.py18 from cert.event_stream import EventStream
29 self.hci_event_stream = EventStream(self.device.hal.FetchHciEvent(empty_proto.Empty()))
30 self.acl_stream = EventStream(self.device.hal.FetchHciAcl(empty_proto.Empty()))
Dcert_self_test.py30 from cert.event_stream import EventStream, FilteringEventStream
144 with EventStream(FetchEvents(events=[1, 2, 3, 1, 2, 3], delay_ms=40)) as event_stream:
149 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
154 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
162 with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
168 with EventStream(FetchEvents(events=[1, 2, 3, 4], delay_ms=50)) as event_stream:
260 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
264 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
269 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
278 with EventStream(FetchEvents(events=[1, 2, 3], delay_ms=50)) as event_stream:
[all …]
Dpy_le_security.py23 from cert.event_stream import EventStream
49 … self._ui_event_stream = EventStream(self._device.security.FetchUiEvents(empty_proto.Empty()))
50 … self._bond_event_stream = EventStream(self._device.security.FetchBondEvents(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(
103 self.outgoing_connection_event_streams[self.next_token] = EventStream(
Dpy_security.py22 from cert.event_stream import EventStream
66 … self._ui_event_stream = EventStream(self._device.security.FetchUiEvents(empty_proto.Empty()))
67 … self._bond_event_stream = EventStream(self._device.security.FetchBondEvents(empty_proto.Empty()))
68 self._enforce_security_policy_stream = EventStream(
Dpy_hci.py18 from cert.event_stream import EventStream
76 self.event_stream = EventStream(self.device.hci.FetchEvents(empty_proto.Empty()))
79 self.le_event_stream = EventStream(self.device.hci.FetchLeSubevents(empty_proto.Empty()))
82 self.acl_stream = EventStream(self.device.hci.FetchAclPackets(empty_proto.Empty()))
Dpy_l2cap.py24 from cert.event_stream import EventStream, IEventStream
75 self._l2cap_stream = EventStream(self._device.l2cap.FetchL2capData(empty_proto.Empty()))
168 … self._le_l2cap_stream = EventStream(self._device.l2cap_le.FetchL2capData(empty_proto.Empty()))
Devent_stream.py65 class EventStream(IEventStream, Closable): class
80 self.future = self.executor.submit(EventStream.__event_loop, self)
/system/bt/gd/hal/cert/
Dsimple_hal_test.py20 from cert.event_stream import EventStream
67 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream:
71 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream:
81 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream:
92 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream:
104 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream:
169 with EventStream(self.dut.hal.FetchHciEvent(empty_pb2.Empty())) as hci_event_stream, \
170 … EventStream(self.cert.hal.FetchHciEvent(empty_pb2.Empty())) as cert_hci_event_stream, \
171 EventStream(self.dut.hal.FetchHciAcl(empty_pb2.Empty())) as acl_data_stream, \
172 EventStream(self.cert.hal.FetchHciAcl(empty_pb2.Empty())) as cert_acl_data_stream:
[all …]
/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_advertising_manager_test.py22 from cert.event_stream import EventStream
56 … with EventStream(self.cert.hci.FetchLeSubevents(empty_proto.Empty())) as hci_le_event_stream:
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
40 … self.cert_hci_le_event_stream = EventStream(self.cert.hci.FetchLeSubevents(empty_proto.Empty()))
41 self.cert_acl_data_stream = EventStream(self.cert.hci.FetchAclPackets(empty_proto.Empty()))
/system/bt/gd/shim/cert/
Dshim_test.py21 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()))
/system/bt/gd/security/cert/
Dcert_security.py21 from cert.event_stream import EventStream
Dsecurity_test.py20 from cert.event_stream import EventStream
Dle_security_test.py19 from cert.event_stream import EventStream