mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-11-27 15:53:57 +00:00
42 lines
1.0 KiB
Go
42 lines
1.0 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/c4ei/yunseokyeol/app/appmessage"
|
|
"github.com/c4ei/yunseokyeol/stability-tests/common/rpc"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
func checkResolveVirtual(syncerClient, syncedClient *rpc.Client) error {
|
|
err := syncedClient.RegisterForBlockAddedNotifications()
|
|
if err != nil {
|
|
return errors.Wrap(err, "error registering for blockAdded notifications")
|
|
}
|
|
|
|
syncedBlockCountResponse, err := syncedClient.GetBlockCount()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
rejectReason, err := mineOnTips(syncerClient)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
if rejectReason != appmessage.RejectReasonNone {
|
|
panic(fmt.Sprintf("mined block rejected: %s", rejectReason))
|
|
}
|
|
|
|
expectedDuration := time.Duration(syncedBlockCountResponse.BlockCount) * 100 * time.Millisecond
|
|
start := time.Now()
|
|
select {
|
|
case <-time.After(expectedDuration):
|
|
return errors.Errorf("it took more than %s to resolve the virtual", expectedDuration)
|
|
case <-syncedClient.OnBlockAdded:
|
|
}
|
|
|
|
log.Infof("It took %s to resolve the virtual", time.Since(start))
|
|
return nil
|
|
}
|