ngamsServer.py 文件源码

def process_request(self,
                        request,
                        client_address):
        """
        Start a new thread to process the request.
        """

        if self._ngamsServer.serving_count >= self._ngamsServer.getCfg().getMaxSimReqs():
            logger.error("Maximum number of serving threads reached, rejecting request")
            wfile = request.makefile('wb')
            wfile.write(b'HTTP/1.0 503 Service Unavailable\r\n\r\n')
            return

        SocketServer.ThreadingMixIn.process_request(self, request, client_address)