fmt

examples/active_message_examples/am_no_return.rs

@@ -88,7 +88,7 @@ fn main() {
         println!("-----------------------------------");
         println!("Testing all am no return");
         println!("[{:?}] exec on all", my_pe);
-        let res =world.exec_am_all(am.clone()).block();
+        let res = world.exec_am_all(am.clone()).block();
         assert!(res.iter().all(|x| *x == ()));
         println!("no return result: {:?}", res);
         println!("---------------------------------------------------------------");

src/active_messaging/registered_active_message.rs

@@ -403,7 +403,7 @@ impl RegisteredActiveMessages {
     ) {
         // println!("[{:?}] exec_local_am", std::thread::current().id());
         world.team.world_counters.inc_outstanding(1);
-         team.team.team_counters.inc_outstanding(1);
+        team.team.team_counters.inc_outstanding(1);
         match am
             .exec(
                 req_data.team.world_pe,
@@ -436,7 +436,7 @@ impl RegisteredActiveMessages {
             }
         }
         world.team.world_counters.dec_outstanding(1);
-         team.team.team_counters.dec_outstanding(1);
+        team.team.team_counters.dec_outstanding(1);
     }
 
     //#[tracing::instrument(skip_all)]
@@ -468,7 +468,7 @@ impl RegisteredActiveMessages {
         };
 
         world.team.world_counters.inc_outstanding(1);
-         team.team.team_counters.inc_outstanding(1);
+        team.team.team_counters.inc_outstanding(1);
         let am = match am
             .exec(
                 team.team.world_pe,
@@ -491,7 +491,7 @@ impl RegisteredActiveMessages {
             ame.process_msg(am, 0, false).await;
         });
         world.team.world_counters.dec_outstanding(1);
-         team.team.team_counters.dec_outstanding(1);
+        team.team.team_counters.dec_outstanding(1);
         //compare against:
         // ame.process_msg(am, 0, true).await;
     }

src/array/iterator/distributed_iterator.rs

@@ -327,7 +327,7 @@ pub trait DistributedIterator: SyncSend + InnerIter + 'static {
     /// let world = LamellarWorldBuilder::new().build();
     /// let array: ReadOnlyArray<usize> = ReadOnlyArray::new(&world,100,Distribution::Block).block();
     ///
-    
+
     ///     array
     ///         .dist_iter()
     ///         .for_each(move |elem| println!("{:?} {elem}",std::thread::current().id()))

src/array/iterator/local_iterator.rs

@@ -320,7 +320,7 @@ pub trait LocalIterator: SyncSend + InnerIter + 'static {
     /// let world = LamellarWorldBuilder::new().build();
     /// let array: ReadOnlyArray<usize> = ReadOnlyArray::new(&world,100,Distribution::Block).block();
     ///
-    /// 
+    ///
     ///     array
     ///         .local_iter()
     ///         .for_each(move |elem| println!("{:?} {elem}",std::thread::current().id()))

src/array/iterator/mod.rs

@@ -82,7 +82,7 @@ pub trait LamellarArrayIterators<T: Dist> {
     /// let my_pe = world.my_pe();
     /// let array: ReadOnlyArray<usize> = ReadOnlyArray::new(&world,100,Distribution::Cyclic).block();
     ///
-    /// 
+    ///
     ///     array.dist_iter().for_each(move |elem| println!("PE{my_pe} elem {elem}"))
     /// .block();
     ///```
@@ -102,7 +102,7 @@ pub trait LamellarArrayIterators<T: Dist> {
     /// let my_pe = world.my_pe();
     /// let array: AtomicArray<usize> = AtomicArray::new(&world,100,Distribution::Cyclic).block();
     ///
-    /// 
+    ///
     ///     array.local_iter().for_each(move |elem| println!("PE{my_pe} elem {}",elem.load())) // "load" is specific to AtomicArray elements, other types can deref the element directly"
     /// .block();
     ///```
@@ -181,7 +181,7 @@ pub trait LamellarArrayMutIterators<T: Dist> {
     /// let my_pe = world.my_pe();
     /// let array: LocalLockArray<usize> = LocalLockArray::new(&world,100,Distribution::Cyclic).block();
     ///
-    /// 
+    ///
     ///     array.dist_iter_mut().for_each(move |elem| *elem = my_pe)
     /// .block();
     ///```
@@ -201,7 +201,7 @@ pub trait LamellarArrayMutIterators<T: Dist> {
     /// let my_pe = world.my_pe();
     /// let array: LocalLockArray<usize> = LocalLockArray::new(&world,100,Distribution::Cyclic).block();
     ///
-    /// 
+    ///
     ///    array.local_iter_mut().for_each(move |elem| *elem = my_pe)
     /// .block();
     fn local_iter_mut(&self) -> Self::LocalIter;