Version 1.6

2025-12-15 15:53:45 +00:00 · 2021-03-26 02:03:22 -07:00
parent b00714d442
commit 2485ca8225
5 changed files with 160 additions and 1 deletions
--- a/LocalPipe.cs
+++ b/LocalPipe.cs
@@ -0,0 +1,86 @@
+using System;
+using System.Collections.Generic;
+using System.IO.Pipes;
+using System.Linq;
+using System.Security.Principal;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MeshCentralRouter
+{
+    public class LocalPipeServer
+    {
+        private String name;
+        private byte[] buffer = new byte[4096];
+        private NamedPipeServerStream pipeServer;
+
+        public delegate void onArgsHandler(string args);
+        public event onArgsHandler onArgs;
+
+        public LocalPipeServer(string name)
+        {
+            this.name = name;
+            pipeServer = new NamedPipeServerStream(name, PipeDirection.InOut, 1, PipeTransmissionMode.Message, PipeOptions.Asynchronous);
+            pipeServer.BeginWaitForConnection(new AsyncCallback(processConnection), null);
+        }
+
+        public void Dispose()
+        {
+            try { pipeServer.Close(); } catch (Exception) { }
+            pipeServer = null;
+        }
+
+        private void processConnection(IAsyncResult ar)
+        {
+            try { pipeServer.EndWaitForConnection(ar); } catch (Exception) { }
+            try { pipeServer.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(processRead), null); } catch (Exception) { }
+        }
+
+
+        private void processRead(IAsyncResult ar)
+        {
+            int len = 0;
+            try { len = pipeServer.EndRead(ar); } catch (Exception) { }
+            if (len > 0)
+            {
+                string args = UTF8Encoding.UTF8.GetString(buffer, 0, len);
+                pipeServer.Close();
+                onArgs(args);
+                pipeServer = new NamedPipeServerStream(name, PipeDirection.InOut, 1, PipeTransmissionMode.Message, PipeOptions.Asynchronous);
+                pipeServer.BeginWaitForConnection(new AsyncCallback(processConnection), null);
+            }
+        }
+
+    }
+
+
+    public class LocalPipeClient
+    {
+        private byte[] buffer = new byte[4096];
+        private NamedPipeClientStream pipeClient;
+
+        public LocalPipeClient(string name)
+        {
+            pipeClient = new NamedPipeClientStream(".", name, PipeDirection.InOut, PipeOptions.Asynchronous, TokenImpersonationLevel.None);
+        }
+
+        public bool TrySendingArguments(string args)
+        {
+            try
+            {
+                byte[] buf = UTF8Encoding.UTF8.GetBytes(args);
+                pipeClient.Connect(10);
+                pipeClient.BeginWrite(buf, 0, buf.Length, new AsyncCallback(processWrite), null);
+            }
+            catch (Exception) { return false; }
+            return true;
+        }
+
+        private void processWrite(IAsyncResult ar)
+        {
+            try { pipeClient.EndWrite(ar); } catch (Exception) { }
+            pipeClient.Close();
+        }
+    }
+
+}