log infos for devP2P infos that could not get processed.

Author: SurfingNerd

crates/ethcore/sync/src/chain/handler.rs

@@ -879,6 +879,7 @@ impl SyncHandler {
             // in the worst case we are refetching a transaction that we already have.
 
             if deadline.is_expired() {
+                debug!(target: "sync", "{}: deadline reached while processing pooled transactions", peer_id);
                 // we did run out of time to finish this opation, but thats Ok.
                 return Ok(());
             }

crates/ethcore/sync/src/chain/supplier.rs

@@ -323,7 +323,8 @@ impl SyncSupplier {
             if let Ok(hash) = v.as_val::<H256>() {
                 // io.chain().transaction(hash)
 
-                if !deadline.should_continue() {
+                if deadline.is_expired() {
+                    debug!(target: "sync", "{} -> GetPooledTransactions: deadline reached, only returning partial result to ", peer_id);
                     break;
                 }
 

crates/rpc/src/v1/tests/helpers/miner_service.rs

@@ -18,7 +18,8 @@
 
 use std::{
     collections::{BTreeMap, BTreeSet, HashMap},
-    sync::Arc, time::Duration,
+    sync::Arc,
+    time::Duration,
 };
 
 use crate::{
@@ -254,7 +255,11 @@ impl MinerService for TestMinerService {
             .map(|tx| Arc::new(VerifiedTransaction::from_pending_block_transaction(tx)))
     }
 
-    fn transaction_if_readable(&self, hash: &H256, max_duration: &Duration) -> Option<Arc<VerifiedTransaction>> {
+    fn transaction_if_readable(
+        &self,
+        hash: &H256,
+        max_duration: &Duration,
+    ) -> Option<Arc<VerifiedTransaction>> {
         self.pending_transactions
             .try_lock_for(*max_duration)?
             .get(hash)