[hyperactor] mesh: v0 shims for v1 meshes

hyperactor_mesh/benches/main.rs

@@ -13,6 +13,7 @@ use criterion::Criterion;
 use criterion::Throughput;
 use criterion::criterion_group;
 use criterion::criterion_main;
+use hyperactor::Proc;
 use hyperactor::channel::ChannelTransport;
 use hyperactor_mesh::ProcMesh;
 use hyperactor_mesh::actor_mesh::ActorMesh;
@@ -51,9 +52,10 @@ fn bench_actor_scaling(c: &mut Criterion) {
                     .await
                     .unwrap();
 
+                let (bootstrap_instance, _) = Proc::local().instance("bench").unwrap();
                 let mut proc_mesh = ProcMesh::allocate(alloc).await.unwrap();
                 let actor_mesh: RootActorMesh<BenchActor> = proc_mesh
-                    .spawn("bench", &(Duration::from_millis(0)))
+                    .spawn(&bootstrap_instance, "bench", &(Duration::from_millis(0)))
                     .await
                     .unwrap();
                 let client = proc_mesh.client();
@@ -149,9 +151,10 @@ fn bench_actor_mesh_message_sizes(c: &mut Criterion) {
                             .await
                             .unwrap();
 
+                        let (bootstrap_instance, _) = Proc::local().instance("bench").unwrap();
                         let mut proc_mesh = ProcMesh::allocate(alloc).await.unwrap();
                         let actor_mesh: RootActorMesh<BenchActor> = proc_mesh
-                            .spawn("bench", &(Duration::from_millis(0)))
+                            .spawn(&bootstrap_instance, "bench", &(Duration::from_millis(0)))
                             .await
                             .unwrap();
 

hyperactor_mesh/examples/dining_philosophers.rs

@@ -20,6 +20,7 @@ use hyperactor::Handler;
 use hyperactor::Instance;
 use hyperactor::Named;
 use hyperactor::PortRef;
+use hyperactor::Proc;
 use hyperactor::Unbind;
 use hyperactor::channel::ChannelTransport;
 use hyperactor_mesh::ProcMesh;
@@ -237,10 +238,12 @@ async fn main() -> Result<ExitCode> {
         })
         .await?;
 
+    let (instance, _) = Proc::local().instance("client").unwrap();
+
     let proc_mesh = ProcMesh::allocate(alloc).await?;
     let params = PhilosopherActorParams { size: group_size };
     let actor_mesh = proc_mesh
-        .spawn::<PhilosopherActor>("philosopher", &params)
+        .spawn::<PhilosopherActor>(&instance, "philosopher", &params)
         .await?;
     let (dining_message_handle, mut dining_message_rx) = proc_mesh.client().open_port();
     actor_mesh

hyperactor_mesh/examples/sieve.rs

@@ -22,6 +22,7 @@ use hyperactor::Context;
 use hyperactor::Handler;
 use hyperactor::Named;
 use hyperactor::PortRef;
+use hyperactor::Proc;
 use hyperactor::channel::ChannelTransport;
 use hyperactor_mesh::Mesh;
 use hyperactor_mesh::ProcMesh;
@@ -116,8 +117,12 @@ async fn main() -> Result<ExitCode> {
 
     let mesh = ProcMesh::allocate(alloc).await?;
 
+    let (instance, _) = Proc::local().instance("client").unwrap();
+
     let sieve_params = SieveParams { prime: 2 };
-    let sieve_mesh = mesh.spawn::<SieveActor>("sieve", &sieve_params).await?;
+    let sieve_mesh = mesh
+        .spawn::<SieveActor>(&instance, "sieve", &sieve_params)
+        .await?;
     let sieve_head = sieve_mesh.get(0).unwrap();
 
     let mut primes = vec![2];