CPunch/gopenfusion
1
0
Fork 0
mirror of https://github.com/CPunch/gopenfusion.git synced 2024-12-04 14:36:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

TestService: wait for OnConnect and OnDisconnect

Browse Source
This commit is contained in:
CPunch 2023-12-01 13:56:15 -06:00
parent 8e65a78d07
commit 96130ddc8d
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
internal/service/service_test.go
View File

@ -72,15 +72,25 @@ func TestService(t *testing.T) {
return nil return nil
}) })
// wait for all dummy peers to connect and disconnect
wg.Add(maxDummyPeers)
srvc.OnConnect = func(peer *protocol.CNPeer) {
wg.Done()
}
wg.Add(maxDummyPeers)
srvc.OnDisconnect = func(peer *protocol.CNPeer) {
wg.Done()
}
// run service // run service
go func() { go func() {
err := srvc.Start() is.NoErr(srvc.Start()) // srvc.Start error
is.NoErr(err) // srvc.Start error
}() }()
is.True(selectWithTimeout(srvc.Started(), timeout)) // wait for service to start with timeout is.True(selectWithTimeout(srvc.Started(), timeout)) // wait for service to start with timeout
wg.Add(maxDummyPeers * 3) // 2 wg.Done() calls per dummy peer wg.Add(maxDummyPeers * 3) // 3 wg.Done() calls per dummy peer. 2 per peer for receiving packets, 1 for Handler() exit
for i := 0; i < maxDummyPeers; i++ { for i := 0; i < maxDummyPeers; i++ {
go func() { go func() {
// make dummy client // make dummy client
@ -93,8 +103,7 @@ func TestService(t *testing.T) {
// send dummy packets // send dummy packets
for i := 0; i < 2; i++ { for i := 0; i < 2; i++ {
err := peer.Send(0x1234) is.NoErr(peer.Send(0x1234)) // peer.Send error
is.NoErr(err) // peer.Send error
} }
}() }()