# Path: muranoagent/app.py
# CONF = config.CONF
# LOG = logging.getLogger(__name__)
# class MuranoAgent(service.Service):
#     def __init__(self):
#     def _load_package(name):
#     def _load(self):
#     def start(self):
#     def _loop_func(self, msg_iterator):
#     def _verify_plan(self, plan):
#     def _run(self, plan):
#     def _send_result(self, result):
#     def _create_rmq_client(self):
#     def _wait_plan(self):
# 
# Path: muranoagent/common/config.py
# CONF = cfg.CONF
# def parse_args(args=None, usage=None, default_config_files=None):


import os
import sys
import eventlet
import __original_module_threading as orig_threading
import threading  # noqa
from oslo_config import cfg
from oslo_log import log as logging
from oslo_service import service
from muranoagent import app
from muranoagent.common import config



# If ../muranoagent/__init__.py exists, add ../ to Python search path, so
# it will override what happens to be installed in /usr/(local/)lib/python...
possible_topdir = os.path.normpath(os.path.join(os.path.abspath(__file__),
                                                os.pardir,
                                                os.pardir,
                                                os.pardir))
if os.path.exists(os.path.join(possible_topdir,
                               'muranoagent',
                               '__init__.py')):
    sys.path.insert(0, possible_topdir)

eventlet.monkey_patch()
# Monkey patch the original current_thread to use the up-to-date _active
# global variable. See https://bugs.launchpad.net/bugs/1863021 and
# https://github.com/eventlet/eventlet/issues/592
orig_threading.current_thread.__globals__['_active'] = threading._active




CONF = cfg.CONF


def main():
    try:
        config.parse_args()
        logging.setup(CONF, 'muranoagent')

# Path: muranoagent/app.py
# CONF = config.CONF
# LOG = logging.getLogger(__name__)
# class MuranoAgent(service.Service):
#     def __init__(self):
#     def _load_package(name):
#     def _load(self):
#     def start(self):
#     def _loop_func(self, msg_iterator):
#     def _verify_plan(self, plan):
#     def _run(self, plan):
#     def _send_result(self, result):
#     def _create_rmq_client(self):
#     def _wait_plan(self):
# 
# Path: muranoagent/common/config.py
# CONF = cfg.CONF
# def parse_args(args=None, usage=None, default_config_files=None):


# Path: muranoagent/cmd/run.py
import os
import sys
import eventlet
import __original_module_threading as orig_threading
import threading  # noqa
from oslo_config import cfg
from oslo_log import log as logging
from oslo_service import service
from muranoagent import app
from muranoagent.common import config




# If ../muranoagent/__init__.py exists, add ../ to Python search path, so
# it will override what happens to be installed in /usr/(local/)lib/python...
possible_topdir = os.path.normpath(os.path.join(os.path.abspath(__file__),
                                                os.pardir,
                                                os.pardir,
                                                os.pardir))
if os.path.exists(os.path.join(possible_topdir,
                               'muranoagent',
                               '__init__.py')):
    sys.path.insert(0, possible_topdir)

eventlet.monkey_patch()
# Monkey patch the original current_thread to use the up-to-date _active
# global variable. See https://bugs.launchpad.net/bugs/1863021 and
# https://github.com/eventlet/eventlet/issues/592
orig_threading.current_thread.__globals__['_active'] = threading._active




CONF = cfg.CONF


def main():
    try:
        config.parse_args()
        logging.setup(CONF, 'muranoagent')

        launcher = service.ServiceLauncher(CONF)