def read_requests(self, control, stream):
        try:
            while True:
                request = WSGIRequest(self._server)
                request.read_request(stream.reader)                
                self.MSG_REQUEST_READ.send(control)(request, None)
                request.read_request_data()
        except EOFError, e:
            if request.state == request.STATE_WAIT_FOR_REQUEST:
                pass #this is normal at the end of the http KA connection (client closes) 
        except __HOLE__, e:
            if e.errno == 104 and request.state == request.STATE_WAIT_FOR_REQUEST:
                pass #connection reset by peer while waiting for request
        except TimeoutError, e:
            self.log.warn("Timeout in reader")
        except Exception, e:
            self.log.exception("Exception in reader")

        self.MSG_READ_ERROR.send(control)(None, None)
dataset/ETHPy150Open concurrence/concurrence/lib/concurrence/http/server.py/HTTPHandler.read_requests