blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Actually fixes non-binding `let` on a future (quic-client) (#29326)

This commit is contained in:
Brooks Prumo 2022-12-19 17:27:21 -05:00 committed by GitHub
parent 4530d161b7
commit 76bfd1a9a1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/src/quic_client.rs
View File

@ -29,7 +29,7 @@ impl TpuConnection for QuicTpuConnection {
let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone(); let inner = self.inner.clone();
_ = RUNTIME let _handle = RUNTIME
.spawn(async move { send_wire_transaction_async(inner, wire_transaction).await }); .spawn(async move { send_wire_transaction_async(inner, wire_transaction).await });
Ok(()) Ok(())
} }
@ -37,7 +37,8 @@ impl TpuConnection for QuicTpuConnection {
fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> { fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> {
let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone(); let inner = self.inner.clone();
_ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); let _handle =
RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
Ok(()) Ok(())
} }
} }

5
quic-client/src/quic_client.rs
View File

@ -174,7 +174,7 @@ impl TpuConnection for QuicTpuConnection {
let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone(); let inner = self.inner.clone();
_ = RUNTIME let _handle = RUNTIME
.spawn(async move { send_wire_transaction_async(inner, wire_transaction).await }); .spawn(async move { send_wire_transaction_async(inner, wire_transaction).await });
Ok(()) Ok(())
} }
@ -182,7 +182,8 @@ impl TpuConnection for QuicTpuConnection {
fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> { fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> {
let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone(); let inner = self.inner.clone();
_ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); let _handle =
RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
Ok(()) Ok(())
} }
} }