|
@ -9,7 +9,7 @@ import ( |
|
|
"github.com/stretchr/testify/assert" |
|
|
"github.com/stretchr/testify/assert" |
|
|
"github.com/stretchr/testify/require" |
|
|
"github.com/stretchr/testify/require" |
|
|
|
|
|
|
|
|
"github.com/tendermint/tendermint/abci/client" |
|
|
|
|
|
|
|
|
abcicli "github.com/tendermint/tendermint/abci/client" |
|
|
"github.com/tendermint/tendermint/abci/server" |
|
|
"github.com/tendermint/tendermint/abci/server" |
|
|
"github.com/tendermint/tendermint/abci/types" |
|
|
"github.com/tendermint/tendermint/abci/types" |
|
|
cmn "github.com/tendermint/tendermint/libs/common" |
|
|
cmn "github.com/tendermint/tendermint/libs/common" |
|
@ -79,13 +79,8 @@ func TestHangingSyncCalls(t *testing.T) { |
|
|
s.Stop() |
|
|
s.Stop() |
|
|
|
|
|
|
|
|
// wait for the response from BeginBlock
|
|
|
// wait for the response from BeginBlock
|
|
|
fmt.Println("waiting for begin block") |
|
|
|
|
|
reqres.Wait() |
|
|
reqres.Wait() |
|
|
fmt.Println("waiting for flush") |
|
|
|
|
|
flush.Wait() |
|
|
flush.Wait() |
|
|
fmt.Println("got all responses") |
|
|
|
|
|
// res := reqres.Response.GetBeginBlock()
|
|
|
|
|
|
// require.NotNil(t, res)
|
|
|
|
|
|
resp <- c.Error() |
|
|
resp <- c.Error() |
|
|
}() |
|
|
}() |
|
|
|
|
|
|
|
|