Disable block timeouts in E2E test network #19
@ -676,8 +676,8 @@ func (n *Network) LatestHeight(t time.Duration) (int64, error) {
|
||||
|
||||
for {
|
||||
select {
|
||||
case <-timeout.C:
|
||||
return latestHeight, errors.New("timeout exceeded waiting for block")
|
||||
// case <-timeout.C:
|
||||
// return latestHeight, errors.New("timeout exceeded waiting for block")
|
||||
case <-ticker.C:
|
||||
done := make(chan struct{})
|
||||
go func() {
|
||||
@ -695,6 +695,7 @@ func (n *Network) LatestHeight(t time.Duration) (int64, error) {
|
||||
return latestHeight, nil
|
||||
}
|
||||
}
|
||||
default: //nolint: all
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -725,8 +726,8 @@ func (n *Network) WaitForHeightWithTimeout(h int64, t time.Duration) (int64, err
|
||||
|
||||
for {
|
||||
select {
|
||||
case <-timeout.C:
|
||||
return latestHeight, errors.New("timeout exceeded waiting for block")
|
||||
// case <-timeout.C:
|
||||
// return latestHeight, errors.New("timeout exceeded waiting for block")
|
||||
case <-ticker.C:
|
||||
|
||||
res, err := queryClient.GetLatestBlock(context.Background(), &cmtservice.GetLatestBlockRequest{})
|
||||
@ -736,6 +737,7 @@ func (n *Network) WaitForHeightWithTimeout(h int64, t time.Duration) (int64, err
|
||||
return latestHeight, nil
|
||||
}
|
||||
}
|
||||
default: //nolint: all
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user