Cleanups.

This commit is contained in:
Joshua Harlow
2012-02-27 17:04:49 -08:00
parent d5f9ddd788
commit 40338394b8
2 changed files with 10 additions and 11 deletions

View File

@@ -391,19 +391,18 @@ class ProgramRuntime(ComponentBase):
def post_start(self):
pass
def configure(self):
# First make a pass and make sure all runtime (e.g. upstart) config files are in place....
startercls = self._getstartercls(utils.fetch_run_type(self.cfg))
starter = startercls(self.cfg)
for app_info in self._get_apps_to_start():
#extract needed keys
app_name = app_info["name"]
app_pth = app_info.get("path", app_name)
app_dir = app_info.get("app_dir", self.appdir)
#adjust the program options now that we have real locations
# Adjust the program options now that we have real locations
program_opts = utils.param_replace_list(self._get_app_options(app_name), self._get_param_map(app_name))
#configure it with the given settings
# Configure it with the given settings
LOG.info("Configuring runner for program [%s]" % (app_name))
runtime_info = (app_pth, app_dir, program_opts)
starter.configure(app_name, runtime_info, self.tracedir)
@@ -413,7 +412,6 @@ class ProgramRuntime(ComponentBase):
# Select how we are going to start it
startercls = self._getstartercls(utils.fetch_run_type(self.cfg))
starter = startercls(self.cfg)
# Start all apps
am_started = 0
for app_info in self._get_apps_to_start():
app_name = app_info["name"]

View File

@@ -19,7 +19,6 @@ import json
# To run the initctl command
import subprocess
from runnerbase import RunnerBase
from devstack import date
from devstack import log as logging
from devstack import settings
@@ -27,6 +26,8 @@ from devstack import shell as sh
from devstack import trace as tr
from devstack import utils
from devstack.runners import runnerbase as base
LOG = logging.getLogger("devstack.runners.upstart")
#my type
@@ -50,9 +51,9 @@ UPSTART_CONF_TMPL = 'upstart.conf'
# Keep track of what we've emitted in the current python session
class UpstartRunner(RunnerBase):
class UpstartRunner(base.RunnerBase):
def __init__(self, cfg):
RunnerBase.__init__(self, cfg)
base.RunnerBase.__init__(self, cfg)
self.events = set()
def stop(self, component_name, name, tracedir):
@@ -62,7 +63,7 @@ class UpstartRunner(RunnerBase):
# Emit the start, keep track and only do one per component name
component_event = component_name + STOP_EVENT_SUFFIX
if component_event in self.events:
LOG.debug("Already emitted event:%s" % (component_event))
LOG.debug("Already emitted event: %s" % (component_event))
else:
LOG.info("About to emit event %s" % (component_event))
rc = subprocess.call(["/sbin/initctl", "emit", component_event])
@@ -101,7 +102,7 @@ class UpstartRunner(RunnerBase):
return params
def _do_upstart_configure(self, component_name, program_name, runtime_info):
(app_pth, app_dir, program_args) = runtime_info
(_, _, program_args) = runtime_info
root_fn = program_name + CONF_EXT
# TODO FIXME symlinks won't work. Need to copy the files there.
# https://bugs.launchpad.net/upstart/+bug/665022
@@ -139,5 +140,5 @@ class UpstartRunner(RunnerBase):
return tracefn
def start(self, component_name, name, runtime_info, tracedir):
(program, appdir, program_args) = runtime_info
(program, _, program_args) = runtime_info
return self._start(component_name, name, program, program_args, tracedir)