summaryrefslogtreecommitdiffstats
path: root/openstack/common/rpc
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2013-05-30 11:02:35 +0000
committerGerrit Code Review <review@openstack.org>2013-05-30 11:02:35 +0000
commit7e2805025d86220df0678110df933745a46db178 (patch)
treea645cf653e190ba246305ba0a5bcb7faf77e1d2d /openstack/common/rpc
parent95da21822653c878973bd267eea36b9683040d6d (diff)
parent484a1df32d5854312ef31c5b488fc07fff8428c4 (diff)
downloadoslo-7e2805025d86220df0678110df933745a46db178.tar.gz
oslo-7e2805025d86220df0678110df933745a46db178.tar.xz
oslo-7e2805025d86220df0678110df933745a46db178.zip
Merge "Enable hacking H403 test"
Diffstat (limited to 'openstack/common/rpc')
-rw-r--r--openstack/common/rpc/common.py6
-rw-r--r--openstack/common/rpc/impl_kombu.py5
-rw-r--r--openstack/common/rpc/service.py3
3 files changed, 9 insertions, 5 deletions
diff --git a/openstack/common/rpc/common.py b/openstack/common/rpc/common.py
index 5a7e525..28dcacd 100644
--- a/openstack/common/rpc/common.py
+++ b/openstack/common/rpc/common.py
@@ -417,7 +417,8 @@ class ClientException(Exception):
"""This encapsulates some actual exception that is expected to be
hit by an RPC proxy object. Merely instantiating it records the
current exception information, which will be passed back to the
- RPC client without exceptional logging."""
+ RPC client without exceptional logging.
+ """
def __init__(self):
self._exc_info = sys.exc_info()
@@ -438,7 +439,8 @@ def client_exceptions(*exceptions):
of expected exceptions that the RPC layer should not consider fatal,
and not log as if they were generated in a real error scenario. Note
that this will cause listed exceptions to be wrapped in a
- ClientException, which is used internally by the RPC layer."""
+ ClientException, which is used internally by the RPC layer.
+ """
def outer(func):
def inner(*args, **kwargs):
return catch_client_exception(exceptions, func, *args, **kwargs)
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py
index 0648e4b..0960b9a 100644
--- a/openstack/common/rpc/impl_kombu.py
+++ b/openstack/common/rpc/impl_kombu.py
@@ -447,8 +447,9 @@ class Connection(object):
self.reconnect()
def _fetch_ssl_params(self):
- """Handles fetching what ssl params
- should be used for the connection (if any)"""
+ """Handles fetching what ssl params should be used for the connection
+ (if any).
+ """
ssl_params = dict()
# http://docs.python.org/library/ssl.html - ssl.wrap_socket
diff --git a/openstack/common/rpc/service.py b/openstack/common/rpc/service.py
index 6b56ebb..3f51d0b 100644
--- a/openstack/common/rpc/service.py
+++ b/openstack/common/rpc/service.py
@@ -30,7 +30,8 @@ LOG = logging.getLogger(__name__)
class Service(service.Service):
"""Service object for binaries running on hosts.
- A service enables rpc by listening to queues based on topic and host."""
+ A service enables rpc by listening to queues based on topic and host.
+ """
def __init__(self, host, topic, manager=None):
super(Service, self).__init__()
self.host = host