diff options
| author | Hervé Beraud <hberaud@redhat.com> | 2019-06-17 17:58:47 +0200 |
|---|---|---|
| committer | Hervé Beraud <hberaud@redhat.com> | 2019-08-09 21:56:40 +0200 |
| commit | 76fce54b9e693203f268774f876fa478ab44412c (patch) | |
| tree | ca5efa01e3128236c38d6507ad905bee90d79778 | |
| parent | 89c4d7ecd0a2a0cd939610d1b35e086b590f13b3 (diff) | |
| download | oslo-messaging-76fce54b9e693203f268774f876fa478ab44412c.tar.gz | |
fix typos9.5.1
Change-Id: Id11db4113c9b1c3add602192c1e915218704ef27
(cherry picked from commit 54356899da5d4a0997abb6819f184a27929cc0e9)
| -rw-r--r-- | oslo_messaging/_drivers/common.py | 2 | ||||
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/oslo_messaging/_drivers/common.py b/oslo_messaging/_drivers/common.py index 44cfe55..c3c70de 100644 --- a/oslo_messaging/_drivers/common.py +++ b/oslo_messaging/_drivers/common.py @@ -373,7 +373,7 @@ class DecayingTimer(object): # greenthread. # So, a connection cannot be shared between thread/greenthread and # this two variables permit to define the purpose of the connection -# to allow drivers to add special handling if needed (like heatbeat). +# to allow drivers to add special handling if needed (like heartbeat). # amqp drivers create 3 kind of connections: # * driver.listen*(): each call create a new 'PURPOSE_LISTEN' connection # * driver.send*(): a pool of 'PURPOSE_SEND' connections is used diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 3642be2..54e4dc0 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -540,7 +540,7 @@ class Connection(object): # expected waiting the events drain, we start heartbeat_check and # retrieve the server heartbeat packet only two times more than # the minimum required for the heartbeat works - # (heatbeat_timeout/heartbeat_rate/2.0, default kombu + # (heartbeat_timeout/heartbeat_rate/2.0, default kombu # heartbeat_rate is 2) self._heartbeat_wait_timeout = ( float(self.heartbeat_timeout_threshold) / @@ -565,7 +565,7 @@ class Connection(object): # NOTE(sileht): value chosen according the best practice from kombu # http://kombu.readthedocs.org/en/latest/reference/kombu.common.html#kombu.common.eventloop - # For heatbeat, we can set a bigger timeout, and check we receive the + # For heartbeat, we can set a bigger timeout, and check we receive the # heartbeat packets regulary if self._heartbeat_supported_and_enabled(): self._poll_timeout = self._heartbeat_wait_timeout @@ -958,8 +958,8 @@ class Connection(object): "occurred, trying to reconnect: %s"), exc) self.ensure_connection() except Exception: - LOG.warning(_LW("Unexpected error during heartbeart " - "thread processing, retrying...")) + LOG.warning(_LW("Unexpected error during heartbeat " + "thread processing, retrying...")) LOG.debug('Exception', exc_info=True) self._heartbeat_exit_event.wait( |