Merge pull request #1720 from elastic/spike/dispose

Spike/dispose

Author: gmarz

src/Elasticsearch.Net/Auditing/Audit.cs

@@ -11,16 +11,16 @@ public class Audit
 		public string Path { get; internal set; }
 		public Exception Exception { get; internal set; }
 
-		public Audit(AuditEvent type, DateTime occured)
+		public Audit(AuditEvent type, DateTime started)
 		{
 			this.Event = type;
-			this.Started = occured;
+			this.Started = started;
 		}
 
 		public override string ToString()
 		{
 			var took = Started - Ended;
-			return $"Node: {Node?.Uri}, Event: {Event.GetStringValue()} NodeAlive: {Node?.IsAlive}, Took: {took.ToString()}";
+			return $"Node: {Node?.Uri}, Event: {Event.GetStringValue()} NodeAlive: {Node?.IsAlive}, Took: {took}";
 		}
 	}
 }

src/Elasticsearch.Net/Configuration/ConnectionConfiguration.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Specialized;
 using System.ComponentModel;
+using System.Threading;
 
 namespace Elasticsearch.Net
 {
@@ -10,15 +11,16 @@ namespace Elasticsearch.Net
 	/// </summary>
 	public class ConnectionConfiguration : ConnectionConfiguration<ConnectionConfiguration>
 	{
-		public static TimeSpan DefaultTimeout = TimeSpan.FromMinutes(1);
-		public static TimeSpan DefaultPingTimeout = TimeSpan.FromSeconds(2);
-		public static TimeSpan DefaultPingTimeoutOnSSL = TimeSpan.FromSeconds(5);
+		public static readonly TimeSpan DefaultTimeout = TimeSpan.FromMinutes(1);
+		public static readonly TimeSpan DefaultPingTimeout = TimeSpan.FromSeconds(2);
+		public static readonly TimeSpan DefaultPingTimeoutOnSSL = TimeSpan.FromSeconds(5);
 
 		/// <summary>
 		/// ConnectionConfiguration allows you to control how ElasticsearchClient behaves and where/how it connects 
 		/// to elasticsearch
 		/// </summary>
 		/// <param name="uri">The root of the elasticsearch node we want to connect to. Defaults to http://localhost:9200</param>
+		[System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Reliability", "CA2000:Dispose objects before losing scope")]
 		public ConnectionConfiguration(Uri uri = null)
 			: this(new SingleNodeConnectionPool(uri ?? new Uri("http://localhost:9200")))
 		{ }
@@ -47,13 +49,17 @@ public ConnectionConfiguration(IConnectionPool connectionPool, Func<ConnectionCo
 		public ConnectionConfiguration(IConnectionPool connectionPool, IConnection connection, Func<ConnectionConfiguration, IElasticsearchSerializer> serializerFactory)
 			: base(connectionPool, connection, serializerFactory)
 		{ }
+
 	}
 
 	[Browsable(false)]
 	[EditorBrowsable(EditorBrowsableState.Never)]
 	public abstract class ConnectionConfiguration<T> : IConnectionConfigurationValues, IHideObjectMembers
 		where T : ConnectionConfiguration<T>
 	{
+		private SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
+		SemaphoreSlim IConnectionConfigurationValues.BootstrapLock => this._semaphore;
+
 		private TimeSpan _requestTimeout;
 		TimeSpan IConnectionConfigurationValues.RequestTimeout => _requestTimeout;
 
@@ -130,11 +136,10 @@ private static void DefaultApiCallHandler(IApiCallDetails status) { }
 		BasicAuthenticationCredentials _basicAuthCredentials;
 		BasicAuthenticationCredentials IConnectionConfigurationValues.BasicAuthenticationCredentials => _basicAuthCredentials;
 
-		protected IElasticsearchSerializer _serializer;
+		private readonly IElasticsearchSerializer _serializer;
 		IElasticsearchSerializer IConnectionConfigurationValues.Serializer => _serializer;
 
 		private readonly IConnectionPool _connectionPool;
-		private readonly Func<T, IElasticsearchSerializer> _serializerFactory;
 		IConnectionPool IConnectionConfigurationValues.ConnectionPool => _connectionPool;
 
 		private readonly IConnection _connection;
@@ -147,9 +152,9 @@ protected ConnectionConfiguration(IConnectionPool connectionPool, IConnection co
 		{
 			this._connectionPool = connectionPool;
 			this._connection = connection ?? new HttpConnection();
-			this._serializerFactory = serializerFactory ?? (c=>this.DefaultSerializer((T)this));
+			serializerFactory = serializerFactory ?? (c=>this.DefaultSerializer((T)this));
 			// ReSharper disable once VirtualMemberCallInContructor
-			this._serializer = this._serializerFactory((T)this);
+			this._serializer = serializerFactory((T)this);
 
 			this._requestTimeout = ConnectionConfiguration.DefaultTimeout;
 			this._sniffOnConnectionFault = true;
@@ -308,6 +313,15 @@ public T BasicAuthentication(string userName, string password)
 		/// <para>Note: HTTP pipelining must also be enabled in Elasticsearch for this to work properly.</para>
 		/// </summary>
 		public T EnableHttpPipelining(bool enabled = true) => Assign(a => a._enableHttpPipelining = enabled);
+
+		void IDisposable.Dispose() => this.DisposeManagedResources();
+
+		protected virtual void DisposeManagedResources()
+		{
+			this._connectionPool?.Dispose();
+			this._connection?.Dispose();
+			this._semaphore?.Dispose();
+		}
 	}
 }
 

src/Elasticsearch.Net/Configuration/IConnectionConfigurationValues.cs

@@ -1,10 +1,14 @@
 using System;
 using System.Collections.Specialized;
+using System.Threading;
 
 namespace Elasticsearch.Net
 {
-	public interface IConnectionConfigurationValues
+	public interface IConnectionConfigurationValues : IDisposable
 	{
+		/// <summary> Provides a semaphoreslim to transport implementations that need to limit access to a resource</summary>
+		SemaphoreSlim BootstrapLock { get; }
+
 		/// <summary> The connection pool to use when talking with elasticsearch </summary>
 		IConnectionPool ConnectionPool { get; }
 

src/Elasticsearch.Net/Connection/HttpConnection.cs

@@ -194,5 +194,9 @@ private void HandleException<TReturn>(ResponseBuilder<TReturn> builder, WebExcep
 				builder.Stream = response.GetResponseStream();
 			}
 		}
+
+		void IDisposable.Dispose() => this.DisposeManagedResources();
+
+		protected virtual void DisposeManagedResources() { }
 	}
 }

src/Elasticsearch.Net/Connection/IConnection.cs

@@ -1,8 +1,9 @@
-using System.Threading.Tasks;
+using System;
+using System.Threading.Tasks;
 
 namespace Elasticsearch.Net
 {
-	public interface IConnection
+	public interface IConnection : IDisposable
 	{
 		Task<ElasticsearchResponse<TReturn>> RequestAsync<TReturn>(RequestData requestData)
 			where TReturn : class;

src/Elasticsearch.Net/ConnectionPool/IConnectionPool.cs

@@ -3,7 +3,7 @@
 
 namespace Elasticsearch.Net
 {
-	public interface IConnectionPool
+	public interface IConnectionPool : IDisposable
 	{
 		/// <summary>
 		/// Returns a readonly constant view of all the nodes in the cluster, this might involve creating copies of the nodes e.g 

src/Elasticsearch.Net/ConnectionPool/SingleNodeConnectionPool.cs

@@ -29,5 +29,9 @@ public SingleNodeConnectionPool(Uri uri, IDateTimeProvider dateTimeProvider = nu
 		}
 
 		public IEnumerable<Node> CreateView(Action<AuditEvent, Node> audit = null) => this.Nodes;
+
+		void IDisposable.Dispose() => this.DisposeManagedResources();
+
+		protected virtual void DisposeManagedResources() { }
 	}
 }

src/Elasticsearch.Net/ConnectionPool/SniffingConnectionPool.cs

@@ -73,5 +73,10 @@ public override IEnumerable<Node> CreateView(Action<AuditEvent, Node> audit = nu
 			}
 		}
 
+		protected override void DisposeManagedResources()
+		{
+			this._readerWriter?.Dispose();
+			base.DisposeManagedResources();
+		}
 	}
 }

src/Elasticsearch.Net/ConnectionPool/StaticConnectionPool.cs

@@ -97,5 +97,8 @@ public virtual IEnumerable<Node> CreateView(Action<AuditEvent, Node> audit = nul
 			}
 		}
 
+		void IDisposable.Dispose() => this.DisposeManagedResources();
+
+		protected virtual void DisposeManagedResources() { }
 	}
 }

src/Elasticsearch.Net/Elasticsearch.Net.csproj

@@ -23,6 +23,7 @@
     <WarningLevel>4</WarningLevel>
     <UseVSHostingProcess>false</UseVSHostingProcess>
     <Prefer32Bit>false</Prefer32Bit>
+    <CodeAnalysisRuleSet>AllRules.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
   <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
     <DebugType>pdbonly</DebugType>
@@ -54,6 +55,7 @@
   <ItemGroup>
     <Compile Include="Configuration\RequestConfiguration.cs" />
     <Compile Include="Exceptions\UnexpectedElasticsearchClientException.cs" />
+    <Compile Include="GlobalSuppressions.cs" />
     <Compile Include="Transport\Pipeline\PipelineException.cs" />
     <Compile Include="Connection\HttpMethod.cs" />
     <Compile Include="Auditing\Audit.cs" />