{"id":2443,"date":"2023-06-13T22:13:32","date_gmt":"2023-06-13T14:13:32","guid":{"rendered":"http:\/\/www.jhouseconsulting.com\/?p=2443"},"modified":"2023-07-01T17:30:31","modified_gmt":"2023-07-01T09:30:31","slug":"xdping-c-function","status":"publish","type":"post","link":"https:\/\/www.jhouseconsulting.com\/jhouseconsulting\/2023\/06\/13\/xdping-c-function-2443","title":{"rendered":"XDPing C# Function"},"content":{"rendered":"

I wrote this C# (csharp) function back in 2020 when developing the Self-Service Session Reset Tool<\/a>. I have since enhanced it for improved error checking and logging and am happy to share it here for anyone else who wants to leverage it. I released a PowerShell version<\/a> back in 2019. I like to integrate these functions into the scripts and tools I create as part of the health checks I do. I believe that by checking that the Broker’s Registrar service is reachable, listening and processing requests on its configured port, we can only then assume it is in a healthy state.<\/p>\n

The original code was taken from the VDAAssistant.Backend.dll library which is included with the Citrix Health Assistant Tool. Citrix don’t obfuscate these libraries, so it’s easy to use tools like JetBrains decompiler to take a look at how they wrote this. From there I reverse engineer the code to extract what I need and wrap it up into a function that will work for me.<\/p>\n

The original Citrix XDPing tool can be found here<\/a>. The Citrix Health Assistant<\/a> tool has since replaced XDPing.<\/p>\n

Here is the code. It’s also available as a full project from my GitHub repository<\/a>. Total number of downloads to date: 10.<\/p>\n

\r\nusing System;\r\nusing System.Text;\r\n\/\/ Required for sockets\r\nusing System.Net.Sockets;\r\n\r\nnamespace XDPing\r\n{\r\n    class Program\r\n    {\r\n        static int Main(string[] args)\r\n        {\r\n            string deliverycontroller = string.Empty;\r\n            int port = 80;\r\n\r\n            for (int i = 0; i < args.Length; i++)\r\n            {\r\n                var arg = args[i].ToLower();\r\n                if (arg == "-deliverycontroller" || arg == "--deliverycontroller" || arg == "\/deliverycontroller")\r\n                {\r\n                    if (args.Length >= i + 2)\r\n                    {\r\n                        deliverycontroller = args[i + 1];\r\n                    }\r\n                }\r\n\r\n                if (arg == "-port" || arg == "--port" || arg == "\/port")\r\n                {\r\n                    if (args.Length >= i + 2)\r\n                    {\r\n                        int.TryParse(args[i + 1], out port);\r\n                    }\r\n                }\r\n            }\r\n\r\n            if (string.IsNullOrEmpty(deliverycontroller))\r\n            {\r\n                Console.WriteLine("Valid command line arguments must be supplied:");\r\n                Console.WriteLine("-deliverycontroller, --deliverycontroller or \/deliverycontroller is a required flag. This must be followed by the name of a Delivery Controller or Cloud Connector.");\r\n                Console.WriteLine("-port, --port or \/port is an optional flag. It will default to 80 if not supplied. This is the port the Broker's Registrar service listens on.");\r\n                return -1;\r\n            }\r\n\r\n            XDPing(deliverycontroller, port);\r\n\r\n            return 0;\r\n        }\r\n\r\n        \/\/\/ <summary>\r\n        \/\/\/ Performs an XDPing to make sure the Delivery Controller or Cloud Connector is in a healthy state.\r\n        \/\/\/ It test whether the Broker service is reachable, listening and processing requests on its configured port.\r\n        \/\/\/ We do this by issuing a blank HTTP POST requests to the Broker's Registrar service.\r\n        \/\/\/ Including "Expect: 100-continue" in the body will ensure we receive a respose of "HTTP\/1.1 100 Continue",\r\n        \/\/\/ which is what we use to verify that it's in a healthy state.\r\n        \/\/\/ <\/summary>\r\n        \/\/\/ <param name="deliverycontroller"><\/param>\r\n        \/\/\/ <param name="port"><\/param>\r\n        \/\/\/ <returns><\/returns>\r\n        static private bool XDPing(string deliverycontroller, int port)\r\n        {\r\n            \/\/ This code has essentially been taken from the Citrix Health Assistant Tool and improved for reliability and troubleshooting purposes.\r\n            \/\/ I was able to reverse engineer the process by decompiling the VDAAssistant.Backend.dll, which is a component of the Citrix Health\r\n            \/\/ Assistant Tool.\r\n            string service = "http:\/\/" + deliverycontroller + ":" + port +"\/Citrix\/CdsController\/IRegistrar";\r\n            string s = string.Format("POST {0} HTTP\/1.1\\r\\nContent-Type: application\/soap+xml; charset=utf-8\\r\\nHost: {1}:{2}\\r\\nContent-Length: 1\\r\\nExpect: 100-continue\\r\\nConnection: Close\\r\\n\\r\\n", (object)service, (object)deliverycontroller, (object)port);\r\n            StringBuilder stringBuilder = new StringBuilder();\r\n            stringBuilder.AppendLine("Attempting an XDPing against " + deliverycontroller + " on TCP port number " + port.ToString());\r\n            bool listening = false;\r\n            try\r\n            {\r\n                Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);\r\n                try\r\n                {\r\n                    socket.Connect(deliverycontroller, port);\r\n                    if (socket.Connected)\r\n                    {\r\n                        stringBuilder.AppendLine("- Socket connected");\r\n                        byte[] bytes = Encoding.ASCII.GetBytes(s);\r\n                        \/\/ Send the string as bytes.\r\n                        socket.Send(bytes, bytes.Length, SocketFlags.None);\r\n                        stringBuilder.AppendLine("- Sent the data");\r\n                        byte[] numArray = new byte[21];\r\n                        socket.ReceiveTimeout = 5000;\r\n                        socket.Receive(numArray);\r\n                        stringBuilder.AppendLine("- Received the following 21 byte array: " + BitConverter.ToString(numArray));\r\n                        \/\/ ASCII conversion - string from bytes\r\n                        string strASCII = Encoding.ASCII.GetString(numArray, 0, numArray.Length);\r\n                        \/\/ UTF conversion - String from bytes  \r\n                        string strUTF8 = Encoding.UTF8.GetString(numArray, 0, numArray.Length);\r\n                        stringBuilder.AppendLine("- Converting the byte array to an ASCII string we get the output between the quotes: \\"" + strASCII + "\\"");\r\n                        stringBuilder.AppendLine("- Converting the byte array to a UTF8 string we get the output between the quotes: \\"" + strUTF8 + "\\"");\r\n                        \/\/ Send an additional single byte of 32 (space) as 1 byte with no flags.\r\n                        socket.Send(new byte[1] { (byte)32 }, 1, SocketFlags.None);\r\n                        stringBuilder.AppendLine("- Sending the following string as a byte to close the connection: \\"" + BitConverter.ToString(new byte[1] { 32 }) + "\\"");\r\n                        if (strASCII.Trim().IndexOf("HTTP\/1.1 100 Continue", StringComparison.CurrentCultureIgnoreCase) == 0)\r\n                        {\r\n                            listening = true;\r\n                            stringBuilder.AppendLine("- The service is listening and healthy");\r\n                        }\r\n                        else\r\n                        {\r\n                            stringBuilder.AppendLine("- The service is not listening");\r\n                        }\r\n                    }\r\n                    else\r\n                    {\r\n                        stringBuilder.AppendLine("- Socket failed to connect");\r\n                    }\r\n                }\r\n                catch (SocketException se)\r\n                {\r\n                    stringBuilder.AppendLine("- Failed to connect to service");\r\n                    stringBuilder.AppendLine("- ERROR: " + se.Message);\r\n                }\r\n                catch (Exception e)\r\n                {\r\n                    stringBuilder.AppendLine("- Failed with an unexpected error");\r\n                    stringBuilder.AppendLine("- ERROR: " + e.Message);\r\n                }\r\n                if (socket.Connected)\r\n                {\r\n                    try\r\n                    {\r\n                        socket.Close();\r\n                        stringBuilder.AppendLine("- Socket closed");\r\n                    }\r\n                    catch (SocketException se)\r\n                    {\r\n                        stringBuilder.AppendLine("- Failed to close the socket");\r\n                        stringBuilder.AppendLine("- ERROR: " + se.Message);\r\n                    }\r\n                    catch (Exception e)\r\n                    {\r\n                        stringBuilder.AppendLine("- Failed with an unexpected error");\r\n                        stringBuilder.AppendLine("- ERROR: " + e.Message);\r\n                    }\r\n                }\r\n                socket.Dispose();\r\n            }\r\n            catch (Exception e)\r\n            {\r\n                stringBuilder.AppendLine("- Failed to create a socket");\r\n                stringBuilder.AppendLine("- ERROR: " + e.Message);\r\n            }\r\n            Console.WriteLine(stringBuilder.ToString().Substring(0, stringBuilder.ToString().Length - 1));\r\n            return listening;\r\n        }\r\n    }\r\n}\r\n<\/pre>\n
Notes:<\/p>\n