summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVishvananda Ishaya <vishvananda@gmail.com>2011-08-18 11:28:02 -0700
committerVishvananda Ishaya <vishvananda@gmail.com>2011-08-18 11:28:02 -0700
commit97552f05d5d26e596ddf0cda8169f3a5d131a55a (patch)
tree6795e800dbc0ba64508b8201213b39f1b9a96b90
parent788e5c5e94c224c3909c4f12ecc569bba3ba1c9e (diff)
fix typo
-rwxr-xr-xbin/nova-compute2
-rwxr-xr-xbin/nova-console2
-rwxr-xr-xbin/nova-network2
-rwxr-xr-xbin/nova-scheduler2
-rwxr-xr-xbin/nova-volume2
-rw-r--r--nova/service.py35
6 files changed, 24 insertions, 21 deletions
diff --git a/bin/nova-compute b/bin/nova-compute
index 9aef201e6..5239fae72 100755
--- a/bin/nova-compute
+++ b/bin/nova-compute
@@ -43,6 +43,6 @@ if __name__ == '__main__':
utils.default_flagfile()
flags.FLAGS(sys.argv)
logging.setup()
- server = service.Server(binary='nova-compute')
+ server = service.Service.create(binary='nova-compute')
service.serve(server)
service.wait()
diff --git a/bin/nova-console b/bin/nova-console
index 7f76fdc29..22f6ef171 100755
--- a/bin/nova-console
+++ b/bin/nova-console
@@ -42,6 +42,6 @@ if __name__ == '__main__':
utils.default_flagfile()
flags.FLAGS(sys.argv)
logging.setup()
- server = service.Server(binary='nova-console')
+ server = service.Service.create(binary='nova-console')
service.serve(server)
service.wait()
diff --git a/bin/nova-network b/bin/nova-network
index ce93e9354..57759d30a 100755
--- a/bin/nova-network
+++ b/bin/nova-network
@@ -43,6 +43,6 @@ if __name__ == '__main__':
utils.default_flagfile()
flags.FLAGS(sys.argv)
logging.setup()
- server = service.Server(binary='nova-compute')
+ server = service.Service.create(binary='nova-network')
service.serve(server)
service.wait()
diff --git a/bin/nova-scheduler b/bin/nova-scheduler
index 07d1c55e6..3b627e62d 100755
--- a/bin/nova-scheduler
+++ b/bin/nova-scheduler
@@ -43,6 +43,6 @@ if __name__ == '__main__':
utils.default_flagfile()
flags.FLAGS(sys.argv)
logging.setup()
- server = service.Server(binary='nova-compute')
+ server = service.Service.create(binary='nova-compute')
service.serve(server)
service.wait()
diff --git a/bin/nova-volume b/bin/nova-volume
index 1451de44a..5405aebbb 100755
--- a/bin/nova-volume
+++ b/bin/nova-volume
@@ -43,6 +43,6 @@ if __name__ == '__main__':
utils.default_flagfile()
flags.FLAGS(sys.argv)
logging.setup()
- server = service.Server(binary='nova-volume')
+ server = service.Service.create(binary='nova-volume')
service.serve(server)
service.wait()
diff --git a/nova/service.py b/nova/service.py
index 8ffd39629..959e79052 100644
--- a/nova/service.py
+++ b/nova/service.py
@@ -67,24 +67,24 @@ class Launcher(object):
self._services = []
@staticmethod
- def run_service(service):
- """Start and wait for a service to finish.
+ def run_server(server):
+ """Start and wait for a server to finish.
- :param service: Service to run and wait for.
+ :param service: Server to run and wait for.
:returns: None
"""
- service.start()
- service.wait()
+ server.start()
+ server.wait()
- def launch_service(self, service):
- """Load and start the given service.
+ def launch_server(self, server):
+ """Load and start the given server.
- :param service: The service you would like to start.
+ :param server: The server you would like to start.
:returns: None
"""
- gt = eventlet.spawn(self.run_service, service)
+ gt = eventlet.spawn(self.run_server, server)
self._services.append(gt)
def stop(self):
@@ -110,13 +110,16 @@ class Launcher(object):
class Service(object):
- """Base class for workers that run on hosts."""
+ """Service object for binaries running on hosts.
+
+ A service takes a manager and enables rpc by listening to queues based
+ on topic. It also periodically runs tasks on the manager and reports
+ it state to the database services table."""
def __init__(self, host, binary, topic, manager, report_interval=None,
periodic_interval=None, *args, **kwargs):
self.host = host
self.binary = binary
- self.name = binary
self.topic = topic
self.manager_class_name = manager
manager_class = utils.import_class(self.manager_class_name)
@@ -289,9 +292,9 @@ class WSGIService(object):
"""Provides ability to launch API from a 'paste' configuration."""
def __init__(self, name, loader=None):
- """Initialize, but do not start the WSGI service.
+ """Initialize, but do not start the WSGI server.
- :param name: The name of the WSGI service given to the loader.
+ :param name: The name of the WSGI server given to the loader.
:param loader: Loads the WSGI application using the given name.
:returns: None
@@ -341,12 +344,12 @@ class WSGIService(object):
_launcher = None
-def serve(*services):
+def serve(*servers):
global _launcher
if not _launcher:
_launcher = Launcher()
- for x in services:
- _launcher.launch_service(x)
+ for server in servers:
+ _launcher.launch_server(server)
def wait():