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

do not crash when sending on a dead socket

This commit is contained in:
Maximilian Schneider 2022-09-15 18:35:16 +02:00
parent 2b50d1bc3d
commit 8c57c5f419
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
service-mango-fills/src/main.rs
View File

@ -113,16 +113,18 @@ async fn main() -> anyhow::Result<()> {
let message = fill_receiver.recv().await.unwrap();
match message {
FillEventFilterMessage::Update(update) => {
info!("ws update {} {:?} fill", update.market, update.status);
debug!("ws update {} {:?} fill", update.market, update.status);
let mut peer_copy = peers_ref_thread.lock().unwrap().clone();
for (k, v) in peer_copy.iter_mut() {
debug!(" > {}", k);
trace!(" > {}", k);
let json = serde_json::to_string(&update);
v.send(Message::Text(json.unwrap())).await.unwrap()
let result = v.send(Message::Text(json.unwrap())).await;
if result.is_err() {
error!(
"ws update {} {:?} fill could not reach {}",
update.market, update.status, k
);
}
}
}
FillEventFilterMessage::Checkpoint(checkpoint) => {