x/python-ganttclient
Code Issues Proposed changes

Add rpc_conn_pool_size flag for the new connection pool

Browse Source
This commit is contained in:
Chris Behrens
2011-05-25 15:42:24 -07:00
committed by termie
parent 26daa48eb5
commit 0e22560ea2
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
nova/rpc.py
View File

@@ -50,7 +50,10 @@ LOG = logging.getLogger('nova.rpc')
FLAGS = flags.FLAGS
flags.DEFINE_integer('rpc_thread_pool_size', 1024, 'Size of RPC thread pool')
flags.DEFINE_integer('rpc_thread_pool_size', 1024,
'Size of RPC thread pool')
flags.DEFINE_integer('rpc_conn_pool_size', 30,
'Size of RPC connection pool')
class Connection(carrot_connection.BrokerConnection):
@@ -99,7 +102,7 @@ class Pool(pools.Pool):
def create(self):
return Connection.instance(new=True)
ConnectionPool = Pool(max_size=20)
ConnectionPool = Pool(max_size=FLAGS.rpc_conn_pool_size)
class Consumer(messaging.Consumer):