Async send for send transaction service (backport #24265) (#24323)

* Async send for send transaction service (#24265)

* async send

(cherry picked from commit 474080608a)

# Conflicts:
#	client/Cargo.toml

* Fix conflicts

Co-authored-by: anatoly yakovenko <anatoly@solana.com>
Co-authored-by: Tyera Eulberg <tyera@solana.com>
This commit is contained in:
mergify[bot]
2022-04-13 19:29:03 -06:00
committed by GitHub
parent 0e6ba29859
commit 785481ace4
9 changed files with 58 additions and 14 deletions

View File

@@ -311,7 +311,9 @@ impl SendTransactionService {
fn send_transaction(tpu_address: &SocketAddr, wire_transaction: &[u8]) {
let mut measure = Measure::start("send_transaction_service-us");
if let Err(err) = connection_cache::send_wire_transaction(wire_transaction, tpu_address) {
if let Err(err) =
connection_cache::send_wire_transaction_async(wire_transaction.to_vec(), tpu_address)
{
warn!("Failed to send transaction to {}: {:?}", tpu_address, err);
}
measure.stop();