Lines Matching refs:sock
264 def _sendto(sock, s, addr):
265 sock.sendto(s.encode('ascii'), addr)
267 def _recv(sock, n):
268 return sock.recv(n).decode('ascii')
271 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
276 _sendto(sock, "%r\n" % _time(), addr)
284 _sendto(sock, LAT_END + "\n", addr)
286 sock.close()
297 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
298 sock.bind(("127.0.0.1", 0))
299 addr = sock.getsockname()
341 process = run_latency_client(addr=sock.getsockname(),
343 s = _recv(sock, 4096)
352 s = _recv(sock, 4096)
361 sock.close()
399 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
400 sock.bind(("127.0.0.1", 0))
401 local_addr = sock.getsockname()
405 _sendto(sock, ("%r#%s\n" % (local_addr, msg)).rjust(packet_size), addr)
414 s = _recv(sock, packet_size)
419 sock.close()
430 with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as sock:
431 sock.bind(("127.0.0.1", 0))
432 addr = sock.getsockname()
477 s = _recv(sock, packet_size)
488 _sendto(sock, s, remote_addr)
489 s = _recv(sock, packet_size)