Add locking to send

brian-dot-net · Nov 25, 2013 · be3abff · be3abff
1 parent ea52a9b
commit be3abff
Showing 1 changed file with 12 additions and 9 deletions.
diff --git a/projects/CommSample/source/CommSample.Core/MemoryChannel.cs b/projects/CommSample/source/CommSample.Core/MemoryChannel.cs
@@ -68,18 +68,21 @@ public Task<int> ReceiveAsync(byte[] buffer)
 
         public void Send(byte[] buffer)
         {
-            this.ThrowIfDisposed();
             int bytesReceived;
-            if (this.pendingReceive != null)
-            {
-                bytesReceived = this.pendingReceive.AddData(buffer);
-            }
-            else
+            lock (this.excessBuffers)
             {
-                bytesReceived = 0;
-            }
+                this.ThrowIfDisposed();
+                if (this.pendingReceive != null)
+                {
+                    bytesReceived = this.pendingReceive.AddData(buffer);
+                }
+                else
+                {
+                    bytesReceived = 0;
+                }
 
-            this.AddExcess(buffer, bytesReceived, false);
+                this.AddExcess(buffer, bytesReceived, false);
+            }
 
             if (bytesReceived > 0)
             {