(&self, process_identifier: i64)
| 475 | } |
| 476 | |
| 477 | async fn remove(&self, process_identifier: i64) -> io::Result<()> { |
| 478 | let _lock = RegistryFileLock::acquire(&self.path)?; |
| 479 | let mut registry = read_registry_file(&self.path); |
| 480 | let original_len = registry.inspectors.len(); |
| 481 | registry.inspectors.retain(|entry| { |
| 482 | !(entry.process_identifier == process_identifier && entry.service_id == self.service_id) |
| 483 | }); |
| 484 | prune_registry_file(&mut registry); |
| 485 | if registry.inspectors.len() != original_len { |
| 486 | write_registry_file(&self.path, ®istry)?; |
| 487 | } |
| 488 | Ok(()) |
| 489 | } |
| 490 | |
| 491 | async fn read_live_entries(&self) -> Vec<PublishedInspector> { |
| 492 | let _lock = RegistryFileLock::acquire(&self.path).ok(); |
nothing calls this directly
no test coverage detected