Browse Source
Migrate `do_send_async` to `send`
First log the warning, then attempt to send. This makes sure we always
log the warning, even if we fail to send the message.
pAndLAndPayout
Thomas Eizinger
3 years ago
No known key found for this signature in database
GPG Key ID: 651AC83A6C6C8B96
1 changed files with
7 additions and
7 deletions
-
daemon/src/maker_cfd.rs
|
|
@ -444,19 +444,19 @@ where |
|
|
|
load_order_by_id(current_order_id, &mut conn).await? |
|
|
|
} |
|
|
|
_ => { |
|
|
|
self.takers |
|
|
|
.do_send_async(maker_inc_connections::TakerMessage { |
|
|
|
taker_id, |
|
|
|
command: TakerCommand::NotifyInvalidOrderId { id: order_id }, |
|
|
|
}) |
|
|
|
.await?; |
|
|
|
|
|
|
|
// An outdated order on the taker side does not require any state change on the
|
|
|
|
// maker. notifying the taker with a specific message should be sufficient.
|
|
|
|
// Since this is a scenario that we should rarely see we log
|
|
|
|
// a warning to be sure we don't trigger this code path frequently.
|
|
|
|
tracing::warn!("Taker tried to take order with outdated id {}", order_id); |
|
|
|
|
|
|
|
self.takers |
|
|
|
.send(maker_inc_connections::TakerMessage { |
|
|
|
taker_id, |
|
|
|
command: TakerCommand::NotifyInvalidOrderId { id: order_id }, |
|
|
|
}) |
|
|
|
.await??; |
|
|
|
|
|
|
|
return Ok(()); |
|
|
|
} |
|
|
|
}; |
|
|
|