mirror/Lidarr
1
0
Fork 0
mirror of https://github.com/lidarr/Lidarr synced 2025-01-03 05:25:10 +00:00
Code Issues Releases Wiki Activity

Fixed: Broken tasks getting stuck in queue

Browse source
This commit is contained in:
Mark McDowall 2020-03-05 17:57:11 -08:00 committed by Qstick
parent c8d8394347
commit b7aa945eae
1 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/NzbDrone.Core/Messaging/Commands/CommandExecutor.cs
View file

@ -65,13 +65,15 @@ private void ExecuteCommands()
private void ExecuteCommand<TCommand>(TCommand command, CommandModel commandModel)
where TCommand : Command
{
var handlerContract = typeof(IExecute<>).MakeGenericType(command.GetType());
var handler = (IExecute<TCommand>)_serviceFactory.Build(handlerContract);
_logger.Trace("{0} -> {1}", command.GetType().Name, handler.GetType().Name);
IExecute<TCommand> handler = null;
try
{
var handlerContract = typeof(IExecute<>).MakeGenericType(command.GetType());
handler = (IExecute<TCommand>)_serviceFactory.Build(handlerContract);
_logger.Trace("{0} -> {1}", command.GetType().Name, handler.GetType().Name);
_commandQueueManager.Start(commandModel);
BroadcastCommandUpdate(commandModel);
@ -106,9 +108,12 @@ private void ExecuteCommand<TCommand>(TCommand command, CommandModel commandMode
{
ProgressMessageContext.CommandModel = null;
}
}
_logger.Trace("{0} <- {1} [{2}]", command.GetType().Name, handler.GetType().Name, commandModel.Duration.ToString());
if (handler != null)
{
_logger.Trace("{0} <- {1} [{2}]", command.GetType().Name, handler.GetType().Name, commandModel.Duration.ToString());
}
}
}
private void BroadcastCommandUpdate(CommandModel command)