Merge pull request #370 from matiu/bug/11sync

Bug/11sync
This commit is contained in:
Matias Alejo Garcia 2014-02-18 15:56:34 -02:00
commit 37f8b6db9f
4 changed files with 21 additions and 6 deletions

View File

@ -17,16 +17,21 @@ module.exports.init = function(app, io_ext) {
module.exports.broadcastTx = function(tx) { module.exports.broadcastTx = function(tx) {
if (ios) { if (ios) {
var t = {}; var t;
if (typeof tx === 'string') { if (typeof tx === 'string') {
t = { t = {
txid: tx txid: tx
}; };
} else { }
t = tx;
else {
t = {
txid: tx.txid,
size: tx.size,
};
// Outputs // Outputs
var valueOut = 0; var valueOut = 0;
t.vout.forEach(function(o) { tx.vout.forEach(function(o) {
valueOut += o.value * util.COIN; valueOut += o.value * util.COIN;
}); });

View File

@ -53,7 +53,9 @@ if (!config.disableP2pSync) {
/** /**
* historic_sync process * historic_sync process
*/ */
var historicSync = new HistoricSync({ shouldBroadcastSync: true }); var historicSync = new HistoricSync({
shouldBroadcastSync: true
});
peerSync.historicSync = historicSync; peerSync.historicSync = historicSync;
if (!config.disableHistoricSync) { if (!config.disableHistoricSync) {

View File

@ -264,7 +264,12 @@ function spec() {
self.connectedCountDB > self.blockChainHeight * 0.9) return next(); self.connectedCountDB > self.blockChainHeight * 0.9) return next();
try {
self.blockExtractor = new BlockExtractor(config.bitcoind.dataDir, config.network); self.blockExtractor = new BlockExtractor(config.bitcoind.dataDir, config.network);
} catch (e) {
p(e.message + '. Disabling file sync.');
return next();
}
self.getFn = self.getBlockFromFile; self.getFn = self.getBlockFromFile;
self.allowReorgs = true; self.allowReorgs = true;
@ -407,6 +412,7 @@ function spec() {
else { else {
self.endTs = Date.now(); self.endTs = Date.now();
self.status = 'finished'; self.status = 'finished';
console.log('Done Syncing', self.info());
return w_cb(err); return w_cb(err);
} }
}); });

View File

@ -18,7 +18,9 @@ program
.option('-v --verbose', 'Verbose 0/1', 0) .option('-v --verbose', 'Verbose 0/1', 0)
.parse(process.argv); .parse(process.argv);
var historicSync = new HistoricSync(); var historicSync = new HistoricSync({
shouldBroadcastSync: true,
});
async.series([ async.series([