RanchiMall/node-open-mining-portal
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added check for dropkicked (self orphaned) blocks that have the same txHash

Browse Source
This commit is contained in:
Matt 2014-04-01 16:39:27 -06:00
parent 9938681fbc
commit dafb0a7a55
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
libs/paymentProcessor.js
View File

@ -123,9 +123,6 @@ function SetupForPool(logger, poolOptions, setupFinished){
/* Number.toFixed gives us the decimal places we want, but as a string. parseFloat turns it back into number /* Number.toFixed gives us the decimal places we want, but as a string. parseFloat turns it back into number
we don't care about trailing zeros in this case. */ we don't care about trailing zeros in this case. */
var toPrecision = function(value, precision){ var toPrecision = function(value, precision){
@ -194,14 +191,14 @@ function SetupForPool(logger, poolOptions, setupFinished){
txDetails.forEach(function(tx, i){ txDetails.forEach(function(tx, i){
var round = rounds[i]; var round = rounds[i];
if (tx.error && tx.error.code === -5){ if (tx.error && tx.error.code === -5 || round.solution !== tx.result.blockhash){
/* Block was dropped from coin daemon even after it happily accepted it earlier. */ /* Block was dropped from coin daemon even after it happily accepted it earlier. */
//If we find another block at the same height then this block was drop-kicked orphaned //If we find another block at the same height then this block was drop-kicked orphaned
var dropKicked = !!rounds.filter(function(r){ var dropKicked = rounds.filter(function(r){
return r.height === round.height && r.solution !== round.solution && r.category !== 'dropkicked'; return r.height === round.height && r.solution !== round.solution && r.category !== 'dropkicked';
}).length; }).length > 0;
if (dropKicked){ if (dropKicked){
logger.warning(logSystem, logComponent, logger.warning(logSystem, logComponent,
@ -536,8 +533,10 @@ function SetupForPool(logger, poolOptions, setupFinished){
finalizeRedisTx(); finalizeRedisTx();
var totalWorkers = Object.keys(workerPayments).length; var totalWorkers = Object.keys(workerPayments).length;
logger.debug(logSystem, logComponent, 'Payments sent, a total of ' + totalAmountUnits + ' ' + poolOptions.coin.symbol +
' was sent to ' + totalWorkers + ' miners'); logger.debug(logSystem, logComponent, 'Payments sent, a total of ' + totalAmountUnits
+ ' ' + poolOptions.coin.symbol + ' was sent to ' + totalWorkers + ' miners');
daemon.cmd('gettransaction', [results[0].response], function(results){ daemon.cmd('gettransaction', [results[0].response], function(results){
if (results[0].error){ if (results[0].error){
callback('Check finished - error with gettransaction ' + JSON.stringify(results[0].error)); callback('Check finished - error with gettransaction ' + JSON.stringify(results[0].error));
@ -595,11 +594,12 @@ function SetupForPool(logger, poolOptions, setupFinished){
daemon.cmd('sendmany', [processingConfig.feeCollectAccount, withdrawal], function(results){ daemon.cmd('sendmany', [processingConfig.feeCollectAccount, withdrawal], function(results){
if (results[0].error){ if (results[0].error){
logger.debug(logSystem, logComponent, 'Profit withdrawal finished - error with sendmany ' + JSON.stringify(results[0].error)); logger.debug(logSystem, logComponent, 'Profit withdrawal finished - error with sendmany '
+ JSON.stringify(results[0].error));
return; return;
} }
logger.debug(logSystem, logComponent, 'Profit sent, a total of ' + withdrawalAmount + ' ' + poolOptions.coin.symbol + logger.debug(logSystem, logComponent, 'Profit sent, a total of ' + withdrawalAmount
' was sent to ' + processingConfig.feeReceiveAddress); + ' ' + poolOptions.coin.symbol + ' was sent to ' + processingConfig.feeReceiveAddress);
}); });
} }
}); });