Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
F
FUCoin
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Iterations
Wiki
Requirements
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Locked files
Deploy
Releases
Model registry
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
Repository analytics
Code review analytics
Issue analytics
Insights
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
DistributedSystems4Students
FUCoin
Merge requests
!5
Configuration system
Code
Review changes
Check out branch
Download
Patches
Plain diff
Merged
Configuration system
dev-group3
into
master
Overview
0
Commits
23
Changes
38
Merged
davbohn
requested to merge
dev-group3
into
master
8 years ago
Overview
0
Commits
23
Changes
38
Expand
State of the system as presented last week. Closes
#18 (closed)
0
0
Merge request reports
Compare
master
master (base)
and
latest version
latest version
c7efb949
23 commits,
8 years ago
38 files
+
1050
−
233
Side-by-side
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
Files
38
Search (e.g. *.vue) (Ctrl+P)
src/main/java/fucoin/actions/control/ActionAnnounceWalletCreation.java
0 → 100644
+
30
−
0
Options
package
fucoin.actions.control
;
import
akka.actor.ActorRef
;
import
akka.actor.UntypedActorContext
;
import
fucoin.actions.transaction.SuperVisorAction
;
import
fucoin.supervisor.SuperVisorImpl
;
/**
* Announce, that there will be some wallets spawned.
* Used by the configurator to wait, until all new wallets have their initial money.
* Send to supervisor.
*/
public
class
ActionAnnounceWalletCreation
extends
SuperVisorAction
{
public
int
numOfWallets
;
public
ActorRef
observer
;
public
ActionAnnounceWalletCreation
(
int
numOfWallets
,
ActorRef
observer
)
{
this
.
numOfWallets
=
numOfWallets
;
this
.
observer
=
observer
;
}
@Override
protected
void
onAction
(
ActorRef
sender
,
ActorRef
self
,
UntypedActorContext
context
,
SuperVisorImpl
abstractNode
)
{
System
.
out
.
println
(
"Waiting for wallet transactions"
);
abstractNode
.
setPendingBankCommits
(
abstractNode
.
getPendingBankCommits
()
+
numOfWallets
);
abstractNode
.
setBankCommitObserver
(
sender
);
}
}
Loading