diff --git a/Client.Core/Client.Core.csproj b/Client.Core/Client.Core.csproj index 550b77a27..8e0431c8e 100644 --- a/Client.Core/Client.Core.csproj +++ b/Client.Core/Client.Core.csproj @@ -40,7 +40,7 @@ - + diff --git a/Client.Core/Internal/RestSharpExtensions.cs b/Client.Core/Internal/RestSharpExtensions.cs index fcb01b114..c9065a199 100644 --- a/Client.Core/Internal/RestSharpExtensions.cs +++ b/Client.Core/Internal/RestSharpExtensions.cs @@ -40,7 +40,7 @@ internal static RestRequest AddAdvancedResponseHandler(this RestRequest restRequ internal static RestResponse ExecuteSync(this RestClient client, RestRequest request, CancellationToken cancellationToken = default) { - return client.Execute(request, cancellationToken); + return client.Execute(request, request.Method); } } } \ No newline at end of file diff --git a/Client.Legacy/FluxClient.cs b/Client.Legacy/FluxClient.cs index 1c6e935dd..f0467d184 100644 --- a/Client.Legacy/FluxClient.cs +++ b/Client.Legacy/FluxClient.cs @@ -165,7 +165,7 @@ public FluxClient(FluxConnectionOptions options) : base(new FluxResultMapper()) var version = AssemblyHelper.GetVersion(typeof(FluxClient)); var restClientOptions = new RestClientOptions(options.Url) { - MaxTimeout = (int)options.Timeout.TotalMilliseconds, + Timeout = TimeSpan.FromMilliseconds(options.Timeout.TotalMilliseconds), UserAgent = $"influxdb-client-csharp/{version}", Proxy = options.WebProxy }; diff --git a/Client.Test/InfluxDbClientFactoryTest.cs b/Client.Test/InfluxDbClientFactoryTest.cs index 3bb3dfcef..5863b28f6 100644 --- a/Client.Test/InfluxDbClientFactoryTest.cs +++ b/Client.Test/InfluxDbClientFactoryTest.cs @@ -140,7 +140,7 @@ public void LoadFromConnectionString() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -160,7 +160,7 @@ public void LoadFromConnectionStringFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -178,7 +178,7 @@ public void LoadFromConnectionStringUnitsMillisecondsSeconds() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -197,7 +197,7 @@ public void LoadFromConnectionStringUnitsMillisecondsSecondsFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -215,7 +215,7 @@ public void LoadFromConnectionStringUnitsMinutes() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -234,7 +234,7 @@ public void LoadFromConnectionStringUnitsMinutesFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -297,7 +297,7 @@ public void LoadFromConfiguration() Assert.AreEqual(LogLevel.Body, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(10_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(10_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); var defaultTags = GetDeclaredField>(options.PointSettings.GetType(), options.PointSettings, "_defaultTags"); @@ -324,7 +324,7 @@ public void LoadFromConfigurationOptions() Assert.AreEqual(LogLevel.Body, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(10_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(10_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); var defaultTags = GetDeclaredField>(options.PointSettings.GetType(), options.PointSettings, "_defaultTags"); @@ -416,7 +416,7 @@ public void Timeout() _client = new InfluxDBClient(options); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(20_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(20_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] @@ -432,7 +432,7 @@ public void TimeoutFactory() _client = InfluxDBClientFactory.Create(options); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(20_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(20_000, apiClient.RestClientOptions.Timeout.Value.TotalMilliseconds); } [Test] diff --git a/Client/Internal/ApiClient.cs b/Client/Internal/ApiClient.cs index a072a2e33..39b64c597 100644 --- a/Client/Internal/ApiClient.cs +++ b/Client/Internal/ApiClient.cs @@ -38,7 +38,7 @@ public ApiClient(InfluxDBClientOptions options, LoggingHandler loggingHandler, G var version = AssemblyHelper.GetVersion(typeof(InfluxDBClient)); RestClientOptions = new RestClientOptions(options.Url) { - MaxTimeout = (int)options.Timeout.TotalMilliseconds, + Timeout = TimeSpan.FromMilliseconds(options.Timeout.TotalMilliseconds), UserAgent = $"influxdb-client-csharp/{version}", Proxy = options.WebProxy, FollowRedirects = options.AllowHttpRedirects,