78e8f1dca0
api_workers=0 does not disable api workers but neutron-server still launches one api worker. Rejecting 0 helps user notice that the value they request in config files is not honored. Also the other rpc workers options disable the corresponding workers completely by setting these options to 0, so setting negative values work but does not bring any special benefit. Change-Id: Iac16b241c71ac1068c6fbea3cc792b74bfc66c03
70 lines
2.6 KiB
Python
70 lines
2.6 KiB
Python
# Copyright 2011 VMware, Inc
|
|
# All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
|
|
from oslo_config import cfg
|
|
|
|
from neutron._i18n import _
|
|
|
|
|
|
SERVICE_OPTS = [
|
|
cfg.IntOpt('periodic_interval',
|
|
default=40,
|
|
help=_('Seconds between running periodic tasks.')),
|
|
cfg.IntOpt('api_workers',
|
|
min=1,
|
|
help=_('Number of separate API worker processes for service. '
|
|
'If not specified, the default is equal to the number '
|
|
'of CPUs available for best performance, capped by '
|
|
'potential RAM usage.')),
|
|
cfg.IntOpt('rpc_workers',
|
|
min=0,
|
|
help=_('Number of RPC worker processes for service. '
|
|
'If not specified, the default is equal to half the '
|
|
'number of API workers. If set to 0, no RPC worker '
|
|
'is launched.')),
|
|
cfg.IntOpt('rpc_state_report_workers',
|
|
default=1,
|
|
min=0,
|
|
help=_('Number of RPC worker processes dedicated to the state '
|
|
'reports queue. If set to 0, no dedicated RPC worker '
|
|
'for state reports queue is launched.')),
|
|
cfg.IntOpt('periodic_fuzzy_delay',
|
|
default=5,
|
|
help=_('Range of seconds to randomly delay when starting the '
|
|
'periodic task scheduler to reduce stampeding. '
|
|
'(Disable by setting to 0)')),
|
|
]
|
|
|
|
RPC_EXTRA_OPTS = [
|
|
cfg.IntOpt('rpc_response_max_timeout',
|
|
default=600,
|
|
help=_('Maximum seconds to wait for a response from an RPC '
|
|
'call.')),
|
|
]
|
|
|
|
|
|
def register_service_opts(opts, conf=cfg.CONF):
|
|
conf.register_opts(opts)
|
|
|
|
|
|
def get_rpc_workers(conf=cfg.CONF):
|
|
"""Retrieve the conf knob rpc_workers, register option first if needed"""
|
|
try:
|
|
return conf.rpc_workers
|
|
except cfg.NoSuchOptError:
|
|
register_service_opts(SERVICE_OPTS, conf=conf)
|
|
return conf.rpc_workers
|