ZeroMQ driver fails to send casts if processing during exit
Bug #1097927 reported by
Erica Windisch
This bug affects 1 person
Affects | Status | Importance | Assigned to | Milestone | |
---|---|---|---|---|---|
oslo.messaging |
Invalid
|
Low
|
Unassigned |
Bug Description
The ZeroMQ driver only completes a cast() when a remote host's olso-zmq-receiver process consumes a message, or if the cast() times out (via rpc_cast_timeout or the per-cast Timeout kwarg).
Because cast() is spawned inside a greenthread, Python will happily exit with unsent messages.
At a minimum, impl_zmq's cleanup() method should wait for all cast() messages to send or timeout.
Changed in oslo: | |
importance: | Undecided → Medium |
affects: | oslo-incubator → oslo.messaging |
Changed in oslo.messaging: | |
importance: | Medium → Low |
tags: | added: zmq |
Changed in oslo.messaging: | |
assignee: | nobody → Li Ma (nick-ma-z) |
Changed in oslo.messaging: | |
assignee: | Li Ma (nick-ma-z) → nobody |
To post a comment you must log in.
Fix proposed to branch: master /review. openstack. org/19334
Review: https:/