timothy/ersatztv
1
0
Fork 0
Code Issues 51 Pull Requests 5 Actions Packages Projects Releases 9 Wiki Activity

add worker service debug logs (#1267)

Browse Source 
* add worker service debug logs

* update mudblazor
This commit is contained in:
Jason Dove
2023-05-05 08:42:33 -05:00
committed by GitHub
parent b0333e89cd
commit e215807e56
3 changed files with 22 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ErsatzTV.Application/Streaming/HlsSessionWorker.cs
+1 -1
View File
@@ -54,7 +54,7 @@ public class HlsSessionWorker : IHlsSessionWorker
{ {
lock (_sync) lock (_sync)
{ {
_logger.LogDebug("Keep alive - session worker for channel {ChannelNumber}", _channelNumber); // _logger.LogDebug("Keep alive - session worker for channel {ChannelNumber}", _channelNumber);
_lastAccess = DateTimeOffset.Now; _lastAccess = DateTimeOffset.Now;
ErsatzTV/ErsatzTV.csproj
+1 -1
View File
@@ -72,7 +72,7 @@
<PrivateAssets>all</PrivateAssets> <PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets> <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference> </PackageReference>
<PackageReference Include="MudBlazor" Version="6.2.2" /> <PackageReference Include="MudBlazor" Version="6.2.3" />
<PackageReference Include="NaturalSort.Extension" Version="4.0.0" /> <PackageReference Include="NaturalSort.Extension" Version="4.0.0" />
<PackageReference Include="PPioli.FluentValidation.Blazor" Version="11.1.0" /> <PackageReference Include="PPioli.FluentValidation.Blazor" Version="11.1.0" />
<PackageReference Include="Refit.HttpClientFactory" Version="6.3.2" /> <PackageReference Include="Refit.HttpClientFactory" Version="6.3.2" />
ErsatzTV/Services/WorkerService.cs
+20
View File
@@ -49,12 +49,17 @@ public class WorkerService : BackgroundService
switch (request) switch (request)
{ {
case RefreshChannelList refreshChannelList: case RefreshChannelList refreshChannelList:
_logger.LogDebug("WorkerService - RefreshChannelList START");
await mediator.Send(refreshChannelList, cancellationToken); await mediator.Send(refreshChannelList, cancellationToken);
_logger.LogDebug("WorkerService - RefreshChannelList FINISH");
break; break;
case RefreshChannelData refreshChannelData: case RefreshChannelData refreshChannelData:
_logger.LogDebug("WorkerService - RefreshChannelData START");
await mediator.Send(refreshChannelData, cancellationToken); await mediator.Send(refreshChannelData, cancellationToken);
_logger.LogDebug("WorkerService - RefreshChannelData FINISH");
break; break;
case BuildPlayout buildPlayout: case BuildPlayout buildPlayout:
_logger.LogDebug("WorkerService - BuildPlayout START");
Either<BaseError, Unit> buildPlayoutResult = await mediator.Send( Either<BaseError, Unit> buildPlayoutResult = await mediator.Send(
buildPlayout, buildPlayout,
cancellationToken); cancellationToken);
@@ -64,27 +69,42 @@ public class WorkerService : BackgroundService
"Unable to build playout {PlayoutId}: {Error}", "Unable to build playout {PlayoutId}: {Error}",
buildPlayout.PlayoutId, buildPlayout.PlayoutId,
error.Value)); error.Value));
_logger.LogDebug("WorkerService - BuildPlayout FINISH");
break; break;
case DeleteOrphanedArtwork deleteOrphanedArtwork: case DeleteOrphanedArtwork deleteOrphanedArtwork:
_logger.LogDebug("WorkerService - DeleteOrphanedArtwork START");
await mediator.Send(deleteOrphanedArtwork, cancellationToken); await mediator.Send(deleteOrphanedArtwork, cancellationToken);
_logger.LogDebug("WorkerService - DeleteOrphanedArtwork FINISH");
break; break;
case DeleteOrphanedSubtitles deleteOrphanedSubtitles: case DeleteOrphanedSubtitles deleteOrphanedSubtitles:
_logger.LogDebug("WorkerService - DeleteOrphanedSubtitles START");
await mediator.Send(deleteOrphanedSubtitles, cancellationToken); await mediator.Send(deleteOrphanedSubtitles, cancellationToken);
_logger.LogDebug("WorkerService - DeleteOrphanedSubtitles FINISH");
break; break;
case AddTraktList addTraktList: case AddTraktList addTraktList:
_logger.LogDebug("WorkerService - AddTraktList START");
await mediator.Send(addTraktList, cancellationToken); await mediator.Send(addTraktList, cancellationToken);
_logger.LogDebug("WorkerService - AddTraktList FINISH");
break; break;
case DeleteTraktList deleteTraktList: case DeleteTraktList deleteTraktList:
_logger.LogDebug("WorkerService - DeleteTraktList START");
await mediator.Send(deleteTraktList, cancellationToken); await mediator.Send(deleteTraktList, cancellationToken);
_logger.LogDebug("WorkerService - DeleteTraktList FINISH");
break; break;
case MatchTraktListItems matchTraktListItems: case MatchTraktListItems matchTraktListItems:
_logger.LogDebug("WorkerService - MatchTraktListItems START");
await mediator.Send(matchTraktListItems, cancellationToken); await mediator.Send(matchTraktListItems, cancellationToken);
_logger.LogDebug("WorkerService - MatchTraktListItems FINISH");
break; break;
case ExtractEmbeddedSubtitles extractEmbeddedSubtitles: case ExtractEmbeddedSubtitles extractEmbeddedSubtitles:
_logger.LogDebug("WorkerService - ExtractEmbeddedSubtitles START");
await mediator.Send(extractEmbeddedSubtitles, cancellationToken); await mediator.Send(extractEmbeddedSubtitles, cancellationToken);
_logger.LogDebug("WorkerService - ExtractEmbeddedSubtitles FINISH");
break; break;
case ReleaseMemory aggressivelyReleaseMemory: case ReleaseMemory aggressivelyReleaseMemory:
_logger.LogDebug("WorkerService - ReleaseMemory START");
await mediator.Send(aggressivelyReleaseMemory, cancellationToken); await mediator.Send(aggressivelyReleaseMemory, cancellationToken);
_logger.LogDebug("WorkerService - ReleaseMemory FINISH");
break; break;
} }
} }