diff --git a/lib/services/db/sync.js b/lib/services/db/sync.js index ed9a5348..c2a0b24d 100644 --- a/lib/services/db/sync.js +++ b/lib/services/db/sync.js @@ -52,7 +52,7 @@ Sync.prototype.initialSync = function() { }; // Get concurrent and serial block operations and write them together block by block -// Useful for when we are fully synced and we want to advance the concurrentTip and +// Useful for when we are fully synced and we want to advance the concurrentTip and // the tip together Sync.prototype.sync = function() { if(this.syncing) { @@ -255,7 +255,7 @@ ProcessSerial.prototype._write = function(block, enc, callback) { return self._process(block, callback); } - self.db.once('concurrentblock', function() { + self.db.once('concurrentaddblock', function() { if(!check()) { var err = new Error('Concurrent block ' + self.db.concurrentTip.__height + ' is less than ' + block.__height); return self.emit('error', err); @@ -383,4 +383,4 @@ WriteStream.prototype._write = function(obj, enc, callback) { }); }; -module.exports = Sync; \ No newline at end of file +module.exports = Sync;