phares3757/parsing-packets
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

IsCancellationRequested

Browse Source
This commit is contained in:
Mike Phares 2024-02-03 18:37:43 -07:00
parent 21ca438183
commit 84c5355dcf
2 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Helpers/HelperPhysicalAddress.cs
View File

@ -128,7 +128,7 @@ internal static class HelperPhysicalAddress
return keyValuePairs; return keyValuePairs;
} }
internal static bool ParsePackets(AppSettings appSettings, ILogger<Worker> logger) internal static bool ParsePackets(AppSettings appSettings, ILogger<Worker> logger, CancellationToken stoppingToken)
{ {
ILiveDevice? liveDevice = null; ILiveDevice? liveDevice = null;
Version version = Pcap.SharpPcapVersion; Version version = Pcap.SharpPcapVersion;
@ -162,7 +162,7 @@ internal static class HelperPhysicalAddress
logger.LogInformation(""); logger.LogInformation("");
liveDevice.Open(DeviceModes.Promiscuous, appSettings.PhysicalAddressConfiguration.ReadTimeoutMilliseconds); liveDevice.Open(DeviceModes.Promiscuous, appSettings.PhysicalAddressConfiguration.ReadTimeoutMilliseconds);
logger.LogInformation("-- Listening on {Name} {Description}", liveDevice.Name, liveDevice.Description); logger.LogInformation("-- Listening on {Name} {Description}", liveDevice.Name, liveDevice.Description);
while (true) while (!stoppingToken.IsCancellationRequested)
{ {
status = liveDevice.GetNextPacket(out PacketCapture e); status = liveDevice.GetNextPacket(out PacketCapture e);
if (status != GetPacketStatus.PacketRead) if (status != GetPacketStatus.PacketRead)

19
Worker.cs
View File

@ -22,24 +22,19 @@ public partial class Worker : BackgroundService
_IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime)); _IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime));
} }
private void Body()
{
_Logger.LogInformation("A) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
_ = _AppSettings.Helper switch
{
nameof(Helpers.HelperPhysicalAddress) => Helpers.HelperPhysicalAddress.ParsePackets(_AppSettings, _Logger),
_ => throw new NotSupportedException()
};
_Logger.LogInformation("B) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
}
private async Task Body(CancellationToken stoppingToken) private async Task Body(CancellationToken stoppingToken)
{ {
if (!_IsWindowsService) if (!_IsWindowsService)
throw new EvaluateException("Set break point and skip!"); throw new EvaluateException("Set break point and skip!");
while (_IsWindowsService && !stoppingToken.IsCancellationRequested) while (_IsWindowsService && !stoppingToken.IsCancellationRequested)
{ {
Body(); _Logger.LogInformation("A) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
_ = _AppSettings.Helper switch
{
nameof(Helpers.HelperPhysicalAddress) => Helpers.HelperPhysicalAddress.ParsePackets(_AppSettings, _Logger, stoppingToken),
_ => throw new NotSupportedException()
};
_Logger.LogInformation("B) Next execute will be at {date}", DateTime.Now.AddMilliseconds(_AppSettings.MillisecondsDelay).ToString("yyyy-MM-dd hh:mm:ss.fff tt"));
await Task.Delay(_AppSettings.MillisecondsDelay, stoppingToken); await Task.Delay(_AppSettings.MillisecondsDelay, stoppingToken);
} }
} }