Reviewed: https://review.opendev.org/c/openstack/oslo.messaging/+/894731 Committed: https://opendev.org/openstack/oslo.messaging/commit/b62208a54c4cfabf641bd9e6e5b91e3e24d54455 Submitter: "Zuul (22348)" Branch: master
commit b62208a54c4cfabf641bd9e6e5b91e3e24d54455 Author: Arnaud Morin <email address hidden> Date: Tue Sep 12 11:18:58 2023 +0200
Use StopWatch timer when waiting for message
When waiting for a message in a queue, the queue.get(block=True) prevent the heartbeats to be sent at correct interval.
So instead of blocking the thread, doing a loop using a StopWatch timer until the timeout is reached.
Closes-Bug: #2035113
Signed-off-by: Arnaud Morin <email address hidden> Change-Id: Ie5cf5d2bd281508bcd2db1409f18ad96b0822639
Reviewed: https:/ /review. opendev. org/c/openstack /oslo.messaging /+/894731 /opendev. org/openstack/ oslo.messaging/ commit/ b62208a54c4cfab f641bd9e6e5b91e 3e24d54455
Committed: https:/
Submitter: "Zuul (22348)"
Branch: master
commit b62208a54c4cfab f641bd9e6e5b91e 3e24d54455
Author: Arnaud Morin <email address hidden>
Date: Tue Sep 12 11:18:58 2023 +0200
Use StopWatch timer when waiting for message
When waiting for a message in a queue, the queue.get( block=True) prevent
the heartbeats to be sent at correct interval.
So instead of blocking the thread, doing a loop using a StopWatch timer
until the timeout is reached.
Closes-Bug: #2035113
Signed-off-by: Arnaud Morin <email address hidden> 8bcd2db1409f18a d96b0822639
Change-Id: Ie5cf5d2bd28150