Checkpoint submitted version

Author: 0x000001A4

BankServer/INSTRUCTIONS.md

@@ -0,0 +1,13 @@
+## How to run
+
+1 - Open the solution with Visual Studio (the solution is inside BoneyBank folder), and build it.  
+2 - Right click over PuppetMaster and start a new instance.
+All terminals (3 boney and 1 Bank) should be opened.
+
+## What was implemented
+
+- Any number of Boney servers running Paxos (default config files starts up 3 Boneys)
+- 1 Bank (must have processID of 4 in the config files since it was hardcoded for this delivery)
+- Periodic compareAndSwap requests sent from Bank to Boneys for each Timer Tick
+- Perfect Channels
+- Logger printing all messages (Proposers, Acceptors, Learners) for each Boney

BankServer/configuration_sample.txt

@@ -5,8 +5,8 @@ P 4 bank http://127.0.0.1:10008
 P 7 client
 P 8 client
 S 3
-T 12:10:15
+T 23:53:30
 D 5000 
-F 1 (1, F, NS) (2, N, NS) (3, N, NS) (4, N, NS)
+F 1 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS)
 F 2 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS)
 F 3 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS) 

BankServer/domain/SlotTimer.cs

@@ -18,8 +18,8 @@ public SlotTimer(IUpdatable updatable, uint slotDuration, string initialTime)
             DateTime dateTime = DateTime.ParseExact(initialTime, "HH:mm:ss",
                                         CultureInfo.InvariantCulture);
             var span = dateTime - DateTime.Now;
-            //if (span.TotalMilliseconds < 0) throw new Exception("The starting time in configuration file must be after the current time.");           DECOMENT WHEN NOT DEBUGGING!!!!!
-            _clock = new System.Timers.Timer() { Interval = 1/*span.TotalMilliseconds*/, AutoReset = false };
+            if (span.TotalMilliseconds < 0) throw new Exception("The starting time in configuration file must be after the current time.");  //         DECOMENT WHEN NOT DEBUGGING!!!!!
+            _clock = new System.Timers.Timer() { Interval = span.TotalMilliseconds, AutoReset = false };
             _updatable = updatable;
             _slotDuration = slotDuration;
         }

BoneyServer/configuration_sample.txt

@@ -5,8 +5,8 @@ P 4 bank http://127.0.0.1:10008
 P 7 client
 P 8 client
 S 3
-T 12:10:15
+T 23:53:30
 D 5000 
-F 1 (1, F, NS) (2, N, NS) (3, N, NS) (4, N, NS)
+F 1 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS)
 F 2 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS)
-F 3 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS)
+F 3 (1, N, NS) (2, N, NS) (3, N, NS) (4, N, NS) 

BoneyServer/domain/SlotTimer.cs

@@ -18,8 +18,8 @@ public SlotTimer(IUpdatable updatable, uint slotDuration, string initialTime)
             DateTime dateTime = DateTime.ParseExact(initialTime, "HH:mm:ss",
                                         CultureInfo.InvariantCulture);
             var span = dateTime - DateTime.Now;
-            //if (span.TotalMilliseconds < 0) throw new Exception("The starting time in configuration file must be after the current time.");           DECOMENT WHEN NOT DEBUGGING!!!!!
-            _clock = new System.Timers.Timer() { Interval = 1/*span.TotalMilliseconds*/, AutoReset = false };
+            if (span.TotalMilliseconds < 0) throw new Exception("The starting time in configuration file must be after the current time.");     //      DECOMENT WHEN NOT DEBUGGING!!!!!
+            _clock = new System.Timers.Timer() { Interval = span.TotalMilliseconds, AutoReset = false };
             _updatable = updatable;
             _slotDuration = slotDuration;
 

BoneyServer/domain/paxos/Paxos.cs

@@ -34,11 +34,10 @@ internal class Paxos : IMultiPaxos
         private uint? _leaderProcessID;                   // The process it suspects to be the leader
         private List<string> _boneyAdress;
 
-        public static uint Instance { get; set; }
+        private uint Instance { get; set; } = 0;
 
         public Paxos(uint sourceProcessID, uint numOfSlots, List<string> boneysAdress)
         {
-            Instance = 0;
             _numberOfBoneyServers = boneysAdress.Count();
             _sourceLeaderNumber = sourceProcessID;
             _sourceProcessID = sourceProcessID;
@@ -63,7 +62,6 @@ public Paxos(uint sourceProcessID, uint numOfSlots, List<string> boneysAdress)
 
         public void Start(PaxosValue value, string address, uint primary)
         {
-            Logger.LogDebug($"Antes do lock");
             lock (this)
             {
                 uint slot = value.Slot;
@@ -200,12 +198,18 @@ private bool iAmLeader() {
 
         private void createInstancesUpTo(uint instance)
         {
-            int currentSize = _paxosInstances.Count();
-            int instancesToAdd = (int)instance - currentSize + 1;
-            Instance += (uint)instancesToAdd;
-            for (int i = 0; i < instancesToAdd; i++)
+            lock(this)
             {
-                _paxosInstances.Add(new PaxosInstance());
+                int currentSize = _paxosInstances.Count();
+                int instancesToAdd = (int)instance - currentSize + 1;
+                if (instancesToAdd > 0)
+                {
+                    Instance += (uint)instancesToAdd;
+                    for (int i = 0; i < instancesToAdd; i++)
+                    {
+                        _paxosInstances.Add(new PaxosInstance());
+                    }
+                }
             }
         }
     }

INSTRUCTIONS.md

@@ -0,0 +1,13 @@
+## How to run
+
+1 - Open the solution with Visual Studio (the solution is inside BoneyBank folder), and build it.  
+2 - Right click over PuppetMaster and start a new instance.
+All terminals (3 boney and 1 Bank) should be opened.
+
+## What was implemented
+
+- Any number of Boney servers running Paxos (default config files starts up 3 Boneys)
+- 1 Bank (must have processID of 4 in the config files since it was hardcoded for this delivery)
+- Periodic compareAndSwap requests sent from Bank to Boneys for each Timer Tick
+- Logger printing all messages (Proposers, Acceptors, Learners) for each Boney
+- Perfect channels between BankServer and BoneyServers that assure that frozen process receive messages later and respond to senders

PuppetMaster/configuration_sample.txt

@@ -6,7 +6,7 @@ P 5 bank http://127.0.0.1:10008
 P 7 client
 P 8 client
 S 3
-T 12:10:15
+T 23:53:30
 D 5000 
 F 1 (1, N, NS) (2, F, S) (3, N, NS) (4, N, NS) (5, N, NS)
 F 2 (1, N, NS) (2, F, S) (3, N, NS) (4, F, NS) (5, N, NS)