Skip to content
Snippets Groups Projects
Commit e4f278e1 authored by Simon Könnecke's avatar Simon Könnecke
Browse files

supervisor track all transactions

parent ca838539
Branches
No related tags found
No related merge requests found
...@@ -42,6 +42,7 @@ public class ActionPrepareDistributedCommittedTransferAnswer extends Coordinator ...@@ -42,6 +42,7 @@ public class ActionPrepareDistributedCommittedTransferAnswer extends Coordinator
int newCount = request.addPositiveAnswer(sender); int newCount = request.addPositiveAnswer(sender);
if (newCount == superVisor.getKnownNeighbors().size()) { if (newCount == superVisor.getKnownNeighbors().size()) {
superVisor.getStatistics().addTransaction(amount);
ActionCommitDistributedCommittedTransfer acdct = new ActionCommitDistributedCommittedTransfer(source, target, amount, true, timestamp, id, request.getObserver()); ActionCommitDistributedCommittedTransfer acdct = new ActionCommitDistributedCommittedTransfer(source, target, amount, true, timestamp, id, request.getObserver());
superVisor.addTransactionLogMessageSuccess("Transfer of " + amount + " FUC from" + source.path().name() + " to " + target.path().name()); superVisor.addTransactionLogMessageSuccess("Transfer of " + amount + " FUC from" + source.path().name() + " to " + target.path().name());
for (ActorRef neighbor : request.getAnswers()) { for (ActorRef neighbor : request.getAnswers()) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment