Lines Matching refs:ct
249 fn insert(&mut self, ct: ClientTransaction) -> Result<()> { in insert()
256 event_type: EventType::Insert(ct), in insert()
292 EventType::Insert(ct) => { in start()
293 if t.contains_key(&ct.id) { in start()
296 t.insert(ct.id, ct); in start()
302 let mut ct = if t.contains_key(&id) { in start() localVariable
311 if ct.attempt >= max_attempts || event.event_body.is_ok() { in start()
312 if let Some(handler) = ct.handler { in start()
319 ct.attempt += 1; in start()
321 let raw = ct.raw.clone(); in start()
322 let timeout = ct.next_timeout(Instant::now()); in start()
323 let id = ct.id; in start()
326 t.insert(ct.id, ct); in start()
334 let ct = t.remove(&id).unwrap(); in start() localVariable
335 if let Some(handler) = ct.handler { in start()
346 let ct = t.remove(&id).unwrap(); in start() localVariable
347 if let Some(handler) = ct.handler { in start()