-
Notifications
You must be signed in to change notification settings - Fork 32
/
Program.cs
158 lines (133 loc) · 5.48 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
using System;
using System.Collections.Generic;
using System.Threading;
using CSharpServer;
using NDesk.Options;
namespace TcpMulticastClient
{
class MulticastClient : TcpClient
{
public MulticastClient(Service service, string address, int port) : base(service, address, port)
{
}
protected override void OnReceived(byte[] buffer, long size)
{
Program.TotalBytes += size;
}
protected override void OnError(int error, string category, string message)
{
Console.WriteLine($"Client caught an error with code {error} and category '{category}': {message}");
++Program.TotalErrors;
}
}
class Program
{
public static byte[] MessageToSend;
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 = 1111;
int threads = Environment.ProcessorCount;
int clients = 100;
int size = 32;
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) },
{ "t|threads=", v => threads = int.Parse(v) },
{ "c|clients=", v => clients = int.Parse(v) },
{ "s|size=", v => size = 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 threads: {threads}");
Console.WriteLine($"Working clients: {clients}");
Console.WriteLine($"Message size: {size}");
Console.WriteLine($"Seconds to benchmarking: {seconds}");
Console.WriteLine();
// Prepare a message to send
MessageToSend = new byte[size];
// Create a new service
var service = new Service(threads);
// Start the service
Console.Write("Service starting...");
service.Start();
Console.WriteLine("Done!");
// Create multicast clients
var multicastClients = new List<MulticastClient>();
for (int i = 0; i < clients; ++i)
{
var client = new MulticastClient(service, address, port);
// client.SetupNoDelay(true);
multicastClients.Add(client);
}
TimestampStart = DateTime.UtcNow;
// Connect clients
Console.Write("Clients connecting...");
foreach (var client in multicastClients)
client.ConnectAsync();
Console.WriteLine("Done!");
foreach (var client in multicastClients)
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 multicastClients)
client.DisconnectAsync();
Console.WriteLine("Done!");
foreach (var client in multicastClients)
while (client.IsConnected)
Thread.Yield();
Console.WriteLine("All clients disconnected!");
TimestampStop = DateTime.UtcNow;
// Stop the service
Console.Write("Service stopping...");
service.Stop();
Console.WriteLine("Done!");
Console.WriteLine();
Console.WriteLine($"Errors: {TotalErrors}");
Console.WriteLine();
TotalMessages = TotalBytes / size;
Console.WriteLine($"Total time: {Service.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds)}");
Console.WriteLine($"Total data: {Service.GenerateDataSize(TotalBytes)}");
Console.WriteLine($"Total messages: {TotalMessages}");
Console.WriteLine($"Data throughput: {Service.GenerateDataSize((long)(TotalBytes / (TimestampStop - TimestampStart).TotalSeconds))}/s");
if (TotalMessages > 0)
{
Console.WriteLine($"Message latency: {Service.GenerateTimePeriod((TimestampStop - TimestampStart).TotalMilliseconds / TotalMessages)}");
Console.WriteLine($"Message throughput: {(long)(TotalMessages / (TimestampStop - TimestampStart).TotalSeconds)} msg/s");
}
}
}
}