Merge pull request #106 from nayato/pipeline

Syncing core channel pipeline elements up to date.

Author: nayato

src/DotNetty.Common/Concurrency/IPausableEventExecutor.cs

@@ -31,7 +31,7 @@ public class SingleThreadEventExecutor : AbstractScheduledEventExecutor
         volatile int executionState = ST_NOT_STARTED;
         readonly PreciseTimeSpan preciseBreakoutInterval;
         PreciseTimeSpan lastExecutionTime;
-        readonly ManualResetEventSlim emptyEvent = new ManualResetEventSlim();
+        readonly ManualResetEventSlim emptyEvent = new ManualResetEventSlim(false, 1);
         readonly TaskScheduler scheduler;
         readonly TaskCompletionSource terminationCompletionSource;
         PreciseTimeSpan gracefulShutdownStartTime;

src/DotNetty.Common/Concurrency/SingleThreadEventExecutor.cs

@@ -167,13 +167,13 @@
     <Compile Include="Internal\IQueue.cs" />
     <Compile Include="Internal\ConcurrentCircularArrayQueue.cs" />
     <Compile Include="Internal\MpscArrayQueue.cs" />
+    <Compile Include="Internal\OneTimeTask.cs" />
     <Compile Include="Internal\PlatformDependent.cs" />
     <Compile Include="Properties\Friends.cs" />
     <Compile Include="Concurrency\AbstractEventExecutor.cs" />
     <Compile Include="Concurrency\AbstractScheduledEventExecutor.cs" />
     <Compile Include="Concurrency\ExecutorTaskScheduler.cs" />
     <Compile Include="Concurrency\IEventExecutor.cs" />
-    <Compile Include="Concurrency\IPausableEventExecutor.cs" />
     <Compile Include="Concurrency\IRunnable.cs" />
     <Compile Include="Concurrency\IWrappedEventExecutor.cs" />
     <Compile Include="Concurrency\SingleThreadEventExecutor.cs" />

src/DotNetty.Common/DotNetty.Common.csproj

@@ -0,0 +1,21 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace DotNetty.Common.Internal
+{
+    using DotNetty.Common.Concurrency;
+    using DotNetty.Common.Utilities;
+
+    /// <summary>
+    ///     <see cref="IRunnable" /> which represent a one time task which may allow the <see cref="IEventExecutor" /> to
+    ///     reduce the amount of
+    ///     produced garbage when queue it for execution.
+    ///     <strong>It is important this will not be reused. After submitted it is not allowed to get submitted again!</strong>
+    /// </summary>
+    public abstract class OneTimeTask : MpscLinkedQueueNode<IRunnable>, IRunnable
+    {
+        public override IRunnable Value => this;
+
+        public abstract void Run();
+    }
+}

src/DotNetty.Common/Internal/OneTimeTask.cs

@@ -86,6 +86,9 @@ static ResourceLeakDetector()
         /// </summary>
         public static DetectionLevel Level { get; set; }
 
+        /// Returns <c>true</c> if resource leak detection is enabled.
+        public static bool Enabled => Level > DetectionLevel.Disabled;
+
         readonly ConcurrentDictionary<string, bool> reportedLeaks = new ConcurrentDictionary<string, bool>();
 
         readonly string resourceType;