Skip to content

SignalR: Benchmark server logging #9264

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 12 commits into from
Closed

SignalR: Benchmark server logging #9264

Changes from 8 commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
33aeab5
static count
staff0rd Apr 9, 2019
bfee5d6
echo peak connections
staff0rd Apr 9, 2019
ce30ba1
timestamp connection logs
staff0rd Apr 10, 2019
52bf31e
access modifier
analogrelay Apr 17, 2019
8af81eb
access modifier
analogrelay Apr 17, 2019
8e91fff
use Interlocked
halter73 May 1, 2019
a69438f
Use interlocked
halter73 May 1, 2019
feff896
use Interlocked
staff0rd May 1, 2019
3ce8060
added EchoHubConnectionCounter
staff0rd May 2, 2019
8967db6
remove Interlocked; add System
staff0rd May 5, 2019
dd8cb08
Merge remote-tracking branch 'upstream/master' into echohubconnection…
staff0rd May 5, 2019
4b8a5ab
instantiate lock
staff0rd May 5, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
29 changes: 29 additions & 0 deletions src/SignalR/perf/benchmarkapps/BenchmarkServer/Hubs/EchoHub.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,11 @@ namespace BenchmarkServer.Hubs
{
public class EchoHub : Hub
{
private static int _connectionCount = 0;
private static int _peakConnectionCount = 0;

static DateTime _serverStart = DateTime.Now;

public async Task Broadcast(int duration)
{
var sent = 0;
Expand All @@ -30,6 +35,30 @@ public async Task Broadcast(int duration)
Console.WriteLine("Broadcast exited: Sent {0} messages", sent);
}

public static string Status => $"{_connectionCount} current, {_peakConnectionCount} peak.";

public void LogConnections(string label) {
var connectionCount = Interlocked.Read(ref _connectionCount);
if (connectionCount < 100 || connectionCount % 100 == 0)
{
var timeSinceServerStart = DateTime.Now.Subtract(_serverStart).ToString(@"hh\:mm\:ss");
Console.WriteLine($"[{timeSinceServerStart}] {label}: {Status}");
}
}

public override Task OnConnectedAsync() {
var newConnectionCount = Interlocked.Increment(ref _connectionCount);
_peakConnectionCount = Math.Max(_connectionCount, _peakConnectionCount);
LogConnections("Connected");
return Task.CompletedTask;
}

public override Task OnDisconnectedAsync(Exception exception) {
Interlocked.Decrement(ref _connectionCount);
LogConnections("Disconnected");
return Task.CompletedTask;
}

public DateTime Echo(DateTime time)
{
return time;
Expand Down