aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Tango.Emulations
diff options
context:
space:
mode:
authorRoy Ben Shabat <Roy.mail.net@gmail.com>2020-11-05 19:33:06 +0200
committerRoy Ben Shabat <Roy.mail.net@gmail.com>2020-11-05 19:33:06 +0200
commitb9009a814b9c91010e44534b42fa15fe164757a3 (patch)
tree007aa60379f5a519ce3c3328887c8aec4951931f /Software/Visual_Studio/Tango.Emulations
parentee3f1aa159ebb326e7c7053501130afa06bf47d4 (diff)
downloadTango-b9009a814b9c91010e44534b42fa15fe164757a3.tar.gz
Tango-b9009a814b9c91010e44534b42fa15fe164757a3.zip
Completed ThreadBreak/Loading Wizards !!!
Diffstat (limited to 'Software/Visual_Studio/Tango.Emulations')
-rw-r--r--Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs17
1 files changed, 17 insertions, 0 deletions
diff --git a/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs b/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs
index 6b49ca4eb..1d420e33f 100644
--- a/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs
+++ b/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs
@@ -470,6 +470,9 @@ namespace Tango.Emulations.Emulators
case MessageType.StandByRequest:
HandleStandByRequest(MessageFactory.ParseTangoMessageFromContainer<StandByRequest>(container));
break;
+ case MessageType.AttemptThreadJoggingRequest:
+ HandleAttemptThreadJoggingRequest(MessageFactory.ParseTangoMessageFromContainer<AttemptThreadJoggingRequest>(container));
+ break;
}
}
@@ -1719,6 +1722,20 @@ namespace Tango.Emulations.Emulators
await Transporter.SendResponse(new StandByResponse(), request.Container.Token);
}
+ private async void HandleAttemptThreadJoggingRequest(TangoMessage<AttemptThreadJoggingRequest> request)
+ {
+ await Task.Delay(3000);
+
+ if (_rnd.Next(0, 100) > 50)
+ {
+ await Transporter.SendResponse(new AttemptThreadJoggingResponse(), request.Container.Token);
+ }
+ else
+ {
+ await Transporter.SendResponse(new AttemptThreadJoggingResponse(), request.Container.Token, new TransportResponseConfig() { ErrorCode = ErrorCode.GeneralError });
+ }
+ }
+
#endregion
#region Public Methods