Nuget Update

Author: Christoph Bauer

src/NetMQ.Tests/NetMQ.Tests.csproj

@@ -43,7 +43,7 @@
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="System.Threading.Tasks.Extensions" Version="4.6.3" />
     <PackageReference Include="xunit" Version="2.9.3" />
-    <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2">
+    <PackageReference Include="xunit.runner.visualstudio" Version="3.1.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>

src/NetMQ/Core/Transports/Tcp/TcpListener.cs

@@ -45,12 +45,12 @@ internal class TcpListener : Own, IProactorEvents
         /// </summary>
         private AsyncSocket? m_handle;
 
-        /*
-                /// <summary>
-                /// socket being accepted
-                /// </summary>
-                private AsyncSocket m_acceptedSocket;
-        */
+/*
+        /// <summary>
+        /// socket being accepted
+        /// </summary>
+        private AsyncSocket m_acceptedSocket;
+*/
 
         /// <summary>
         /// Socket the listener belongs to.
@@ -107,7 +107,7 @@ protected override void ProcessPlug()
         protected override void ProcessTerm(int linger)
         {
             Assumes.NotNull(m_handle);
-
+           
             m_ioObject.SetHandler(this);
             m_ioObject.RemoveSocket(m_handle);
             Close();
@@ -123,7 +123,7 @@ public virtual void SetAddress(string addr)
             m_address.Resolve(addr, m_options.IPv4Only);
 
             Assumes.NotNull(m_address.Address);
-
+           
 
             try
             {
@@ -195,75 +195,74 @@ public void InCompleted(SocketError socketError, int bytesTransferred)
             switch (socketError)
             {
                 case SocketError.Success:
-                    {
-                        // TODO: check TcpFilters
-                        var acceptedSocket = m_handle.GetAcceptedSocket();
+                {
+                    // TODO: check TcpFilters
+                    var acceptedSocket = m_handle.GetAcceptedSocket();
 
                         acceptedSocket.NoDelay = true;
 
-                        if (m_options.TcpKeepalive != -1)
-                        {
-                            acceptedSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, m_options.TcpKeepalive);
+                    if (m_options.TcpKeepalive != -1)
+                    {
+                        acceptedSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, m_options.TcpKeepalive);
 
-                            if (m_options.TcpKeepaliveIdle != -1 && m_options.TcpKeepaliveIntvl != -1)
-                            {
-                                var bytes = new ByteArraySegment(new byte[12]);
+                        if (m_options.TcpKeepaliveIdle != -1 && m_options.TcpKeepaliveIntvl != -1)
+                        {
+                            var bytes = new ByteArraySegment(new byte[12]);
 
-                                Endianness endian = BitConverter.IsLittleEndian ? Endianness.Little : Endianness.Big;
+                            Endianness endian = BitConverter.IsLittleEndian ? Endianness.Little : Endianness.Big;
 
-                                bytes.PutInteger(endian, m_options.TcpKeepalive, 0);
-                                bytes.PutInteger(endian, m_options.TcpKeepaliveIdle, 4);
-                                bytes.PutInteger(endian, m_options.TcpKeepaliveIntvl, 8);
+                            bytes.PutInteger(endian, m_options.TcpKeepalive, 0);
+                            bytes.PutInteger(endian, m_options.TcpKeepaliveIdle, 4);
+                            bytes.PutInteger(endian, m_options.TcpKeepaliveIntvl, 8);
 #if NET
                                 if (!OperatingSystem.IsWindows())
                                 {
                                     throw new InvalidOperationException("Not supported on you platform"); // There is a pull request for .net8.0
 
                                 }
 #endif
-                                acceptedSocket.IOControl(IOControlCode.KeepAliveValues, (byte[])bytes, null);
-
-                            }
+                            acceptedSocket.IOControl(IOControlCode.KeepAliveValues, (byte[])bytes, null);
                         }
+                    }
 
-                        // Create the engine object for this connection.
-                        var engine = new StreamEngine(acceptedSocket, m_options, m_endpoint);
+                    // Create the engine object for this connection.
+                    var engine = new StreamEngine(acceptedSocket, m_options, m_endpoint);
 
-                        // Choose I/O thread to run connector in. Given that we are already
-                        // running in an I/O thread, there must be at least one available.
-                        IOThread? ioThread = ChooseIOThread(m_options.Affinity);
+                    // Choose I/O thread to run connector in. Given that we are already
+                    // running in an I/O thread, there must be at least one available.
+                    IOThread? ioThread = ChooseIOThread(m_options.Affinity);
 
-                        Assumes.NotNull(ioThread);
+                    Assumes.NotNull(ioThread);
 
-                        // Create and launch a session object.
-                        // TODO: send null in address parameter, is unneeded in this case
-                        SessionBase session = SessionBase.Create(ioThread, false, m_socket, m_options, new Address(m_handle.LocalEndPoint));
-                        session.IncSeqnum();
-                        LaunchChild(session);
+                    // Create and launch a session object.
+                    // TODO: send null in address parameter, is unneeded in this case
+                    SessionBase session = SessionBase.Create(ioThread, false, m_socket, m_options, new Address(m_handle.LocalEndPoint));
+                    session.IncSeqnum();
+                    LaunchChild(session);
 
-                        SendAttach(session, engine, false);
+                    SendAttach(session, engine, false);
 
-                        m_socket.EventAccepted(m_endpoint, acceptedSocket);
+                    m_socket.EventAccepted(m_endpoint, acceptedSocket);
 
-                        Accept();
-                        break;
-                    }
+                    Accept();
+                    break;
+                }
                 case SocketError.ConnectionReset:
                 case SocketError.NoBufferSpaceAvailable:
                 case SocketError.TooManyOpenSockets:
-                    {
-                        m_socket.EventAcceptFailed(m_endpoint, socketError.ToErrorCode());
+                {
+                    m_socket.EventAcceptFailed(m_endpoint, socketError.ToErrorCode());
 
-                        Accept();
-                        break;
-                    }
+                    Accept();
+                    break;
+                }
                 default:
-                    {
-                        NetMQException exception = NetMQException.Create(socketError);
+                {
+                    NetMQException exception = NetMQException.Create(socketError);
 
-                        m_socket.EventAcceptFailed(m_endpoint, exception.ErrorCode);
-                        throw exception;
-                    }
+                    m_socket.EventAcceptFailed(m_endpoint, exception.ErrorCode);
+                    throw exception;
+                }
             }
         }
 

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,7 +42,7 @@ 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)

src/NetMQ/NetMQPoller.cs

@@ -641,7 +641,7 @@ private void RunPoller()
 
 #if !NET35
                 // Try to dequeue and execute all pending tasks before stopping poller
-                while (m_tasksQueue.TryDequeue(out Task? task, TimeSpan.Zero) )
+                while (m_tasksQueue.TryDequeue(out Task? task, TimeSpan.Zero))
                     TryExecuteTask(task!);
 #endif
             }

src/NetMQ/NetMQQueue.cs

@@ -117,7 +117,6 @@ public bool TryDequeue(out T? result, TimeSpan timeout)
 
             m_queue.TryDequeue(out T? result);
 
-
             return result;
         }