From 8493ede19e2883faa4e4e18a41d3204b73093d86 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20Bajto=C5=A1?= Date: Thu, 2 Apr 2015 14:14:32 +0200 Subject: [PATCH] Add missing error handlers to checkpoints() --- lib/persisted-model.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/persisted-model.js b/lib/persisted-model.js index f1df2656..36e84b30 100644 --- a/lib/persisted-model.js +++ b/lib/persisted-model.js @@ -976,13 +976,15 @@ function tryReplicate(sourceModel, targetModel, since, options, callback) { function checkpoints() { var cb = arguments[arguments.length - 1]; sourceModel.checkpoint(function(err, source) { + if (err) return cb(err); newSourceCp = source.seq; targetModel.checkpoint(function(err, target) { + if (err) return cb(err); newTargetCp = target.seq; debug('\tcreated checkpoints'); debug('\t\t%s for source model %s', newSourceCp, sourceModel.modelName); debug('\t\t%s for target model %s', newTargetCp, targetModel.modelName); - cb(err); + cb(); }); }); }