# HG changeset patch
# User cin
# Date 2017-10-05 06:21:23
# Node ID 8dd666e6b6bf2232c63e1ba3c282bd92c13d919b
# Parent  d6fe09f5592cac1081fc4a0235d72198e9a56238

Added implab nuget spec

diff --git a/Implab.Playground/Program.cs b/Implab.Playground/Program.cs
--- a/Implab.Playground/Program.cs
+++ b/Implab.Playground/Program.cs
@@ -49,7 +49,6 @@ namespace Implab.Playground {
             return actual != 0;
         }
 
-        /*
         static void EnqueueRange<T>(AsyncQueue<T> q, T[] data, int offset, int len) {
             for (var i = offset; i < offset + len; i++)
                 q.Enqueue(data[i]);
@@ -66,15 +65,15 @@ namespace Implab.Playground {
             }
             return actual != 0;
         }
-        */
+        
         
-        static void EnqueueRange<T>(AsyncQueue<T> q, T[] data, int offset, int len) {
+        /*static void EnqueueRange<T>(AsyncQueue<T> q, T[] data, int offset, int len) {
             q.EnqueueRange(data, offset, len);
         }
 
         static bool TryDequeueRange<T>(AsyncQueue<T> q, T[] buffer, int offset, int len, out int actual) {
             return q.TryDequeueRange(buffer, offset, len, out actual);
-        }
+        }*/
         
 
         static void Main(string[] args) {
diff --git a/Implab/Implab.csproj b/Implab/Implab.csproj
--- a/Implab/Implab.csproj
+++ b/Implab/Implab.csproj
@@ -67,6 +67,12 @@
     <WarningLevel>4</WarningLevel>
     <ConsolePause>false</ConsolePause>
   </PropertyGroup>
+  <PropertyGroup>
+    <SignAssembly>true</SignAssembly>
+  </PropertyGroup>
+  <PropertyGroup>
+    <AssemblyOriginatorKeyFile>implab.snk</AssemblyOriginatorKeyFile>
+  </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
     <Reference Include="System.Xml" />
@@ -207,7 +213,12 @@
     <Compile Include="Xml\XmlNameContext.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
-  <ItemGroup />
+  <ItemGroup>
+    <None Include="Implab.nuspec">
+      <SubType>Designer</SubType>
+    </None>
+    <None Include="implab.snk" />
+  </ItemGroup>
   <ProjectExtensions>
     <MonoDevelop>
       <Properties>
@@ -279,5 +290,7 @@
       </Properties>
     </MonoDevelop>
   </ProjectExtensions>
-  <ItemGroup />
+  <ItemGroup>
+    <Content Include="license.txt" />
+  </ItemGroup>
 </Project>
\ No newline at end of file
diff --git a/Implab/Implab.nuspec b/Implab/Implab.nuspec
new file mode 100644
--- /dev/null
+++ b/Implab/Implab.nuspec
@@ -0,0 +1,17 @@
+<?xml version="1.0"?>
+<package >
+  <metadata>
+    <id>Implab</id>
+    <version>$version$</version>
+    <title>$title$</title>
+    <authors>Implab team</authors>
+    <owners>Implab team</owners>
+    <projectUrl>https://implab.org/</projectUrl>
+    <!-- <iconUrl>http://ICON_URL_HERE_OR_DELETE_THIS_LINE</iconUrl> -->
+    <requireLicenseAcceptance>false</requireLicenseAcceptance>
+    <description>Common components for asynchronous applications, tracing, logging, json and xml traits.</description>
+    <releaseNotes>Added strong name.</releaseNotes>
+    <copyright>Copyright 2017</copyright>
+    <tags>async xml json</tags>
+  </metadata>
+</package>
\ No newline at end of file
diff --git a/Implab/Parallels/AsyncQueue.cs b/Implab/Parallels/AsyncQueue.cs
--- a/Implab/Parallels/AsyncQueue.cs
+++ b/Implab/Parallels/AsyncQueue.cs
@@ -3,6 +3,7 @@ using System.Collections.Generic;
 using System;
 using System.Collections;
 using System.Diagnostics;
+using System.Runtime.CompilerServices;
 
 namespace Implab.Parallels {
     public class AsyncQueue<T> : IEnumerable<T> {
@@ -51,6 +52,16 @@ namespace Implab.Parallels {
                 get { return m_size; }
             }
 
+            [MethodImpl(MethodImplOptions.AggressiveInlining)]
+            void AwaitWrites(int mark) {
+                if (m_hi != mark) {
+                    SpinWait spin = new SpinWait();
+                    do {
+                        spin.SpinOnce();
+                    } while (m_hi != mark);
+                }
+            }
+
             public bool TryEnqueue(T value) {
                 int alloc;
                 do {
@@ -61,12 +72,7 @@ namespace Implab.Parallels {
                 
                 m_data[alloc] = value;
 
-                SpinWait spin = new SpinWait();
-                // m_hi is volatile
-                while (alloc != m_hi) {
-                    // spin wait for commit
-                    spin.SpinOnce();
-                }
+                AwaitWrites(alloc);
                 m_hi = alloc + 1;
 
                 return true;
@@ -77,10 +83,7 @@ namespace Implab.Parallels {
             /// </summary>
             public void Seal() {
                 var actual = Math.Min(Interlocked.Exchange(ref m_alloc, m_size), m_size);
-                SpinWait spin = new SpinWait();
-                while (m_hi != actual) {
-                    spin.SpinOnce();
-                }
+                AwaitWrites(actual);
             }
 
             public bool TryDequeue(out T value, out bool recycle) {
@@ -114,11 +117,7 @@ namespace Implab.Parallels {
                 
                 Array.Copy(batch, offset, m_data, alloc, enqueued);
 
-                SpinWait spin = new SpinWait();
-                while (alloc != m_hi) {
-                    spin.SpinOnce();
-                }
-
+                AwaitWrites(alloc);
                 m_hi = alloc + enqueued;
                 return true;
             }
@@ -361,9 +360,7 @@ namespace Implab.Parallels {
         }
 
         public List<T> Drain() {
-            // start the new queue
-            var chunk = new Chunk(DEFAULT_CHUNK_SIZE);
-
+            Chunk chunk = null;
             do {
                 var first = m_first;
                 // first.next is volatile
@@ -374,6 +371,10 @@ namespace Implab.Parallels {
                         return new List<T>();
                 }
 
+                // start the new queue
+                if (chunk == null)
+                    chunk = new Chunk(DEFAULT_CHUNK_SIZE);
+
                 // here we will create inconsistency which will force others to spin
                 // and prevent from fetching. chunk.next = null
                 if (first != Interlocked.CompareExchange(ref m_first, chunk, first))
diff --git a/Implab/Properties/AssemblyInfo.cs b/Implab/Properties/AssemblyInfo.cs
--- a/Implab/Properties/AssemblyInfo.cs
+++ b/Implab/Properties/AssemblyInfo.cs
@@ -1,5 +1,4 @@
 using System.Reflection;
-using System.Runtime.CompilerServices;
 using System.Runtime.InteropServices;
 
 // Information about this assembly is defined by the following attributes. 
@@ -7,11 +6,9 @@ using System.Runtime.InteropServices;
 
 [assembly: AssemblyTitle("Implab")]
 [assembly: AssemblyDescription("Tools")]
-[assembly: AssemblyConfiguration("")]
-[assembly: AssemblyCompany("")]
-[assembly: AssemblyProduct("")]
+[assembly: AssemblyCompany("Implab.org")]
 [assembly: AssemblyCopyright("Implab")]
-[assembly: AssemblyTrademark("")]
+[assembly: AssemblyTrademark("Implab")]
 // The assembly version has the format "{Major}.{Minor}.{Build}.{Revision}".
 // The form "{Major}.{Minor}.*" will automatically update the build and revision,
 // and "{Major}.{Minor}.{Build}.*" will update just the revision.
diff --git a/Implab/implab.snk b/Implab/implab.snk
new file mode 100644
index e69de29bb2d1d6434b8b29ae775ad8c2e48c5391..2a97e5bd29ee66d5071da2075f5e6471e9418560
GIT binary patch
literal 596
zc$@)L0;~N80ssI2Bme+XQ$aES1ONa50097>8h#|4vJ)g><nsp-q2GV)JL8cY{)c0)
z{UFB!$sn0yR!UQ3u7z-KgVCgkEqI#DhhG-Ae(o3Z$@wkz2q)P_Zym~aG|D-q{Kr60
z9)VtMSKL?yR!b55<OfBd56NOo7*ta$|IB`s5OSw~HT%Yw;$OwgyPlt93s;leam&Er
z$jL3oCGh47Pns>rhZCkG@b$eW)d55JbM%cx|Eq*jW<ZaH(QbY!C-DaOY>%iTc*wDy
z=nX8^^ZeEm2Kw%Q(-NIcCe`?0SQp2vk2<2D59vJ#-^38)QA@>+9Kd>r=&+r|h(_-B
zT<3J#>{<F&j$y?X&ceTJ%L0*AKZnj?Vp1#g-L?XXfeR$=CEDt>@uc*l?`s~%-VX@7
z&)eD_@-zp-KxVqv5vC@m*d|_D@!Efr-e0UFc&t6G>#M2>k57u?tk*d#p*`{$8=CfB
zt5S9K_M1j@6Q+>r`r%C&v0edT;8{+5CERgD1P*K~sefevEZJshQkU5s{VtEo^mU!c
zE5_2Pa)Jlm##;S!2}-MPMBB+)APHoX;bziy9XYG1A1}2;e4XHG9wX@cJZ8M&wjtay
z&Vlfmgx+R>dG$!%t0!veEMORO*fm^1m@FO=PDV)El`Y?s9ZT)dGFoKWl@R`yz1E!?
zW-Nd|wE7&fCz5#c$EQO~%&&SXocLUC?cz1#H4%;ZfX|!<J|ZOo&p}%3G{bxR88b{M
isz3pFM;Iow*CYhl8Q)GaKy?zB@*n-wfxMtukavJNu_hw`

diff --git a/Implab/license.txt b/Implab/license.txt
new file mode 100644
--- /dev/null
+++ b/Implab/license.txt
@@ -0,0 +1,22 @@
+Copyright 2012 Sergey Smirnov
+
+Redistribution and use in source and binary forms, with or without 
+modification, are permitted provided that the following conditions are met:
+
+1. Redistributions of source code must retain the above copyright notice, this
+list of conditions and the following disclaimer.
+
+2. Redistributions in binary form must reproduce the above copyright notice, 
+this list of conditions and the following disclaimer in the documentation 
+and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
\ No newline at end of file