diff --git a/loadtest/main.go b/loadtest/main.go index 99ab610b26..b1f4b4b978 100644 --- a/loadtest/main.go +++ b/loadtest/main.go @@ -402,7 +402,7 @@ func (c *LoadTestClient) generateMessage(config Config, key cryptotypes.PrivKey, }} default: - fmt.Printf("Unrecognized message type %s", config.MessageType) + fmt.Printf("Unrecognized message type %s\n", config.MessageType) } if strings.Contains(config.MessageType, "failure") { diff --git a/loadtest/sign.go b/loadtest/sign.go index ca839c1ed0..de8cd913c2 100644 --- a/loadtest/sign.go +++ b/loadtest/sign.go @@ -69,7 +69,6 @@ func (sc *SignerClient) GetTestAccountsKeys(maxAccounts int) []cryptotypes.PrivK var testAccountsKeys = make([]cryptotypes.PrivKey, int(math.Min(float64(len(files)), float64(maxAccounts)))) var wg sync.WaitGroup - keysChan := make(chan cryptotypes.PrivKey, maxAccounts) fmt.Printf("Loading accounts\n") for i, file := range files { if i >= maxAccounts { @@ -79,15 +78,11 @@ func (sc *SignerClient) GetTestAccountsKeys(maxAccounts int) []cryptotypes.PrivK go func(i int, fileName string) { defer wg.Done() key := sc.GetKey(fmt.Sprint(i), "test", filepath.Join(userHomeDir, "test_accounts", fileName)) - keysChan <- key + testAccountsKeys[i] = key }(i, file.Name()) } wg.Wait() - close(keysChan) - // Collect keys from the channel - for key := range keysChan { - testAccountsKeys = append(testAccountsKeys, key) - } + fmt.Printf("Finished loading %d accounts \n", len(testAccountsKeys)) return testAccountsKeys } diff --git a/loadtest/tx.go b/loadtest/tx.go index 76a90390f4..6c7ded2e7e 100644 --- a/loadtest/tx.go +++ b/loadtest/tx.go @@ -15,7 +15,6 @@ func SendTx( loadtestClient LoadTestClient, sentCount *int64, ) { - grpcRes, _ := loadtestClient.GetTxClient().BroadcastTx( ctx, &typestx.BroadcastTxRequest{