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

Improve responsiveness of current DreamMaker stage

Browse Source
This commit is contained in:
Dominion
2023-03-24 14:26:14 -04:00
parent 0942f08fda
commit 8f4ba0bcf3
1 changed files with 27 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Tgstation.Server.Host/Components/Deployment/DreamMaker.cs
+27 -5
View File
@@ -719,18 +719,40 @@ namespace Tgstation.Server.Host.Components.Deployment
{
var noEstimate = !estimatedDuration.HasValue;
progressReporter.StageName = currentStage;
progressReporter.ReportProgress(noEstimate ? null : 0);
double? lastReport = noEstimate ? null : 0;
progressReporter.ReportProgress(lastReport);
var sleepInterval = estimatedDuration.HasValue ? estimatedDuration.Value / 100 : TimeSpan.FromMilliseconds(250);
var minimumSleepInterval = TimeSpan.FromMilliseconds(250);
var sleepInterval = estimatedDuration.HasValue ? estimatedDuration.Value / 100 : minimumSleepInterval;
if (estimatedDuration.HasValue)
{
logger.LogDebug("Compile is expected to take: {0}", estimatedDuration);
}
else
{
logger.LogTrace("No metric to estimate compile time.");
}
logger.LogDebug("Compile is expected to take: {0}", estimatedDuration);
try
{
for (var iteration = 0; iteration < (estimatedDuration.HasValue ? 99 : Int32.MaxValue); ++iteration)
{
await Task.Delay(sleepInterval, cancellationToken);
var nextInterval = DateTimeOffset.Now + sleepInterval;
do
{
var remainingSleepThisInterval = nextInterval - DateTimeOffset.Now;
var nextSleepSpan = remainingSleepThisInterval < minimumSleepInterval ? remainingSleepThisInterval : minimumSleepInterval;
await Task.Delay(nextSleepSpan, cancellationToken);
progressReporter.StageName = currentStage;
progressReporter.ReportProgress(lastReport);
}
while (DateTimeOffset.Now < nextInterval);
progressReporter.StageName = currentStage;
progressReporter.ReportProgress(noEstimate ? null : sleepInterval * (iteration + 1) / estimatedDuration.Value);
lastReport = noEstimate ? null : sleepInterval * (iteration + 1) / estimatedDuration.Value;
progressReporter.ReportProgress(lastReport);
}
}
catch (OperationCanceledException)