Issue 4393: Correcting Unnecessary Use of Arc

node/core/dispute-coordinator/src/initialized.rs

@@ -916,7 +916,7 @@ impl Initialized {
 			} else {
 				self.metrics.on_queued_best_effort_participation();
 			}
-			let request_timer = Arc::new(self.metrics.time_participation_pipeline());
+			let request_timer = self.metrics.time_participation_pipeline();
 			let r = self
 				.participation
 				.queue_participation(

node/core/dispute-coordinator/src/lib.rs

@@ -347,7 +347,7 @@ impl DisputeCoordinatorSubsystem {
 						?candidate_hash,
 						"Found valid dispute, with no vote from us on startup - participating."
 					);
-					let request_timer = Arc::new(self.metrics.time_participation_pipeline());
+					let request_timer = self.metrics.time_participation_pipeline();
 					participation_requests.push((
 						ParticipationPriority::with_priority_if(is_included),
 						ParticipationRequest::new(

node/core/dispute-coordinator/src/participation/queues/mod.rs

@@ -14,7 +14,7 @@
 // You should have received a copy of the GNU General Public License
 // along with Polkadot.  If not, see <http://www.gnu.org/licenses/>.
 
-use std::{cmp::Ordering, collections::BTreeMap, sync::Arc};
+use std::{cmp::Ordering, collections::BTreeMap};
 
 use futures::channel::oneshot;
 use polkadot_node_subsystem::{messages::ChainApiMessage, overseer};
@@ -65,12 +65,12 @@ pub struct Queues {
 }
 
 /// A dispute participation request that can be queued.
-#[derive(Debug, Clone)]
+#[derive(Debug)]
 pub struct ParticipationRequest {
 	candidate_hash: CandidateHash,
 	candidate_receipt: CandidateReceipt,
 	session: SessionIndex,
-	_request_timer: Arc<Option<prometheus::HistogramTimer>>, // Sends metric data when request is dropped
+	_request_timer: Option<prometheus::HistogramTimer>, // Sends metric data when request is dropped
 }
 
 /// Whether a `ParticipationRequest` should be put on best-effort or the priority queue.
@@ -117,7 +117,7 @@ impl ParticipationRequest {
 	pub fn new(
 		candidate_receipt: CandidateReceipt,
 		session: SessionIndex,
-		request_timer: Arc<Option<prometheus::HistogramTimer>>,
+		request_timer: Option<prometheus::HistogramTimer>,
 	) -> Self {
 		Self {
 			candidate_hash: candidate_receipt.hash(),
@@ -142,8 +142,8 @@ impl ParticipationRequest {
 	}
 }
 
-// We want to compare participation requests in unit tests, so we
-// only implement Eq for tests.
+// We want to compare and clone participation requests in unit tests, so we
+// only implement Eq and Clone for tests.
 #[cfg(test)]
 impl PartialEq for ParticipationRequest {
 	fn eq(&self, other: &Self) -> bool {
@@ -160,6 +160,21 @@ impl PartialEq for ParticipationRequest {
 }
 #[cfg(test)]
 impl Eq for ParticipationRequest {}
+#[cfg(test)]
+impl Clone for ParticipationRequest {
+	fn clone(&self) -> Self {
+		ParticipationRequest {
+			candidate_receipt: self.candidate_receipt.clone(),
+			candidate_hash: self.candidate_hash.clone(),
+			session: self.session,
+			_request_timer: None,
+		}
+	}
+
+	fn clone_from(&mut self, source: &Self) {
+		*self = source.clone();
+	}
+}
 
 impl Queues {
 	/// Create new `Queues`.

node/core/dispute-coordinator/src/participation/queues/tests.rs

@@ -18,7 +18,6 @@ use crate::{metrics::Metrics, ParticipationPriority};
 use ::test_helpers::{dummy_candidate_receipt, dummy_hash};
 use assert_matches::assert_matches;
 use polkadot_primitives::{BlockNumber, Hash};
-use std::sync::Arc;
 
 use super::{CandidateComparator, ParticipationRequest, QueueError, Queues};
 
@@ -27,7 +26,7 @@ fn make_participation_request(hash: Hash) -> ParticipationRequest {
 	let mut receipt = dummy_candidate_receipt(dummy_hash());
 	// make it differ:
 	receipt.commitments_hash = hash;
-	let request_timer = Arc::new(Metrics::default().time_participation_pipeline());
+	let request_timer = Metrics::default().time_participation_pipeline();
 	ParticipationRequest::new(receipt, 1, request_timer)
 }
 

node/core/dispute-coordinator/src/participation/tests.rs

@@ -72,7 +72,7 @@ async fn participate_with_commitments_hash<Context>(
 	};
 	let session = 1;
 
-	let request_timer = Arc::new(participation.metrics.time_participation_pipeline());
+	let request_timer = participation.metrics.time_participation_pipeline();
 	let req = ParticipationRequest::new(candidate_receipt, session, request_timer);
 
 	participation