diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-07 17:26:09 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-07 17:35:01 -0800 |
| commit | b4c20acf2471a7cee23e4e2b7729a100da6c557b (patch) | |
| tree | e2d7c3047a6e852e2c5b23a7ebf83aa4b561f051 /test/test_unit.py | |
| parent | e5a5477d346a140abd8bba9e5da2a8f9967ac911 (diff) | |
| download | kafka-python-b4c20acf2471a7cee23e4e2b7729a100da6c557b.tar.gz | |
Handle dirty flag in conn.recv()
* If the connection is dirty, reinit
* If we get a BufferUnderflowError, the server could have gone away, so mark it dirty
Diffstat (limited to 'test/test_unit.py')
0 files changed, 0 insertions, 0 deletions