mirror of
https://github.com/tendermint/tendermint.git
synced 2026-07-30 12:02:53 +00:00
Anton KaliaevandGitHub
e13b4386ff
`abci.Client`:
- Sync and Async methods now accept a context for cancellation
* grpc client uses context to cancel both Sync and Async requests
* local client ignores context parameter
* socket client uses context to cancel Sync requests and to drop Async requests before sending them if context was cancelled prior to that
- Async methods return an error
* socket client returns an error immediately if queue is full for Async requests
* local client always returns nil error
* grpc client returns an error if context was cancelled before we got response or the receiving queue had a space for response (do not confuse with the sending queue from the socket client)
- specify clients semantics in [doc.go](https://raw.githubusercontent.com/tendermint/tendermint/27112fffa62276bc016d56741f686f0f77931748/abci/client/doc.go)
`mempool.TxInfo`
- add optional `Context` to `TxInfo`, which can be used to cancel `CheckTx` request
Closes #5190
57 lines
1.4 KiB
Go
57 lines
1.4 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
|
|
abcicli "github.com/tendermint/tendermint/abci/client"
|
|
"github.com/tendermint/tendermint/abci/types"
|
|
"github.com/tendermint/tendermint/libs/log"
|
|
)
|
|
|
|
var ctx = context.Background()
|
|
|
|
func startClient(abciType string) abcicli.Client {
|
|
// Start client
|
|
client, err := abcicli.NewClient("tcp://127.0.0.1:26658", abciType, true)
|
|
if err != nil {
|
|
panic(err.Error())
|
|
}
|
|
logger := log.NewTMLogger(log.NewSyncWriter(os.Stdout))
|
|
client.SetLogger(logger.With("module", "abcicli"))
|
|
if err := client.Start(); err != nil {
|
|
panicf("connecting to abci_app: %v", err.Error())
|
|
}
|
|
|
|
return client
|
|
}
|
|
|
|
func commit(client abcicli.Client, hashExp []byte) {
|
|
res, err := client.CommitSync(ctx)
|
|
if err != nil {
|
|
panicf("client error: %v", err)
|
|
}
|
|
if !bytes.Equal(res.Data, hashExp) {
|
|
panicf("Commit hash was unexpected. Got %X expected %X", res.Data, hashExp)
|
|
}
|
|
}
|
|
|
|
func deliverTx(client abcicli.Client, txBytes []byte, codeExp uint32, dataExp []byte) {
|
|
res, err := client.DeliverTxSync(ctx, types.RequestDeliverTx{Tx: txBytes})
|
|
if err != nil {
|
|
panicf("client error: %v", err)
|
|
}
|
|
if res.Code != codeExp {
|
|
panicf("DeliverTx response code was unexpected. Got %v expected %v. Log: %v", res.Code, codeExp, res.Log)
|
|
}
|
|
if !bytes.Equal(res.Data, dataExp) {
|
|
panicf("DeliverTx response data was unexpected. Got %X expected %X", res.Data, dataExp)
|
|
}
|
|
}
|
|
|
|
func panicf(format string, a ...interface{}) {
|
|
panic(fmt.Sprintf(format, a...))
|
|
}
|