grassrootseconomics
/
openethereum
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Moving own transaction tracing to miner create

This commit is contained in:
Tomasz Drwięga 2016-04-17 20:36:37 +02:00
parent 8389f771e9
commit d093c5755e
2 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
miner/src/miner.rs
View File

@ -230,8 +230,23 @@ impl MinerService for Miner {
fn import_own_transaction<T>(&self, transaction: SignedTransaction, fetch_account: T) ->
Result<TransactionImportResult, Error>
where T: Fn(&Address) -> AccountDetails {
let hash = transaction.hash();
trace!(target: "own_tx", "Importing transaction: {:?}", transaction);
let mut transaction_queue = self.transaction_queue.lock().unwrap();
transaction_queue.add(transaction, &fetch_account)
let import = transaction_queue.add(transaction, &fetch_account);
match import {
Ok(ref res) => {
trace!(target: "own_tx", "Imported transaction to {:?} (hash: {:?})", res, hash);
trace!(target: "own_tx", "Status: {:?}", self.status());
},
Err(ref e) => {
trace!(target: "own_tx", "Failed to import transaction {:?} (hash: {:?})", e, hash);
trace!(target: "own_tx", "Status: {:?}", self.status());
},
}
import
}
fn pending_transactions_hashes(&self) -> Vec<H256> {

17
rpc/src/v1/impls/eth.rs
View File

@ -182,31 +182,22 @@ impl<C, S, A, M, EM> EthClient<C, S, A, M, EM>
fn dispatch_transaction(&self, signed_transaction: SignedTransaction) -> Result<Value, Error> {
let hash = signed_transaction.hash();
trace!(target: "tx", "Importing transaction: {:?}", signed_transaction);
let (import, status) = {
let import = {
let client = take_weak!(self.client);
let miner = take_weak!(self.miner);
let import = miner.import_own_transaction(signed_transaction, |a: &Address| {
miner.import_own_transaction(signed_transaction, |a: &Address| {
AccountDetails {
nonce: client.nonce(&a),
balance: client.balance(&a),
}
});
let status_after = miner.status();
(import, status_after)
})
};
match import {
Ok(res) => {
trace!(target: "tx", "Imported transaction to {:?} (hash: {:?})", res, hash);
trace!(target: "tx", "Status: {:?}", status);
to_value(&hash)
}
Ok(_) => to_value(&hash),
Err(e) => {
warn!("Error sending transaction: {:?}", e);
trace!(target: "tx", "Failed to import transaction {:?} (hash: {:?})", e, hash);
trace!(target: "tx", "Status: {:?}", status);
to_value(&H256::zero())
}
}