StochasticEvent.cs

using System;
using System.IO;
using System.Threading.Tasks;
using System.Xml;
using TAG.Simulator.ObjectModel.Distributions;
using Waher.Content.Xml;
using Waher.Script;
 
namespace TAG.Simulator.ObjectModel.Events
{
    public class StochasticEvent : Event, ITimeTriggerEvent
    {
        private string distributionId;
        private IDistribution distribution;
        private Expression guard;
        private int guardLimit;
 
        public StochasticEvent(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(StochasticEvent);
 
        public string DistributionId => this.distributionId;
 
        public override IDistribution Distribution => this.distribution;
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new StochasticEvent(Parent, Model);
        }
 
        public override Task FromXml(XmlElement Definition)
        {
            this.distributionId = XML.Attribute(Definition, "distribution");
            this.guardLimit = XML.Attribute(Definition, "guardLimit", 1000);
 
            if (Definition.HasAttribute("guard"))
                this.guard = new Expression(Definition.GetAttribute("guard"));
            else
                this.guard = null;
 
            return base.FromXml(Definition);
        }
 
        public override Task Initialize()
        {
            if (!this.Model.TryGetDistribution(this.distributionId, out this.distribution))
                throw new Exception("Distribution not found: " + this.distributionId);
 
            return base.Initialize();
        }
 
        public void CheckTrigger(double t1, double t2, int NrCycles)
        {
            int n = this.distribution.CheckTrigger(t1, t2, NrCycles);
            while (n > 0)
            {
                Task.Run(() => this.Trigger(this.Model.GetEventVariables(null), this.guard, this.guardLimit));
                n--;
            }
        }
 
        public override string UseCaseLinkName => this.distributionId;
 
        public override void ExportUseCaseData(StreamWriter Output, int Index)
        {
            base.ExportUseCaseData(Output, Index);
 
            if (!(this.guard is null))
            {
                Output.Write("note left of UC");
                Output.WriteLine(Index.ToString());
                Output.Write(this.distributionId);
                Output.WriteLine(" is subject to conditions defined by script");
                Output.WriteLine("end note");
            }
        }
 
    }
}