Fixup return position impl trait overcapturing for the 2024 edition

Cargo.toml

@@ -581,9 +581,8 @@ nonstandard_style = { level = "deny", priority = -2 }
 rust_2018_idioms = { level = "deny", priority = -2 }
 
 rust-2024-compatibility = { level = "warn", priority = -1 }
-# TODO: Fix all of the below, https://github.com/microsoft/openvmm/issues/288
 edition_2024_expr_fragment_specifier = "allow"
-impl_trait_overcaptures = "allow"
+# TODO: Fix all of the below, https://github.com/microsoft/openvmm/issues/288
 deprecated-safe-2024 = "allow"
 
 unused_qualifications = "warn"

openhcl/openhcl_boot/src/host_params/dt.rs

@@ -69,7 +69,7 @@ fn allocate_vtl2_ram(
     params: &ShimParams,
     partition_memory_map: &[MemoryEntry],
     ram_size: Option<u64>,
-) -> OffStackRef<'static, impl AsRef<[MemoryEntry]>> {
+) -> OffStackRef<'static, impl AsRef<[MemoryEntry]> + use<>> {
     // First, calculate how many numa nodes there are by looking at unique numa
     // nodes in the memory map.
     let mut numa_nodes = off_stack!(ArrayVec<u32, MAX_NUMA_NODES>, ArrayVec::new_const());
@@ -262,7 +262,7 @@ fn allocate_vtl2_ram(
 fn parse_host_vtl2_ram(
     params: &ShimParams,
     memory: &[MemoryEntry],
-) -> OffStackRef<'static, impl AsRef<[MemoryEntry]>> {
+) -> OffStackRef<'static, impl AsRef<[MemoryEntry]> + use<>> {
     // If no VTL2 protectable ram was provided by the host, use the build time
     // value encoded in ShimParams.
     let mut vtl2_ram = off_stack!(ArrayVec<MemoryEntry, MAX_NUMA_NODES>, ArrayVec::new_const());

openhcl/openhcl_boot/src/host_params/mod.rs

@@ -126,7 +126,7 @@ impl PartitionInfo {
     }
 
     /// Returns the parameter regions that are not being reclaimed.
-    pub fn vtl2_config_regions(&self) -> impl Iterator<Item = MemoryRange> {
+    pub fn vtl2_config_regions(&self) -> impl Iterator<Item = MemoryRange> + use<> {
         subtract_ranges(
             [self.vtl2_full_config_region],
             [self.vtl2_config_region_reclaim],

openhcl/openhcl_boot/src/main.rs

@@ -314,7 +314,7 @@ enum ReservedMemoryType {
 fn reserved_memory_regions(
     partition_info: &PartitionInfo,
     sidecar: Option<&SidecarConfig<'_>>,
-) -> OffStackRef<'static, impl AsRef<[(MemoryRange, ReservedMemoryType)]>> {
+) -> OffStackRef<'static, impl AsRef<[(MemoryRange, ReservedMemoryType)]> + use<>> {
     let mut reserved = off_stack!(ArrayVec<(MemoryRange, ReservedMemoryType), MAX_RESERVED_MEM_RANGES>, ArrayVec::new_const());
     reserved.clear();
     reserved.extend(

openvmm/openvmm_entry/src/ttrpc/mod.rs

@@ -365,7 +365,7 @@ impl VmService {
         &self,
         ctx: mesh::CancelContext,
         request: inspect_proto::InspectRequest,
-    ) -> impl Future<Output = anyhow::Result<InspectResponse2>> {
+    ) -> impl Future<Output = anyhow::Result<InspectResponse2>> + use<> {
         let mut inspection = InspectionBuilder::new(&request.path)
             .depth(Some(request.depth as usize))
             .inspect(inspect::adhoc(|req| {
@@ -388,7 +388,7 @@ impl VmService {
         &self,
         ctx: mesh::CancelContext,
         request: inspect_proto::UpdateRequest,
-    ) -> impl Future<Output = anyhow::Result<UpdateResponse2>> {
+    ) -> impl Future<Output = anyhow::Result<UpdateResponse2>> + use<> {
         let update = inspect::update(
             &request.path,
             &request.value,
@@ -604,13 +604,13 @@ impl VmService {
         Ok(())
     }
 
-    fn pause_vm(&mut self, vm: &Vm) -> impl Future<Output = anyhow::Result<()>> {
+    fn pause_vm(&mut self, vm: &Vm) -> impl Future<Output = anyhow::Result<()>> + use<> {
         let (send, recv) = mesh::oneshot();
         vm.worker_rpc.send(VmRpc::Pause(Rpc((), send)));
         async move { recv.await.map(drop).context("pause failed") }
     }
 
-    fn resume_vm(&mut self, vm: &Vm) -> impl Future<Output = anyhow::Result<()>> {
+    fn resume_vm(&mut self, vm: &Vm) -> impl Future<Output = anyhow::Result<()>> + use<> {
         let (send, recv) = mesh::oneshot();
         vm.worker_rpc.send(VmRpc::Resume(Rpc((), send)));
         async move { recv.await.map(drop).context("resume failed") }
@@ -620,7 +620,7 @@ impl VmService {
         &mut self,
         mut ctx: mesh::CancelContext,
         vm: Arc<Vm>,
-    ) -> anyhow::Result<impl Future<Output = anyhow::Result<()>>> {
+    ) -> anyhow::Result<impl Future<Output = anyhow::Result<()>> + use<>> {
         let mut notify_recv = vm
             .notify_recv
             .lock()
@@ -645,7 +645,7 @@ impl VmService {
         &mut self,
         vm: &Vm,
         request: vmservice::ModifyResourceRequest,
-    ) -> anyhow::Result<impl Future<Output = anyhow::Result<()>>> {
+    ) -> anyhow::Result<impl Future<Output = anyhow::Result<()>> + use<>> {
         use vmservice::modify_resource_request::Resource;
         match request.resource.context("missing resource")? {
             Resource::ScsiDisk(disk) => {

support/fdt/src/parser.rs

@@ -671,7 +671,7 @@ impl<'a> Property<'a> {
     }
 
     /// Read data as an iterator of u64 values.
-    pub fn as_64_list(&self) -> Result<impl Iterator<Item = u64> + 'a, Error<'a>> {
+    pub fn as_64_list(&self) -> Result<impl Iterator<Item = u64> + use<'a>, Error<'a>> {
         Ok(U64b::slice_from(self.data)
             .ok_or(Error(ErrorKind::PropertyDataTypeBuffer {
                 node_name: self.node_name,

support/mesh/mesh_protobuf/src/protobuf.rs

@@ -666,7 +666,7 @@ impl<'a, 'b, R> MessageReader<'a, 'b, R> {
     }
 
     /// Returns an iterator to consume the resources for this message.
-    pub fn take_resources(&mut self) -> impl 'b + ExactSizeIterator<Item = Result<R>> {
+    pub fn take_resources(&mut self) -> impl ExactSizeIterator<Item = Result<R>> + use<'b, R> {
         let state = self.state;
         self.resources.clone().map(move |i| {
             state

vm/devices/pci/pci_core/src/capabilities/msix.rs

@@ -233,7 +233,7 @@ impl MsixEmulator {
         bar: u8,
         count: u16,
         register_msi: &mut dyn RegisterMsi,
-    ) -> (Self, impl PciCapability) {
+    ) -> (Self, impl PciCapability + use<>) {
         let state = MsixState {
             enabled: false,
             vectors: (0..count)

vm/devices/storage/disk_nvme/nvme_driver/src/driver.rs

@@ -444,7 +444,7 @@ impl<T: DeviceBacking> NvmeDriver<T> {
         drop(self);
     }
 
-    fn reset(&mut self) -> impl 'static + Send + std::future::Future<Output = ()> {
+    fn reset(&mut self) -> impl Send + std::future::Future<Output = ()> + use<T> {
         let driver = self.driver.clone();
         let mut task = std::mem::take(&mut self.task).unwrap();
         async move {

vm/devices/vmbus/vmbus_client_hcl/src/lib.rs

@@ -32,9 +32,9 @@ use zerocopy::AsBytes;
 
 /// Returns the synic client and message source for use with
 /// [`vmbus_client::VmbusClient`].
-pub fn new_synic_client_and_messsage_source(
-    driver: &(impl Driver + ?Sized),
-) -> anyhow::Result<(impl SynicClient, impl VmbusMessageSource)> {
+pub fn new_synic_client_and_messsage_source<T: Driver + ?Sized>(
+    driver: &T,
+) -> anyhow::Result<(impl SynicClient + use<T>, impl VmbusMessageSource + use<T>)> {
     // Open an HCL vmbus fd for issuing synic requests.
     let hcl_vmbus = Arc::new(HclVmbus::new().context("failed to open hcl_vmbus")?);
     let synic = HclSynic {

vm/devices/vmbus/vmbus_server/src/hvsock.rs

@@ -114,7 +114,7 @@ impl HvsockRelay {
         &self,
         ctx: &mut CancelContext,
         service_id: Guid,
-    ) -> impl std::future::Future<Output = anyhow::Result<UnixStream>> + Send {
+    ) -> impl std::future::Future<Output = anyhow::Result<UnixStream>> + Send + use<> {
         let inner = self.inner.clone();
         let host_send = self.host_send.clone();
         let (send, recv) = mesh::oneshot();

vmm_core/state_unit/src/lib.rs

@@ -887,12 +887,12 @@ impl ReadySet {
 /// future with a span, and wrapping its error with something more informative.
 ///
 /// `operation` and `name` are used in tracing and error construction.
-fn state_change<I: 'static, R: 'static + Send>(
+fn state_change<I: 'static, R: 'static + Send, Req: FnOnce(Rpc<I, R>) -> StateRequest>(
     name: Arc<str>,
     unit: &Unit,
-    request: impl FnOnce(Rpc<I, R>) -> StateRequest,
+    request: Req,
     input: Option<I>,
-) -> impl Future<Output = Result<Option<R>, UnitRecvError>> {
+) -> impl Future<Output = Result<Option<R>, UnitRecvError>> + use<I, R, Req> {
     let (response_send, response_recv) = oneshot();
     let send = unit.send.clone();
 

vmm_core/virt_whp/src/vtl2.rs

@@ -190,7 +190,7 @@ pub(crate) struct Vtl2Emulation {
 mod inspect_helpers {
     use super::*;
 
-    pub(super) fn vsm_config_raw(raw: &AtomicU64) -> impl Inspect {
+    pub(super) fn vsm_config_raw(raw: &AtomicU64) -> impl Inspect + use<> {
         let config = HvRegisterVsmPartitionConfig::from(raw.load(Ordering::Relaxed));
         inspect::AsDebug(config)
     }