This repository was archived by the owner on Nov 6, 2020. It is now read-only.
File tree Expand file tree Collapse file tree 5 files changed +5
-5
lines changed Expand file tree Collapse file tree 5 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -288,7 +288,7 @@ pub trait BlockChainClient:
288
288
fn block_transaction ( & self , id : TransactionId ) -> Option < LocalizedTransaction > ;
289
289
290
290
/// Get pool transaction with a given hash.
291
- fn pooled_transaction ( & self , hash : H256 ) -> Option < Arc < VerifiedTransaction > > ;
291
+ fn queued_transaction ( & self , hash : H256 ) -> Option < Arc < VerifiedTransaction > > ;
292
292
293
293
/// Get uncle with given id.
294
294
fn uncle ( & self , id : UncleId ) -> Option < encoded:: Header > ;
Original file line number Diff line number Diff line change @@ -1889,7 +1889,7 @@ impl BlockChainClient for Client {
1889
1889
self . transaction_address ( id) . and_then ( |address| self . chain . read ( ) . transaction ( & address) )
1890
1890
}
1891
1891
1892
- fn pooled_transaction ( & self , hash : H256 ) -> Option < Arc < VerifiedTransaction > > {
1892
+ fn queued_transaction ( & self , hash : H256 ) -> Option < Arc < VerifiedTransaction > > {
1893
1893
self . importer . miner . transaction ( & hash)
1894
1894
}
1895
1895
Original file line number Diff line number Diff line change @@ -741,7 +741,7 @@ impl BlockChainClient for TestBlockChainClient {
741
741
fn block_transaction ( & self , _id : TransactionId ) -> Option < LocalizedTransaction > {
742
742
None // Simple default.
743
743
}
744
- fn pooled_transaction ( & self , _hash : H256 ) -> Option < Arc < VerifiedTransaction > > {
744
+ fn queued_transaction ( & self , _hash : H256 ) -> Option < Arc < VerifiedTransaction > > {
745
745
None
746
746
}
747
747
Original file line number Diff line number Diff line change @@ -706,7 +706,7 @@ impl SyncHandler {
706
706
for item in tx_rlp {
707
707
let hash = item. as_val :: < H256 > ( ) . map_err ( |_| DownloaderImportError :: Invalid ) ?;
708
708
709
- if io. chain ( ) . pooled_transaction ( hash) . is_none ( ) {
709
+ if io. chain ( ) . queued_transaction ( hash) . is_none ( ) {
710
710
let unfetched = sync. unfetched_pooled_transactions . entry ( hash) . or_insert_with ( || super :: UnfetchedTransaction {
711
711
announcer : peer_id,
712
712
next_fetch : Instant :: now ( ) ,
Original file line number Diff line number Diff line change @@ -224,7 +224,7 @@ impl SyncSupplier {
224
224
const LIMIT : usize = 256 ;
225
225
226
226
let transactions = r. iter ( ) . take ( LIMIT ) . filter_map ( |v| {
227
- v. as_val :: < H256 > ( ) . ok ( ) . and_then ( |hash| io. chain ( ) . pooled_transaction ( hash) )
227
+ v. as_val :: < H256 > ( ) . ok ( ) . and_then ( |hash| io. chain ( ) . queued_transaction ( hash) )
228
228
} ) . collect :: < Vec < _ > > ( ) ;
229
229
230
230
let added = transactions. len ( ) ;
You can’t perform that action at this time.
0 commit comments