[rhmessaging-commits] rhmessaging commits: r4334 - in mgmt/newdata/wooly/python/wooly: wsgiserver and 1 other directory.

Author: justi9 Date: 2010-09-23 09:49:25 -0400 (Thu, 23 Sep 2010) New Revision: 4334 Modified: mgmt/newdata/wooly/python/wooly/server.py mgmt/newdata/wooly/python/wooly/wsgiserver/__init__.py Log: For bz 63581. Grow and shrink the worker thread pool as needed. Adjust the socket backfill and initial threads. Modified: mgmt/newdata/wooly/python/wooly/server.py =================================================================== --- mgmt/newdata/wooly/python/wooly/server.py 2010-09-22 21:42:13 UTC (rev 4333) +++ mgmt/newdata/wooly/python/wooly/server.py 2010-09-23 13:49:25 UTC (rev 4334) @@ -204,8 +204,8 @@ self.wsgi_server = CherryPyWSGIServer \ ((self.server.host, self.server.port), self.server.service_request, - request_queue_size=40, - numthreads=20) + request_queue_size=32, + numthreads=32) self.wsgi_server.environ["wsgi.version"] = (1, 1) Modified: mgmt/newdata/wooly/python/wooly/wsgiserver/__init__.py =================================================================== --- mgmt/newdata/wooly/python/wooly/wsgiserver/__init__.py 2010-09-22 21:42:13 UTC (rev 4333) +++ mgmt/newdata/wooly/python/wooly/wsgiserver/__init__.py 2010-09-23 13:49:25 UTC (rev 4334) @@ -1676,6 +1676,13 @@ if self.interrupt: raise self.interrupt + idle = self.requests.idle + + if idle < 16: + self.requests.grow(16) + elif idle > 32: + self.requests.shrink(2) + def bind(self, family, type, proto=0): """Create (or recreate) the actual socket object.""" self.socket = socket.socket(family, type, proto)