Merge pull request #116 from Aaronontheweb/2.1.2-release-notes

added 2.1.2 release notes; reformatted

RELEASE_NOTES.md

@@ -1,3 +1,7 @@
+#### 2.1.2 Jul 14 2016
+* Made DNS resolution configurable - can target IPV4 / IPV6 or any other `AddressFamily`.
+* Caught `ObjectDisposedException`s that are thrown on shutdown so they are no longer logged.
+
 #### 2.1.1 May 27 2016
 * Fixed byte buffers - there were reporting that they were encoding as `LittleEndian`. Turns out they were using `BigEndian`. This has been fixed.
 * Fixed issue with `AbstractDerivedByteBuf` where calling `Retain` would return the original underlying buffer and not the derived buffer.

benchmark/Helios.Benchmark.DedicatedThreadFiber/Program.cs

@@ -85,5 +85,4 @@ private static void CreateAndWaitForWorkItems(int numWorkItems, int numThreads)
             }
         }
     }
-}
-
+}

benchmark/Helios.Benchmark.DedicatedThreadFiber/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

benchmark/Helios.Benchmark.SocketReliability/Program.cs

@@ -90,5 +90,4 @@ public void RunBenchmark()
             Console.WriteLine("Server Receives. Expected: {0} / Acutal: {1}", sends, ServerReceiveBuffer.Count);
         }
     }
-}
-
+}

benchmark/Helios.Benchmark.SocketReliability/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

benchmark/Helios.Benchmark.TCPThroughput/Program.cs

@@ -69,5 +69,4 @@ public void RunBenchmark(int messages)
             WaitUntilNMessagesReceived(sends, TimeSpan.FromMinutes(3)); //set a really long timeout, just in case
         }
     }
-}
-
+}

benchmark/Helios.Benchmark.TCPThroughput/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

benchmark/Helios.HorizontalScaling.Performance/Channels/ErrorCounterHandler.cs

@@ -26,5 +26,4 @@ public override void ExceptionCaught(IChannelHandlerContext context, Exception e
             _errorCount.Increment();
         }
     }
-}
-
+}

benchmark/Helios.HorizontalScaling.Performance/Channels/TcpServerSocketChannelHorizontalScaleSpec.cs

@@ -68,7 +68,7 @@ static TcpServerSocketChannelHorizontalScaleSpec()
         private static readonly TimeSpan SaturationThreshold = TimeSpan.FromSeconds(15);
 
         private IReadFinishedSignal _signal;
-        
+
         protected virtual IChannelHandler GetEncoder()
         {
             return new LengthFieldPrepender(4, false);
@@ -111,15 +111,15 @@ public void SetUp(BenchmarkContext context)
             ClientBootstrap = new ClientBootstrap().Group(ClientGroup)
                 .Option(ChannelOption.TcpNodelay, true)
                 .Channel<TcpSocketChannel>().Handler(new ActionChannelInitializer<TcpSocketChannel>(
-                channel =>
-                {
-                    channel.Pipeline.AddLast(GetEncoder())
-                    .AddLast(GetDecoder())
-                    .AddLast(new IntCodec(true))
-                    .AddLast(new CounterHandlerInbound(_inboundThroughputCounter))
-                    .AddLast(new CounterHandlerOutbound(_outboundThroughputCounter))
-                    .AddLast(new ErrorCounterHandler(_errorCounter));
-                }));
+                    channel =>
+                    {
+                        channel.Pipeline.AddLast(GetEncoder())
+                            .AddLast(GetDecoder())
+                            .AddLast(new IntCodec(true))
+                            .AddLast(new CounterHandlerInbound(_inboundThroughputCounter))
+                            .AddLast(new CounterHandlerOutbound(_outboundThroughputCounter))
+                            .AddLast(new ErrorCounterHandler(_errorCounter));
+                    }));
 
             var token = _shutdownBenchmark.Token;
             _eventLoop = () =>
@@ -151,12 +151,13 @@ public void SetUp(BenchmarkContext context)
 
             // connect to server with 1 client initially
             _clientChannels.Add(ClientBootstrap.ConnectAsync(_serverChannel.LocalAddress).Result);
-
         }
 
         private Action _eventLoop;
 
-        [PerfBenchmark(Description = "Measures how quickly and with how much GC overhead a TcpSocketChannel --> TcpServerSocketChannel connection can decode / encode realistic messages",
+        [PerfBenchmark(
+            Description =
+                "Measures how quickly and with how much GC overhead a TcpSocketChannel --> TcpServerSocketChannel connection can decode / encode realistic messages",
             NumberOfIterations = IterationCount, RunMode = RunMode.Iterations)]
         [CounterMeasurement(InboundThroughputCounterName)]
         [CounterMeasurement(OutboundThroughputCounterName)]
@@ -182,11 +183,14 @@ public void TcpServerSocketChannel_horizontal_scale_stress_test(BenchmarkContext
                 Thread.Sleep(SleepInterval);
                 if (++runCount%10 == 0)
                 {
-                    Console.WriteLine("{0} minutes remaining [{1} connections active].", (due - DateTime.Now).TotalMinutes, runCount);
+                    Console.WriteLine("{0} minutes remaining [{1} connections active].",
+                        (due - DateTime.Now).TotalMinutes, runCount);
                     var saturation = (DateTime.Now - lastMeasure);
                     if (saturation > SaturationThreshold)
                     {
-                        Console.WriteLine("Took {0} to create 10 connections; exceeded pre-defined saturation threshold of {1}. Ending stress test.", saturation, SaturationThreshold);
+                        Console.WriteLine(
+                            "Took {0} to create 10 connections; exceeded pre-defined saturation threshold of {1}. Ending stress test.",
+                            saturation, SaturationThreshold);
                         break;
                     }
                     lastMeasure = DateTime.Now;
@@ -207,13 +211,13 @@ public void TearDown()
             }
             Task.WaitAll(shutdownTasks.ToArray());
             CloseChannel(_serverChannel);
-            Task.WaitAll(ClientGroup.ShutdownGracefullyAsync(), ServerGroup.ShutdownGracefullyAsync(), WorkerGroup.ShutdownGracefullyAsync());
+            Task.WaitAll(ClientGroup.ShutdownGracefullyAsync(), ServerGroup.ShutdownGracefullyAsync(),
+                WorkerGroup.ShutdownGracefullyAsync());
         }
 
         private static void CloseChannel(IChannel cc)
         {
             cc?.CloseAsync().Wait();
         }
     }
-}
-
+}

benchmark/Helios.HorizontalScaling.Performance/Properties/AssemblyInfo.cs

@@ -9,6 +9,7 @@
 // General Information about an assembly is controlled through the following 
 // set of attributes. Change these attribute values to modify the information
 // associated with an assembly.
+
 [assembly: AssemblyTitle("Helios.HorizontalScaling.Performance")]
 [assembly: AssemblyDescription("")]
 [assembly: AssemblyConfiguration("")]
@@ -21,9 +22,11 @@
 // Setting ComVisible to false makes the types in this assembly not visible 
 // to COM components.  If you need to access a type in this assembly from 
 // COM, set the ComVisible attribute to true on that type.
+
 [assembly: ComVisible(false)]
 
 // The following GUID is for the ID of the typelib if this project is exposed to COM
+
 [assembly: Guid("96870699-c5a6-411a-856e-3e0f6bf6f9f9")]
 
 // Version information for an assembly consists of the following four values:
@@ -36,6 +39,6 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
 
+[assembly: AssemblyVersion("1.0.0.0")]
+[assembly: AssemblyFileVersion("1.0.0.0")]

benchmark/Helios.HorizontalScaling.Performance/packages.config

@@ -1,4 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
+
 <packages>
   <package id="NBench" version="0.3.0" targetFramework="net461" />
 </packages>

benchmark/Helios.Tests.Performance/Channels/CounterHandlerInbound.cs

@@ -22,5 +22,4 @@ public override void ChannelRead(IChannelHandlerContext context, object message)
             context.FireChannelRead(message);
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/CounterHandlerOutbound.cs

@@ -23,5 +23,4 @@ public override Task WriteAsync(IChannelHandlerContext context, object message)
             return context.WriteAsync(message);
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/EmbeddedChannelPerfSpecs.cs

@@ -93,5 +93,4 @@ public void CleanUp()
             channel = null;
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/IReadFinishedSignal.cs

@@ -56,5 +56,4 @@ public void Signal()
 
         public bool Finished { get; private set; }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/LocalChannelPerfSpecs.cs

@@ -152,5 +152,4 @@ private static void CloseChannel(IChannel cc)
             cc?.CloseAsync().Wait();
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/ReadFinishedHandler.cs

@@ -27,5 +27,4 @@ public override void ChannelRead(IChannelHandlerContext context, object message)
             context.FireChannelRead(message);
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/TcpChannelInboundOnlyPerfSpec.cs

@@ -143,5 +143,4 @@ private static void CloseChannel(IChannel cc)
             cc?.CloseAsync().Wait();
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Channels/TcpChannelPerfSpecs.cs

@@ -153,5 +153,4 @@ private static void CloseChannel(IChannel cc)
             cc?.CloseAsync().Wait();
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Collections/AllCollectionsSpec.cs

@@ -115,5 +115,4 @@ public void ConcurrentQueueWithResizing(BenchmarkContext context)
             }
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Concurrency/EventExecutorSpecs.cs

@@ -68,5 +68,4 @@ protected override IEventExecutor CreateExecutor()
             return new SingleThreadEventExecutor("Foo", TimeSpan.FromMilliseconds(100));
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Concurrency/FiberSpecs.cs

@@ -118,5 +118,4 @@ protected override IFiber CreateFiber()
             return FiberFactory.CreateFiber(FiberMode.Synchronous);
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

benchmark/Helios.Tests.Performance/Socket/SocketThroughputSpec.cs

@@ -68,5 +68,4 @@ public void PerfCleanup()
             CleanUp();
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Socket/TcpThroughputSpec.cs

@@ -13,5 +13,4 @@ public override TransportType TransportType
             get { return TransportType.Tcp; }
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/Socket/UdpThroughputSpec.cs

@@ -13,5 +13,4 @@ public override TransportType TransportType
             get { return TransportType.Tcp; }
         }
     }
-}
-
+}

benchmark/Helios.Tests.Performance/packages.config

@@ -1,4 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
+
 <packages>
   <package id="NBench" version="0.3.0" targetFramework="net45" />
 </packages>

samples/Helios.RawSocket/Program.cs

@@ -20,5 +20,4 @@ private static void Main()
             Application.Run(new SocketClient());
         }
     }
-}
-
+}

samples/Helios.RawSocket/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

samples/Helios.RawSocket/SocketClient.cs

@@ -131,5 +131,4 @@ private void ConnectionEstablishedCallback(INode remoteAddress, IConnection resp
 
         #endregion
     }
-}
-
+}

samples/Helios.RawUdpSocket/Program.cs

@@ -20,5 +20,4 @@ private static void Main()
             Application.Run(new SocketClient());
         }
     }
-}
-
+}

samples/Helios.RawUdpSocket/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

samples/Helios.RawUdpSocket/SocketClient.cs

@@ -124,5 +124,4 @@ private void btnSend_Click(object sender, EventArgs e)
             }
         }
     }
-}
-
+}

samples/Helios.Samples.TcpDownloadServer/Program.cs

@@ -10,5 +10,4 @@ private static void Main(string[] args)
         {
         }
     }
-}
-
+}

samples/Helios.Samples.TcpDownloadServer/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]

samples/Helios.Samples.TcpReactorServer/Program.cs

@@ -66,5 +66,4 @@ public static void ReceiveData(NetworkData data, IConnection connection)
             connection.Send(new NetworkData {Buffer = sendBytes, Length = sendBytes.Length, RemoteHost = node});
         }
     }
-}
-
+}

samples/Helios.Samples.TcpReactorServer/Properties/AssemblyInfo.cs

@@ -40,5 +40,4 @@
 // [assembly: AssemblyVersion("1.0.*")]
 
 [assembly: AssemblyVersion("1.0.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
-
+[assembly: AssemblyFileVersion("1.0.0.0")]