Merge pull request #21 from david-farrar/master

don't reap what isn't there
shutdown properly when the reactor signals an error
fix sending responses when we do not yet have the answer

lib/exaproxy/reactor/redirector/manager.py

@@ -200,7 +200,10 @@ def acquire (self):
 		return worker
 
 	def release (self, wid):
-		if wid not in self.stopping and wid in self.worker:
+		if wid not in self.worker:
+			return
+
+		if wid not in self.stopping:
 			self.available.add(wid)
 
 		else:

lib/exaproxy/reactor/redirector/reactor.py

@@ -32,7 +32,7 @@ def run(self):
 
 		# we may have new workers to deal with queued requests
 		client_id, command, decision = self.decider.doqueue()
-		while client_id is not None:
+		while command is not None:
 			self.querier.sendResponse(client_id, command, decision)
 			client_id, command, decision = self.decider.doqueue()
 
@@ -62,7 +62,7 @@ def run(self):
 			# decisions made by the child processes
 			for worker in events.get('read_workers', []):
 				client_id, command, decision = self.decider.getDecision(worker)
-				if client_id is not None:
+				if command is not None:
 					self.querier.sendResponse(client_id, command, decision)
 
 			# we should have available workers now so check for queued requests

lib/exaproxy/supervisor.py

@@ -245,7 +245,7 @@ def run (self):
 				# check for IO change with select
 				status = self.reactor.run()
 				if status is False:
-					self.exit()
+					self._shutdown = True
 
 				# must follow the reactor so we are sure to go through the reactor at least once
 				# and flush any logs