huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Crankier: Log connection exceptions (#9045)

This commit is contained in:
Stafford Williams 2019-04-10 17:36:18 +10:00 committed by Stephen Halter
parent 9158039c95
commit 3b32f43453
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/SignalR/perf/benchmarkapps/Crankier/Client.cs
View File

@ -12,12 +12,27 @@ namespace Microsoft.AspNetCore.SignalR.Crankier
{
public class Client
{
private readonly int _processId;
private readonly IAgent _agent;
private HubConnection _connection;
private CancellationTokenSource _sendCts;
private bool _sendInProgress;
private volatile ConnectionState _connectionState = ConnectionState.Connecting;
public ConnectionState State => _connectionState;
public Client(int processId, IAgent agent)
{
_processId = processId;
_agent = agent;
}
private void LogFault(string description, Exception exception)
{
var message = $"{description}: {exception.GetType()}: {exception.Message}";
Trace.WriteLine(message);
_agent.LogAsync(_processId, message);
}
public async Task CreateAndStartConnectionAsync(string url, HttpTransportType transportType)
{
_connection = new HubConnectionBuilder()
@ -33,7 +48,7 @@ namespace Microsoft.AspNetCore.SignalR.Crankier
}
else
{
Trace.WriteLine($"Connection terminated with error: {ex.GetType()}: {ex.Message}");
LogFault("Connection terminated with error", ex);
_connectionState = ConnectionState.Faulted;
}
@ -57,7 +72,7 @@ namespace Microsoft.AspNetCore.SignalR.Crankier
}
catch (Exception ex)
{
Trace.WriteLine($"Connection.Start Failed: {ex.GetType()}: {ex.Message}");
LogFault("Connection.Start Failed", ex);
if (connectCount == 3)
{

2
src/SignalR/perf/benchmarkapps/Crankier/Worker.cs
View File

@ -62,7 +62,7 @@ namespace Microsoft.AspNetCore.SignalR.Crankier
_targetConnectionCount += numberOfConnections;
for (var count = 0; count < numberOfConnections; count++)
{
var client = new Client();
var client = new Client(_processId, _agent);
_clients.Add(client);
await client.CreateAndStartConnectionAsync(targetAddress, transportType);