examples/bench: Fix linting errors

Author: 1st1

examples/bench/echoclient.py

@@ -3,11 +3,10 @@
 
 
 import argparse
+import concurrent.futures
+import socket
 import time
 
-from concurrent.futures import ProcessPoolExecutor
-from socket import *
-
 
 if __name__ == '__main__':
     parser = argparse.ArgumentParser()
@@ -48,12 +47,12 @@ def run_test(n):
             n //= args.mpr
 
         if unix:
-            sock = socket(AF_UNIX, SOCK_STREAM)
+            sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
         else:
-            sock = socket(AF_INET, SOCK_STREAM)
+            sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 
         try:
-            sock.setsockopt(IPPROTO_TCP, TCP_NODELAY, 1)
+            sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
         except (OSError, NameError):
             pass
 
@@ -73,10 +72,10 @@ def run_test(n):
     NMESSAGES = args.num
     start = time.time()
     for _ in range(TIMES):
-        with ProcessPoolExecutor(max_workers=N) as e:
+        with concurrent.futures.ProcessPoolExecutor(max_workers=N) as e:
             for _ in range(N):
                 e.submit(run_test, NMESSAGES)
     end = time.time()
     duration = end-start
-    print(NMESSAGES*N*TIMES,'in', duration)
-    print(NMESSAGES*N*TIMES/duration, 'requests/sec')
+    print(NMESSAGES * N * TIMES, 'in', duration)
+    print(NMESSAGES * N * TIMES / duration, 'requests/sec')

examples/bench/echoserver.py

@@ -2,20 +2,18 @@
 import asyncio
 import gc
 import os.path
-import socket as socket_module
-
-from socket import *
+import socket
 
 
 PRINT = 0
 
 
 async def echo_server(loop, address, unix):
     if unix:
-        sock = socket(AF_UNIX, SOCK_STREAM)
+        sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
     else:
-        sock = socket(AF_INET, SOCK_STREAM)
-        sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
+        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
     sock.bind(address)
     sock.listen(5)
     sock.setblocking(False)
@@ -31,7 +29,7 @@ async def echo_server(loop, address, unix):
 
 async def echo_client(loop, client):
     try:
-        client.setsockopt(IPPROTO_TCP, TCP_NODELAY, 1)
+        client.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
     except (OSError, NameError):
         pass
 
@@ -48,7 +46,7 @@ async def echo_client(loop, client):
 async def echo_client_streams(reader, writer):
     sock = writer.get_extra_info('socket')
     try:
-        sock.setsockopt(IPPROTO_TCP, TCP_NODELAY, 1)
+        sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
     except (OSError, NameError):
         pass
     if PRINT: