From f3fe79ab600db863b03766d2079ead61abfb924e Mon Sep 17 00:00:00 2001 From: psychobunny Date: Mon, 14 Apr 2014 13:52:14 -0400 Subject: [PATCH] initialize / shutdown dbs simultaneously --- src/database.js | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/src/database.js b/src/database.js index 66f503370f..8fcd8e0712 100644 --- a/src/database.js +++ b/src/database.js @@ -5,6 +5,7 @@ var nconf = require('nconf'), secondaryDBConfig = nconf.get('secondary_database'), secondaryModules = nconf.get('secondary_db_modules'), winston = require('winston'), + async = require('async'), ALLOWED_MODULES = ['hash', 'list', 'sets', 'sorted']; @@ -23,6 +24,17 @@ function setupSecondaryDB() { primaryDB[module] = secondaryDB[module]; } } + + var primaryDBinit = primaryDB.init, + primaryDBclose = primaryDB.close; + + primaryDB.init = function(callback) { + async.parallel([primaryDBinit, secondaryDB.init], callback); + }; + + primaryDB.close = function(callback) { + async.parallel([primaryDBclose, secondaryDB.close], callback); + }; }