kylefang/deployd
1
0
Fork 0
mirror of https://github.com/zhigang1992/deployd.git synced 2026-05-22 20:37:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

added connection loader to db, fixes db connection race condition

Browse Source
This commit is contained in:
Ritchie
2011-12-28 12:35:02 -07:00
parent 2f60da5757
commit efc8f7d083
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
lib/db.js
View File

@@ -4,8 +4,8 @@ var config = require('./config')
, connectionString = config['db-host'] + config['db']
, Db = mongodb.Db
, Server = mongodb.Server
, server_config = new Server(config['db-host'], 27017, {auto_reconnect: true, native_parser: true})
, db = new Db(config['db'], server_config, {})
, server = new Server(config['db-host'], 27017, {auto_reconnect: true, native_parser: true})
, db = new Db(config['db'], server, {})
;
@@ -15,14 +15,15 @@ function ready(fn) {
, args = arguments
;
server_config.connected
server.state === 'connected'
? fn.apply(this, arguments)
: server_config.connect(db, function(err) {
if(err) console.log(err);
else {
fn.apply(_self, args);
}
})
: db.open(function(err) {
if(err) console.log(err);
else {
fn.apply(_self, args);
}
})
;
}
}