diff options
| author | Soren Hansen <soren@linux2go.dk> | 2011-02-16 00:10:17 +0100 |
|---|---|---|
| committer | Soren Hansen <soren@linux2go.dk> | 2011-02-16 00:10:17 +0100 |
| commit | 00f785dab7d269b9baf403f51bc1d4b2ea1dc06a (patch) | |
| tree | 8bb041faa32c90f205d66056bc25bd322909e534 /nova | |
| parent | dfcf07192cf40d0451c7dfa3802994e4cef8d116 (diff) | |
| download | nova-00f785dab7d269b9baf403f51bc1d4b2ea1dc06a.tar.gz nova-00f785dab7d269b9baf403f51bc1d4b2ea1dc06a.tar.xz nova-00f785dab7d269b9baf403f51bc1d4b2ea1dc06a.zip | |
Make rpc thread pool size configurable.
Diffstat (limited to 'nova')
| -rw-r--r-- | nova/rpc.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index efe6164ad..067d954d0 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -43,6 +43,8 @@ from nova import utils FLAGS = flags.FLAGS LOG = logging.getLogger('nova.rpc') +FLAGS.DEFINE_integer('rpc_thread_pool_size', 1024, 'Size of RPC thread pool') + class Connection(carrot_connection.BrokerConnection): """Connection instance object""" @@ -156,7 +158,7 @@ class AdapterConsumer(TopicConsumer): def __init__(self, connection=None, topic="broadcast", proxy=None): LOG.debug(_('Initing the Adapter Consumer for %s') % topic) self.proxy = proxy - self.pool = greenpool.GreenPool(1024) + self.pool = greenpool.GreenPool(FLAGS.rpc_thread_pool_size) super(AdapterConsumer, self).__init__(connection=connection, topic=topic) |