xuemingqiang/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

some abstractions in prep for SHARDING-39

Browse Source
This commit is contained in:
Eliot Horowitz
2010-03-22 09:51:06 -04:00
parent f154df074d
commit 92dca86601
5 changed files with 58 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
scripting/sm_db.cpp
View File

@@ -144,11 +144,13 @@ namespace mongo {
string host = "127.0.0.1";
if ( argc > 0 )
host = c.toString( argv[0] );
int numCommas = DBClientBase::countCommas( host );
shared_ptr< DBClientWithCommands > conn;
string errmsg;
if ( host.find( "," ) == string::npos ){
if ( numCommas == 0 ){
DBClientConnection * c = new DBClientConnection( true );
conn.reset( c );
if ( ! c->connect( host , errmsg ) ){
@@ -157,30 +159,21 @@ namespace mongo {
}
ScriptEngine::runConnectCallback( *c );
}
else { // paired
int numCommas = 0;
for ( uint i=0; i<host.size(); i++ )
if ( host[i] == ',' )
numCommas++;
assert( numCommas > 0 );
if ( numCommas == 1 ){
DBClientPaired * c = new DBClientPaired();
conn.reset( c );
if ( ! c->connect( host ) ){
JS_ReportError( cx , "couldn't connect to pair" );
else if ( numCommas == 1 ){ // paired
DBClientPaired * c = new DBClientPaired();
conn.reset( c );
if ( ! c->connect( host ) ){
JS_ReportError( cx , "couldn't connect to pair" );
return JS_FALSE;
}
}
else if ( numCommas == 2 ){
conn.reset( new SyncClusterConnection( host ) );
}
else {
JS_ReportError( cx , "1 (paired) or 2(quorum) commas are allowed" );
return JS_FALSE;
}
}
else if ( numCommas == 2 ){
conn.reset( new SyncClusterConnection( host ) );
}
else {
JS_ReportError( cx , "1 (paired) or 2(quorum) commas are allowed" );
return JS_FALSE;
}
assert( JS_SetPrivate( cx , obj , (void*)( new shared_ptr< DBClientWithCommands >( conn ) ) ) );