Source code for ironic.command.pxe_filter

# 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.

import sys

from oslo_config import cfg
from oslo_log import log
from oslo_service import service

from ironic.common import rpc_service
from ironic.common import service as ironic_service
from ironic.objects import base as objects_base
from ironic.objects import indirection

CONF = cfg.CONF
LOG = log.getLogger(__name__)




class RPCService(rpc_service.BaseRPCService):



    def stop(self):
        try:
            self.manager.del_host()
        except Exception as e:
            LOG.exception('Service error occurred when cleaning up '
                          'the RPC manager. Error: %s', e)

        try:
            if self.rpcserver is not None:
                self.rpcserver.stop()
                self.rpcserver.wait()
        except Exception as e:
            LOG.exception('Service error occurred when stopping the '
                          'RPC server. Error: %s', e)

        super().stop(graceful=True)
        LOG.info('Stopped RPC server for service %(service)s on host '
                 '%(host)s.',
                 {'service': self.topic, 'host': self.host})






def main():
    assert 'ironic.pxe_filter.service' not in sys.modules

    # Parse config file and command line options, then start logging
    ironic_service.prepare_service('ironic_pxe_filter', sys.argv)
    if CONF.rpc_transport == 'json-rpc':
        raise RuntimeError("This service is not designed to work with "
                           "rpc_transport = json-rpc. Please use another "
                           "RPC transport.")

    # Sets the indirection API to direct API calls for objects across the
    # RPC layer.
    if CONF.rpc_transport in ['local', 'none'] or CONF.use_rpc_for_database:
        objects_base.IronicObject.indirection_api = \
            indirection.IronicObjectIndirectionAPI()

    mgr = RPCService(
        CONF.host, 'ironic.pxe_filter.service', 'PXEFilterManager')

    launcher = service.launch(CONF, mgr, restart_method='mutate')

    sys.exit(launcher.wait())



if __name__ == '__main__':
    sys.exit(main())