extern/smegmesh
1
0
Fork 1
mirror of https://github.com/tim-beatham/smegmesh.git synced 2024-12-13 10:01:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

main

Browse Source 
- Prep for demo
This commit is contained in:
Tim Beatham 2024-01-17 16:21:49 +00:00
parent 915263e49a
commit 901674a5e3
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/sync/syncer.go
View File

@ -99,10 +99,11 @@ func (s *SyncerImpl) Sync(correspondingMesh mesh.MeshProvider) (bool, error) {
var wait sync.WaitGroup var wait sync.WaitGroup
for index, node := range gossipNodes { for index := range gossipNodes {
wait.Add(1) wait.Add(1)
syncNode := func(i int) { syncNode := func(i int) {
node := gossipNodes[i]
correspondingPeer, err := correspondingMesh.GetNode(node) correspondingPeer, err := correspondingMesh.GetNode(node)
defer wait.Done() defer wait.Done()