Debugging
This commit is contained in:
parent
f62a6e804a
commit
ef131fbf59
1 changed files with 3 additions and 1 deletions
|
|
@ -125,7 +125,7 @@ impl Db {
|
||||||
roads: Vec<u16>,
|
roads: Vec<u16>,
|
||||||
writer_stream: mpsc::Sender<ServerFrames>,
|
writer_stream: mpsc::Sender<ServerFrames>,
|
||||||
) {
|
) {
|
||||||
info!("Adding new dispatcher for raods: {roads:?}");
|
info!("Adding new dispatcher for roads: {roads:?}");
|
||||||
let mut state = self.state.lock().unwrap();
|
let mut state = self.state.lock().unwrap();
|
||||||
|
|
||||||
for r in roads.iter() {
|
for r in roads.iter() {
|
||||||
|
|
@ -149,6 +149,7 @@ impl Db {
|
||||||
|
|
||||||
pub(crate) fn add_open_ticket(&self, ticket: Ticket) {
|
pub(crate) fn add_open_ticket(&self, ticket: Ticket) {
|
||||||
let mut state = self.state.lock().unwrap();
|
let mut state = self.state.lock().unwrap();
|
||||||
|
info!("Adding open ticket: {ticket:?}");
|
||||||
state
|
state
|
||||||
.open_tickets
|
.open_tickets
|
||||||
.entry(Road(ticket.road))
|
.entry(Road(ticket.road))
|
||||||
|
|
@ -162,6 +163,7 @@ impl Db {
|
||||||
}
|
}
|
||||||
|
|
||||||
pub(crate) fn remove_open_ticket(&self, road: Road, ticket: Ticket) -> bool {
|
pub(crate) fn remove_open_ticket(&self, road: Road, ticket: Ticket) -> bool {
|
||||||
|
info!("Removing open ticket: {ticket:?}");
|
||||||
let mut state = self.state.lock().unwrap();
|
let mut state = self.state.lock().unwrap();
|
||||||
if let Some(tickets) = state.open_tickets.get_mut(&road) {
|
if let Some(tickets) = state.open_tickets.get_mut(&road) {
|
||||||
tickets.retain(|t| t.plate != ticket.plate);
|
tickets.retain(|t| t.plate != ticket.plate);
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue