mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

Merge branch 'master' of github.com:mongodb/mongo

Browse Source
This commit is contained in:
Aaron 2010-05-13 11:09:34 -07:00
commit d7e538ba9f
1 changed files with 26 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
db/client.cpp
View File

@ -56,34 +56,35 @@ namespace mongo {
}
void Client::dropTempCollectionsInDB( const string db ) {
list<string>::iterator i = _tempCollections.begin();
while ( i!=_tempCollections.end() ) {
string ns = *i;
dblock l;
Client::Context ctx( ns );
if ( nsdetails( ns.c_str() ) &&
ns.compare( 0, db.length(), db ) == 0 ) {
try {
string err;
BSONObjBuilder b;
dropCollection( ns, err, b );
i = _tempCollections.erase(i);
++i;
}
catch ( ... ){
log() << "error dropping temp collection: " << ns << endl;
}
} else {
++i;
}
}
list<string>::iterator i = _tempCollections.begin();
while ( i!=_tempCollections.end() ) {
string ns = *i;
dblock l;
Client::Context ctx( ns );
if ( nsdetails( ns.c_str() ) &&
ns.compare( 0, db.length(), db ) == 0 ) {
try {
string err;
BSONObjBuilder b;
dropCollection( ns, err, b );
i = _tempCollections.erase(i);
if ( i!=_tempCollections.end() )
++i;
}
catch ( ... ){
log() << "error dropping temp collection: " << ns << endl;
}
} else {
++i;
}
}
}
void Client::dropAllTempCollectionsInDB(const string db) {
for ( set<Client*>::iterator i = clients.begin(); i!=clients.end(); i++ ){
Client* cli = *i;
cli->dropTempCollectionsInDB(db);
}
for ( set<Client*>::iterator i = clients.begin(); i!=clients.end(); i++ ){
Client* cli = *i;
cli->dropTempCollectionsInDB(db);
}
}
bool Client::shutdown(){