flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-08 08:26:20 +00:00
Code Issues Releases Wiki Activity

Added handling for websocket send failing

Browse Source
This commit is contained in:
Jan Korf 2022-04-30 16:14:17 +02:00
parent 270ea06f24
commit 94b8184f7b
1 changed files with 19 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
CryptoExchange.Net/Sockets/SocketConnection.cs
View File

@ -254,12 +254,12 @@ namespace CryptoExchange.Net.Sockets
private void StartProcessingTask() private void StartProcessingTask()
{ {
log.Write(LogLevel.Trace, "Starting processing task"); log.Write(LogLevel.Trace, $"Starting {SocketId} processing task");
_socketProcessReconnectTask = Task.Run(async () => _socketProcessReconnectTask = Task.Run(async () =>
{ {
await _socket.ProcessAsync().ConfigureAwait(false); await _socket.ProcessAsync().ConfigureAwait(false);
await ReconnectAsync().ConfigureAwait(false); await ReconnectAsync().ConfigureAwait(false);
log.Write(LogLevel.Trace, "Processing task finished"); log.Write(LogLevel.Trace, $"Processing {SocketId} task finished");
}); });
} }
@ -566,7 +566,10 @@ namespace CryptoExchange.Net.Sockets
{ {
pendingRequests.Add(pending); pendingRequests.Add(pending);
} }
Send(obj); var sendOk = Send(obj);
if(!sendOk)
pending.Fail();
return pending.Event.WaitAsync(timeout); return pending.Event.WaitAsync(timeout);
} }
@ -576,22 +579,30 @@ namespace CryptoExchange.Net.Sockets
/// <typeparam name="T">The type of the object to send</typeparam> /// <typeparam name="T">The type of the object to send</typeparam>
/// <param name="obj">The object to send</param> /// <param name="obj">The object to send</param>
/// <param name="nullValueHandling">How null values should be serialized</param> /// <param name="nullValueHandling">How null values should be serialized</param>
public virtual void Send<T>(T obj, NullValueHandling nullValueHandling = NullValueHandling.Ignore) public virtual bool Send<T>(T obj, NullValueHandling nullValueHandling = NullValueHandling.Ignore)
{ {
if(obj is string str) if(obj is string str)
Send(str); return Send(str);
else else
Send(JsonConvert.SerializeObject(obj, Formatting.None, new JsonSerializerSettings { NullValueHandling = nullValueHandling })); return Send(JsonConvert.SerializeObject(obj, Formatting.None, new JsonSerializerSettings { NullValueHandling = nullValueHandling }));
} }
/// <summary> /// <summary>
/// Send string data over the websocket connection /// Send string data over the websocket connection
/// </summary> /// </summary>
/// <param name="data">The data to send</param> /// <param name="data">The data to send</param>
public virtual void Send(string data) public virtual bool Send(string data)
{ {
log.Write(LogLevel.Trace, $"Socket {SocketId} sending data: {data}"); log.Write(LogLevel.Trace, $"Socket {SocketId} sending data: {data}");
try
{
_socket.Send(data); _socket.Send(data);
return true;
}
catch(Exception)
{
return false;
}
} }
/// <summary> /// <summary>