|
|
|
@ -1544,10 +1544,6 @@ namespace WebSocketSharp
|
|
|
|
internal void Send (Opcode opcode, Stream stream, Dictionary <CompressionMethod, Stream> cache)
|
|
|
|
internal void Send (Opcode opcode, Stream stream, Dictionary <CompressionMethod, Stream> cache)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
lock (_forSend) {
|
|
|
|
lock (_forSend) {
|
|
|
|
lock (_forConn) {
|
|
|
|
|
|
|
|
if (_readyState != WebSocketState.OPEN)
|
|
|
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
Stream cached;
|
|
|
|
Stream cached;
|
|
|
|
if (!cache.TryGetValue (_compression, out cached)) {
|
|
|
|
if (!cache.TryGetValue (_compression, out cached)) {
|
|
|
|
@ -1557,6 +1553,7 @@ namespace WebSocketSharp
|
|
|
|
else
|
|
|
|
else
|
|
|
|
cached.Position = 0;
|
|
|
|
cached.Position = 0;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (_readyState == WebSocketState.OPEN)
|
|
|
|
sendFragmented (opcode, cached, Mask.UNMASK, _compression != CompressionMethod.NONE);
|
|
|
|
sendFragmented (opcode, cached, Mask.UNMASK, _compression != CompressionMethod.NONE);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex) {
|
|
|
|
catch (Exception ex) {
|
|
|
|
@ -1565,7 +1562,6 @@ namespace WebSocketSharp
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#endregion
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
|