Fixed: Removing pending items from Queue

pull/2/head
Mark McDowall 10 years ago
parent 43e4c16cbf
commit 5d41ebd322

@ -102,7 +102,7 @@ namespace NzbDrone.Core.Download.Pending
var queue = new Queue.Queue var queue = new Queue.Queue
{ {
Id = HashConverter.GetHashInt31(string.Format("pending-{0}-ep{1}", pendingRelease.Id, episode.Id)), Id = GetQueueId(pendingRelease, episode),
Series = pendingRelease.RemoteEpisode.Series, Series = pendingRelease.RemoteEpisode.Series,
Episode = episode, Episode = episode,
Quality = pendingRelease.RemoteEpisode.ParsedEpisodeInfo.Quality, Quality = pendingRelease.RemoteEpisode.ParsedEpisodeInfo.Quality,
@ -265,7 +265,12 @@ namespace NzbDrone.Core.Download.Pending
private int FindPendingReleaseId(int queueId) private int FindPendingReleaseId(int queueId)
{ {
return GetPendingReleases().First(p => p.RemoteEpisode.Episodes.Any(e => queueId == (e.Id ^ (p.Id << 16)))).Id; return GetPendingReleases().First(p => p.RemoteEpisode.Episodes.Any(e => queueId == GetQueueId(p, e))).Id;
}
private int GetQueueId(PendingRelease pendingRelease, Episode episode)
{
return HashConverter.GetHashInt31(String.Format("pending-{0}-ep{1}", pendingRelease.Id, episode.Id));
} }
public void Handle(SeriesDeletedEvent message) public void Handle(SeriesDeletedEvent message)

Loading…
Cancel
Save