Program.cs

using System;
using System.Collections.Generic;
using System.Net;
using Waher.Runtime.Inventory;

namespace Waher.Networking.Cluster.ConsoleSandbox
{
	class Program
	{
		static void Main(string[] args)
		{
			try
			{
				Types.Initialize(typeof(ClusterEndpoint).Assembly, typeof(Program).Assembly);

				Console.WriteLine("Welcome to the cluster sandbox.");
				Console.WriteLine();
				Console.Write("Multicast address (default=239.255.0.0): ");
				string s = Console.In.ReadLine();
				if (string.IsNullOrEmpty(s))
					s = "239.255.0.0";

				IPAddress Address = IPAddress.Parse(s);

				Console.Write("Port (default=12345): ");
				s = Console.In.ReadLine();
				if (string.IsNullOrEmpty(s))
					s = "12345";

				int Port = int.Parse(s);

				Console.Write("Secret: ");
				s = Console.In.ReadLine();

				Dictionary<string, bool> Locked = new Dictionary<string, bool>();
				Dictionary<IPEndPoint, string> Names = new Dictionary<IPEndPoint, string>();
				string Name = Dns.GetHostName();

				using (ClusterEndpoint Endpoint = new ClusterEndpoint(Address, Port, s))
				{
					Console.Out.WriteLine();
					Console.Out.WriteLine("You are now connected to the cluster.");
					Console.Out.WriteLine("Pressing a letter or a digit will lock/release a corresponding resource.");
					Console.Out.WriteLine("Press ESC to quit the application.");

					Endpoint.GetStatus += (sender, e) =>
					{
						e.Status = Name;
					};

					Endpoint.EndpointOnline += (sender, e) =>
					{
						lock (Names)
						{
							Names[e.Endpoint] = string.Empty;
						}

						Console.Out.WriteLine("New endpoint online: " + e.Endpoint.ToString());
					};

					Endpoint.EndpointOffline += (sender, e) =>
					{
						string RemoteName;

						lock (Names)
						{
							if (!Names.TryGetValue(e.Endpoint, out RemoteName))
								RemoteName = string.Empty;
						}

						Console.Out.WriteLine("Endpoint offline: " + e.Endpoint.ToString() + " (" + RemoteName + ")");
					};

					Endpoint.EndpointStatus += (sender, e) =>
					{
						if (e.Status is string RemoteName)
						{
							bool New;

							lock (Names)
							{
								New = !Names.TryGetValue(e.Endpoint, out string s2) || RemoteName != s2;

								if (New)
									Names[e.Endpoint] = RemoteName;
							}

							if (New)
								Console.Out.WriteLine(e.Endpoint.ToString() + " is " + RemoteName);
						}
					};

					ConsoleKeyInfo KeyInfo = Console.ReadKey(true);
					while (KeyInfo.Key != ConsoleKey.Escape)
					{
						char ch = KeyInfo.KeyChar;
						if (char.IsLetterOrDigit(ch))
						{
							s = new string(ch, 1);

							if (Locked.ContainsKey(s))
							{
								Console.Out.WriteLine("Releasing " + s + ".");
								Endpoint.Release(s);
								Console.Out.WriteLine(s + " released.");
								Locked.Remove(s);
							}
							else
							{
								Console.Out.WriteLine("Locking " + s + ".");

								Endpoint.Lock(s, 10000, (sender, e) =>
								{
									if (e.LockSuccessful)
									{
										Console.Out.WriteLine(e.State.ToString() + " locked.");
										Locked[e.State.ToString()] = true;
									}
									else if (e.LockedBy is null)
										Console.Out.WriteLine(e.State.ToString() + " is already locked.");
									else
										Console.Out.WriteLine(e.State.ToString() + " is already locked by " + e.LockedBy.ToString());
								}, s);
							}
						}

						KeyInfo = Console.ReadKey(true);
					}
				}
			}
			catch (Exception ex)
			{
				Console.Out.WriteLine(ex.Message);
			}
		}
	}
}