mirror of
https://github.com/fluencelabs/aqua.git
synced 2025-03-16 04:00:50 +00:00
22778914ca
* Topology optimization for Folds * cache RawCursor's parent for better performance * Tests fixed * wip * wip * Use the new Topology to find paths * Compile bug fixed * Old tests works * One more fixed test * Move before seq next * One more fixed test * Bugfix * Disabled debug output * maybe fix? * maybe fix? * Topology wip * Maybe fix * Maybe fix * Fold optimization * Root topology * Respect forceExit in endsOn * better caching * better caching * Root afterOn = const * XorGroup endsOn should break * no EndsOn for Root * Maybe better? * Uncycling * Eval * Respect ParTag.Detach * Detach test * Detach test failing * Detach test fixed * Go to relay via relay * Fixes #380 * Increment Aqua version to 0.5.2 * Add image to transform readme, update dependencies * Review fixes * Updated Scala version in the release flow
23 lines
541 B
Plaintext
23 lines
541 B
Plaintext
service Kademlia("kad"):
|
|
neighborhood: string, ?bool, ?bool -> []string
|
|
|
|
service Peer("peer"):
|
|
timestamp_sec: -> ()
|
|
timeout: u32, string -> ()
|
|
|
|
func ack_peers() -> []string:
|
|
acked_peers: *string
|
|
|
|
on HOST_PEER_ID:
|
|
nodes <- Kademlia.neighborhood(%init_peer_id%, nil, nil)
|
|
for n <- nodes par:
|
|
status: *string
|
|
on n:
|
|
Peer.timestamp_sec()
|
|
status <<- "acked"
|
|
|
|
if status! == "acked":
|
|
acked_peers <<- n
|
|
|
|
Peer.timeout(15000, "") -- this line's indentation triggers the bug
|
|
<- acked_peers |