How to use Success class of Microsoft.Coyote.Actors.BugFinding.Tests package

Best Coyote code snippet using Microsoft.Coyote.Actors.BugFinding.Tests.Success

ChainReplicationTests.cs

Source:ChainReplicationTests.cs

...258                {259                    this.Target = target;260                }261            }262            internal class Success : Event263            {264            }265            internal class HeadChanged : Event266            {267            }268            internal class TailChanged : Event269            {270            }271            private class HeadFailed : Event272            {273            }274            private class TailFailed : Event275            {276            }277            private class ServerFailed : Event278            {279            }280            private class FixSuccessor : Event281            {282            }283            private class FixPredecessor : Event284            {285            }286            private class Local : Event287            {288            }289            private class Done : Event290            {291            }292            private List<ActorId> Servers;293            private List<ActorId> Clients;294            private ActorId FailureDetector;295            private ActorId Head;296            private ActorId Tail;297            private int FaultyNodeIndex;298            private int LastUpdateReceivedSucc;299            private int LastAckSent;300            [Start]301            [OnEntry(nameof(InitOnEntry))]302            [OnEventGotoState(typeof(Local), typeof(WaitForFailure))]303            private class Init : State304            {305            }306            private void InitOnEntry(Event e)307            {308                this.Servers = (e as SetupEvent).Servers;309                this.Clients = (e as SetupEvent).Clients;310                this.FailureDetector = this.CreateActor(311                    typeof(FailureDetector),312                    new FailureDetector.SetupEvent(this.Id, this.Servers));313                this.Head = this.Servers[0];314                this.Tail = this.Servers[this.Servers.Count - 1];315                this.RaiseEvent(new Local());316            }317            [OnEventGotoState(typeof(HeadFailed), typeof(CorrectHeadFailure))]318            [OnEventGotoState(typeof(TailFailed), typeof(CorrectTailFailure))]319            [OnEventGotoState(typeof(ServerFailed), typeof(CorrectServerFailure))]320            [OnEventDoAction(typeof(FailureDetector.FailureDetected), nameof(CheckWhichNodeFailed))]321            private class WaitForFailure : State322            {323            }324            private void CheckWhichNodeFailed(Event e)325            {326                this.Assert(this.Servers.Count > 1, "All nodes have failed.");327                var failedServer = (e as FailureDetector.FailureDetected).Server;328                if (this.Head.Equals(failedServer))329                {330                    this.RaiseEvent(new HeadFailed());331                }332                else if (this.Tail.Equals(failedServer))333                {334                    this.RaiseEvent(new TailFailed());335                }336                else337                {338                    for (int i = 0; i < this.Servers.Count - 1; i++)339                    {340                        if (this.Servers[i].Equals(failedServer))341                        {342                            this.FaultyNodeIndex = i;343                        }344                    }345                    this.RaiseEvent(new ServerFailed());346                }347            }348            [OnEntry(nameof(CorrectHeadFailureOnEntry))]349            [OnEventGotoState(typeof(Done), typeof(WaitForFailure), nameof(UpdateFailureDetector))]350            [OnEventDoAction(typeof(HeadChanged), nameof(UpdateClients))]351            private class CorrectHeadFailure : State352            {353            }354            private void CorrectHeadFailureOnEntry()355            {356                this.Servers.RemoveAt(0);357                this.Monitor<InvariantMonitor>(358                    new InvariantMonitor.UpdateServers(this.Servers));359                this.Monitor<ServerResponseSeqMonitor>(360                    new ServerResponseSeqMonitor.UpdateServers(this.Servers));361                this.Head = this.Servers[0];362                this.SendEvent(this.Head, new BecomeHead(this.Id));363            }364            private void UpdateClients()365            {366                for (int i = 0; i < this.Clients.Count; i++)367                {368                    this.SendEvent(this.Clients[i], new Client.UpdateHeadTail(this.Head, this.Tail));369                }370                this.RaiseEvent(new Done());371            }372            private void UpdateFailureDetector()373            {374                this.SendEvent(this.FailureDetector, new FailureDetector.FailureCorrected(this.Servers));375            }376            [OnEntry(nameof(CorrectTailFailureOnEntry))]377            [OnEventGotoState(typeof(Done), typeof(WaitForFailure), nameof(UpdateFailureDetector))]378            [OnEventDoAction(typeof(TailChanged), nameof(UpdateClients))]379            private class CorrectTailFailure : State380            {381            }382            private void CorrectTailFailureOnEntry()383            {384                this.Servers.RemoveAt(this.Servers.Count - 1);385                this.Monitor<InvariantMonitor>(386                    new InvariantMonitor.UpdateServers(this.Servers));387                this.Monitor<ServerResponseSeqMonitor>(388                    new ServerResponseSeqMonitor.UpdateServers(this.Servers));389                this.Tail = this.Servers[this.Servers.Count - 1];390                this.SendEvent(this.Tail, new BecomeTail(this.Id));391            }392            [OnEntry(nameof(CorrectServerFailureOnEntry))]393            [OnEventGotoState(typeof(Done), typeof(WaitForFailure), nameof(UpdateFailureDetector))]394            [OnEventDoAction(typeof(FixSuccessor), nameof(UpdateClients))]395            [OnEventDoAction(typeof(FixPredecessor), nameof(ProcessFixPredecessor))]396            [OnEventDoAction(typeof(ChainReplicationServer.NewSuccInfo), nameof(SetLastUpdate))]397            [OnEventDoAction(typeof(Success), nameof(ProcessSuccess))]398            private class CorrectServerFailure : State399            {400            }401            private void CorrectServerFailureOnEntry()402            {403                this.Servers.RemoveAt(this.FaultyNodeIndex);404                this.Monitor<InvariantMonitor>(405                    new InvariantMonitor.UpdateServers(this.Servers));406                this.Monitor<ServerResponseSeqMonitor>(407                    new ServerResponseSeqMonitor.UpdateServers(this.Servers));408                this.RaiseEvent(new FixSuccessor());409            }410            private void ProcessFixPredecessor()411            {412                this.SendEvent(this.Servers[this.FaultyNodeIndex - 1], new ChainReplicationServer.NewSuccessor(413                    this.Id, this.Servers[this.FaultyNodeIndex], this.LastAckSent, this.LastUpdateReceivedSucc));414            }415            private void SetLastUpdate(Event e)416            {417                this.LastUpdateReceivedSucc = (e as418                    ChainReplicationServer.NewSuccInfo).LastUpdateReceivedSucc;419                this.LastAckSent = (e as420                    ChainReplicationServer.NewSuccInfo).LastAckSent;421                this.RaiseEvent(new FixPredecessor());422            }423            private void ProcessSuccess() => this.RaiseEvent(new Done());424        }425        private class ChainReplicationServer : StateMachine426        {427            internal class SetupEvent : Event428            {429                public int Id;430                public bool IsHead;431                public bool IsTail;432                public SetupEvent(int id, bool isHead, bool isTail)433                    : base()434                {435                    this.Id = id;436                    this.IsHead = isHead;437                    this.IsTail = isTail;438                }439            }440            internal class PredSucc : Event441            {442                public ActorId Predecessor;443                public ActorId Successor;444                public PredSucc(ActorId pred, ActorId succ)445                    : base()446                {447                    this.Predecessor = pred;448                    this.Successor = succ;449                }450            }451            internal class ForwardUpdate : Event452            {453                public ActorId Predecessor;454                public int NextSeqId;455                public ActorId Client;456                public int Key;457                public int Value;458                public ForwardUpdate(ActorId pred, int nextSeqId, ActorId client, int key, int val)459                    : base()460                {461                    this.Predecessor = pred;462                    this.NextSeqId = nextSeqId;463                    this.Client = client;464                    this.Key = key;465                    this.Value = val;466                }467            }468            internal class BackwardAck : Event469            {470                public int NextSeqId;471                public BackwardAck(int nextSeqId)472                    : base()473                {474                    this.NextSeqId = nextSeqId;475                }476            }477            internal class NewPredecessor : Event478            {479                public ActorId Main;480                public ActorId Predecessor;481                public NewPredecessor(ActorId main, ActorId pred)482                    : base()483                {484                    this.Main = main;485                    this.Predecessor = pred;486                }487            }488            internal class NewSuccessor : Event489            {490                public ActorId Main;491                public ActorId Successor;492                public int LastUpdateReceivedSucc;493                public int LastAckSent;494                public NewSuccessor(ActorId main, ActorId succ,495                    int lastUpdateReceivedSucc, int lastAckSent)496                    : base()497                {498                    this.Main = main;499                    this.Successor = succ;500                    this.LastUpdateReceivedSucc = lastUpdateReceivedSucc;501                    this.LastAckSent = lastAckSent;502                }503            }504            internal class NewSuccInfo : Event505            {506                public int LastUpdateReceivedSucc;507                public int LastAckSent;508                public NewSuccInfo(int lastUpdateReceivedSucc, int lastAckSent)509                    : base()510                {511                    this.LastUpdateReceivedSucc = lastUpdateReceivedSucc;512                    this.LastAckSent = lastAckSent;513                }514            }515            internal class ResponseToQuery : Event516            {517                public int Value;518                public ResponseToQuery(int val)519                    : base()520                {521                    this.Value = val;522                }523            }524            internal class ResponseToUpdate : Event525            {526            }527            private class Local : Event528            {529            }530            private int ServerId;531            private bool IsHead;532            private bool IsTail;533            private ActorId Predecessor;534            private ActorId Successor;535            private Dictionary<int, int> KeyValueStore;536            private List<int> History;537            private List<SentLog> SentHistory;538            private int NextSeqId;539            [Start]540            [OnEntry(nameof(InitOnEntry))]541            [OnEventGotoState(typeof(Local), typeof(WaitForRequest))]542            [OnEventDoAction(typeof(PredSucc), nameof(SetupPredSucc))]543            [DeferEvents(typeof(Client.Update), typeof(Client.Query),544                typeof(BackwardAck), typeof(ForwardUpdate))]545            private class Init : State546            {547            }548            private void InitOnEntry(Event e)549            {550                this.ServerId = (e as SetupEvent).Id;551                this.IsHead = (e as SetupEvent).IsHead;552                this.IsTail = (e as SetupEvent).IsTail;553                this.KeyValueStore = new Dictionary<int, int>();554                this.History = new List<int>();555                this.SentHistory = new List<SentLog>();556                this.NextSeqId = 0;557            }558            private void SetupPredSucc(Event e)559            {560                this.Predecessor = (e as PredSucc).Predecessor;561                this.Successor = (e as PredSucc).Successor;562                this.RaiseEvent(new Local());563            }564            [OnEventGotoState(typeof(Client.Update), typeof(ProcessUpdate), nameof(ProcessUpdateAction))]565            [OnEventGotoState(typeof(ForwardUpdate), typeof(ProcessFwdUpdate))]566            [OnEventGotoState(typeof(BackwardAck), typeof(ProcessBckAck))]567            [OnEventDoAction(typeof(Client.Query), nameof(ProcessQueryAction))]568            [OnEventDoAction(typeof(NewPredecessor), nameof(UpdatePredecessor))]569            [OnEventDoAction(typeof(NewSuccessor), nameof(UpdateSuccessor))]570            [OnEventDoAction(typeof(ChainReplicationMaster.BecomeHead), nameof(ProcessBecomeHead))]571            [OnEventDoAction(typeof(ChainReplicationMaster.BecomeTail), nameof(ProcessBecomeTail))]572            [OnEventDoAction(typeof(FailureDetector.Ping), nameof(SendPong))]573            private class WaitForRequest : State574            {575            }576            private void ProcessUpdateAction()577            {578                this.NextSeqId++;579                this.Assert(this.IsHead, "Server {0} is not head", this.ServerId);580            }581            private void ProcessQueryAction(Event e)582            {583                var client = (e as Client.Query).Client;584                var key = (e as Client.Query).Key;585                this.Assert(this.IsTail, "Server {0} is not tail", this.Id);586                if (this.KeyValueStore.ContainsKey(key))587                {588                    this.Monitor<ServerResponseSeqMonitor>(new ServerResponseSeqMonitor.ResponseToQuery(589                        this.Id, key, this.KeyValueStore[key]));590                    this.SendEvent(client, new ResponseToQuery(this.KeyValueStore[key]));591                }592                else593                {594                    this.SendEvent(client, new ResponseToQuery(-1));595                }596            }597            private void ProcessBecomeHead(Event e)598            {599                this.IsHead = true;600                this.Predecessor = this.Id;601                var target = (e as ChainReplicationMaster.BecomeHead).Target;602                this.SendEvent(target, new ChainReplicationMaster.HeadChanged());603            }604            private void ProcessBecomeTail(Event e)605            {606                this.IsTail = true;607                this.Successor = this.Id;608                for (int i = 0; i < this.SentHistory.Count; i++)609                {610                    this.Monitor<ServerResponseSeqMonitor>(new ServerResponseSeqMonitor.ResponseToUpdate(611                        this.Id, this.SentHistory[i].Key, this.SentHistory[i].Value));612                    this.SendEvent(this.SentHistory[i].Client, new ResponseToUpdate());613                    this.SendEvent(this.Predecessor, new BackwardAck(this.SentHistory[i].NextSeqId));614                }615                var target = (e as ChainReplicationMaster.BecomeTail).Target;616                this.SendEvent(target, new ChainReplicationMaster.TailChanged());617            }618            private void SendPong(Event e)619            {620                var target = (e as FailureDetector.Ping).Target;621                this.SendEvent(target, new FailureDetector.Pong());622            }623            private void UpdatePredecessor(Event e)624            {625                var main = (e as NewPredecessor).Main;626                this.Predecessor = (e as NewPredecessor).Predecessor;627                if (this.History.Count > 0)628                {629                    if (this.SentHistory.Count > 0)630                    {631                        this.SendEvent(main, new NewSuccInfo(632                            this.History[this.History.Count - 1],633                            this.SentHistory[0].NextSeqId));634                    }635                    else636                    {637                        this.SendEvent(main, new NewSuccInfo(638                            this.History[this.History.Count - 1],639                            this.History[this.History.Count - 1]));640                    }641                }642            }643            private void UpdateSuccessor(Event e)644            {645                var main = (e as NewSuccessor).Main;646                this.Successor = (e as NewSuccessor).Successor;647                var lastUpdateReceivedSucc = (e as NewSuccessor).LastUpdateReceivedSucc;648                var lastAckSent = (e as NewSuccessor).LastAckSent;649                if (this.SentHistory.Count > 0)650                {651                    for (int i = 0; i < this.SentHistory.Count; i++)652                    {653                        if (this.SentHistory[i].NextSeqId > lastUpdateReceivedSucc)654                        {655                            this.SendEvent(this.Successor, new ForwardUpdate(this.Id, this.SentHistory[i].NextSeqId,656                                this.SentHistory[i].Client, this.SentHistory[i].Key, this.SentHistory[i].Value));657                        }658                    }659                    int tempIndex = -1;660                    for (int i = this.SentHistory.Count - 1; i >= 0; i--)661                    {662                        if (this.SentHistory[i].NextSeqId == lastAckSent)663                        {664                            tempIndex = i;665                        }666                    }667                    for (int i = 0; i < tempIndex; i++)668                    {669                        this.SendEvent(this.Predecessor, new BackwardAck(this.SentHistory[0].NextSeqId));670                        this.SentHistory.RemoveAt(0);671                    }672                }673                this.SendEvent(main, new ChainReplicationMaster.Success());674            }675            [OnEntry(nameof(ProcessUpdateOnEntry))]676            [OnEventGotoState(typeof(Local), typeof(WaitForRequest))]677            private class ProcessUpdate : State678            {679            }680            private void ProcessUpdateOnEntry(Event e)681            {682                var client = (e as Client.Update).Client;683                var key = (e as Client.Update).Key;684                var value = (e as Client.Update).Value;685                if (this.KeyValueStore.ContainsKey(key))686                {687                    this.KeyValueStore[key] = value;688                }689                else690                {691                    this.KeyValueStore.Add(key, value);692                }693                this.History.Add(this.NextSeqId);694                this.Monitor<InvariantMonitor>(695                    new InvariantMonitor.HistoryUpdate(this.Id, new List<int>(this.History)));696                this.SentHistory.Add(new SentLog(this.NextSeqId, client, key, value));697                this.Monitor<InvariantMonitor>(698                    new InvariantMonitor.SentUpdate(this.Id, new List<SentLog>(this.SentHistory)));699                this.SendEvent(this.Successor, new ForwardUpdate(this.Id, this.NextSeqId, client, key, value));700                this.RaiseEvent(new Local());701            }702            [OnEntry(nameof(ProcessFwdUpdateOnEntry))]703            [OnEventGotoState(typeof(Local), typeof(WaitForRequest))]704            private class ProcessFwdUpdate : State705            {706            }707            private void ProcessFwdUpdateOnEntry(Event e)708            {709                var pred = (e as ForwardUpdate).Predecessor;710                var nextSeqId = (e as ForwardUpdate).NextSeqId;711                var client = (e as ForwardUpdate).Client;712                var key = (e as ForwardUpdate).Key;713                var value = (e as ForwardUpdate).Value;714                if (pred.Equals(this.Predecessor))715                {716                    this.NextSeqId = nextSeqId;717                    if (this.KeyValueStore.ContainsKey(key))718                    {719                        this.KeyValueStore[key] = value;720                    }721                    else722                    {723                        this.KeyValueStore.Add(key, value);724                    }725                    if (!this.IsTail)726                    {727                        this.History.Add(nextSeqId);728                        this.Monitor<InvariantMonitor>(729                            new InvariantMonitor.HistoryUpdate(this.Id, new List<int>(this.History)));730                        this.SentHistory.Add(new SentLog(this.NextSeqId, client, key, value));731                        this.Monitor<InvariantMonitor>(732                            new InvariantMonitor.SentUpdate(this.Id, new List<SentLog>(this.SentHistory)));733                        this.SendEvent(this.Successor, new ForwardUpdate(this.Id, this.NextSeqId, client, key, value));734                    }735                    else736                    {737                        if (!this.IsHead)738                        {739                            this.History.Add(nextSeqId);740                        }741                        this.Monitor<ServerResponseSeqMonitor>(new ServerResponseSeqMonitor.ResponseToUpdate(742                            this.Id, key, value));743                        this.SendEvent(client, new ResponseToUpdate());744                        this.SendEvent(this.Predecessor, new BackwardAck(nextSeqId));745                    }746                }747                this.RaiseEvent(new Local());...

RaftTests.cs

Source:RaftTests.cs

...233            /// </summary>234            public class AppendEntriesResponse : Event235            {236                public int Term; // current Term, for leader to update itself237                public bool Success; // true if follower contained entry matching PrevLogIndex and PrevLogTerm238                public ActorId Server;239                public ActorId ReceiverEndpoint; // client240                public AppendEntriesResponse(int term, bool success, ActorId server, ActorId client)241                    : base()242                {243                    this.Term = term;244                    this.Success = success;245                    this.Server = server;246                    this.ReceiverEndpoint = client;247                }248            }249            // Events for transitioning a server between roles.250            private class BecomeFollower : Event251            {252            }253            private class BecomeCandidate : Event254            {255            }256            private class BecomeLeader : Event257            {258            }259            internal class ShutDown : Event260            {261            }262            /// <summary>263            /// The id of this server.264            /// </summary>265            private int ServerId;266            /// <summary>267            /// The cluster manager id.268            /// </summary>269            private ActorId ClusterManager;270            /// <summary>271            /// The servers.272            /// </summary>273            private ActorId[] Servers;274            /// <summary>275            /// Leader id.276            /// </summary>277            private ActorId LeaderId;278            /// <summary>279            /// The election timer of this server.280            /// </summary>281            private ActorId ElectionTimer;282            /// <summary>283            /// The periodic timer of this server.284            /// </summary>285            private ActorId PeriodicTimer;286            /// <summary>287            /// Latest term server has seen (initialized to 0 on288            /// first boot, increases monotonically).289            /// </summary>290            private int CurrentTerm;291            /// <summary>292            /// Candidate id that received vote in current term (or null if none).293            /// </summary>294            private ActorId VotedFor;295            /// <summary>296            /// Log entries.297            /// </summary>298            private List<Log> Logs;299            /// <summary>300            /// Index of highest log entry known to be committed (initialized301            /// to 0, increases monotonically).302            /// </summary>303            private int CommitIndex;304            /// <summary>305            /// Index of the highest log entry applied (initialized to 0, increases monotonically).306            /// </summary>307            private int LastApplied;308            /// <summary>309            /// For each server, index of the next log entry to send to that310            /// server (initialized to leader last log index + 1).311            /// </summary>312            private Dictionary<ActorId, int> NextIndex;313            /// <summary>314            /// For each server, index of highest log entry known to be replicated315            /// on server (initialized to 0, increases monotonically).316            /// </summary>317            private Dictionary<ActorId, int> MatchIndex;318            /// <summary>319            /// Number of received votes.320            /// </summary>321            private int VotesReceived;322            /// <summary>323            /// The latest client request.324            /// </summary>325            private Client.Request LastClientRequest;326            [Start]327            [OnEntry(nameof(EntryOnInit))]328            [OnEventDoAction(typeof(ConfigureEvent), nameof(SetupEvent))]329            [OnEventGotoState(typeof(BecomeFollower), typeof(Follower))]330            [DeferEvents(typeof(VoteRequest), typeof(AppendEntriesRequest))]331            private class Init : State332            {333            }334            private void EntryOnInit()335            {336                this.CurrentTerm = 0;337                this.LeaderId = null;338                this.VotedFor = null;339                this.Logs = new List<Log>();340                this.CommitIndex = 0;341                this.LastApplied = 0;342                this.NextIndex = new Dictionary<ActorId, int>();343                this.MatchIndex = new Dictionary<ActorId, int>();344            }345            private void SetupEvent(Event e)346            {347                this.ServerId = (e as ConfigureEvent).Id;348                this.Servers = (e as ConfigureEvent).Servers;349                this.ClusterManager = (e as ConfigureEvent).ClusterManager;350                this.ElectionTimer = this.CreateActor(typeof(ElectionTimer));351                this.SendEvent(this.ElectionTimer, new ElectionTimer.ConfigureEvent(this.Id));352                this.PeriodicTimer = this.CreateActor(typeof(PeriodicTimer));353                this.SendEvent(this.PeriodicTimer, new PeriodicTimer.ConfigureEvent(this.Id));354                this.RaiseEvent(new BecomeFollower());355            }356            [OnEntry(nameof(FollowerOnInit))]357            [OnEventDoAction(typeof(Client.Request), nameof(RedirectClientRequest))]358            [OnEventDoAction(typeof(VoteRequest), nameof(VoteAsFollower))]359            [OnEventDoAction(typeof(VoteResponse), nameof(RespondVoteAsFollower))]360            [OnEventDoAction(typeof(AppendEntriesRequest), nameof(AppendEntriesAsFollower))]361            [OnEventDoAction(typeof(AppendEntriesResponse), nameof(RespondAppendEntriesAsFollower))]362            [OnEventDoAction(typeof(ElectionTimer.Timeout), nameof(StartLeaderElection))]363            [OnEventDoAction(typeof(ShutDown), nameof(ShuttingDown))]364            [OnEventGotoState(typeof(BecomeFollower), typeof(Follower))]365            [OnEventGotoState(typeof(BecomeCandidate), typeof(Candidate))]366            [IgnoreEvents(typeof(PeriodicTimer.Timeout))]367            private class Follower : State368            {369            }370            private void FollowerOnInit()371            {372                this.LeaderId = null;373                this.VotesReceived = 0;374                this.SendEvent(this.ElectionTimer, new ElectionTimer.StartTimerEvent());375            }376            private void RedirectClientRequest(Event e)377            {378                if (this.LeaderId != null)379                {380                    this.SendEvent(this.LeaderId, e);381                }382                else383                {384                    this.SendEvent(this.ClusterManager, new ClusterManager.RedirectRequest(e));385                }386            }387            private void StartLeaderElection()388            {389                this.RaiseEvent(new BecomeCandidate());390            }391            private void VoteAsFollower(Event e)392            {393                var request = e as VoteRequest;394                if (request.Term > this.CurrentTerm)395                {396                    this.CurrentTerm = request.Term;397                    this.VotedFor = null;398                }399                this.Vote(e as VoteRequest);400            }401            private void RespondVoteAsFollower(Event e)402            {403                var request = e as VoteResponse;404                if (request.Term > this.CurrentTerm)405                {406                    this.CurrentTerm = request.Term;407                    this.VotedFor = null;408                }409            }410            private void AppendEntriesAsFollower(Event e)411            {412                var request = e as AppendEntriesRequest;413                if (request.Term > this.CurrentTerm)414                {415                    this.CurrentTerm = request.Term;416                    this.VotedFor = null;417                }418                this.AppendEntries(e as AppendEntriesRequest);419            }420            private void RespondAppendEntriesAsFollower(Event e)421            {422                var request = e as AppendEntriesResponse;423                if (request.Term > this.CurrentTerm)424                {425                    this.CurrentTerm = request.Term;426                    this.VotedFor = null;427                }428            }429            [OnEntry(nameof(CandidateOnInit))]430            [OnEventDoAction(typeof(Client.Request), nameof(RedirectClientRequest))]431            [OnEventDoAction(typeof(VoteRequest), nameof(VoteAsCandidate))]432            [OnEventDoAction(typeof(VoteResponse), nameof(RespondVoteAsCandidate))]433            [OnEventDoAction(typeof(AppendEntriesRequest), nameof(AppendEntriesAsCandidate))]434            [OnEventDoAction(typeof(AppendEntriesResponse), nameof(RespondAppendEntriesAsCandidate))]435            [OnEventDoAction(typeof(ElectionTimer.Timeout), nameof(StartLeaderElection))]436            [OnEventDoAction(typeof(PeriodicTimer.Timeout), nameof(BroadcastVoteRequests))]437            [OnEventDoAction(typeof(ShutDown), nameof(ShuttingDown))]438            [OnEventGotoState(typeof(BecomeLeader), typeof(Leader))]439            [OnEventGotoState(typeof(BecomeFollower), typeof(Follower))]440            [OnEventGotoState(typeof(BecomeCandidate), typeof(Candidate))]441            private class Candidate : State442            {443            }444            private void CandidateOnInit()445            {446                this.CurrentTerm++;447                this.VotedFor = this.Id;448                this.VotesReceived = 1;449                this.SendEvent(this.ElectionTimer, new ElectionTimer.StartTimerEvent());450                this.BroadcastVoteRequests();451            }452            private void BroadcastVoteRequests()453            {454                // BUG: duplicate votes from same follower455                this.SendEvent(this.PeriodicTimer, new PeriodicTimer.StartTimerEvent());456                for (int idx = 0; idx < this.Servers.Length; idx++)457                {458                    if (idx == this.ServerId)459                    {460                        continue;461                    }462                    var lastLogIndex = this.Logs.Count;463                    var lastLogTerm = this.GetLogTermForIndex(lastLogIndex);464                    this.SendEvent(this.Servers[idx], new VoteRequest(this.CurrentTerm, this.Id,465                        lastLogIndex, lastLogTerm));466                }467            }468            private void VoteAsCandidate(Event e)469            {470                var request = e as VoteRequest;471                if (request.Term > this.CurrentTerm)472                {473                    this.CurrentTerm = request.Term;474                    this.VotedFor = null;475                    this.Vote(e as VoteRequest);476                    this.RaiseEvent(new BecomeFollower());477                }478                else479                {480                    this.Vote(e as VoteRequest);481                }482            }483            private void RespondVoteAsCandidate(Event e)484            {485                var request = e as VoteResponse;486                if (request.Term > this.CurrentTerm)487                {488                    this.CurrentTerm = request.Term;489                    this.VotedFor = null;490                    this.RaiseEvent(new BecomeFollower());491                }492                else if (request.Term != this.CurrentTerm)493                {494                    return;495                }496                if (request.VoteGranted)497                {498                    this.VotesReceived++;499                    if (this.VotesReceived >= (this.Servers.Length / 2) + 1)500                    {501                        this.VotesReceived = 0;502                        this.RaiseEvent(new BecomeLeader());503                    }504                }505            }506            private void AppendEntriesAsCandidate(Event e)507            {508                var request = e as AppendEntriesRequest;509                if (request.Term > this.CurrentTerm)510                {511                    this.CurrentTerm = request.Term;512                    this.VotedFor = null;513                    this.AppendEntries(e as AppendEntriesRequest);514                    this.RaiseEvent(new BecomeFollower());515                }516                else517                {518                    this.AppendEntries(e as AppendEntriesRequest);519                }520            }521            private void RespondAppendEntriesAsCandidate(Event e)522            {523                var request = e as AppendEntriesResponse;524                if (request.Term > this.CurrentTerm)525                {526                    this.CurrentTerm = request.Term;527                    this.VotedFor = null;528                    this.RaiseEvent(new BecomeFollower());529                }530            }531            [OnEntry(nameof(LeaderOnInit))]532            [OnEventDoAction(typeof(Client.Request), nameof(ProcessClientRequest))]533            [OnEventDoAction(typeof(VoteRequest), nameof(VoteAsLeader))]534            [OnEventDoAction(typeof(VoteResponse), nameof(RespondVoteAsLeader))]535            [OnEventDoAction(typeof(AppendEntriesRequest), nameof(AppendEntriesAsLeader))]536            [OnEventDoAction(typeof(AppendEntriesResponse), nameof(RespondAppendEntriesAsLeader))]537            [OnEventDoAction(typeof(ShutDown), nameof(ShuttingDown))]538            [OnEventGotoState(typeof(BecomeFollower), typeof(Follower))]539            [IgnoreEvents(typeof(ElectionTimer.Timeout), typeof(PeriodicTimer.Timeout))]540            private class Leader : State541            {542            }543            private void LeaderOnInit()544            {545                this.Monitor<SafetyMonitor>(new SafetyMonitor.NotifyLeaderElected(this.CurrentTerm));546                this.SendEvent(this.ClusterManager, new ClusterManager.NotifyLeaderUpdate(this.Id, this.CurrentTerm));547                var logIndex = this.Logs.Count;548                var logTerm = this.GetLogTermForIndex(logIndex);549                this.NextIndex.Clear();550                this.MatchIndex.Clear();551                for (int idx = 0; idx < this.Servers.Length; idx++)552                {553                    if (idx == this.ServerId)554                    {555                        continue;556                    }557                    this.NextIndex.Add(this.Servers[idx], logIndex + 1);558                    this.MatchIndex.Add(this.Servers[idx], 0);559                }560                for (int idx = 0; idx < this.Servers.Length; idx++)561                {562                    if (idx == this.ServerId)563                    {564                        continue;565                    }566                    this.SendEvent(this.Servers[idx], new AppendEntriesRequest(this.CurrentTerm, this.Id,567                        logIndex, logTerm, new List<Log>(), this.CommitIndex, null));568                }569            }570            private void ProcessClientRequest(Event e)571            {572                this.LastClientRequest = e as Client.Request;573                var log = new Log(this.CurrentTerm, this.LastClientRequest.Command);574                this.Logs.Add(log);575                this.BroadcastLastClientRequest();576            }577            private void BroadcastLastClientRequest()578            {579                var lastLogIndex = this.Logs.Count;580                this.VotesReceived = 1;581                for (int idx = 0; idx < this.Servers.Length; idx++)582                {583                    if (idx == this.ServerId)584                    {585                        continue;586                    }587                    var server = this.Servers[idx];588                    if (lastLogIndex < this.NextIndex[server])589                    {590                        continue;591                    }592                    var logs = this.Logs.GetRange(this.NextIndex[server] - 1, this.Logs.Count - (this.NextIndex[server] - 1));593                    var prevLogIndex = this.NextIndex[server] - 1;594                    var prevLogTerm = this.GetLogTermForIndex(prevLogIndex);595                    this.SendEvent(server, new AppendEntriesRequest(this.CurrentTerm, this.Id, prevLogIndex,596                        prevLogTerm, logs, this.CommitIndex, this.LastClientRequest.Client));597                }598            }599            private void VoteAsLeader(Event e)600            {601                var request = e as VoteRequest;602                if (request.Term > this.CurrentTerm)603                {604                    this.CurrentTerm = request.Term;605                    this.VotedFor = null;606                    this.RedirectLastClientRequestToClusterManager();607                    this.Vote(e as VoteRequest);608                    this.RaiseEvent(new BecomeFollower());609                }610                else611                {612                    this.Vote(e as VoteRequest);613                }614            }615            private void RespondVoteAsLeader(Event e)616            {617                var request = e as VoteResponse;618                if (request.Term > this.CurrentTerm)619                {620                    this.CurrentTerm = request.Term;621                    this.VotedFor = null;622                    this.RedirectLastClientRequestToClusterManager();623                    this.RaiseEvent(new BecomeFollower());624                }625            }626            private void AppendEntriesAsLeader(Event e)627            {628                var request = e as AppendEntriesRequest;629                if (request.Term > this.CurrentTerm)630                {631                    this.CurrentTerm = request.Term;632                    this.VotedFor = null;633                    this.RedirectLastClientRequestToClusterManager();634                    this.AppendEntries(e as AppendEntriesRequest);635                    this.RaiseEvent(new BecomeFollower());636                }637            }638            private void RespondAppendEntriesAsLeader(Event e)639            {640                var request = e as AppendEntriesResponse;641                if (request.Term > this.CurrentTerm)642                {643                    this.CurrentTerm = request.Term;644                    this.VotedFor = null;645                    this.RedirectLastClientRequestToClusterManager();646                    this.RaiseEvent(new BecomeFollower());647                }648                else if (request.Term != this.CurrentTerm)649                {650                    return;651                }652                if (request.Success)653                {654                    this.NextIndex[request.Server] = this.Logs.Count + 1;655                    this.MatchIndex[request.Server] = this.Logs.Count;656                    this.VotesReceived++;657                    if (request.ReceiverEndpoint != null &&658                        this.VotesReceived >= (this.Servers.Length / 2) + 1)659                    {660                        var commitIndex = this.MatchIndex[request.Server];661                        if (commitIndex > this.CommitIndex &&662                            this.Logs[commitIndex - 1].Term == this.CurrentTerm)663                        {664                            this.CommitIndex = commitIndex;665                        }666                        this.VotesReceived = 0;...

TwoActorIntegrationTests.cs

Source:TwoActorIntegrationTests.cs

...32            {33                this.Id = id;34            }35        }36        private class SuccessE : Event37        {38        }39        private class IgnoredE : Event40        {41        }42        private class M1a : StateMachine43        {44            private bool Test = false;45            private ActorId TargetId;46            [Start]47            [OnEntry(nameof(InitOnEntry))]48            [OnExit(nameof(InitOnExit))]49            [OnEventGotoState(typeof(DefaultEvent), typeof(S1))]50            [OnEventDoAction(typeof(E1), nameof(Action1))]51            private class Init : State52            {53            }54            private void InitOnEntry()55            {56                this.TargetId = this.CreateActor(typeof(M1b));57                this.RaiseEvent(new E1());58            }59            private void InitOnExit()60            {61                this.SendEvent(this.TargetId, new E3(this.Test), options: new SendOptions(assert: 1));62            }63            private class S1 : State64            {65            }66            private void Action1()67            {68                this.Test = true;69            }70        }71        [OnEventDoAction(typeof(E3), nameof(EntryAction))]72        private class M1b : Actor73        {74            private void EntryAction(Event e)75            {76                if (e.GetType() == typeof(E3))77                {78                    this.Action2(e);79                }80            }81            private void Action2(Event e)82            {83                this.Assert((e as E3).Value is false, "Reached test assertion.");84            }85        }86        [Fact(Timeout = 5000)]87        public void TestTwoActorIntegration1()88        {89            this.TestWithError(r =>90            {91                r.CreateActor(typeof(M1a));92            },93            configuration: this.GetConfiguration().WithTestingIterations(100),94            expectedError: "Reached test assertion.",95            replay: true);96        }97        private class M2a : StateMachine98        {99            private ActorId TargetId;100            private int Count;101            [Start]102            [OnEntry(nameof(InitOnEntry))]103            [OnEventGotoState(typeof(SuccessE), typeof(Active))]104            private class Init : State105            {106            }107            private void InitOnEntry()108            {109                this.TargetId = this.CreateActor(typeof(M2b));110                this.RaiseEvent(new SuccessE());111            }112            [OnEntry(nameof(ActiveOnEntry))]113            [OnEventGotoState(typeof(SuccessE), typeof(WaitEvent))]114            private class Active : State115            {116            }117            private void ActiveOnEntry()118            {119                this.Count += 1;120                if (this.Count is 1)121                {122                    this.SendEvent(this.TargetId, new E4(this.Id), options: new SendOptions(assert: 1));123                }124                if (this.Count is 2)125                {126                    this.SendEvent(this.TargetId, new IgnoredE());127                }128                this.RaiseEvent(new SuccessE());129            }130            [OnEventGotoState(typeof(E1), typeof(Active))]131            private class WaitEvent : State132            {133            }134            private class Done : State135            {136            }137        }138        private class M2b : StateMachine139        {140            [Start]141            [OnEventGotoState(typeof(E4), typeof(Active))]142            [OnEventDoAction(typeof(IgnoredE), nameof(Action1))]143            private class Waiting : State144            {145            }146            private void Action1()147            {148                this.Assert(false, "Reached test assertion.");149            }150            [OnEntry(nameof(ActiveOnEntry))]151            [OnEventGotoState(typeof(SuccessE), typeof(Waiting))]152            private class Active : State153            {154            }155            private void ActiveOnEntry(Event e)156            {157                this.SendEvent((e as E4).Id, new E1(), options: new SendOptions(assert: 1));158                this.RaiseEvent(new SuccessE());159            }160        }161        [Fact(Timeout = 5000)]162        public void TestTwoActorIntegration2()163        {164            this.TestWithError(r =>165            {166                r.CreateActor(typeof(M2a));167            },168            configuration: this.GetConfiguration().WithTestingIterations(100),169            expectedError: "Reached test assertion.",170            replay: true);171        }172        private class M3a : StateMachine173        {174            private ActorId TargetId;175            private int Count;176            [Start]177            [OnEntry(nameof(InitOnEntry))]178            [OnEventGotoState(typeof(SuccessE), typeof(Active))]179            private class Init : State180            {181            }182            private void InitOnEntry()183            {184                this.TargetId = this.CreateActor(typeof(M3b));185                this.RaiseEvent(new SuccessE());186            }187            [OnEntry(nameof(ActiveOnEntry))]188            [OnEventGotoState(typeof(SuccessE), typeof(WaitEvent))]189            private class Active : State190            {191            }192            private void ActiveOnEntry()193            {194                this.Count += 1;195                if (this.Count is 1)196                {197                    this.SendEvent(this.TargetId, new E4(this.Id), options: new SendOptions(assert: 1));198                }199                if (this.Count is 2)200                {201                    this.SendEvent(this.TargetId, HaltEvent.Instance);202                    this.SendEvent(this.TargetId, new IgnoredE());203                }204                this.RaiseEvent(new SuccessE());205            }206            [OnEventGotoState(typeof(E1), typeof(Active))]207            private class WaitEvent : State208            {209            }210            private class Done : State211            {212            }213        }214        private class M3b : StateMachine215        {216            [Start]217            [OnEventGotoState(typeof(E4), typeof(Active))]218            [OnEventGotoState(typeof(HaltEvent), typeof(Inactive))]219            private class Waiting : State220            {221            }222            [OnEntry(nameof(ActiveOnEntry))]223            [OnEventGotoState(typeof(SuccessE), typeof(Waiting))]224            private class Active : State225            {226            }227            private void ActiveOnEntry(Event e)228            {229                this.SendEvent((e as E4).Id, new E1(), options: new SendOptions(assert: 1));230                this.RaiseEvent(new SuccessE());231            }232            [OnEventDoAction(typeof(IgnoredE), nameof(Action1))]233            [IgnoreEvents(typeof(E4))]234            private class Inactive : State235            {236            }237            private void Action1()238            {239                this.Assert(false, "Reached test assertion.");240            }241        }242        [Fact(Timeout = 5000)]243        public void TestTwoActorIntegration3()244        {245            this.TestWithError(r =>246            {247                r.CreateActor(typeof(M3a));248            },249            configuration: this.GetConfiguration().WithTestingIterations(100),250            expectedError: "Reached test assertion.",251            replay: true);252        }253        private class M4a : StateMachine254        {255            private ActorId TargetId;256            [Start]257            [OnEntry(nameof(InitOnEntry))]258            [OnEventGotoState(typeof(SuccessE), typeof(Active))]259            private class Init : State260            {261            }262            private void InitOnEntry()263            {264                this.TargetId = this.CreateActor(typeof(M4b));265                this.RaiseEvent(new SuccessE());266            }267            [OnEntry(nameof(ActiveOnEntry))]268            [OnEventGotoState(typeof(SuccessE), typeof(Waiting))]269            private class Active : State270            {271            }272            private void ActiveOnEntry()273            {274                this.SendEvent(this.TargetId, new E4(this.Id), options: new SendOptions(assert: 1));275                this.RaiseEvent(new SuccessE());276            }277            [OnEventGotoState(typeof(E1), typeof(Active))]278            private class Waiting : State279            {280            }281        }282        private class M4b : StateMachine283        {284            private int Count = 0;285            [Start]286            [OnEventGotoState(typeof(E4), typeof(Active))]287            private class Waiting : State288            {289            }290            [OnEntry(nameof(ActiveOnEntry))]291            [OnEventGotoState(typeof(SuccessE), typeof(Waiting))]292            private class Active : State293            {294            }295            private void ActiveOnEntry(Event e)296            {297                this.Count++;298                if (this.Count is 1)299                {300                    this.SendEvent((e as E4).Id, new E1(), options: new SendOptions(assert: 1));301                }302                else if (this.Count is 2)303                {304                    this.SendEvent((e as E4).Id, new E1(), options: new SendOptions(assert: 1));305                    this.RaiseHaltEvent();306                    return;307                }308                this.RaiseEvent(new SuccessE());309            }310            protected override Task OnHaltAsync(Event e)311            {312                this.Assert(false, "Reached test assertion.");313                return Task.CompletedTask;314            }315        }316        [Fact(Timeout = 5000)]317        public void TestTwoActorIntegration4()318        {319            this.TestWithError(r =>320            {321                r.CreateActor(typeof(M4a));322            },...

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2using System;3using System.Threading.Tasks;4using Microsoft.Coyote;5using Microsoft.Coyote.Actors;6using Microsoft.Coyote.Actors.BugFinding;7using Microsoft.Coyote.Actors.BugFinding.Tasks;8using Microsoft.Coyote.Actors.BugFinding.Threading;9using Microsoft.Coyote.Actors.BugFinding.Timers;10using Microsoft.Coyote.Actors.BugFinding;11using Microsoft.Coyote.Specifications;12using Microsoft.Coyote.SystematicTesting;13using Microsoft.Coyote.Actors.BugFinding.Tests;14using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;15using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;16using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;17using Microsoft.Coyote.Actors.BugFinding.Tests;18using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;19using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;20using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;21using Microsoft.Coyote.Actors.BugFinding.Tests;22using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;23using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;24using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;25using Microsoft.Coyote.Actors.BugFinding.Tests;26using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;27using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;28using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;29using Microsoft.Coyote.Actors.BugFinding.Tests;30using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;31using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;32using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;33using Microsoft.Coyote.Actors.BugFinding.Tests;34using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;35using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;36using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;37using Microsoft.Coyote.Actors.BugFinding.Tests;38using Microsoft.Coyote.Actors.BugFinding.Tests.Tasks;39using Microsoft.Coyote.Actors.BugFinding.Tests.Threading;40using Microsoft.Coyote.Actors.BugFinding.Tests.Timers;41using Microsoft.Coyote.Actors.BugFinding.Tests;

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2using System;3using System.Collections.Generic;4using System.Linq;5using System.Text;6using System.Threading.Tasks;7{8    {9        static void Main(string[] args)10        {11            var actor = new Success();12            actor.Run();13        }14    }15}16using Microsoft.Coyote.Actors.BugFinding.Tests;17using System;18using System.Collections.Generic;19using System.Linq;20using System.Text;21using System.Threading.Tasks;22{23    {24        static void Main(string[] args)25        {26            var actor = new Success();27            actor.Run();28        }29    }30}31using Microsoft.Coyote.Actors.BugFinding.Tests;32using System;33using System.Collections.Generic;34using System.Linq;35using System.Text;36using System.Threading.Tasks;37{38    {39        static void Main(string[] args)40        {41            var actor = new Success();42            actor.Run();43        }44    }45}46using Microsoft.Coyote.Actors.BugFinding.Tests;47using System;48using System.Collections.Generic;49using System.Linq;50using System.Text;51using System.Threading.Tasks;52{53    {54        static void Main(string[] args)55        {56            var actor = new Success();57            actor.Run();58        }59    }60}

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2using Microsoft.Coyote.Actors;3using Microsoft.Coyote.Actors.BugFinding;4using Microsoft.Coyote.Specifications;5using System;6using System.Collections.Generic;7using System.Linq;8using System.Text;9using System.Threading.Tasks;10{11    {12        static void Main(string[] args)13        {14            var configuration = Configuration.Create();15            configuration.WithTestingIterations(100);16            configuration.WithRandomSchedulingSeed(0);17            configuration.WithMaxSchedulingSteps(1000);18            configuration.WithVerbosityEnabled(true);19            configuration.WithMaxFairSchedulingSteps(1000);20            configuration.WithMaxUnfairSchedulingSteps(1000);21            configuration.WithMaxStepsFromAnyEntryToExit(1000);22            configuration.WithMaxStepsFromAnyEntryToError(1000);23            configuration.WithMaxStepsFromAnyActionToExit(1000);24            configuration.WithMaxStepsFromAnyActionToError(1000);25            configuration.WithMaxStepsFromAnyChoiceToExit(1000);26            configuration.WithMaxStepsFromAnyChoiceToError(1000);27            configuration.WithMaxStepsFromAnyChoiceToAction(1000);28            configuration.WithMaxStepsFromAnyActionToChoice(1000);29            configuration.WithMaxStepsFromAnyEntryToChoice(1000);30            configuration.WithMaxStepsFromAnyChoiceToEntry(1000);31            configuration.WithMaxStepsFromAnyActionToEntry(1000);32            configuration.WithMaxStepsFromAnyEntryToAction(1000);33            configuration.WithMaxStepsFromAnyActionToAction(1000);34            configuration.WithMaxStepsFromAnyChoiceToChoice(1000);35            configuration.WithMaxStepsFromAnyEntryToEntry(1000);36            configuration.WithMaxStepsFromAnyErrorToExit(1000);37            configuration.WithMaxStepsFromAnyErrorToAction(1000);38            configuration.WithMaxStepsFromAnyErrorToChoice(1000);39            configuration.WithMaxStepsFromAnyErrorToEntry(1000);40            configuration.WithMaxStepsFromAnyErrorToError(1000);41            ActorRuntime runtime = ActorRuntime.Create(configuration);42            runtime.RegisterMonitor<Success>();43            runtime.CreateActor(typeof(MonitorActor));44        }45    }46    {47        protected override async Task OnInitializeAsync(Event initialEvent)48        {49            await this.CreateActorAsync(typeof(Actor1));50        }

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2{3    {4        public int Value { get; set; }5    }6}7using Microsoft.Coyote.Actors.BugFinding.Tests;8{9    {10        public int Value { get; set; }11    }12}13using Microsoft.Coyote.Actors.BugFinding.Tests;14{15    {16        public int Value { get; set; }17    }18}19using Microsoft.Coyote.Actors.BugFinding.Tests;20{21    {22        public int Value { get; set; }23    }24}25using Microsoft.Coyote.Actors.BugFinding.Tests;26{27    {28        public int Value { get; set; }29    }30}

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2using System;3{4    {5        static void Main(string[] args)6        {7            var success = new Success();8            success.Start();9        }10    }11}12using Microsoft.Coyote.Actors.BugFinding.Tests;13using System;14{15    {16        static void Main(string[] args)17        {18            var success = new Success();19            success.Start();20        }21    }22}

Success

Using AI Code Generation

1{2    {3        public int Value;4        public Success(int value) => Value = value;5    }6}7{8    {9        public int Value;10        public Success(int value) => Value = value;11    }12}13{14    {15        public int Value;16        public Success(int value) => Value = value;17    }18}19{20    {21        public int Value;22        public Success(int value) => Value = value;23    }24}25{26    {27        public int Value;28        public Success(int value) => Value = value;29    }30}31{32    {33        public int Value;34        public Success(int value) => Value = value;35    }36}37{38    {39        public int Value;40        public Success(int value) => Value = value;41    }42}43{44    {45        public int Value;

Success

Using AI Code Generation

1{2    {3        static void Main(string[] args)4        {5            var config = Configuration.Create().WithTestingIterations(100);6            var test = new Test(config);7            test.Run();8        }9    }10}11using Microsoft.Coyote.Actors;12using Microsoft.Coyote.Actors.BugFinding.Tests;13using Microsoft.Coyote.Specifications;14using System;15using System.Collections.Generic;16using System.Linq;17using System.Text;18using System.Threading.Tasks;19{20    {21        [OnEventDoAction(typeof(UnitEvent), nameof(Handle))]22        class Init : State { }23        void Handle()24        {25            this.RaiseEvent(new UnitEvent());26        }27    }28}29I'm using the latest version of Coyote (0.2.5) and I'm trying to run a simple test. I have 2 files: 1.cs and 2.cs. 1.cs creates a configuration and runs the test, 2.cs is the test itself. I'm running the test using the following command:

Success

Using AI Code Generation

1using Microsoft.Coyote.Actors.BugFinding.Tests;2using Microsoft.Coyote.Specifications;3using System;4using System.Threading.Tasks;5{6    {7        protected override Task OnInitializeAsync(Event initialEvent)8        {9            this.Assert(false, "Assert failed");10            return Task.CompletedTask;11        }12    }13}14using Microsoft.Coyote.Actors.BugFinding.Tests;15using Microsoft.Coyote.Specifications;16using System;17using System.Threading.Tasks;18{19    {20        protected override Task OnInitializeAsync(Event initialEvent)21        {22            this.Assert(this.RandomInteger() == 0, "Assert failed");23            return Task.CompletedTask;24        }25    }26}27using Microsoft.Coyote.Actors.BugFinding.Tests;28using Microsoft.Coyote.Specifications;29using System;30using System.Threading.Tasks;31{32    {33        protected override Task OnInitializeAsync(Event initialEvent)34        {35            this.Assert(this.RandomInteger() == this.RandomInteger(), "Assert failed");36            return Task.CompletedTask;37        }38    }39}40using Microsoft.Coyote.Actors.BugFinding.Tests;41using Microsoft.Coyote.Specifications;42using System;43using System.Threading.Tasks;44{45    {46        protected override Task OnInitializeAsync(Event initialEvent)47        {48            this.Assert(this.RandomInteger() == this.RandomInteger(), "Assert failed");49            return Task.CompletedTask;50        }51    }52}53using Microsoft.Coyote.Actors.BugFinding.Tests;54using Microsoft.Coyote.Specifications;55using System;56using System.Threading.Tasks;57{58    {59        protected override Task OnInitializeAsync(Event initialEvent)60        {61            this.Assert(this.RandomInteger() == this.RandomInteger(), "Assert failed");

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.