[Modify] Retry the read if it returns zero
Experimental modification to avoid 'cannot be read from the stream'.
This commit is contained in:
parent
579f327597
commit
02be830741
@ -67,6 +67,7 @@ namespace WebSocketSharp
|
|||||||
#region Private Fields
|
#region Private Fields
|
||||||
|
|
||||||
private static readonly byte[] _last = new byte[] { 0x00 };
|
private static readonly byte[] _last = new byte[] { 0x00 };
|
||||||
|
private static readonly int _retry = 5;
|
||||||
private const string _tspecials = "()<>@,;:\\\"/[]?={} \t";
|
private const string _tspecials = "()<>@,;:\\\"/[]?={} \t";
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
@ -653,17 +654,24 @@ namespace WebSocketSharp
|
|||||||
{
|
{
|
||||||
var buff = new byte[length];
|
var buff = new byte[length];
|
||||||
var offset = 0;
|
var offset = 0;
|
||||||
|
var retry = 0;
|
||||||
|
|
||||||
AsyncCallback callback = null;
|
AsyncCallback callback = null;
|
||||||
callback = ar => {
|
callback = ar => {
|
||||||
try {
|
try {
|
||||||
var nread = stream.EndRead (ar);
|
var nread = stream.EndRead (ar);
|
||||||
if (nread == 0 || nread == length) {
|
if (nread == 0 && retry < _retry) {
|
||||||
|
retry++;
|
||||||
|
}
|
||||||
|
else if (nread == 0 || nread == length) {
|
||||||
if (completed != null)
|
if (completed != null)
|
||||||
completed (buff.SubArray (0, offset + nread));
|
completed (buff.SubArray (0, offset + nread));
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
else {
|
||||||
|
retry = 0;
|
||||||
|
}
|
||||||
|
|
||||||
offset += nread;
|
offset += nread;
|
||||||
length -= nread;
|
length -= nread;
|
||||||
|
Loading…
Reference in New Issue
Block a user