yggdrasil-network/yggdrasil-go
1
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go.git synced 2025-11-04 11:15:07 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix debug builds

Browse source
This commit is contained in:
Arceliar 2019-08-24 15:32:19 -05:00
parent c573170886
commit 8c7e9ec7c0
1 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/yggdrasil/debug.go
View file

@ -571,7 +571,9 @@ func DEBUG_simLinkPeers(p, q *peer) {
continue
case packet := <-send:
packets = append(packets, packet)
source.core.switchTable.idleIn <- source.port
<-source.core.switchTable.SyncExec(func() {
source.core.switchTable._idleIn(source.port)
})
continue
default:
}
@ -585,15 +587,21 @@ func DEBUG_simLinkPeers(p, q *peer) {
packets = append(packets, packet)
case packet := <-send:
packets = append(packets, packet)
source.core.switchTable.idleIn <- source.port
<-source.core.switchTable.SyncExec(func() {
source.core.switchTable._idleIn(source.port)
})
}
}
}()
}
goWorkers(p, q)
goWorkers(q, p)
p.core.switchTable.idleIn <- p.port
q.core.switchTable.idleIn <- q.port
<-p.core.switchTable.SyncExec(func() {
p.core.switchTable._idleIn(p.port)
})
<-q.core.switchTable.SyncExec(func() {
q.core.switchTable._idleIn(q.port)
})
}
/*