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

Added a reorg to block.

Browse Source
This commit is contained in:
Chris Kleeschulte 2017-11-09 21:53:37 -05:00
parent 262cf8b850
commit 18a52c214d
No known key found for this signature in database
GPG Key ID: 33195D27EF6BDB7F
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/services/block/index.js
View File

@ -36,6 +36,7 @@ var BlockService = function(options) {
this._recentBlockHashes = new LRU(this._recentBlockHashesCount); this._recentBlockHashes = new LRU(this._recentBlockHashesCount);
this._readAheadBlockCount = options.readAheadBlockCount || 2; // this is the number of blocks to direct the p2p service to read aheead this._readAheadBlockCount = options.readAheadBlockCount || 2; // this is the number of blocks to direct the p2p service to read aheead
this._pauseSync = options.pause; this._pauseSync = options.pause;
this._reorgToBlock = options.reorgToBlock;
}; };
inherits(BlockService, BaseService); inherits(BlockService, BaseService);
@ -201,7 +202,7 @@ BlockService.prototype._checkTip = function(callback) {
header = header || self._header.getLastHeader(); header = header || self._header.getLastHeader();
if (header.hash === self._tip.hash) { if (header.hash === self._tip.hash && !self._reorgToBlock) {
log.info('Block Service: saved tip is good to go.'); log.info('Block Service: saved tip is good to go.');
return callback(); return callback();
} }
@ -652,6 +653,15 @@ BlockService.prototype._findLatestValidBlockHeader = function(callback) {
var self = this; var self = this;
if (self._reorgToBlock) {
return self._header.getBlockHeader(self._reorgToBlock, function(err, header) {
if (err || !header) {
return callback(err || new Error('Block Service: header not found to reorg to.'));
}
callback(null, header);
});
}
var blockServiceHash = self._tip.hash; var blockServiceHash = self._tip.hash;
var blockServiceHeight = self._tip.height; var blockServiceHeight = self._tip.height;
var iterCount = 0; var iterCount = 0;