mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-01-09 22:47:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

added logs to transaction processing

Browse Source
This commit is contained in:
Sergio Mena
2022-05-31 17:37:52 +02:00
parent dfeaa62ca9
commit 51685158fe
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/e2e/runner/load.go
View File

@@ -54,7 +54,7 @@ func Load(ctx context.Context, logger log.Logger, r *rand.Rand, testnet *e2e.Tes
go loadGenerate(ctx, r, chTx, txSize, nNodes)
for w := 0; w < concurrency; w++ {
go loadProcess(ctx, testnet, ips, chTx, chSuccess)
go loadProcess(ctx, logger, testnet, ips, chTx, chSuccess)
}
// Montior transaction to ensure load propagates to the network
@@ -180,7 +180,7 @@ func prepareClientsIps(ips []string) []*rpchttp.HTTP {
}
// loadProcess processes transactions
func loadProcess(ctx context.Context, testnet *e2e.Testnet, ips []string, chTx <-chan types.Tx, chSuccess chan<- int) {
func loadProcess(ctx context.Context, logger log.Logger, testnet *e2e.Testnet, ips []string, chTx <-chan types.Tx, chSuccess chan<- int) {
// Each worker gets its own client to each usable node, which
// allows for some concurrency while still bounding it.
@@ -213,12 +213,18 @@ func loadProcess(ctx context.Context, testnet *e2e.Testnet, ips []string, chTx <
client := clientRing.Value.(*rpchttp.HTTP)
if status, err := client.Status(ctx); err != nil {
logger.Error("problem with client status",
"err", err)
continue
} else if status.SyncInfo.CatchingUp {
logger.Error("problem catching up")
continue
}
if _, err := client.BroadcastTxSync(ctx, tx); err != nil {
logger.Error("problem broadcasting txsync",
"tx", tx,
"err", err)
continue
}
successes++