Lines Matching refs:id
75 id: TransactionId, field
127 pub fn stop_with_error(&mut self, id: TransactionId, error: Error) -> Result<()> { in stop_with_error()
132 let v = self.transactions.remove(&id); in stop_with_error()
136 event_type: EventType::Callback(t.id), in stop_with_error()
173 for id in self.transactions.keys() { in close()
175 event_type: EventType::Callback(*id), in close()
193 pub fn start(&mut self, id: TransactionId, deadline: Instant) -> Result<()> { in start()
197 if self.transactions.contains_key(&id) { in start()
202 .insert(id, AgentTransaction { id, deadline }); in start()
209 pub fn stop(&mut self, id: TransactionId) -> Result<()> { in stop()
210 self.stop_with_error(id, Error::ErrTransactionStopped) in stop()
232 for (id, t) in &self.transactions { in collect()
234 to_remove.push(*id); in collect()
238 for id in &to_remove { in collect()
239 self.transactions.remove(id); in collect()
242 for id in to_remove { in collect()
244 event_type: EventType::Callback(id), in collect()