|
|
@ -198,6 +198,8 @@ namespace Emby.Server.Implementations.HttpServer
|
|
|
|
await SendKeepAliveResponse().ConfigureAwait(false);
|
|
|
|
await SendKeepAliveResponse().ConfigureAwait(false);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
else
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
try
|
|
|
|
{
|
|
|
|
{
|
|
|
|
await OnReceive(
|
|
|
|
await OnReceive(
|
|
|
|
new WebSocketMessageInfo
|
|
|
|
new WebSocketMessageInfo
|
|
|
@ -207,6 +209,11 @@ namespace Emby.Server.Implementations.HttpServer
|
|
|
|
Connection = this
|
|
|
|
Connection = this
|
|
|
|
}).ConfigureAwait(false);
|
|
|
|
}).ConfigureAwait(false);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
catch (Exception exception)
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
_logger.LogWarning(exception, "Failed to process WebSocket message");
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
internal InboundWebSocketMessage<object>? DeserializeWebSocketMessage(ReadOnlySequence<byte> bytes, out long bytesConsumed)
|
|
|
|
internal InboundWebSocketMessage<object>? DeserializeWebSocketMessage(ReadOnlySequence<byte> bytes, out long bytesConsumed)
|
|
|
|