Browse Source

fix typos

Change-Id: Id11db4113c9b1c3add602192c1e915218704ef27
(cherry picked from commit 54356899da)
tags/9.5.1^0
Hervé Beraud 8 months ago
parent
commit
76fce54b9e
2 changed files with 5 additions and 5 deletions
  1. +1
    -1
      oslo_messaging/_drivers/common.py
  2. +4
    -4
      oslo_messaging/_drivers/impl_rabbit.py

+ 1
- 1
oslo_messaging/_drivers/common.py View File

@@ -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


+ 4
- 4
oslo_messaging/_drivers/impl_rabbit.py View File

@@ -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(


Loading…
Cancel
Save