diff options
author | Vishvananda Ishaya <vishvananda@gmail.com> | 2011-01-18 18:29:56 -0800 |
---|---|---|
committer | Vishvananda Ishaya <vishvananda@gmail.com> | 2011-01-18 18:29:56 -0800 |
commit | eb33a6b78b8d802c3f92a80e5d5e4a60aef5bf68 (patch) | |
tree | be28644743097fd8228134f31be9f3dc683db7c8 /nova/service.py | |
parent | 324d8fdf284bd5109e34692049256722d731b572 (diff) | |
parent | 4eed55b46cfaba58b5d344f0ca96eba090d8bd34 (diff) | |
download | nova-eb33a6b78b8d802c3f92a80e5d5e4a60aef5bf68.tar.gz nova-eb33a6b78b8d802c3f92a80e5d5e4a60aef5bf68.tar.xz nova-eb33a6b78b8d802c3f92a80e5d5e4a60aef5bf68.zip |
merged trunk
Diffstat (limited to 'nova/service.py')
-rw-r--r-- | nova/service.py | 29 |
1 files changed, 8 insertions, 21 deletions
diff --git a/nova/service.py b/nova/service.py index 7203430c6..efc08fd63 100644 --- a/nova/service.py +++ b/nova/service.py @@ -21,7 +21,6 @@ Generic Node baseclass for all workers that run on hosts """ import inspect -import logging import os import sys import time @@ -35,10 +34,10 @@ from sqlalchemy.exc import OperationalError from nova import context from nova import db from nova import exception +from nova import log as logging from nova import flags from nova import rpc from nova import utils -from nova.db.sqlalchemy import models FLAGS = flags.FLAGS @@ -114,11 +113,13 @@ class Service(object): self.timers.append(periodic) def _create_service_ref(self, context): + zone = FLAGS.node_availability_zone service_ref = db.service_create(context, {'host': self.host, 'binary': self.binary, 'topic': self.topic, - 'report_count': 0}) + 'report_count': 0, + 'availability_zone': zone}) self.service_id = service_ref['id'] def __getattr__(self, key): @@ -155,7 +156,7 @@ class Service(object): report_interval = FLAGS.report_interval if not periodic_interval: periodic_interval = FLAGS.periodic_interval - logging.warn(_("Starting %s node"), topic) + logging.audit(_("Starting %s node"), topic) service_obj = cls(host, binary, topic, manager, report_interval, periodic_interval) @@ -208,30 +209,16 @@ class Service(object): self.model_disconnected = True logging.exception(_("model server went away")) - try: - models.register_models() - except OperationalError: - logging.exception(_("Data store is unreachable." - " Trying again in %d seconds.") % - FLAGS.sql_retry_interval) - time.sleep(FLAGS.sql_retry_interval) - def serve(*services): - argv = FLAGS(sys.argv) + FLAGS(sys.argv) + logging.basicConfig() if not services: services = [Service.create()] name = '_'.join(x.binary for x in services) - logging.debug("Serving %s" % name) - - logging.getLogger('amqplib').setLevel(logging.WARN) - - if FLAGS.verbose: - logging.getLogger().setLevel(logging.DEBUG) - else: - logging.getLogger().setLevel(logging.WARNING) + logging.debug(_("Serving %s"), name) logging.debug(_("Full set of FLAGS:")) for flag in FLAGS: |