Lines Matching refs:subscriber
373 other as Subscriber (S)
396 self.subscriber = self.android_devices[1]
403 sub_connect_id = self.exec_connect(self.subscriber, "subscriber")
413 sub_id = self.subscriber.droid.wifiAwareSubscribe(sub_connect_id,
417 event_sub_match = self.subscriber.ed.pop_event(
423 asserts.fail('Timed out while waiting for %s on Subscriber' %
427 self.reliable_tx(self.subscriber, sub_id,
437 "Subscriber -> publisher message corrupted")
446 event_sub_rx = self.subscriber.ed.pop_event(
452 "Publisher -> subscriber message corrupted")
454 asserts.fail('Timed out while waiting for %s on subscriber' %
470 event_sub_term = self.subscriber.ed.pop_event(
477 asserts.fail('Timed out while waiting for %s on subscriber' %
506 """Measure the latency of Aware discovery on the subscriber.
512 other as Subscriber (S)
526 self.subscriber = self.android_devices[1]
533 sub_connect_id = self.exec_connect(self.subscriber, "subscriber",
553 sub_id = self.subscriber.droid.wifiAwareSubscribe(
556 event_sub = self.subscriber.ed.pop_event(
564 event_discovery = self.subscriber.ed.pop_event(
575 'Timed out while waiting for %s|%s on Subscriber',
578 self.subscriber.droid.wifiAwareDestroyDiscoverySession(sub_id)
591 """Measure the latency of Aware discovery on the subscriber.
608 other as Subscriber (S)
621 self.subscriber = self.android_devices[1]
629 sub_connect_id = self.exec_connect(self.subscriber, "subscriber")
633 sub_id = self.subscriber.droid.wifiAwareSubscribe(sub_connect_id,
637 event_sub_match = self.subscriber.ed.pop_event(
643 asserts.fail('Timed out while waiting for %s on Subscriber' %
650 self.subscriber.droid.wifiAwareSendMessage(
658 self.subscriber.droid.wifiAwareSendMessage(
673 events = self.subscriber.ed.pop_events(events_regex,
691 self.log.warning('Timed out while waiting for %s on Subscriber'
769 other as Subscriber (S)
782 self.subscriber = self.android_devices[1]
788 sub_connect_id = self.exec_connect(self.subscriber, "subscriber")
792 sub_id = self.subscriber.droid.wifiAwareSubscribe(sub_connect_id,
796 event_sub_match = self.subscriber.ed.pop_event(
802 asserts.fail('Timed out while waiting for %s on Subscriber' %
814 self.subscriber.droid.wifiAwareSendMessage(
818 events = self.subscriber.ed.pop_events(events_regex,
835 asserts.fail('Timed out while waiting for %s on Subscriber',
849 other as Subscriber (S)
861 self.subscriber = self.android_devices[1]
866 sub_connect_id = self.exec_connect(self.subscriber, "subscriber")
870 sub_id = self.subscriber.droid.wifiAwareSubscribe(sub_connect_id,
874 event_sub_match = self.subscriber.ed.pop_event(
880 asserts.fail('Timed out while waiting for %s on Subscriber' %
884 self.exec_rtt(device=self.subscriber,
889 self.exec_rtt(device=self.subscriber,
894 self.exec_rtt(device=self.subscriber,
950 other as Subscriber (S)
975 self.subscriber = self.android_devices[1]
986 sub_connect_id = self.exec_connect(self.subscriber, "subscriber")
991 sub_id = self.subscriber.droid.wifiAwareSubscribe(sub_connect_id,
998 event_sub_match = self.subscriber.ed.pop_event(
1004 asserts.fail('Timed out while waiting for %s on Subscriber' %
1009 self.reliable_tx(self.subscriber, sub_id,
1022 "Subscriber -> publisher message corrupted")
1037 event_sub_rx = self.subscriber.ed.pop_event(
1040 asserts.fail('Timed out while waiting for %s on subscriber' %
1046 "Publisher -> subscriber message corrupted")
1049 sub_ns = self.subscriber.droid.wifiAwareCreateNetworkSpecifier(sub_id,
1051 self.log.info("Subscriber network specifier - '%s'", sub_ns)
1053 sub_req_key = self.subscriber.droid.connectivityRequestWifiAwareNetwork(
1058 event_network = self.subscriber.ed.wait_for_event(
1064 self.log.info('Subscriber %s: %s', con_const.EVENT_NETWORK_CALLBACK,
1067 asserts.fail('Timed out while waiting for %s/%s on Subscriber' %
1111 nsd_discovery = self.subscriber.droid.nsdDiscoverServices(
1115 event_nsd = self.subscriber.ed.wait_for_event(
1122 'Subscriber %s: %s',
1127 'Timed out while waiting for %s on Subscriber' %
1131 self.subscriber.droid.nsdResolveService(event_nsd['data'])
1133 event_nsd = self.subscriber.ed.wait_for_event(
1140 'Subscriber %s: %s',
1145 'Timed out while waiting for %s on Subscriber' %
1157 self.subscriber.droid.nsdStopServiceDiscovery(nsd_discovery)
1169 result, data = self.subscriber.run_iperf_client(
