mirror of
https://github.com/JKorf/CryptoExchange.Net.git
synced 2026-08-12 00:43:03 +00:00
Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a02b3f88d7 | |||
| af44ca4c9f | |||
| cf2b57bb96 |
@@ -6,16 +6,16 @@
|
||||
<PackageId>CryptoExchange.Net</PackageId>
|
||||
<Authors>JKorf</Authors>
|
||||
<Description>A base package for implementing cryptocurrency API's</Description>
|
||||
<PackageVersion>5.4.1</PackageVersion>
|
||||
<AssemblyVersion>5.4.1</AssemblyVersion>
|
||||
<FileVersion>5.4.1</FileVersion>
|
||||
<PackageVersion>5.4.2</PackageVersion>
|
||||
<AssemblyVersion>5.4.2</AssemblyVersion>
|
||||
<FileVersion>5.4.2</FileVersion>
|
||||
<PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
|
||||
<RepositoryType>git</RepositoryType>
|
||||
<RepositoryUrl>https://github.com/JKorf/CryptoExchange.Net.git</RepositoryUrl>
|
||||
<PackageProjectUrl>https://github.com/JKorf/CryptoExchange.Net</PackageProjectUrl>
|
||||
<NeutralLanguage>en</NeutralLanguage>
|
||||
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
|
||||
<PackageReleaseNotes>5.4.1 - Added CalculateTradableAmount to SymbolOrderBook, Improved socket reconnect robustness, Fixed api rate limiter not working correctly</PackageReleaseNotes>
|
||||
<PackageReleaseNotes>5.4.2 - Reverted socket changes as it seems to cause reconnect to hang</PackageReleaseNotes>
|
||||
<Nullable>enable</Nullable>
|
||||
<LangVersion>9.0</LangVersion>
|
||||
<PackageLicenseExpression>MIT</PackageLicenseExpression>
|
||||
|
||||
@@ -211,16 +211,8 @@ namespace CryptoExchange.Net.Sockets
|
||||
while (_closeTask == null)
|
||||
await Task.Delay(50).ConfigureAwait(false);
|
||||
|
||||
await _closeSem.WaitAsync().ConfigureAwait(false);
|
||||
try
|
||||
{
|
||||
await _closeTask.ConfigureAwait(false);
|
||||
_closeTask = null;
|
||||
}
|
||||
finally
|
||||
{
|
||||
_closeSem.Release();
|
||||
}
|
||||
await _closeTask.ConfigureAwait(false);
|
||||
_closeTask = null;
|
||||
|
||||
if (!Parameters.AutoReconnect)
|
||||
{
|
||||
@@ -293,19 +285,8 @@ namespace CryptoExchange.Net.Sockets
|
||||
return;
|
||||
|
||||
_log.Write(LogLevel.Debug, $"Socket {Id} reconnect requested");
|
||||
await _closeSem.WaitAsync().ConfigureAwait(false);
|
||||
try
|
||||
{
|
||||
if (_processState != ProcessState.Processing)
|
||||
return;
|
||||
|
||||
_closeTask = CloseInternalAsync();
|
||||
await _closeTask.ConfigureAwait(false);
|
||||
}
|
||||
finally
|
||||
{
|
||||
_closeSem.Release();
|
||||
}
|
||||
_closeTask = CloseInternalAsync();
|
||||
await _closeTask.ConfigureAwait(false);
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
@@ -449,19 +430,8 @@ namespace CryptoExchange.Net.Sockets
|
||||
{
|
||||
// Connection closed unexpectedly, .NET framework
|
||||
OnError?.Invoke(ioe);
|
||||
await _closeSem.WaitAsync().ConfigureAwait(false);
|
||||
try
|
||||
{
|
||||
if (_processState != ProcessState.Processing)
|
||||
return;
|
||||
|
||||
if (_closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
}
|
||||
catch
|
||||
{
|
||||
_closeSem.Release();
|
||||
}
|
||||
if (_closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
break;
|
||||
}
|
||||
}
|
||||
@@ -518,17 +488,8 @@ namespace CryptoExchange.Net.Sockets
|
||||
{
|
||||
// Connection closed unexpectedly
|
||||
OnError?.Invoke(wse);
|
||||
await _closeSem.WaitAsync().ConfigureAwait(false);
|
||||
try
|
||||
{
|
||||
if (_processState == ProcessState.Processing && _closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
}
|
||||
catch
|
||||
{
|
||||
_closeSem.Release();
|
||||
}
|
||||
|
||||
if (_closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
break;
|
||||
}
|
||||
|
||||
@@ -536,17 +497,8 @@ namespace CryptoExchange.Net.Sockets
|
||||
{
|
||||
// Connection closed unexpectedly
|
||||
_log.Write(LogLevel.Debug, $"Socket {Id} received `Close` message");
|
||||
await _closeSem.WaitAsync().ConfigureAwait(false);
|
||||
try
|
||||
{
|
||||
if (_processState == ProcessState.Processing && _closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
}
|
||||
catch
|
||||
{
|
||||
_closeSem.Release();
|
||||
}
|
||||
|
||||
if (_closeTask?.IsCompleted != false)
|
||||
_closeTask = CloseInternalAsync();
|
||||
break;
|
||||
}
|
||||
|
||||
|
||||
@@ -33,6 +33,9 @@ Make a one time donation in a crypto currency of your choice. If you prefer to d
|
||||
Alternatively, sponsor me on Github using [Github Sponsors](https://github.com/sponsors/JKorf).
|
||||
|
||||
## Release notes
|
||||
* Version 5.4.2 - 01 Apr 2023
|
||||
* Reverted socket changes as it seems to cause reconnect to hang
|
||||
|
||||
* Version 5.4.1 - 18 Mar 2023
|
||||
* Added CalculateTradableAmount to SymbolOrderBook
|
||||
* Improved socket reconnect robustness
|
||||
|
||||
Reference in New Issue
Block a user