Fix rustc 1.79 clippy warnings.

gz · gz · commit dfb11fa1c5ab · 2024-06-23T16:27:27.000+02:00
Signed-off-by: Gerd Zellweger &lt;mail@gerdzellweger.com&gt;
diff --git a/crates/dbsp/src/circuit/circuit_builder.rs b/crates/dbsp/src/circuit/circuit_builder.rs
@@ -591,7 +591,10 @@ where
             local_node_id: self.local_node_id,
             origin_node_id: self.origin_node_id.clone(),
             circuit: self.circuit.clone(),
-            val: std::mem::transmute(self.val.clone()),
+            val: std::mem::transmute::<
+                Rc<UnsafeCell<StreamValue<D>>>,
+                Rc<UnsafeCell<StreamValue<D2>>>,
+            >(self.val.clone()),
         }
     }
 }
diff --git a/crates/dbsp/src/trace/layers/layer.rs b/crates/dbsp/src/trace/layers/layer.rs
@@ -820,7 +820,7 @@ where
                 (source2, lower2, upper2),
                 key_filter,
                 value_filter,
-                usize::max_value(),
+                usize::MAX,
             );
             // TODO: account for filtered out keys.
             effort = (self.vals.keys() - starting_updates) as isize;
diff --git a/crates/dbsp/src/trace/mod.rs b/crates/dbsp/src/trace/mod.rs
@@ -433,7 +433,7 @@ where
 
     /// Merges `self` with `other` by running merger to completion.
     fn merge(&self, other: &Self) -> Self {
-        let mut fuel = isize::max_value();
+        let mut fuel = isize::MAX;
         let mut merger = Self::Merger::new_merger(self, other);
         merger.work(self, other, &None, &None, &mut fuel);
         merger.done()
diff --git a/crates/dbsp/src/trace/spine_fueled.rs b/crates/dbsp/src/trace/spine_fueled.rs
@@ -703,7 +703,7 @@ where
 
     fn consolidate(mut self) -> Option<B> {
         // Merge batches until there is nothing left to merge.
-        let mut fuel = isize::max_value();
+        let mut fuel = isize::MAX;
         while !self.reduced() {
             self.exert(&mut fuel);
         }
@@ -1150,7 +1150,7 @@ where
     fn complete_merges(&mut self) {
         for merge_state in self.merging.iter_mut() {
             if merge_state.is_inprogress() {
-                let mut fuel = isize::max_value();
+                let mut fuel = isize::MAX;
                 merge_state.work(&self.key_filter, &self.value_filter, &mut fuel);
             }
         }
@@ -1346,7 +1346,7 @@ where
         key_filter: &Option<Filter<B::Key>>,
         value_filter: &Option<Filter<B::Val>>,
     ) -> Option<B> {
-        let mut fuel = isize::max_value();
+        let mut fuel = isize::MAX;
         self.work(key_filter, value_filter, &mut fuel);
         if let MergeVariant::Complete(batch) = self {
             batch

Original file line number	Diff line number	Diff line change
`@@ -591,7 +591,10 @@ where`
`591`	`591`	`local_node_id: self.local_node_id,`
`592`	`592`	`origin_node_id: self.origin_node_id.clone(),`
`593`	`593`	`circuit: self.circuit.clone(),`
`594`		`- val: std::mem::transmute(self.val.clone()),`
	`594`	`+ val: std::mem::transmute::<`
	`595`	`+ Rc<UnsafeCell<StreamValue<D>>>,`
	`596`	`+ Rc<UnsafeCell<StreamValue<D2>>>,`
	`597`	`+ >(self.val.clone()),`
`595`	`598`	`}`
`596`	`599`	`}`
`597`	`600`	`}`