27     def __init__(self, apdev=None, global_ctrl_override=None):  argument
34         self.host = remotehost.Host(hostname)
35         self.hostname = hostname
36         self.port = port
41             self.ctrl = wpaspy.Ctrl(global_ctrl)
42             self.mon = wpaspy.Ctrl(global_ctrl)
43             self.dbg = ""
45             self.ctrl = wpaspy.Ctrl(hostname, port)
46             self.mon = wpaspy.Ctrl(hostname, port)
47             self.dbg = hostname + "/" + str(port)
48         self.mon.attach()
50     def cmd_execute(self, cmd_array, shell=False):  argument
51         if self.hostname is None:
62             return self.host.execute(cmd_array)
64     def request(self, cmd, timeout=10):  argument
65         logger.debug(self.dbg + ": CTRL(global): " + cmd)
66         return self.ctrl.request(cmd, timeout)
68     def wait_event(self, events, timeout):  argument
71             while self.mon.pending():
72                 ev = self.mon.recv()
73                 logger.debug(self.dbg + "(global): " + ev)
81             if not self.mon.pending(timeout=remaining):
85     def add(self, ifname, driver=None):  argument
89         res = self.request(cmd)
93     def add_iface(self, ifname, confname):  argument
94         res = self.request("ADD " + ifname + " config=" + confname)
98     def add_bss(self, phy, confname, ignore_error=False):  argument
99         res = self.request("ADD bss_config=" + phy + ":" + confname)
104     def add_link(self, ifname, confname):  argument
105         res = self.request("ADD " + ifname + " config=" + confname)
109     def remove(self, ifname):  argument
110         self.request("REMOVE " + ifname, timeout=30)
112     def relog(self):  argument
113         self.request("RELOG")
115     def flush(self):  argument
116         self.request("FLUSH")
118     def get_ctrl_iface_port(self, ifname):  argument
119         if self.hostname is None:
122         res = self.request("INTERFACES ctrl")
138     def terminate(self):  argument
139         self.mon.detach()
140         self.mon.close()
141         self.mon = None
142         self.ctrl.terminate()
143         self.ctrl = None
145     def send_file(self, src, dst):  argument
146         self.host.send_file(src, dst)
149     def __init__(self, ifname, bssidx=0, hostname=None, ctrl=hapd_ctrl,  argument
151         self.hostname = hostname
152         self.host = remotehost.Host(hostname, ifname)
153         self.ifname = ifname
155             self.ctrl = wpaspy.Ctrl(os.path.join(ctrl, ifname))
156             self.mon = wpaspy.Ctrl(os.path.join(ctrl, ifname))
157             self.dbg = ifname
159             self.ctrl = wpaspy.Ctrl(hostname, port)
160             self.mon = wpaspy.Ctrl(hostname, port)
161             self.dbg = hostname + "/" + ifname
162         self.mon.attach()
163         self.bssid = None
164         self.bssidx = bssidx
165         self.mld_addr = None
167     def cmd_execute(self, cmd_array, shell=False):  argument
168         if self.hostname is None:
179             return self.host.execute(cmd_array)
181     def close_ctrl(self):  argument
182         if self.mon is not None:
183             self.mon.detach()
184             self.mon.close()
185             self.mon = None
186             self.ctrl.close()
187             self.ctrl = None
189     def own_addr(self):  argument
190         if self.bssid is None:
191             self.bssid = self.get_status_field('bssid[%d]' % self.bssidx)
192         return self.bssid
194     def own_mld_addr(self):  argument
195         if self.mld_addr is None:
196             self.mld_addr = self.get_status_field('mld_addr[%d]' % self.bssidx)
197         return self.mld_addr
199     def get_addr(self, group=False):  argument
200         if self.own_mld_addr() is None:
201             return self.own_addr()
202         return self.own_mld_addr()
204     def request(self, cmd):  argument
205         logger.debug(self.dbg + ": CTRL: " + cmd)
206         return self.ctrl.request(cmd)
208     def ping(self):  argument
209         return "PONG" in self.request("PING")
211     def set(self, field, value):  argument
212         if "OK" not in self.request("SET " + field + " " + value):
218     def set_defaults(self, set_channel=True):  argument
219         self.set("driver", "nl80211")
221             self.set("hw_mode", "g")
222             self.set("channel", "1")
223             self.set("ieee80211n", "1")
224         self.set("logger_stdout", "-1")
225         self.set("logger_stdout_level", "0")
227     def set_open(self, ssid):  argument
228         self.set_defaults()
229         self.set("ssid", ssid)
231     def set_wpa2_psk(self, ssid, passphrase):  argument
232         self.set_defaults()
233         self.set("ssid", ssid)
234         self.set("wpa_passphrase", passphrase)
235         self.set("wpa", "2")
236         self.set("wpa_key_mgmt", "WPA-PSK")
237         self.set("rsn_pairwise", "CCMP")
239     def set_wpa_psk(self, ssid, passphrase):  argument
240         self.set_defaults()
241         self.set("ssid", ssid)
242         self.set("wpa_passphrase", passphrase)
243         self.set("wpa", "1")
244         self.set("wpa_key_mgmt", "WPA-PSK")
245         self.set("wpa_pairwise", "TKIP")
247     def set_wpa_psk_mixed(self, ssid, passphrase):  argument
248         self.set_defaults()
249         self.set("ssid", ssid)
250         self.set("wpa_passphrase", passphrase)
251         self.set("wpa", "3")
252         self.set("wpa_key_mgmt", "WPA-PSK")
253         self.set("wpa_pairwise", "TKIP")
254         self.set("rsn_pairwise", "CCMP")
256     def set_wep(self, ssid, key):  argument
257         self.set_defaults()
258         self.set("ssid", ssid)
259         self.set("wep_key0", key)
261     def enable(self):  argument
262         if "OK" not in self.request("ENABLE"):
263             raise Exception("Failed to enable hostapd interface " + self.ifname)
265     def disable(self):  argument
266         if "OK" not in self.request("DISABLE"):
267             raise Exception("Failed to disable hostapd interface " + self.ifname)
269     def link_remove(self, count=10):  argument
270         if "OK" not in self.request("LINK_REMOVE %u" % count):
271             raise Exception("Failed to remove hostapd link " + self.ifname)
273     def dump_monitor(self):  argument
274         while self.mon.pending():
275             ev = self.mon.recv()
276             logger.debug(self.dbg + ": " + ev)
278     def wait_event(self, events, timeout):  argument
283             while self.mon.pending():
284                 ev = self.mon.recv()
285                 logger.debug(self.dbg + ": " + ev)
293             if not self.mon.pending(timeout=remaining):
297     def wait_sta(self, addr=None, timeout=2, wait_4way_hs=False):  argument
298         ev = self.wait_event(["AP-STA-CONNECT"], timeout=timeout)
304             ev2 = self.wait_event(["EAPOL-4WAY-HS-COMPLETED"],
312     def wait_sta_disconnect(self, addr=None, timeout=2):  argument
313         ev = self.wait_event(["AP-STA-DISCONNECT"], timeout=timeout)
320     def wait_4way_hs(self, addr=None, timeout=1):  argument
321         ev = self.wait_event(["EAPOL-4WAY-HS-COMPLETED"], timeout=timeout)
328     def wait_ptkinitdone(self, addr, timeout=2):  argument
330             sta = self.get_sta(addr)
340     def get_status(self):  argument
341         res = self.request("STATUS")
349     def get_status_field(self, field):  argument
350         vals = self.get_status()
355     def get_driver_status(self):  argument
356         res = self.request("STATUS-DRIVER")
364     def get_driver_status_field(self, field):  argument
365         vals = self.get_driver_status()
370     def get_config(self):  argument
371         res = self.request("GET_CONFIG")
379     def mgmt_rx(self, timeout=5):  argument
380         ev = self.wait_event(["MGMT-RX"], timeout=timeout)
404     def mgmt_tx(self, msg):  argument
407         res = self.request("MGMT_TX " + binascii.hexlify(hdr + msg['payload']).decode())
411     def get_sta(self, addr, info=None, next=False):  argument
414             res = self.request("STA-FIRST")
416             res = self.request(cmd + addr + " " + info)
418             res = self.request(cmd + addr)
431     def get_mib(self, param=None):  argument
433             res = self.request("MIB " + param)
435             res = self.request("MIB")
444     def get_pmksa(self, addr):  argument
445         res = self.request("PMKSA")
459     def dpp_qr_code(self, uri):  argument
460         res = self.request("DPP_QR_CODE " + uri)
465     def dpp_nfc_uri(self, uri):  argument
466         res = self.request("DPP_NFC_URI " + uri)
471     def dpp_bootstrap_gen(self, type="qrcode", chan=None, mac=None, info=None,  argument
479                 mac = self.own_addr()
491         res = self.request(cmd)
496     def dpp_bootstrap_set(self, id, conf=None, configurator=None, ssid=None,  argument
507         if "OK" not in self.request(cmd):
510     def dpp_listen(self, freq, netrole=None, qr=None, role=None):  argument
518         if "OK" not in self.request(cmd):
521     def dpp_auth_init(self, peer=None, uri=None, conf=None, configurator=None,  argument
528                 peer = self.dpp_nfc_uri(nfc_uri)
530                 peer = self.dpp_qr_code(uri)
550         res = self.request(cmd)
558     def dpp_pkex_init(self, identifier, code, role=None, key=None, curve=None,  argument
561             id1 = self.dpp_bootstrap_gen(type="pkex", key=key, curve=curve)
575         res = self.request("DPP_PKEX_ADD " + cmd)
580     def dpp_pkex_resp(self, freq, identifier, code, key=None, curve=None,  argument
582         id0 = self.dpp_bootstrap_gen(type="pkex", key=key, curve=curve)
587         res = self.request("DPP_PKEX_ADD " + cmd)
590         self.dpp_listen(freq, role=listen_role)
592     def dpp_configurator_add(self, curve=None, key=None,  argument
601         res = self.request(cmd)
606     def dpp_configurator_remove(self, conf_id):  argument
607         res = self.request("DPP_CONFIGURATOR_REMOVE %d" % conf_id)
611     def note(self, txt):  argument
612         self.request("NOTE " + txt)
614     def send_file(self, src, dst):  argument
615         self.host.send_file(src, dst)
617     def get_ptksa(self, bssid, cipher):  argument
618         res = self.request("PTKSA_CACHE_LIST")