Merge pull request #565 from danp60/bugfix/close_bad_thrift_connections

Thrift connection pool does not clean up stale connections

Author: Mpdreamz

src/Connections/Elasticsearch.Net.Connection.Thrift/ThriftConnection.cs

@@ -2,7 +2,8 @@
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Configuration;
-using System.IO;
+using System.IO;
+using System.Net.Sockets;
 using System.Security.Cryptography.X509Certificates;
 using System.Text;
 using System.Threading;
@@ -284,6 +285,16 @@ private ElasticsearchResponse<Stream> Execute(RestRequest restRequest, object de
 						return response;
 					}
 				}
+				catch (SocketException)
+				{
+					client.InputProtocol.Transport.Close();
+					throw;
+				}
+				catch (IOException)
+				{
+					client.InputProtocol.Transport.Close();
+					throw;
+				}
 				finally
 				{
 					//make sure we make the client available again.

src/Connections/Elasticsearch.Net.Connection.Thrift/Transport/TBufferedTransport.cs

@@ -78,6 +78,10 @@ public override void Close()
 			{
 				outputBuffer.Close();
 			}
+			if (transport != null)
+			{
+				transport.Close();
+			}
 		}
 
 		public override int Read(byte[] buf, int off, int len)