Lines Matching refs:self
154 def __init__(self, iface, fst_group, fst_pri, fst_llt=None, rsn=False): argument
155 self.iface = iface
156 self.fst_group = fst_group
157 self.fst_pri = fst_pri
158 self.fst_llt = fst_llt # None llt means no llt parameter will be set
159 self.instance = None # Hostapd/WpaSupplicant instance
160 self.peer_obj = None # Peer object, must be a FstDevice child object
161 self.new_peer_addr = None # Peer MAC address for new session iface
162 self.old_peer_addr = None # Peer MAC address for old session iface
163 self.role = 'initiator' # Role: initiator/responder
164 s = self.grequest("FST-MANAGER TEST_REQUEST IS_SUPPORTED")
167 self.rsn = rsn
169 def ifname(self): argument
170 return self.iface
172 def get_instance(self): argument
176 def get_own_mac_address(self): argument
180 def get_new_peer_addr(self): argument
181 return self.new_peer_addr
183 def get_old_peer_addr(self): argument
184 return self.old_peer_addr
186 def get_actual_peer_addr(self): argument
190 def grequest(self, req): argument
194 def wait_gevent(self, events, timeout=None): argument
198 def request(self, req): argument
200 h = self.get_instance()
203 def wait_event(self, events, timeout=None): argument
205 h = self.get_instance()
211 def set_old_peer_addr(self, peer_addr=None): argument
214 self.old_peer_addr = peer_addr
216 self.old_peer_addr = self.get_actual_peer_addr()
218 def set_new_peer_addr(self, peer_addr=None): argument
221 self.new_peer_addr = peer_addr
223 self.new_peer_addr = self.get_actual_peer_addr()
225 def add_peer(self, obj, old_peer_addr=None, new_peer_addr=None): argument
232 self.peer_obj = obj
233 self.set_old_peer_addr(old_peer_addr)
234 self.set_new_peer_addr(new_peer_addr)
236 def get_peer(self): argument
238 return self.peer_obj
240 def set_fst_parameters(self, group_id=None, pri=None, llt=None): argument
244 self.fst_group = group_id
246 self.fst_pri = pri
248 self.fst_llt = llt
250 def get_local_mbies(self, ifname=None): argument
251 if_name = ifname if ifname is not None else self.iface
252 return self.grequest("FST-MANAGER TEST_REQUEST GET_LOCAL_MBIES " + if_name)
254 def add_session(self): argument
257 if self.peer_obj is None:
259 self.dump_monitor()
260 grp = ' ' + self.fst_group if self.fst_group != '' else ''
261 sid = self.grequest("FST-MANAGER SESSION_ADD" + grp)
265 self.dump_monitor()
268 def set_session_param(self, params): argument
272 return self.grequest(request)
274 def get_session_params(self, sid): argument
276 res = self.grequest(request)
285 def iface_peers(self, ifname): argument
286 grp = self.fst_group if self.fst_group != '' else ''
287 res = self.grequest("FST-MANAGER IFACE_PEERS " + grp + ' ' + ifname)
292 def get_peer_mbies(self, ifname, peer_addr): argument
293 return self.grequest("FST-MANAGER GET_PEER_MBIES %s %s" % (ifname, peer_addr))
295 def list_ifaces(self): argument
296 grp = self.fst_group if self.fst_group != '' else ''
297 res = self.grequest("FST-MANAGER LIST_IFACES " + grp)
310 def list_groups(self): argument
311 res = self.grequest("FST-MANAGER LIST_GROUPS")
316 def configure_session(self, sid, new_iface, old_iface=None): argument
321 self.dump_monitor()
322 oldiface = old_iface if old_iface is not None else self.iface
323 s = self.set_session_param(sid + ' old_ifname=' + oldiface)
327 s = self.set_session_param(sid + " new_ifname=" + new_iface)
330 if self.new_peer_addr is not None and self.new_peer_addr != '':
331 s = self.set_session_param(sid + " new_peer_addr=" + self.new_peer_addr)
334 if self.old_peer_addr is not None and self.old_peer_addr != '':
335 s = self.set_session_param(sid + " old_peer_addr=" + self.old_peer_addr)
338 if self.fst_llt is not None and self.fst_llt != '':
339 s = self.set_session_param(sid + " llt=" + self.fst_llt)
342 self.dump_monitor()
344 def send_iface_attach_request(self, ifname, group, llt, priority): argument
350 res = self.grequest(request)
354 def send_iface_detach_request(self, ifname): argument
355 res = self.grequest("FST-DETACH " + ifname)
359 def send_session_setup_request(self, sid): argument
360 s = self.grequest("FST-MANAGER SESSION_INITIATE " + sid)
365 def send_session_setup_response(self, sid, response): argument
367 s = self.grequest(request)
372 def send_test_session_setup_request(self, fsts_id, argument
377 s = self.grequest(request)
382 def send_test_session_setup_response(self, fsts_id, argument
387 s = self.grequest(request)
392 def send_test_ack_request(self, fsts_id): argument
393 s = self.grequest("FST-MANAGER TEST_REQUEST SEND_ACK_REQUEST " + fsts_id)
398 def send_test_ack_response(self, fsts_id): argument
399 s = self.grequest("FST-MANAGER TEST_REQUEST SEND_ACK_RESPONSE " + fsts_id)
404 def send_test_tear_down(self, fsts_id): argument
405 s = self.grequest("FST-MANAGER TEST_REQUEST SEND_TEAR_DOWN " + fsts_id)
410 def get_fsts_id_by_sid(self, sid): argument
411 s = self.grequest("FST-MANAGER TEST_REQUEST GET_FSTS_ID " + sid)
416 def wait_for_iface_event(self, timeout): argument
418 ev = self.wait_gevent(["FST-EVENT-IFACE"], timeout)
427 def wait_for_session_event(self, timeout, events_to_ignore=[], argument
430 ev = self.wait_gevent(["FST-EVENT-SESSION"], timeout)
445 def initiate_session(self, sid, response="accept"): argument
453 s = self.grequest("FST-MANAGER SESSION_INITIATE"+ strsid)
456 ev = self.peer_obj.wait_gevent(["FST-EVENT-SESSION"], timeout=5)
465 ev = self.peer_obj.wait_gevent(["FST-EVENT-SESSION"], timeout=5)
478 …s = self.peer_obj.grequest("FST-MANAGER SESSION_RESPOND "+ event['id'] + " " + response) # Or rej…
489 ev = self.wait_gevent(["FST-EVENT-SESSION"], timeout=5)
509 def transfer_session(self, sid): argument
515 self.dump_monitor()
518 s = self.grequest(request)
523 ev = self.peer_obj.wait_gevent(["FST-EVENT-SESSION"], timeout=5)
535 self.dump_monitor()
538 def wait_for_tear_down(self): argument
539 ev = self.wait_gevent(["FST-EVENT-SESSION"], timeout=5)
553 def teardown_session(self, sid): argument
556 s = self.grequest("FST-MANAGER SESSION_TEARDOWN" + strsid)
559 self.peer_obj.wait_for_tear_down()
562 def remove_session(self, sid, wait_for_tear_down=True): argument
565 s = self.grequest("FST-MANAGER SESSION_REMOVE" + strsid)
569 self.peer_obj.wait_for_tear_down()
571 def remove_all_sessions(self): argument
573 grp = ' ' + self.fst_group if self.fst_group != '' else ''
574 s = self.grequest("FST-MANAGER LIST_SESSIONS" + grp)
579 self.remove_session(sid, wait_for_tear_down=False)
586 def __init__(self, iface, ssid, mode, chan, fst_group, fst_pri, argument
591 self.ssid = ssid
592 self.mode = mode
593 self.chan = chan
594 self.reg_ctrl = fst_test_common.HapdRegCtrl()
595 self.reg_ctrl.add_ap(iface, self.chan)
596 self.global_instance = hostapd.HostapdGlobal()
597 FstDevice.__init__(self, iface, fst_group, fst_pri, fst_llt, rsn)
599 def start(self, return_early=False): argument
604 params['ssid'] = self.ssid
605 params['hw_mode'] = self.mode
606 params['channel'] = self.chan
608 if self.rsn:
613 self.hapd = hostapd.add_ap(self.iface, params)
614 if not self.hapd.ping():
616 self.reg_ctrl.start()
617 self.get_global_instance()
619 return self.hapd
620 if len(self.fst_group) != 0:
621 self.send_iface_attach_request(self.iface, self.fst_group,
622 self.fst_llt, self.fst_pri)
623 return self.hapd
625 def stop(self): argument
628 if len(self.fst_group) != 0:
629 self.remove_all_sessions()
631 self.send_iface_detach_request(self.iface)
634 self.reg_ctrl.stop()
635 del self.global_instance
636 self.global_instance = None
638 def get_instance(self): argument
640 if self.instance is None:
641 self.instance = hostapd.Hostapd(self.iface)
642 return self.instance
644 def get_global_instance(self): argument
645 return self.global_instance
647 def get_own_mac_address(self): argument
649 h = self.get_instance()
653 def get_actual_peer_addr(self): argument
657 h = self.get_instance()
666 def grequest(self, req): argument
669 h = self.get_global_instance()
672 def wait_gevent(self, events, timeout=None): argument
674 h = self.get_global_instance()
680 def get_ssid(self): argument
681 return self.ssid
683 def dump_monitor(self): argument
685 if self.instance:
686 self.instance.dump_monitor()
692 def __init__(self, iface, fst_group, fst_pri, fst_llt=None, rsn=False): argument
696 FstDevice.__init__(self, iface, fst_group, fst_pri, fst_llt, rsn)
697 self.connected = None # FstAP object the station is connected to
699 def start(self): argument
704 h = self.get_instance()
705 h.interface_add(self.iface, drv_params="force_connect_cmd=1")
708 if len(self.fst_group) != 0:
709 self.send_iface_attach_request(self.iface, self.fst_group,
710 self.fst_llt, self.fst_pri)
713 def stop(self): argument
717 h = self.get_instance()
719 if len(self.fst_group) != 0:
720 self.remove_all_sessions()
721 self.send_iface_detach_request(self.iface)
723 h.interface_remove(self.iface)
726 self.instance = None
728 def get_instance(self): argument
730 if self.instance is None:
731 self.instance = WpaSupplicant(global_iface='/tmp/wpas-wlan5')
732 return self.instance
734 def get_own_mac_address(self): argument
736 h = self.get_instance()
740 def get_actual_peer_addr(self): argument
742 h = self.get_instance()
746 def grequest(self, req): argument
749 h = self.get_instance()
752 def wait_gevent(self, events, timeout=None): argument
754 h = self.get_instance()
760 def scan(self, freq=None, no_wait=False, only_new=False): argument
766 h = self.get_instance()
773 def connect(self, ap, **kwargs): argument
777 h = self.get_instance()
782 self.connected = ap
784 def connect_to_external_ap(self, ap, ssid, check_connection=True, **kwargs): argument
788 h = self.get_instance()
791 self.connected = ap
795 self.connected = None
799 def disconnect(self, check_disconnect=True): argument
801 if self.connected is not None:
802 h = self.get_instance()
806 hap = self.connected.get_instance()
809 … raise Exception("No disconnection event received from %s" % self.connected.get_ssid())
811 self.connected = None
814 def disconnect_from_external_ap(self, check_disconnect=True): argument
817 if self.connected is not None:
818 h = self.get_instance()
822 hap = self.connected
827 self.connected = None
829 def dump_monitor(self): argument
831 if self.instance:
832 self.instance.dump_monitor()