Lines Matching refs:socket

5 import socket
21         self.send_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
22         self.recv_fd = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
36         self.socket = Socket()
55             self.socket.recv_fd.bind(self.file_path)
56         except socket.error as msg:
58         self.socket.recv_fd.settimeout(2)
59         self.socket.send_fd.connect("/var/run/dpdk/rte/telemetry")
61         self.socket.send_fd.sendall(JSON.encode())
63         self.socket.recv_fd.listen(1)
64         self.socket.client_fd = self.socket.recv_fd.accept()[0]
67         self.socket.client_fd.send((API_UNREG + self.file_path + "\"}}").encode())
68         self.socket.client_fd.close()
71         self.socket.client_fd.send(METRICS_REQ.encode())
72         data = self.socket.client_fd.recv(BUFFER_SIZE).decode()
85         self.socket.client_fd.send(GLOBAL_METRICS_REQ.encode())
86         data = self.socket.client_fd.recv(BUFFER_SIZE).decode()