openstack/vitrage
Code Issues Proposed changes

oslo messaging removed the blocking option

Browse Source 
Use a threaded option with max size 1

Change-Id: I158fee200b828c4329af1b5e9cf2ef0c728ecf1d
This commit is contained in:
Eyal 2020-03-08 09:04:38 +02:00
parent 785d8f0167
commit 4a740b4a41
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
devstack/plugin.sh
View File

@ -242,6 +242,8 @@ function configure_vitrage {
elif is_service_enabled etcd3; then elif is_service_enabled etcd3; then
iniset $VITRAGE_CONF coordination backend_url "etcd3+http://${SERVICE_HOST}:$ETCD_PORT" iniset $VITRAGE_CONF coordination backend_url "etcd3+http://${SERVICE_HOST}:$ETCD_PORT"
fi fi
iniset $VITRAGE_CONF DEFAULT "executor_thread_pool_size" 1
} }
# init_vitrage() - Initialize etc. # init_vitrage() - Initialize etc.

3
vitrage/messaging.py
View File

@ -60,8 +60,7 @@ def get_notification_listener(transport, targets, endpoints,
allow_requeue=False): allow_requeue=False):
"""Return a configured oslo_messaging notification listener.""" """Return a configured oslo_messaging notification listener."""
return oslo_msg.get_notification_listener( return oslo_msg.get_notification_listener(
transport, targets, endpoints, executor='blocking', transport, targets, endpoints, allow_requeue=allow_requeue)
allow_requeue=allow_requeue)
class VitrageNotifier(object): class VitrageNotifier(object):

1
vitrage/rpc.py
View File

@ -97,6 +97,5 @@ def get_server(target, endpoints, transport, serializer=None):
return messaging.get_rpc_server(transport, return messaging.get_rpc_server(transport,
target, target,
endpoints, endpoints,
executor='blocking',
serializer=serializer, serializer=serializer,
access_policy=access_policy) access_policy=access_policy)