diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-31 19:22:19 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-03-31 19:22:19 -0700 |
| commit | c02df4bcc6ee6920db1be259f44a8f958bb36791 (patch) | |
| tree | 738362abc2665de4806d7b2e8c3b7bda29a57f07 /example.py | |
| parent | 3664ae85e5a4c47075489e01688897f8cea8b11d (diff) | |
| download | kafka-python-c02df4bcc6ee6920db1be259f44a8f958bb36791.tar.gz | |
Avoid race condition on client._conns in send() (#1772)
There was a very small possibility that between checking `self._can_send_request(node_id)` and grabbing the connection object via `self._conns[node_id]` that the connection could get closed / recycled / removed from _conns and cause a KeyError. This PR should prevent such a KeyError. In the case where the connection is disconnected by the time we call send(), we should expect conn.send() simply to fail the request.
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions