cyberpresidentvanellope/tgstation-server
1
0
Fork 0
mirror of https://github.com/tgstation/tgstation-server.git synced 2026-08-25 22:17:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup a ValueTask message

Browse Source
This commit is contained in:
Jordan Dominion
2023-12-17 23:25:30 -05:00
parent cef33be32c
commit 3c7cf0360f
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Tgstation.Server.Host/Components/InstanceManager.cs
+6 -4
View File
@@ -353,7 +353,7 @@ namespace Tgstation.Server.Host.Components
await container.OnZeroReferences.WaitAsync(cancellationToken);
// we are the one responsible for cancelling his jobs
var tasks = new List<ValueTask<Models.Job>>();
ValueTask<Models.Job[]> groupedTask = default;
await databaseContextFactory.UseContext(
async db =>
{
@@ -363,11 +363,13 @@ namespace Tgstation.Server.Host.Components
.Where(x => x.Instance.Id == metadata.Id && !x.StoppedAt.HasValue)
.Select(x => new Models.Job(x.Id.Value))
.ToListAsync(cancellationToken);
foreach (var job in jobs)
tasks.Add(jobService.CancelJob(job, user, true, cancellationToken));
groupedTask = ValueTaskExtensions.WhenAll(
jobs.Select(job => jobService.CancelJob(job, user, true, cancellationToken)),
jobs.Count);
});
await ValueTaskExtensions.WhenAll(tasks);
await groupedTask;
}
catch
{