More Warnings fixed

Christoph Bauer · Christoph Bauer · commit fa221a72587d · 2025-06-12T16:27:22.000+02:00
diff --git a/src/NetMQ.Tests/RouterTests.cs b/src/NetMQ.Tests/RouterTests.cs
@@ -44,7 +44,7 @@ public void ReceiveReadyDot35Bug()
             using (var server = new RouterSocket())
             {
                 server.BindRandomPort("tcp://127.0.0.1");
-                server.ReceiveReady += (s, e) => Assert.True(false, "Should not receive");
+                server.ReceiveReady += (s, e) => Assert.Fail( "Should not receive");
 
                 Assert.False(server.Poll(TimeSpan.FromMilliseconds(1500)));
             }
diff --git a/src/NetMQ/AsyncReceiveExtensions.cs b/src/NetMQ/AsyncReceiveExtensions.cs
@@ -91,7 +91,7 @@ public static async Task<NetMQMessage> ReceiveMultipartMessageAsync(
                 registration = cancellationToken.Register(PropagateCancel);
             }
 
-            void Listener(object sender, NetMQSocketEventArgs args)
+            void Listener(object? sender, NetMQSocketEventArgs args)
             {
                 if (socket.TryReceive(ref msg, TimeSpan.Zero))
                 {
@@ -174,7 +174,7 @@ void PropagateCancel()
                 registration = cancellationToken.Register(PropagateCancel);
             }
 
-            void Listener(object sender, NetMQSocketEventArgs args)
+            void Listener(object? sender, NetMQSocketEventArgs args)
             {
                 if (socket.TryReceive(ref msg, TimeSpan.Zero))
                 {
@@ -241,7 +241,7 @@ public static Task<bool> SkipFrameAsync(
                 registration = cancellationToken.Register(PropagateCancel);
             }
 
-            void Listener(object sender, NetMQSocketEventArgs args)
+            void Listener(object? sender, NetMQSocketEventArgs args)
             {
                 if (socket.TryReceive(ref msg, TimeSpan.Zero))
                 {
diff --git a/src/NetMQ/Core/Address.cs b/src/NetMQ/Core/Address.cs
@@ -104,7 +104,7 @@ public Address(EndPoint endpoint)
             }
 
             Debug.Assert(endpoint != null);
-            AddressString = endpoint.ToString()!;
+            AddressString = endpoint!.ToString()!;
         }
 
 
diff --git a/src/NetMQ/Core/Patterns/Peer.cs b/src/NetMQ/Core/Patterns/Peer.cs
@@ -148,7 +148,7 @@ protected override void XAttachPipe(Pipe pipe, bool icanhasall)
         /// <param name="pipe">the Pipe that is being removed</param>
         protected override void XTerminated(Pipe pipe)
         {           
-            m_outpipes.TryGetValue(pipe.RoutingId, out Outpipe old);
+            m_outpipes.TryGetValue(pipe.RoutingId, out Outpipe? old);
             m_outpipes.Remove(pipe.RoutingId);
 
             Debug.Assert(old != null);
@@ -208,7 +208,7 @@ protected override bool XSend(ref Msg msg)
                     // Find the pipe associated with the routingId stored in the prefix.                    
                     var routingId = BitConverter.ToUInt32(msg.UnsafeToArray(), 0);
 
-                    if (m_outpipes.TryGetValue(routingId, out Outpipe op))
+                    if (m_outpipes.TryGetValue(routingId, out Outpipe? op))
                     {
                         m_currentOut = op.Pipe;
                         if (!m_currentOut.CheckWrite())
diff --git a/src/NetMQ/Core/Patterns/Router.cs b/src/NetMQ/Core/Patterns/Router.cs
@@ -214,7 +214,7 @@ protected override void XTerminated(Pipe pipe)
             {
                 Assumes.NotNull(pipe.Identity);
 
-                m_outpipes.TryGetValue(pipe.Identity, out Outpipe old);
+                m_outpipes.TryGetValue(pipe.Identity, out Outpipe? old);
                 m_outpipes.Remove(pipe.Identity);
 
                 Debug.Assert(old != null);
@@ -290,7 +290,7 @@ protected override bool XSend(ref Msg msg)
                     // mandatory is set.
 
                     var identity = msg.UnsafeToArray();
-                    if (m_outpipes.TryGetValue(identity, out Outpipe op))
+                    if (m_outpipes.TryGetValue(identity, out Outpipe? op))
                     {
                         m_currentOut = op.Pipe;
                         if (!m_currentOut.CheckWrite())
@@ -556,7 +556,7 @@ private bool IdentifyPeer(Pipe pipe)
                     msg.Close();
 
 
-                    if (m_outpipes.TryGetValue(identity, out Outpipe existPipe))
+                    if (m_outpipes.TryGetValue(identity, out Outpipe? existPipe))
                     {
                         if (!m_handover)
                         {
diff --git a/src/NetMQ/Core/Patterns/Stream.cs b/src/NetMQ/Core/Patterns/Stream.cs
@@ -143,7 +143,7 @@ protected override void XTerminated(Pipe pipe)
         {
             Assumes.NotNull(pipe.Identity);
 
-            m_outpipes.TryGetValue(pipe.Identity, out Outpipe old);
+            m_outpipes.TryGetValue(pipe.Identity, out Outpipe? old);
             m_outpipes.Remove(pipe.Identity);
 
             Debug.Assert(old != null);
@@ -206,7 +206,7 @@ protected override bool XSend(ref Msg msg)
                     // mandatory is set.
 
                     var identity = msg.UnsafeToArray();
-                    if (m_outpipes.TryGetValue(identity, out Outpipe op))
+                    if (m_outpipes.TryGetValue(identity, out Outpipe? op))
                     {
                         m_currentOut = op.Pipe;
                         if (!m_currentOut.CheckWrite())
diff --git a/src/NetMQ/Core/SocketBase.cs b/src/NetMQ/Core/SocketBase.cs
@@ -929,7 +929,7 @@ public void TermEndpoint(string addr)
                     if (UnregisterEndpoint(addr, this))
                         return;
 
-                    if (!m_inprocs.TryGetValue(addr, out Pipe pipe))
+                    if (!m_inprocs.TryGetValue(addr, out Pipe? pipe))
                         throw new EndpointNotFoundException("Endpoint was not found and cannot be disconnected");
 
                     pipe.SendDisconnectMessage();
@@ -938,7 +938,7 @@ public void TermEndpoint(string addr)
                 }
                 else
                 {
-                    if (!m_endpoints.TryGetValue(addr, out Endpoint endpoint))
+                    if (!m_endpoints.TryGetValue(addr, out Endpoint? endpoint))
                         throw new EndpointNotFoundException("Endpoint was not found and cannot be disconnected");
 
                     endpoint.Pipe?.Terminate(false);
diff --git a/src/NetMQ/Core/Transports/Pgm/PgmAddress.cs b/src/NetMQ/Core/Transports/Pgm/PgmAddress.cs
@@ -65,7 +65,7 @@ public void Resolve(string name, bool ip4Only)
             if (addrStr == "*")
                 addrStr = "0.0.0.0";
 
-            if (!IPAddress.TryParse(addrStr, out IPAddress ipAddress))
+            if (!IPAddress.TryParse(addrStr, out IPAddress? ipAddress))
                 throw new InvalidException($"In PgmAddress.Resolve({name},{ip4Only}), addrStr ({addrStr}) must be a valid IPAddress.");
 
             this.Address = new IPEndPoint(ipAddress, port);
diff --git a/src/NetMQ/Core/Transports/Tcp/TcpAddress.cs b/src/NetMQ/Core/Transports/Tcp/TcpAddress.cs
@@ -91,7 +91,7 @@ public void Resolve(string name, bool ip4Only)
                 }
             }
 
-            IPAddress ipAddress;
+            IPAddress? ipAddress;
 
             // Interpret * as Any.
             if (addrStr == "*")
diff --git a/src/NetMQ/Core/Utils/OpCode.cs b/src/NetMQ/Core/Utils/OpCode.cs
@@ -17,7 +17,7 @@ public static bool Open()
             // While this is supported in modern CPUs, the technique used for allocating executable memory, copying OP Code
             // for the read of the time stamp and invoking the OP Code can be detected as Malware by some anti-virus vendors.
             // https://github.com/zeromq/netmq/issues/1071
-            string val = Environment.GetEnvironmentVariable("NETQM_SUPPRESS_RDTSC");
+            string? val = Environment.GetEnvironmentVariable("NETQM_SUPPRESS_RDTSC");
             if (!string.IsNullOrEmpty(val))
                 return false;
 #if NETSTANDARD || NET 
@@ -83,8 +83,8 @@ private static bool IsARMArchitecture()
         {
             // force to load from mono gac
             Assembly currentAssembly = Assembly.Load("Mono.Posix, Version=2.0.0.0, Culture=neutral, PublicKeyToken=0738eb9f132ed756");
-            Type syscall = currentAssembly.GetType("Mono.Unix.Native.Syscall");
-            Type utsname = currentAssembly.GetType("Mono.Unix.Native.Utsname");
+            Type? syscall = currentAssembly.GetType("Mono.Unix.Native.Syscall");
+            Type? utsname = currentAssembly.GetType("Mono.Unix.Native.Utsname");
             if (syscall is null || utsname is null) return false;
             MethodInfo? uname = syscall.GetMethod("uname");
             object?[] parameters = { null };
@@ -111,9 +111,9 @@ public static void Close()
                     Assembly.Load("Mono.Posix, Version=2.0.0.0, Culture=neutral, " +
                     "PublicKeyToken=0738eb9f132ed756");
 
-                Type syscall = assembly.GetType("Mono.Unix.Native.Syscall");
-                MethodInfo munmap = syscall.GetMethod("munmap");
-                munmap.Invoke(null, new object[] { s_codeBuffer, s_size });
+                Type? syscall = assembly.GetType("Mono.Unix.Native.Syscall");
+                MethodInfo? munmap = syscall?.GetMethod("munmap");
+                munmap?.Invoke(null, new object[] { s_codeBuffer, s_size });
             }
             else
             {
diff --git a/src/NetMQ/Core/Utils/Poller.cs b/src/NetMQ/Core/Utils/Poller.cs
@@ -167,7 +167,7 @@ public void AddHandle(Socket handle, IPollEvents events)
         /// <param name="handle">the System.Net.Sockets.Socket to remove</param>
         public void RemoveHandle(Socket handle)
         {
-            PollSet pollSet = m_addList.FirstOrDefault(p => p.Socket == handle);
+            PollSet? pollSet = m_addList.FirstOrDefault(p => p.Socket == handle);
 
             // If the socket was removed before being added there is no reason to mark retired, so just cancelling the socket and removing from add list.
 
diff --git a/src/NetMQ/Monitoring/NetMQMonitor.cs b/src/NetMQ/Monitoring/NetMQMonitor.cs
@@ -152,7 +152,7 @@ public NetMQMonitor(NetMQSocket socket, string endpoint, bool ownsSocket = false
 
         #endregion
 
-        private void Handle(object sender, NetMQSocketEventArgs socketEventArgs)
+        private void Handle(object? sender, NetMQSocketEventArgs socketEventArgs)
         {
             var monitorEvent = MonitorEvent.Read(m_monitoringSocket.SocketHandle);
 
diff --git a/src/NetMQ/NetMQActor.cs b/src/NetMQ/NetMQActor.cs
@@ -151,8 +151,8 @@ private NetMQActor(PairSocket self, PairSocket shim, IShimHandler shimHandler)
 
             var args = new NetMQActorEventArgs(this);
 
-            void OnReceive(object sender, NetMQSocketEventArgs e) => m_receiveEvent!.Fire(this, args);
-            void OnSend   (object sender, NetMQSocketEventArgs e) => m_sendEvent   !.Fire(this, args);
+            void OnReceive(object? sender, NetMQSocketEventArgs e) => m_receiveEvent!.Fire(this, args);
+            void OnSend   (object? sender, NetMQSocketEventArgs e) => m_sendEvent   !.Fire(this, args);
 
             m_receiveEvent = new EventDelegator<NetMQActorEventArgs>(
                 () => m_self.ReceiveReady += OnReceive,
diff --git a/src/NetMQ/NetMQBeacon.cs b/src/NetMQ/NetMQBeacon.cs
@@ -189,7 +189,7 @@ public void Run(PairSocket shim)
 #endif
             }
 
-            private void PingElapsed(object sender, NetMQTimerEventArgs e)
+            private void PingElapsed(object? sender, NetMQTimerEventArgs e)
             {
                 Assumes.NotNull(m_transmit);
 
@@ -201,7 +201,7 @@ private void OnUdpReady(Socket socket)
                 Assumes.NotNull(m_pipe);
 
                 if (!TryReceiveUdpFrame(out NetMQFrame? frame, out string? peerName))
-		    return;
+                    return;
 
                 // If filter is set, check that beacon matches it
                 var isValid = frame.MessageSize >= m_filter?.MessageSize && Compare(frame, m_filter, m_filter.MessageSize);
@@ -222,7 +222,7 @@ private void OnUdpReady(Socket socket)
                 }
             }
 
-            private void OnPipeReady(object sender, NetMQSocketEventArgs e)
+            private void OnPipeReady(object? sender, NetMQSocketEventArgs e)
             {
                 Assumes.NotNull(m_pipe);
                 Assumes.NotNull(m_pingTimer);
@@ -323,7 +323,7 @@ public NetMQBeacon()
         {
             m_actor = NetMQActor.Create(new Shim());
 
-            void OnReceive(object sender, NetMQActorEventArgs e) => m_receiveEvent!.Fire(this, new NetMQBeaconEventArgs(this));
+            void OnReceive(object? sender, NetMQActorEventArgs e) => m_receiveEvent!.Fire(this, new NetMQBeaconEventArgs(this));
 
             m_receiveEvent = new EventDelegator<NetMQBeaconEventArgs>(
                 () => m_actor.ReceiveReady += OnReceive,
diff --git a/src/NetMQ/NetMQException.cs b/src/NetMQ/NetMQException.cs
@@ -25,15 +25,15 @@ public class NetMQException : Exception
         /// Create NetMQ Exception
         /// </summary>
         public NetMQException()
-        {}
+        { }
 
         /// <summary>
         /// Create a new NetMQ exception
         /// </summary>
         /// <param name="message"></param>
         public NetMQException(string message)
             : base(message)
-        {}
+        { }
 
         /// <summary>
         /// Create a new NetMQ exception
@@ -42,23 +42,34 @@ public NetMQException(string message)
         /// <param name="innerException"></param>
         public NetMQException(string message, Exception innerException)
             : base(message, innerException)
-        {}
+        { }
 
         /// <summary>Constructor for serialisation.</summary>
         protected NetMQException(SerializationInfo info, StreamingContext context)
+#pragma warning disable SYSLIB0051
             : base(info, context)
+#pragma warning restore SYSLIB0051
         {
             ErrorCode = (ErrorCode)info.GetInt32("ErrorCode");
         }
 
         /// <inheritdoc />
+
+#if !NET
+       
         [SecurityPermission(SecurityAction.Demand, SerializationFormatter = true)]
+#endif
+#pragma warning disable CS0672 // Member overrides obsolete member
         public override void GetObjectData(SerializationInfo info, StreamingContext context)
+#pragma warning restore CS0672 // Member overrides obsolete member
         {
             info.AddValue("ErrorCode", ErrorCode);
+#pragma warning disable SYSLIB0051
             base.GetObjectData(info, context);
+#pragma warning restore SYSLIB0051
         }
 
+
         #endregion
 
         /// <summary>
diff --git a/src/NetMQ/NetMQFrame.cs b/src/NetMQ/NetMQFrame.cs
@@ -258,7 +258,7 @@ public bool Equals(NetMQFrame? other)
             return true;
         }
 
-        bool IEquatable<NetMQFrame>.Equals(NetMQFrame other)
+        bool IEquatable<NetMQFrame>.Equals(NetMQFrame? other)
         {
             return Equals(other);
         }
diff --git a/src/NetMQ/NetMQPoller.cs b/src/NetMQ/NetMQPoller.cs
@@ -633,7 +633,7 @@ private void RunPoller()
                         else if (item.ResultEvent.HasError() || item.ResultEvent.HasIn())
                         {
                             Assumes.NotNull(item.FileDescriptor);
-                            if (m_pollinSockets.TryGetValue(item.FileDescriptor, out Action<Socket> action))
+                            if (m_pollinSockets.TryGetValue(item.FileDescriptor, out Action<Socket>? action))
                                 action(item.FileDescriptor);
                         }
                     }
@@ -687,7 +687,7 @@ public void StopAsync()
 
         #endregion
 
-        private void OnSocketEventsChanged(object sender, NetMQSocketEventArgs e)
+        private void OnSocketEventsChanged(object? sender, NetMQSocketEventArgs e)
         {
             // when the sockets SendReady or ReceiveReady changed we marked the poller as dirty in order to reset the poll events
             m_isPollSetDirty = true;
diff --git a/src/NetMQ/NetMQProactor.cs b/src/NetMQ/NetMQProactor.cs
@@ -48,7 +48,7 @@ private void Run(PairSocket shim)
             m_receiveSocket.ReceiveReady -= OnSocketReady;
         }
 
-        private void OnShimReady(object sender, NetMQSocketEventArgs e)
+        private void OnShimReady(object? sender, NetMQSocketEventArgs e)
         {
             Assumes.NotNull(m_poller);
 
@@ -59,7 +59,7 @@ private void OnShimReady(object sender, NetMQSocketEventArgs e)
             }
         }
 
-        private void OnSocketReady(object sender, NetMQSocketEventArgs e)
+        private void OnSocketReady(object? sender, NetMQSocketEventArgs e)
         {
             NetMQMessage message = m_receiveSocket.ReceiveMultipartMessage();
 
diff --git a/src/NetMQ/NetMQQueue.cs b/src/NetMQ/NetMQQueue.cs
@@ -57,7 +57,7 @@ public NetMQQueue(int capacity = 0)
             m_dequeueMsg.InitEmpty();
         }
 
-        private void OnReceiveReady(object sender, NetMQSocketEventArgs e)
+        private void OnReceiveReady(object? sender, NetMQSocketEventArgs e)
         {
             m_eventDelegator.Fire(this, new NetMQQueueEventArgs<T>(this));
         }
diff --git a/src/NetMQ/Proxy.cs b/src/NetMQ/Proxy.cs
@@ -114,8 +114,8 @@ public void Stop()
             m_state = StateStopped;
         }
 
-        private void OnFrontendReady(object sender, NetMQSocketEventArgs e) => ProxyBetween(m_frontend, m_backend, m_controlIn);
-        private void OnBackendReady (object sender, NetMQSocketEventArgs e) => ProxyBetween(m_backend, m_frontend, m_controlOut);
+        private void OnFrontendReady(object? sender, NetMQSocketEventArgs e) => ProxyBetween(m_frontend, m_backend, m_controlIn);
+        private void OnBackendReady (object? sender, NetMQSocketEventArgs e) => ProxyBetween(m_backend, m_frontend, m_controlOut);
 
         private static void ProxyBetween(IReceivingSocket from, IOutgoingSocket to, IOutgoingSocket? control)
         {

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ public void ReceiveReadyDot35Bug()`
`44`	`44`	`using (var server = new RouterSocket())`
`45`	`45`	`{`
`46`	`46`	`server.BindRandomPort("tcp://127.0.0.1");`
`47`		`- server.ReceiveReady += (s, e) => Assert.True(false, "Should not receive");`
	`47`	`+ server.ReceiveReady += (s, e) => Assert.Fail( "Should not receive");`
`48`	`48`
`49`	`49`	`Assert.False(server.Poll(TimeSpan.FromMilliseconds(1500)));`
`50`	`50`	`}`
Original file line number	Diff line number	Diff line change
`@@ -91,7 +91,7 @@ public static async Task<NetMQMessage> ReceiveMultipartMessageAsync(`
`91`	`91`	`registration = cancellationToken.Register(PropagateCancel);`
`92`	`92`	`}`
`93`	`93`
`94`		`- void Listener(object sender, NetMQSocketEventArgs args)`
	`94`	`+ void Listener(object? sender, NetMQSocketEventArgs args)`
`95`	`95`	`{`
`96`	`96`	`if (socket.TryReceive(ref msg, TimeSpan.Zero))`
`97`	`97`	`{`
`@@ -174,7 +174,7 @@ void PropagateCancel()`
`174`	`174`	`registration = cancellationToken.Register(PropagateCancel);`
`175`	`175`	`}`
`176`	`176`
`177`		`- void Listener(object sender, NetMQSocketEventArgs args)`
	`177`	`+ void Listener(object? sender, NetMQSocketEventArgs args)`
`178`	`178`	`{`
`179`	`179`	`if (socket.TryReceive(ref msg, TimeSpan.Zero))`
`180`	`180`	`{`
`@@ -241,7 +241,7 @@ public static Task<bool> SkipFrameAsync(`
`241`	`241`	`registration = cancellationToken.Register(PropagateCancel);`
`242`	`242`	`}`
`243`	`243`
`244`		`- void Listener(object sender, NetMQSocketEventArgs args)`
	`244`	`+ void Listener(object? sender, NetMQSocketEventArgs args)`
`245`	`245`	`{`
`246`	`246`	`if (socket.TryReceive(ref msg, TimeSpan.Zero))`
`247`	`247`	`{`
Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ public Address(EndPoint endpoint)`
`104`	`104`	`}`
`105`	`105`
`106`	`106`	`Debug.Assert(endpoint != null);`
`107`		`- AddressString = endpoint.ToString()!;`
	`107`	`+ AddressString = endpoint!.ToString()!;`
`108`	`108`	`}`
`109`	`109`
`110`	`110`
Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,7 @@ protected override void XTerminated(Pipe pipe)`
`214`	`214`	`{`
`215`	`215`	`Assumes.NotNull(pipe.Identity);`
`216`	`216`
`217`		`- m_outpipes.TryGetValue(pipe.Identity, out Outpipe old);`
	`217`	`+ m_outpipes.TryGetValue(pipe.Identity, out Outpipe? old);`
`218`	`218`	`m_outpipes.Remove(pipe.Identity);`
`219`	`219`
`220`	`220`	`Debug.Assert(old != null);`
`@@ -290,7 +290,7 @@ protected override bool XSend(ref Msg msg)`
`290`	`290`	`// mandatory is set.`
`291`	`291`
`292`	`292`	`var identity = msg.UnsafeToArray();`
`293`		`- if (m_outpipes.TryGetValue(identity, out Outpipe op))`
	`293`	`+ if (m_outpipes.TryGetValue(identity, out Outpipe? op))`
`294`	`294`	`{`
`295`	`295`	`m_currentOut = op.Pipe;`
`296`	`296`	`if (!m_currentOut.CheckWrite())`
`@@ -556,7 +556,7 @@ private bool IdentifyPeer(Pipe pipe)`
`556`	`556`	`msg.Close();`
`557`	`557`
`558`	`558`
`559`		`- if (m_outpipes.TryGetValue(identity, out Outpipe existPipe))`
	`559`	`+ if (m_outpipes.TryGetValue(identity, out Outpipe? existPipe))`
`560`	`560`	`{`
`561`	`561`	`if (!m_handover)`
`562`	`562`	`{`
Original file line number	Diff line number	Diff line change
`@@ -143,7 +143,7 @@ protected override void XTerminated(Pipe pipe)`
`143`	`143`	`{`
`144`	`144`	`Assumes.NotNull(pipe.Identity);`
`145`	`145`
`146`		`- m_outpipes.TryGetValue(pipe.Identity, out Outpipe old);`
	`146`	`+ m_outpipes.TryGetValue(pipe.Identity, out Outpipe? old);`
`147`	`147`	`m_outpipes.Remove(pipe.Identity);`
`148`	`148`
`149`	`149`	`Debug.Assert(old != null);`
`@@ -206,7 +206,7 @@ protected override bool XSend(ref Msg msg)`
`206`	`206`	`// mandatory is set.`
`207`	`207`
`208`	`208`	`var identity = msg.UnsafeToArray();`
`209`		`- if (m_outpipes.TryGetValue(identity, out Outpipe op))`
	`209`	`+ if (m_outpipes.TryGetValue(identity, out Outpipe? op))`
`210`	`210`	`{`
`211`	`211`	`m_currentOut = op.Pipe;`
`212`	`212`	`if (!m_currentOut.CheckWrite())`
Original file line number	Diff line number	Diff line change
`@@ -929,7 +929,7 @@ public void TermEndpoint(string addr)`
`929`	`929`	`if (UnregisterEndpoint(addr, this))`
`930`	`930`	`return;`
`931`	`931`
`932`		`- if (!m_inprocs.TryGetValue(addr, out Pipe pipe))`
	`932`	`+ if (!m_inprocs.TryGetValue(addr, out Pipe? pipe))`
`933`	`933`	`throw new EndpointNotFoundException("Endpoint was not found and cannot be disconnected");`
`934`	`934`
`935`	`935`	`pipe.SendDisconnectMessage();`
`@@ -938,7 +938,7 @@ public void TermEndpoint(string addr)`
`938`	`938`	`}`
`939`	`939`	`else`
`940`	`940`	`{`
`941`		`- if (!m_endpoints.TryGetValue(addr, out Endpoint endpoint))`
	`941`	`+ if (!m_endpoints.TryGetValue(addr, out Endpoint? endpoint))`
`942`	`942`	`throw new EndpointNotFoundException("Endpoint was not found and cannot be disconnected");`
`943`	`943`
`944`	`944`	`endpoint.Pipe?.Terminate(false);`
Original file line number	Diff line number	Diff line change
`@@ -91,7 +91,7 @@ public void Resolve(string name, bool ip4Only)`
`91`	`91`	`}`
`92`	`92`	`}`
`93`	`93`
`94`		`- IPAddress ipAddress;`
	`94`	`+ IPAddress? ipAddress;`
`95`	`95`
`96`	`96`	`// Interpret * as Any.`
`97`	`97`	`if (addrStr == "*")`