requests: refactor to enable coverage (#7692)

The fuzzer got stuck in `accept` when running in coverage mode. This
causes coverage builds to timeout. This fixes it locally for me.

projects/requests/fuzz_server.py

@@ -34,40 +34,43 @@ def SetFuzzedInput(input_bytes):
 class ServerThread(threading.Thread):
 
     def __init__(self):
+        self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        self.s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+        self.s.bind(("127.0.0.1", 8001))
+        self.s.listen(1)
+
         threading.Thread.__init__(self)
 
     def run(self):
         global fuzzed_input
-        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        conn, addr = self.s.accept()
-        s.bind(("127.0.0.1", 8001))
+        conn.recv(1024)
-        s.listen(1)
+        conn.send(fuzzed_input)
-        while 1:
+        time.sleep(0.005)
-            conn, addr = s.accept()
+        conn.close()
-            conn.recv(1024)
+        self.s.shutdown(1)
-            conn.send(fuzzed_input)
+        self.s.close()
-            time.sleep(0.005)
+        time.sleep(0.01)
-            conn.close()
 
 def TestOneInput(input_bytes):
+  t1 = ServerThread()
+  # Launch threads
+  t1.start()
   SetFuzzedInput(input_bytes)
   try:
-    r = requests.get('http://127.0.0.1:8001/', timeout=0.01)
+    r = requests.get('http://127.0.0.1:8001/', timeout=2.0)
     r.status_code
     r.headers
     r.text
   except requests.exceptions.RequestException as e:
     pass
+  t1.join()
 
 
 def main():
+  atheris.instrument_all()
   atheris.Setup(sys.argv, TestOneInput, enable_python_coverage=True)
-  t1 = ServerThread()
-  # Launch threads
-  t1.start()
-
   atheris.Fuzz()
-  # Wait for threads to finish
-  t1.join()
 
 
 if __name__ == "__main__":