17     def __init__(self, path, port=9877):  argument
19         self.started = False
20         self.attached = False
21         self.path = path
22         self.port = port
24         self.udp = False
29                     self.udp = True
31                 self.udp = True
33         if not self.udp:
34             self.s = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
35             self.dest = path
36             self.local = "/tmp/wpa_ctrl_" + str(os.getpid()) + '-' + str(counter)
38             self.s.bind(self.local)
40                 self.s.connect(self.dest)
42                 self.s.close()
43                 os.unlink(self.local)
47                 self.s = None
51                     self.sockaddr = sockaddr
53                 self.s = socket.socket(af, socktype)
54                 self.s.settimeout(5)
55                 self.s.sendto(b"GET_COOKIE", sockaddr)
56                 reply, server = self.s.recvfrom(4096)
57                 self.cookie = reply
58                 self.port = port
61                 if self.s != None:
62                     self.s.close()
64         self.started = True
66     def __del__(self):  argument
67         self.close()
69     def close(self):  argument
70         if self.attached:
72                 self.detach()
75                 self.attached = False
77         if self.started:
78             self.s.close()
79             if not self.udp:
80                 os.unlink(self.local)
81             self.started = False
83     def request(self, cmd, timeout=10):  argument
90         if self.udp:
91             self.s.sendto(self.cookie + cmd, self.sockaddr)
93             self.s.send(cmd)
94         [r, w, e] = select.select([self.s], [], [], timeout)
96             res = self.s.recv(4096).decode()
104     def attach(self):  argument
105         if self.attached:
107         res = self.request("ATTACH")
109             self.attached = True
113     def detach(self):  argument
114         if not self.attached:
116         if self.s.fileno() == -1:
117             self.attached = False
119         while self.pending():
120             ev = self.recv()
121         res = self.request("DETACH")
123             self.attached = False
127     def terminate(self):  argument
128         if self.attached:
130                 self.detach()
133                 self.attached = False
134         self.request("TERMINATE")
135         self.close()
137     def pending(self, timeout=0):  argument
138         [r, w, e] = select.select([self.s], [], [], timeout)
143     def recv(self):  argument
144         res = self.s.recv(4096).decode()