mirror of https://github.com/quasar/Quasar.git
Small fix
This commit is contained in:
parent
3bdd5aa294
commit
9aef2df7f7
|
@ -42,6 +42,7 @@ private void OnClientState(bool connected)
|
|||
ClientState(this, connected);
|
||||
}
|
||||
|
||||
if (connected && _parentServer.BufferManager.BuffersAvailable == 0)
|
||||
_parentServer.BufferManager.IncreaseBufferCount(1);
|
||||
|
||||
if (!connected && !_parentServer.Processing)
|
||||
|
@ -397,4 +398,4 @@ public void AddTypesToSerializer(Type parent, params Type[] types)
|
|||
AddTypeToSerializer(parent, type);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
|
@ -183,17 +183,6 @@ public bool ReturnBuffer(byte[] buffer)
|
|||
return true;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Frees all buffers.
|
||||
/// </summary>
|
||||
public void FreeAllBuffers()
|
||||
{
|
||||
while (_buffers.Count != 0)
|
||||
{
|
||||
DecreaseBufferCount(1);
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Increases the number of buffers available in the pool by a given size.
|
||||
/// </summary>
|
||||
|
|
|
@ -392,7 +392,6 @@ public void Disconnect()
|
|||
}
|
||||
}
|
||||
|
||||
BufferManager.FreeAllBuffers();
|
||||
Listening = false;
|
||||
OnServerState(false);
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue