From 254295fd70fd6637a98886937ef5f009cdd687cb Mon Sep 17 00:00:00 2001
From: Johannes Richter <johannes.richter@kernkonzept.com>
Date: Tue, 25 Mar 2014 10:00:33 +0100
Subject: Fix for hanging connections

* client.stop_event_stream() was not closing

Change-Id: Idf38565332a7865063caf614992ba376804da1a7
---
 pygerrit/stream.py | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'pygerrit')

diff --git a/pygerrit/stream.py b/pygerrit/stream.py
index 1705bf0..1504dde 100644
--- a/pygerrit/stream.py
+++ b/pygerrit/stream.py
@@ -41,10 +41,13 @@ class GerritStream(Thread):
         self._gerrit = gerrit
         self._ssh_client = ssh_client
         self._stop = Event()
+        self._channel = None
 
     def stop(self):
         """ Stop the thread. """
         self._stop.set()
+        if self._channel is not None:
+            self._channel.close()
 
     def _error_event(self, error):
         """ Dispatch `error` to the Gerrit client. """
@@ -53,6 +56,7 @@ class GerritStream(Thread):
     def run(self):
         """ Listen to the stream and send events to the client. """
         channel = self._ssh_client.get_transport().open_session()
+        self._channel = channel
         channel.exec_command("gerrit stream-events")
         stdout = channel.makefile()
         stderr = channel.makefile_stderr()
-- 
cgit v1.2.1