implemented pow multithreaded worker

Author: Wizdave97

client/consensus/pow/src/lib.rs

@@ -277,7 +277,7 @@ where
 		execution_context: ExecutionContext,
 	) -> Result<(), Error<B>> {
 		if *block.header().number() < self.check_inherents_after {
-			return Ok(());
+			return Ok(())
 		}
 
 		if let Err(e) = self.can_author_with.can_author_with(&block_id) {
@@ -287,7 +287,7 @@ where
 				e,
 			);
 
-			return Ok(());
+			return Ok(())
 		}
 
 		let inherent_data = inherent_data_providers
@@ -389,7 +389,7 @@ where
 			&inner_seal,
 			difficulty,
 		)? {
-			return Err(Error::<B>::InvalidSeal.into());
+			return Err(Error::<B>::InvalidSeal.into())
 		}
 
 		aux.difficulty = difficulty;
@@ -407,7 +407,7 @@ where
 							fetch_seal::<B>(best_header.digest().logs.last(), best_hash)?;
 
 						self.algorithm.break_tie(&best_inner_seal, &inner_seal)
-					}
+					},
 				},
 			));
 		}
@@ -437,20 +437,20 @@ impl<B: BlockT, Algorithm> PowVerifier<B, Algorithm> {
 		let hash = header.hash();
 
 		let (seal, inner_seal) = match header.digest_mut().pop() {
-			Some(DigestItem::Seal(id, seal)) => {
+			Some(DigestItem::Seal(id, seal)) => 
 				if id == POW_ENGINE_ID {
 					(DigestItem::Seal(id, seal.clone()), seal)
 				} else {
 					return Err(Error::WrongEngine(id));
 				}
-			}
+			
 			_ => return Err(Error::HeaderUnsealed(hash)),
 		};
 
 		let pre_hash = header.hash();
 
 		if !self.algorithm.preliminary_verify(&pre_hash, &inner_seal)?.unwrap_or(true) {
-			return Err(Error::FailedPreliminaryVerify);
+			return Err(Error::FailedPreliminaryVerify)
 		}
 
 		Ok((header, seal))
@@ -579,7 +579,7 @@ where
 
 			if sync_oracle.is_major_syncing() {
 				debug!(target: "pow", "Skipping proposal due to sync.");
-				continue;
+				continue
 			}
 
 			let best_header = match select_chain.best_chain().await {
@@ -591,7 +591,7 @@ where
 						 Select best chain error: {:?}",
 						err
 					);
-					continue;
+					continue
 				}
 			};
 			let best_hash = best_header.hash();
@@ -603,7 +603,7 @@ where
 					 Probably a node update is required!",
 					err,
 				);
-				continue;
+				continue
 			}
 
 			// The worker is locked for the duration of the whole proposing period. Within this
@@ -618,7 +618,7 @@ where
 						 Fetch difficulty failed: {:?}",
 						err,
 					);
-					continue;
+					continue
 				}
 			};
 
@@ -634,7 +634,7 @@ where
 						 Creating inherent data providers failed: {:?}",
 						err,
 					);
-					continue;
+					continue
 				}
 			};
 
@@ -647,7 +647,7 @@ where
 						 Creating inherent data failed: {:?}",
 						e,
 					);
-					continue;
+					continue
 				}
 			};
 
@@ -667,7 +667,7 @@ where
 						 Creating proposer failed: {:?}",
 						err,
 					);
-					continue;
+					continue
 				}
 			};
 
@@ -683,7 +683,7 @@ where
 						 Creating proposal failed: {:?}",
 						err,
 					);
-					continue;
+					continue
 				}
 			};
 
@@ -719,12 +719,12 @@ fn find_pre_digest<B: BlockT>(header: &B::Header) -> Result<Option<Vec<u8>>, Err
 	for log in header.digest().logs() {
 		trace!(target: "pow", "Checking log {:?}, looking for pre runtime digest", log);
 		match (log, pre_digest.is_some()) {
-			(DigestItem::PreRuntime(POW_ENGINE_ID, _), true) => {
-				return Err(Error::MultiplePreRuntimeDigests)
-			}
+			(DigestItem::PreRuntime(POW_ENGINE_ID, _), true) => 
+				return Err(Error::MultiplePreRuntimeDigests),
+			
 			(DigestItem::PreRuntime(POW_ENGINE_ID, v), false) => {
 				pre_digest = Some(v.clone());
-			}
+			},
 			(_, _) => trace!(target: "pow", "Ignoring digest not meant for us"),
 		}
 	}
@@ -742,7 +742,7 @@ fn fetch_seal<B: BlockT>(
 			if id == &POW_ENGINE_ID {
 				Ok(seal.clone())
 			} else {
-				return Err(Error::<B>::WrongEngine(*id).into());
+				return Err(Error::<B>::WrongEngine(*id).into())
 			}
 		}
 		_ => return Err(Error::<B>::HeaderUnsealed(hash).into()),