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

rpc-sts: respect app exit in tx receiver thread

This commit is contained in:
Trent Nelson 2022-08-25 13:50:38 -06:00 committed by Trent Nelson
parent 900f8a3b2b
commit 14c60bae16
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
send-transaction-service/src/send_transaction_service.rs
View File

@ -414,7 +414,11 @@ impl SendTransactionService {
.spawn(move || loop {
let recv_timeout_ms = config.batch_send_rate_ms;
let stats = &stats_report.stats;
match receiver.recv_timeout(Duration::from_millis(recv_timeout_ms)) {
let recv_result = receiver.recv_timeout(Duration::from_millis(recv_timeout_ms));
if exit.load(Ordering::Relaxed) {
break;
}
match recv_result {
Err(RecvTimeoutError::Disconnected) => {
info!("Terminating send-transaction-service.");
exit.store(true, Ordering::Relaxed);