|
@@ -175,6 +175,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
|
|
|
} else {
|
|
} else {
|
|
|
core.local_cancel_log.remove(&new_order.client_id);
|
|
core.local_cancel_log.remove(&new_order.client_id);
|
|
|
core.local_orders_backup.remove(&new_order.client_id);
|
|
core.local_orders_backup.remove(&new_order.client_id);
|
|
|
|
|
+ core.local_orders.remove(&new_order.client_id);
|
|
|
}
|
|
}
|
|
|
} else {
|
|
} else {
|
|
|
rst.push(new_order.clone());
|
|
rst.push(new_order.clone());
|
|
@@ -217,12 +218,15 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
|
|
|
} else {
|
|
} else {
|
|
|
core.local_cancel_log.remove(&new_order.client_id);
|
|
core.local_cancel_log.remove(&new_order.client_id);
|
|
|
core.local_orders_backup.remove(&new_order.client_id);
|
|
core.local_orders_backup.remove(&new_order.client_id);
|
|
|
|
|
+ core.local_orders.remove(&new_order.client_id);
|
|
|
}
|
|
}
|
|
|
} else {
|
|
} else {
|
|
|
rst.push(new_order.clone());
|
|
rst.push(new_order.clone());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- &_ => {}
|
|
|
|
|
|
|
+ &_ => {
|
|
|
|
|
+ rst = order_infos;
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
core.update_order(rst, trace_stack).await;
|
|
core.update_order(rst, trace_stack).await;
|