Miscellany
public text v1 · immutable--- StreamStream.cs 2007-04-03 06:12:23.687950102 +0200
+++ StreamStream.cs.new 2007-03-31 02:52:04.355589853 +0200
@@ -212,15 +212,18 @@
if (bytesRead != 0)
{
writeComplete.WaitOne();
+
if (exception != null)
throw exception;
outStream.BeginWrite(buffer, 0, bytesRead, new AsyncCallback(Read_WriteComplete), buffer);
bytesLeft -= bytesRead;
+ Thread.Sleep(1);
}
else break;
}
writeComplete.WaitOne();
writeComplete.Set();
+ Thread.Sleep(1);
wStream = null;
return count - bytesLeft;
}
@@ -268,15 +271,19 @@
bf.Encipher (buffer, totalRead);
writeComplete.WaitOne();
+
if (exception != null)
throw exception;
outStream.BeginWrite(buffer, 0, totalRead, new AsyncCallback(Read_WriteComplete), buffer);
bytesLeft -= bytesRead;
+ Thread.Sleep(1);
}
else break;
}
writeComplete.WaitOne();
+
writeComplete.Set();
+ Thread.Sleep(1);
wStream = null;
return count - bytesLeft + paddingLength;
}
@@ -320,15 +327,19 @@
if (bytesRead != 0)
{
writeComplete.WaitOne();
+
if (exception != null)
throw exception;
stream.BeginWrite(buffer, 0, bytesRead, new AsyncCallback(Write_WriteComplete), buffer);
+ Thread.Sleep(1);
bytesLeft -= bytesRead;
}
else break;
}
writeComplete.WaitOne();
+
writeComplete.Set();
+ Thread.Sleep(1);
}
/// <summary>
@@ -372,9 +383,11 @@
bytesToWrite = bytesRead;
writeComplete.WaitOne();
+
if (exception != null)
throw exception;
stream.BeginWrite(buffer, 0, bytesToWrite, new AsyncCallback(Write_WriteComplete), buffer);
+ Thread.Sleep(1);
bytesLeft -= bytesRead;
}
else break;
@@ -382,6 +395,7 @@
writeComplete.WaitOne();
writeComplete.Set();
+ Thread.Sleep(1);
}
/// <summary>