-
Notifications
You must be signed in to change notification settings - Fork 551
/
Program.cs
171 lines (148 loc) · 5.79 KB
/
Program.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
using System;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Threading;
using NetCoreServer;
using NDesk.Options;
namespace HttpTraceClient
{
class HttpTraceClient : HttpClient
{
public HttpTraceClient(string address, int port, int messages) : base(address, port)
{
_messages = messages;
}
public void SendMessage() { SendRequestAsync(Request.MakeTraceRequest("/")); }
protected override void OnConnected()
{
for (long i = _messages; i > 0; i--)
SendMessage();
}
protected override void OnSent(long sent, long pending)
{
_sent += sent;
base.OnSent(sent, pending);
}
protected override void OnReceived(byte[] buffer, long offset, long size)
{
_received += size;
Program.TimestampStop = DateTime.UtcNow;
Program.TotalBytes += size;
base.OnReceived(buffer, offset, size);
}
protected override void OnReceivedResponse(HttpResponse response)
{
if (response.Status == 200)
Program.TotalMessages++;
else
Program.TotalErrors++;
SendMessage();
}
protected override void OnReceivedResponseError(HttpResponse response, string error)
{
Console.WriteLine($"Response error: {error}");
Program.TotalErrors++;
SendMessage();
}
protected override void OnError(SocketError error)
{
Console.WriteLine($"Client caught an error with code {error}");
Program.TotalErrors++;
}
private long _sent = 0;
private long _received = 0;
private long _messages = 0;
}
class Program
{
public static DateTime TimestampStart = DateTime.UtcNow;
public static DateTime TimestampStop = DateTime.UtcNow;
public static long TotalErrors;
public static long TotalBytes;
public static long TotalMessages;
static void Main(string[] args)
{
bool help = false;
string address = "127.0.0.1";
int port = 8080;
int clients = 100;
int messages = 1;
int seconds = 10;
var options = new OptionSet()
{
{ "h|?|help", v => help = v != null },
{ "a|address=", v => address = v },
{ "p|port=", v => port = int.Parse(v) },
{ "c|clients=", v => clients = int.Parse(v) },
{ "m|messages=", v => messages = int.Parse(v) },
{ "z|seconds=", v => seconds = int.Parse(v) }
};
try
{
options.Parse(args);
}
catch (OptionException e)
{
Console.Write("Command line error: ");
Console.WriteLine(e.Message);
Console.WriteLine("Try `--help' to get usage information.");
return;
}
if (help)
{
Console.WriteLine("Usage:");
options.WriteOptionDescriptions(Console.Out);
return;
}
Console.WriteLine($"Server address: {address}");
Console.WriteLine($"Server port: {port}");
Console.WriteLine($"Working clients: {clients}");
Console.WriteLine($"Working messages: {messages}");
Console.WriteLine($"Seconds to benchmarking: {seconds}");
Console.WriteLine();
// Create HTTP clients
var httpClients = new List<HttpTraceClient>();
for (int i = 0; i < clients; i++)
{
var client = new HttpTraceClient(address, port, messages);
// client.OptionNoDelay = true;
httpClients.Add(client);
}
TimestampStart = DateTime.UtcNow;
// Connect clients
Console.Write("Clients connecting...");
foreach (var client in httpClients)
client.ConnectAsync();
Console.WriteLine("Done!");
foreach (var client in httpClients)
while (!client.IsConnected)
Thread.Yield();
Console.WriteLine("All clients connected!");
// Wait for benchmarking
Console.Write("Benchmarking...");
Thread.Sleep(seconds * 1000);
Console.WriteLine("Done!");
// Disconnect clients
Console.Write("Clients disconnecting...");
foreach (var client in httpClients)
client.DisconnectAsync();
Console.WriteLine("Done!");
foreach (var client in httpClients)
while (client.IsConnected)
Thread.Yield();
Console.WriteLine("All clients disconnected!");
Console.WriteLine();
Console.WriteLine($"Errors: {TotalErrors}");
Console.WriteLine();
Console.WriteLine($"Total time: {Utilities.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds)}");
Console.WriteLine($"Total data: {Utilities.GenerateDataSize(TotalBytes)}");
Console.WriteLine($"Total messages: {TotalMessages}");
Console.WriteLine($"Data throughput: {Utilities.GenerateDataSize((long)(TotalBytes / (TimestampStop - TimestampStart).TotalSeconds))}/s");
if (TotalMessages > 0)
{
Console.WriteLine($"Message latency: {Utilities.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds / TotalMessages)}");
Console.WriteLine($"Message throughput: {(long)(TotalMessages / (TimestampStop - TimestampStart).TotalSeconds)} msg/s");
}
}
}
}