enable local IP setting iKadmium#17

jeffputz · Jul 10, 2023 · 509301f · 509301f
1 parent b64f5f2
commit 509301f
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 4 deletions.
diff --git a/Kadmium-sACN/Constants.cs b/Kadmium-sACN/Constants.cs
@@ -6,7 +6,8 @@ namespace Kadmium_sACN
 {
 	public static class Constants
 	{
-		public const int Port = 5568;
+		public const int RemotePort = 5568;
+		public const int LocalPort = 5569;
 		public const int MaxPacketLength = 1444;
 		public const int Universe_MinValue = 1;
 		public const int Universe_MaxValue = 63999;

diff --git a/Kadmium-sACN/SacnReceiver/SacnReceiver.cs b/Kadmium-sACN/SacnReceiver/SacnReceiver.cs
@@ -34,7 +34,7 @@ protected SacnReceiver(ISacnMulticastAddressProvider ipv4Provider, ISacnMulticas
 
 		public void Listen(IPAddress address)
 		{
-			var endpoint = new IPEndPoint(address, Constants.Port);
+			var endpoint = new IPEndPoint(address, Constants.RemotePort);
 
 			Pipe pipe = new Pipe();
 			Socket = new Socket(endpoint.AddressFamily, SocketType.Dgram, ProtocolType.Udp);

diff --git a/Kadmium-sACN/SacnSender/SacnSender.cs b/Kadmium-sACN/SacnSender/SacnSender.cs
@@ -16,10 +16,15 @@ public class SacnSender : IDisposable
 		private ISacnMulticastAddressProvider Ipv6MulticastAddressProvider { get; }
 		private Socket Ipv4Socket { get; } = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
 		private Socket Ipv6Socket { get; } = new Socket(AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp);
+
+		private IPAddress _ip;
 
 		public SacnSender() : this(new SacnMulticastAddressProviderIPV4(), new SacnMulticastAddressProviderIPV6())
 		{ }
 
+		public SacnSender(IPAddress localAddress) : this(new SacnMulticastAddressProviderIPV4(), new SacnMulticastAddressProviderIPV6())
+		{ }
+
 		protected SacnSender(ISacnMulticastAddressProvider ipv4AddressProvider, ISacnMulticastAddressProvider ipv6AddressProvider)
 		{
 			Ipv4MulticastAddressProvider = ipv4AddressProvider;
@@ -28,13 +33,16 @@ protected SacnSender(ISacnMulticastAddressProvider ipv4AddressProvider, ISacnMul
 
 		protected async Task SendInternal(IPAddress address, SacnPacket packet)
 		{
-			var endpoint = new IPEndPoint(address, Constants.Port);
+			var endpoint = new IPEndPoint(address, Constants.RemotePort);
 			using (var owner = MemoryPool<byte>.Shared.Rent(packet.Length))
 			{
 				var bytes = owner.Memory.Slice(0, packet.Length);
 				packet.Write(bytes.Span);
 				var socket = address.AddressFamily == AddressFamily.InterNetworkV6 ? Ipv6Socket : Ipv4Socket;
-
+
+				if (_ip != null)
+					socket.Bind(new IPEndPoint(_ip, Constants.LocalPort));
+
 				var args = new SocketAsyncEventArgs
 				{
 					SocketFlags = SocketFlags.None,