using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Diagnostics;

namespace udp_recv {
	class Program {

		static void recv() {
			IPEndPoint ep = null;
			var receiver = new UdpClient(new IPEndPoint(IPAddress.Any, 12345));
			Int32 next = 0, total = 0, lost = 0;;
			Stopwatch sw = new Stopwatch();
			var data = new Byte[65536];
			Console.WriteLine("Wait messages");
			while(true) {
				Int32 size = receiver.Client.Receive(data, data.Length, SocketFlags.None);
				Int32 num = data[0] | data[1] << 8 | data[2] << 16;
				if(num == 0) {
					total = 0;
					next = 1;
					lost = 0;
					sw.Restart();
				} else if (num == 0xFFFFFF) { // последний
					sw.Stop();
					Console.WriteLine($"Receive {total} bytes  Time {sw.ElapsedMilliseconds}  Speed {total / sw.ElapsedMilliseconds} kbyte/sec  Lost {lost} packets");
				} else if(next != num) { // пропуск
					lost += num - next;
					total += size;
					next = num + 1;
				} else {
					total += size;
					next = num + 1;
				}
			}
		}

		static void Main(string[] args) {
			recv();
		}
	}
}

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace udp_send {
	class Program {

		static void send(Int32 count, Int32 size, String addr) {
			var sender = new UdpClient();
			var ep = new IPEndPoint(IPAddress.Parse(addr), 12345);
			var data = new Byte[size];
			Console.WriteLine($"Send {count} packets size: {size} Total {count * size} to {addr}");
			var sw = Stopwatch.StartNew();
			for(Int32 i = 0; i < count; i++) {
				data[0] = (Byte) (i & 0xFF);
				data[1] = (Byte) ((i >> 8) & 0xFF);
				data[2] = (Byte) ((i >> 16) & 0xFF);
				sender.Send(data, size, ep);
			}
			data[0] = 0xFF;
			data[1] = 0xFF;
			data[2] = 0xFF;
			sender.Send(data, size, ep);
			Int64 t = sw.ElapsedMilliseconds;
			Console.WriteLine($"Time {t} msec speed {count * size / t} kbyte/sec");
			Thread.Sleep(100);
			sender.Send(data, size, ep);
		}

		static void Main(string[] args) {
			if(args.Length == 0) {
				Console.WriteLine("Usage:\n udp_send [count msg] [size one] [server]\n\n Example:\nudp_send 1000 1472 127.0.0.1\n");
			}
			String addr = "127.0.0.1";
			Int32 count = 1000;
			Int32 size = 1472;
			if(args.Length > 0) {
				count = Int32.Parse(args[0]);
			}
			if(args.Length > 1) {
				size = Int32.Parse(args[1]);
			}
			if(args.Length > 2) {
				addr = args[2];
			}
			send(count, size, addr);
		}
	}
}

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace tcp_recv {
	class Program {

		static void recv() {
			IPEndPoint ep = null;
			var receiver = new TcpListener(new IPEndPoint(IPAddress.Any, 12345));
			receiver.Start(1);
			var data = new Byte[65536];
			Console.WriteLine("Wait messages");
			while(true) {
				TcpClient client = receiver.AcceptTcpClient();
				NetworkStream io = client.GetStream();
				Int32 total = 0, read = 1;
				var sw = Stopwatch.StartNew();
				while(read != 0) {
					read = io.Read(data, 0, data.Length);
					total += read;
				}
				client.Close();
				Int64 t = sw.ElapsedMilliseconds;
				Console.WriteLine($"Time {t} msec speed {total / t} kbyte/sec");
			}
		}

		static void Main(string[] args) {
			recv();
		}
	}
}

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace tcp_send {
	class Program {
		static void send(Int32 size, String addr) {
			var sender = new TcpClient(addr, 12345);
			NetworkStream io = sender.GetStream();
			var data = new Byte[65536];
			Console.WriteLine($"Send size: {size} to {addr}");
			Int32 total = size;
			var sw = Stopwatch.StartNew();
			while(size > 0) {
				Int32 send = size > 65536 ? 65536 : size;
				io.Write(data, 0, send);
				size -= send;
			}
			sender.Close();
			Int64 t = sw.ElapsedMilliseconds;
			Console.WriteLine($"Time {t} msec speed {total / t} kbyte/sec");
		}

		static void Main(string[] args) {
			if(args.Length == 0) {
				Console.WriteLine("Usage:\n tcp_send [size] [server]\n\n Example:\ntcp_send 1000000 127.0.0.1\n");
			}
			String addr = "127.0.0.1";
			Int32 size = 10000000;
			if(args.Length > 0) {
				size = Int32.Parse(args[0]);
			}
			if(args.Length > 1) {
				addr = args[1];
			}
			send(size, addr);
		}
	}
}

		static void send(Int32 size, String addr) {
			var sender = new TcpClient(addr, 12345);
			NetworkStream io = sender.GetStream();
			var data = new Byte[1024];
			Console.WriteLine($"Send size: {size} (block {data.Length}) to {addr}");
			Int32 total = size;
			var sw = Stopwatch.StartNew();
			while(size > 0) {
				Int32 send = size > data.Length ? data.Length : size;
				io.Write(data, 0, send);
				size -= send;
			}
			sender.Close();
			Int64 t = sw.ElapsedMilliseconds;
			Console.WriteLine($"Time {t} msec speed {total / t} kbyte/sec");
		}