summaryrefslogtreecommitdiff
path: root/s/config.cpp
diff options
context:
space:
mode:
Diffstat (limited to 's/config.cpp')
-rw-r--r--s/config.cpp409
1 files changed, 219 insertions, 190 deletions
diff --git a/s/config.cpp b/s/config.cpp
index 1ad15d5..35a3be2 100644
--- a/s/config.cpp
+++ b/s/config.cpp
@@ -25,17 +25,17 @@
#include "../db/pdfile.h"
#include "../db/cmdline.h"
-#include "server.h"
-#include "config.h"
#include "chunk.h"
+#include "config.h"
#include "grid.h"
+#include "server.h"
namespace mongo {
int ConfigServer::VERSION = 3;
Shard Shard::EMPTY;
- string ShardNS::shard = "config.shards";
+ string ShardNS::shard = "config.shards";
string ShardNS::database = "config.databases";
string ShardNS::collection = "config.collections";
string ShardNS::chunk = "config.chunks";
@@ -45,42 +45,41 @@ namespace mongo {
BSONField<bool> ShardFields::draining("draining");
BSONField<long long> ShardFields::maxSize ("maxSize");
- BSONField<long long> ShardFields::currSize("currSize");
OID serverID;
/* --- DBConfig --- */
- DBConfig::CollectionInfo::CollectionInfo( DBConfig * db , const BSONObj& in ){
+ DBConfig::CollectionInfo::CollectionInfo( const BSONObj& in ) {
_dirty = false;
_dropped = in["dropped"].trueValue();
if ( in["key"].isABSONObj() )
- shard( db , in["_id"].String() , in["key"].Obj() , in["unique"].trueValue() );
+ shard( in["_id"].String() , in["key"].Obj() , in["unique"].trueValue() );
}
- void DBConfig::CollectionInfo::shard( DBConfig * db , const string& ns , const ShardKeyPattern& key , bool unique ){
- _cm.reset( new ChunkManager( db, ns , key , unique ) );
+ void DBConfig::CollectionInfo::shard( const string& ns , const ShardKeyPattern& key , bool unique ) {
+ _cm.reset( new ChunkManager( ns , key , unique ) );
_dirty = true;
_dropped = false;
}
- void DBConfig::CollectionInfo::unshard(){
+ void DBConfig::CollectionInfo::unshard() {
_cm.reset();
_dropped = true;
_dirty = true;
}
-
- void DBConfig::CollectionInfo::save( const string& ns , DBClientBase* conn ){
+
+ void DBConfig::CollectionInfo::save( const string& ns , DBClientBase* conn ) {
BSONObj key = BSON( "_id" << ns );
-
+
BSONObjBuilder val;
val.append( "_id" , ns );
val.appendDate( "lastmod" , time(0) );
val.appendBool( "dropped" , _dropped );
if ( _cm )
_cm->getInfo( val );
-
+
conn->update( ShardNS::collection , key , val.obj() , true );
string err = conn->getLastError();
uassert( 13473 , (string)"failed to save collection (" + ns + "): " + err , err.size() == 0 );
@@ -88,14 +87,14 @@ namespace mongo {
_dirty = false;
}
- bool DBConfig::isSharded( const string& ns ){
+ bool DBConfig::isSharded( const string& ns ) {
if ( ! _shardingEnabled )
return false;
scoped_lock lk( _lock );
return _isSharded( ns );
}
- bool DBConfig::_isSharded( const string& ns ){
+ bool DBConfig::_isSharded( const string& ns ) {
if ( ! _shardingEnabled )
return false;
Collections::iterator i = _collections.find( ns );
@@ -105,25 +104,28 @@ namespace mongo {
}
- const Shard& DBConfig::getShard( const string& ns ){
+ const Shard& DBConfig::getShard( const string& ns ) {
if ( isSharded( ns ) )
return Shard::EMPTY;
-
+
uassert( 10178 , "no primary!" , _primary.ok() );
return _primary;
}
-
- void DBConfig::enableSharding(){
+
+ void DBConfig::enableSharding() {
if ( _shardingEnabled )
return;
+
+ assert( _name != "config" );
+
scoped_lock lk( _lock );
- _shardingEnabled = true;
+ _shardingEnabled = true;
_save();
}
-
- ChunkManagerPtr DBConfig::shardCollection( const string& ns , ShardKeyPattern fieldsAndOrder , bool unique ){
+
+ ChunkManagerPtr DBConfig::shardCollection( const string& ns , ShardKeyPattern fieldsAndOrder , bool unique ) {
uassert( 8042 , "db doesn't have sharding enabled" , _shardingEnabled );
-
+
scoped_lock lk( _lock );
CollectionInfo& ci = _collections[ns];
@@ -131,35 +133,48 @@ namespace mongo {
log() << "enable sharding on: " << ns << " with shard key: " << fieldsAndOrder << endl;
- ci.shard( this , ns , fieldsAndOrder , unique );
- ci.getCM()->maybeChunkCollection();
-
+ // From this point on, 'ns' is going to be treated as a sharded collection. We assume this is the first
+ // time it is seen by the sharded system and thus create the first chunk for the collection. All the remaining
+ // chunks will be created as a by-product of splitting.
+ ci.shard( ns , fieldsAndOrder , unique );
+ ChunkManagerPtr cm = ci.getCM();
+ uassert( 13449 , "collections already sharded" , (cm->numChunks() == 0) );
+ cm->createFirstChunk( getPrimary() );
_save();
- return ci.getCM();
+
+ try {
+ cm->maybeChunkCollection();
+ }
+ catch ( UserException& e ) {
+ // failure to chunk is not critical enough to abort the command (and undo the _save()'d configDB state)
+ log() << "couldn't chunk recently created collection: " << ns << " " << e << endl;
+ }
+
+ return cm;
}
- bool DBConfig::removeSharding( const string& ns ){
- if ( ! _shardingEnabled ){
+ bool DBConfig::removeSharding( const string& ns ) {
+ if ( ! _shardingEnabled ) {
return false;
}
-
+
scoped_lock lk( _lock );
-
+
Collections::iterator i = _collections.find( ns );
if ( i == _collections.end() )
return false;
-
+
CollectionInfo& ci = _collections[ns];
if ( ! ci.isSharded() )
return false;
-
+
ci.unshard();
_save();
return true;
}
-
- ChunkManagerPtr DBConfig::getChunkManager( const string& ns , bool shouldReload ){
+
+ ChunkManagerPtr DBConfig::getChunkManager( const string& ns , bool shouldReload ) {
scoped_lock lk( _lock );
if ( shouldReload )
@@ -170,93 +185,80 @@ namespace mongo {
return ci.getCM();
}
- void DBConfig::setPrimary( string s ){
+ void DBConfig::setPrimary( string s ) {
scoped_lock lk( _lock );
_primary.reset( s );
_save();
}
-
- void DBConfig::serialize(BSONObjBuilder& to){
+
+ void DBConfig::serialize(BSONObjBuilder& to) {
to.append("_id", _name);
to.appendBool("partitioned", _shardingEnabled );
to.append("primary", _primary.getName() );
}
-
- bool DBConfig::unserialize(const BSONObj& from){
+
+ void DBConfig::unserialize(const BSONObj& from) {
log(1) << "DBConfig unserialize: " << _name << " " << from << endl;
assert( _name == from["_id"].String() );
_shardingEnabled = from.getBoolField("partitioned");
_primary.reset( from.getStringField("primary") );
- // this is a temporary migration thing
+ // In the 1.5.x series, we used to have collection metadata nested in the database entry. The 1.6.x series
+ // had migration code that ported that info to where it belongs now: the 'collections' collection. We now
+ // just assert that we're not migrating from a 1.5.x directly into a 1.7.x without first converting.
BSONObj sharded = from.getObjectField( "sharded" );
- if ( sharded.isEmpty() )
- return false;
-
- BSONObjIterator i(sharded);
- while ( i.more() ){
- BSONElement e = i.next();
- uassert( 10182 , "sharded things have to be objects" , e.type() == Object );
-
- BSONObj c = e.embeddedObject();
- uassert( 10183 , "key has to be an object" , c["key"].type() == Object );
-
- _collections[e.fieldName()].shard( this , e.fieldName() , c["key"].Obj() , c["unique"].trueValue() );
- }
- return true;
+ if ( ! sharded.isEmpty() )
+ uasserted( 13509 , "can't migrate from 1.5.x release to the current one; need to upgrade to 1.6.x first");
}
- bool DBConfig::load(){
+ bool DBConfig::load() {
scoped_lock lk( _lock );
return _load();
}
- bool DBConfig::_load(){
+ bool DBConfig::_load() {
ScopedDbConnection conn( configServer.modelServer() );
-
- BSONObj o = conn->findOne( ShardNS::database , BSON( "_id" << _name ) );
+ BSONObj o = conn->findOne( ShardNS::database , BSON( "_id" << _name ) );
- if ( o.isEmpty() ){
+ if ( o.isEmpty() ) {
conn.done();
return false;
}
-
- if ( unserialize( o ) )
- _save();
-
+
+ unserialize( o );
+
BSONObjBuilder b;
b.appendRegex( "_id" , (string)"^" + _name + "." );
-
auto_ptr<DBClientCursor> cursor = conn->query( ShardNS::collection ,b.obj() );
assert( cursor.get() );
- while ( cursor->more() ){
+ while ( cursor->more() ) {
BSONObj o = cursor->next();
- _collections[o["_id"].String()] = CollectionInfo( this , o );
+ _collections[o["_id"].String()] = CollectionInfo( o );
}
-
- conn.done();
+
+ conn.done();
return true;
}
- void DBConfig::_save(){
+ void DBConfig::_save() {
ScopedDbConnection conn( configServer.modelServer() );
-
+
BSONObj n;
{
BSONObjBuilder b;
serialize(b);
n = b.obj();
}
-
+
conn->update( ShardNS::database , BSON( "_id" << _name ) , n , true );
string err = conn->getLastError();
uassert( 13396 , (string)"DBConfig save failed: " + err , err.size() == 0 );
-
- for ( Collections::iterator i=_collections.begin(); i!=_collections.end(); ++i ){
+
+ for ( Collections::iterator i=_collections.begin(); i!=_collections.end(); ++i ) {
if ( ! i->second.isDirty() )
continue;
i->second.save( i->first , conn.get() );
@@ -265,18 +267,17 @@ namespace mongo {
conn.done();
}
-
- bool DBConfig::reload(){
+ bool DBConfig::reload() {
scoped_lock lk( _lock );
return _reload();
}
-
- bool DBConfig::_reload(){
+
+ bool DBConfig::_reload() {
// TODO: i don't think is 100% correct
return _load();
}
-
- bool DBConfig::dropDatabase( string& errmsg ){
+
+ bool DBConfig::dropDatabase( string& errmsg ) {
/**
* 1) make sure everything is up
* 2) update config server
@@ -287,81 +288,88 @@ namespace mongo {
log() << "DBConfig::dropDatabase: " << _name << endl;
configServer.logChange( "dropDatabase.start" , _name , BSONObj() );
-
+
// 1
- if ( ! configServer.allUp( errmsg ) ){
+ if ( ! configServer.allUp( errmsg ) ) {
log(1) << "\t DBConfig::dropDatabase not all up" << endl;
return 0;
}
-
+
// 2
grid.removeDB( _name );
{
ScopedDbConnection conn( configServer.modelServer() );
conn->remove( ShardNS::database , BSON( "_id" << _name ) );
+ errmsg = conn->getLastError();
+ if ( ! errmsg.empty() ) {
+ log() << "could not drop '" << _name << "': " << errmsg << endl;
+ conn.done();
+ return false;
+ }
+
conn.done();
}
- if ( ! configServer.allUp( errmsg ) ){
+ if ( ! configServer.allUp( errmsg ) ) {
log() << "error removing from config server even after checking!" << endl;
return 0;
}
log(1) << "\t removed entry from config server for: " << _name << endl;
-
+
set<Shard> allServers;
// 3
- while ( true ){
- int num;
+ while ( true ) {
+ int num = 0;
if ( ! _dropShardedCollections( num , allServers , errmsg ) )
return 0;
log() << " DBConfig::dropDatabase: " << _name << " dropped sharded collections: " << num << endl;
if ( num == 0 )
break;
}
-
+
// 4
{
ScopedDbConnection conn( _primary );
BSONObj res;
- if ( ! conn->dropDatabase( _name , &res ) ){
+ if ( ! conn->dropDatabase( _name , &res ) ) {
errmsg = res.toString();
return 0;
}
conn.done();
}
-
+
// 5
- for ( set<Shard>::iterator i=allServers.begin(); i!=allServers.end(); i++ ){
+ for ( set<Shard>::iterator i=allServers.begin(); i!=allServers.end(); i++ ) {
ScopedDbConnection conn( *i );
BSONObj res;
- if ( ! conn->dropDatabase( _name , &res ) ){
+ if ( ! conn->dropDatabase( _name , &res ) ) {
errmsg = res.toString();
return 0;
}
- conn.done();
+ conn.done();
}
-
+
log(1) << "\t dropped primary db for: " << _name << endl;
configServer.logChange( "dropDatabase" , _name , BSONObj() );
return true;
}
- bool DBConfig::_dropShardedCollections( int& num, set<Shard>& allServers , string& errmsg ){
+ bool DBConfig::_dropShardedCollections( int& num, set<Shard>& allServers , string& errmsg ) {
num = 0;
set<string> seen;
- while ( true ){
+ while ( true ) {
Collections::iterator i = _collections.begin();
- for ( ; i != _collections.end(); ++i ){
+ for ( ; i != _collections.end(); ++i ) {
if ( i->second.isSharded() )
break;
}
-
+
if ( i == _collections.end() )
break;
- if ( seen.count( i->first ) ){
+ if ( seen.count( i->first ) ) {
errmsg = "seen a collection twice!";
return false;
}
@@ -371,19 +379,20 @@ namespace mongo {
i->second.getCM()->getAllShards( allServers );
i->second.getCM()->drop( i->second.getCM() );
-
+ uassert( 10176 , str::stream() << "shard state missing for " << i->first , removeSharding( i->first ) );
+
num++;
uassert( 10184 , "_dropShardedCollections too many collections - bailing" , num < 100000 );
log(2) << "\t\t dropped " << num << " so far" << endl;
}
-
+
return true;
}
-
- void DBConfig::getAllShards(set<Shard>& shards) const{
+
+ void DBConfig::getAllShards(set<Shard>& shards) const {
shards.insert(getPrimary());
- for (Collections::const_iterator it(_collections.begin()), end(_collections.end()); it != end; ++it){
- if (it->second.isSharded()){
+ for (Collections::const_iterator it(_collections.begin()), end(_collections.end()); it != end; ++it) {
+ if (it->second.isSharded()) {
it->second.getCM()->getAllShards(shards);
} // TODO: handle collections on non-primary shard
}
@@ -391,20 +400,20 @@ namespace mongo {
/* --- ConfigServer ---- */
- ConfigServer::ConfigServer() : DBConfig( "config" ){
+ ConfigServer::ConfigServer() : DBConfig( "config" ) {
_shardingEnabled = false;
}
-
+
ConfigServer::~ConfigServer() {
}
- bool ConfigServer::init( string s ){
+ bool ConfigServer::init( string s ) {
vector<string> configdbs;
splitStringDelim( s, &configdbs, ',' );
return init( configdbs );
}
- bool ConfigServer::init( vector<string> configHosts ){
+ bool ConfigServer::init( vector<string> configHosts ) {
uassert( 10187 , "need configdbs" , configHosts.size() );
string hn = getHostName();
@@ -412,19 +421,19 @@ namespace mongo {
sleepsecs(5);
dbexit( EXIT_BADOPTIONS );
}
-
+
set<string> hosts;
- for ( size_t i=0; i<configHosts.size(); i++ ){
+ for ( size_t i=0; i<configHosts.size(); i++ ) {
string host = configHosts[i];
hosts.insert( getHost( host , false ) );
configHosts[i] = getHost( host , true );
}
-
- for ( set<string>::iterator i=hosts.begin(); i!=hosts.end(); i++ ){
+
+ for ( set<string>::iterator i=hosts.begin(); i!=hosts.end(); i++ ) {
string host = *i;
bool ok = false;
- for ( int x=10; x>0; x-- ){
- if ( ! hostbyname( host.c_str() ).empty() ){
+ for ( int x=10; x>0; x-- ) {
+ if ( ! hostbyname( host.c_str() ).empty() ) {
ok = true;
break;
}
@@ -436,10 +445,10 @@ namespace mongo {
}
_config = configHosts;
-
+
string fullString;
joinStringDelim( configHosts, &fullString, ',' );
- _primary.setAddress( fullString , true );
+ _primary.setAddress( ConnectionString( fullString , ConnectionString::SYNC ) );
log(1) << " config string : " << fullString << endl;
return true;
@@ -448,14 +457,14 @@ namespace mongo {
bool ConfigServer::checkConfigServersConsistent( string& errmsg , int tries ) const {
if ( _config.size() == 1 )
return true;
-
+
if ( tries <= 0 )
return false;
-
+
unsigned firstGood = 0;
int up = 0;
vector<BSONObj> res;
- for ( unsigned i=0; i<_config.size(); i++ ){
+ for ( unsigned i=0; i<_config.size(); i++ ) {
BSONObj x;
try {
ScopedDbConnection conn( _config[i] );
@@ -469,125 +478,125 @@ namespace mongo {
}
conn.done();
}
- catch ( std::exception& ){
- log(LL_WARNING) << " couldn't check on config server:" << _config[i] << " ok for now" << endl;
+ catch ( SocketException& e ) {
+ warning() << " couldn't check on config server:" << _config[i] << " ok for now : " << e.toString() << endl;
}
res.push_back(x);
}
- if ( up == 0 ){
+ if ( up == 0 ) {
errmsg = "no config servers reachable";
return false;
}
- if ( up == 1 ){
+ if ( up == 1 ) {
log( LL_WARNING ) << "only 1 config server reachable, continuing" << endl;
return true;
}
BSONObj base = res[firstGood];
- for ( unsigned i=firstGood+1; i<res.size(); i++ ){
+ for ( unsigned i=firstGood+1; i<res.size(); i++ ) {
if ( res[i].isEmpty() )
continue;
string c1 = base.getFieldDotted( "collections.chunks" );
string c2 = res[i].getFieldDotted( "collections.chunks" );
-
+
string d1 = base.getFieldDotted( "collections.databases" );
string d2 = res[i].getFieldDotted( "collections.databases" );
if ( c1 == c2 && d1 == d2 )
continue;
-
+
stringstream ss;
ss << "config servers " << _config[firstGood] << " and " << _config[i] << " differ";
log( LL_WARNING ) << ss.str();
- if ( tries <= 1 ){
+ if ( tries <= 1 ) {
ss << "\n" << c1 << "\t" << c2 << "\n" << d1 << "\t" << d2;
errmsg = ss.str();
return false;
}
-
+
return checkConfigServersConsistent( errmsg , tries - 1 );
}
-
+
return true;
}
- bool ConfigServer::ok( bool checkConsistency ){
+ bool ConfigServer::ok( bool checkConsistency ) {
if ( ! _primary.ok() )
return false;
-
- if ( checkConsistency ){
+
+ if ( checkConsistency ) {
string errmsg;
- if ( ! checkConfigServersConsistent( errmsg ) ){
+ if ( ! checkConfigServersConsistent( errmsg ) ) {
log( LL_ERROR ) << "config servers not in sync! " << errmsg << endl;
return false;
}
}
-
+
return true;
}
- bool ConfigServer::allUp(){
+ bool ConfigServer::allUp() {
string errmsg;
return allUp( errmsg );
}
-
- bool ConfigServer::allUp( string& errmsg ){
+
+ bool ConfigServer::allUp( string& errmsg ) {
try {
ScopedDbConnection conn( _primary );
conn->getLastError();
conn.done();
return true;
}
- catch ( DBException& ){
+ catch ( DBException& ) {
log() << "ConfigServer::allUp : " << _primary.toString() << " seems down!" << endl;
errmsg = _primary.toString() + " seems down";
return false;
}
-
+
}
-
- int ConfigServer::dbConfigVersion(){
+
+ int ConfigServer::dbConfigVersion() {
ScopedDbConnection conn( _primary );
int version = dbConfigVersion( conn.conn() );
conn.done();
return version;
}
-
- int ConfigServer::dbConfigVersion( DBClientBase& conn ){
+
+ int ConfigServer::dbConfigVersion( DBClientBase& conn ) {
auto_ptr<DBClientCursor> c = conn.query( "config.version" , BSONObj() );
int version = 0;
- if ( c->more() ){
+ if ( c->more() ) {
BSONObj o = c->next();
version = o["version"].numberInt();
uassert( 10189 , "should only have 1 thing in config.version" , ! c->more() );
}
else {
- if ( conn.count( ShardNS::shard ) || conn.count( ShardNS::database ) ){
+ if ( conn.count( ShardNS::shard ) || conn.count( ShardNS::database ) ) {
version = 1;
}
}
-
+
return version;
}
-
- void ConfigServer::reloadSettings(){
+
+ void ConfigServer::reloadSettings() {
set<string> got;
-
+
ScopedDbConnection conn( _primary );
auto_ptr<DBClientCursor> c = conn->query( ShardNS::settings , BSONObj() );
assert( c.get() );
- while ( c->more() ){
+ while ( c->more() ) {
BSONObj o = c->next();
string name = o["_id"].valuestrsafe();
got.insert( name );
- if ( name == "chunksize" ){
+ if ( name == "chunksize" ) {
log(1) << "MaxChunkSize: " << o["value"] << endl;
Chunk::MaxChunkSize = o["value"].numberInt() * 1024 * 1024;
}
- else if ( name == "balancer" ){
+ else if ( name == "balancer" ) {
// ones we ignore here
}
else {
@@ -595,12 +604,12 @@ namespace mongo {
}
}
- if ( ! got.count( "chunksize" ) ){
+ if ( ! got.count( "chunksize" ) ) {
conn->insert( ShardNS::settings , BSON( "_id" << "chunksize" <<
"value" << (Chunk::MaxChunkSize / ( 1024 * 1024 ) ) ) );
}
-
-
+
+
// indexes
try {
conn->ensureIndex( ShardNS::chunk , BSON( "ns" << 1 << "min" << 1 ) , true );
@@ -608,66 +617,86 @@ namespace mongo {
conn->ensureIndex( ShardNS::chunk , BSON( "ns" << 1 << "lastmod" << 1 ) , true );
conn->ensureIndex( ShardNS::shard , BSON( "host" << 1 ) , true );
}
- catch ( std::exception& e ){
+ catch ( std::exception& e ) {
log( LL_WARNING ) << "couldn't create indexes on config db: " << e.what() << endl;
}
conn.done();
}
- string ConfigServer::getHost( string name , bool withPort ){
- if ( name.find( ":" ) != string::npos ){
+ string ConfigServer::getHost( string name , bool withPort ) {
+ if ( name.find( ":" ) != string::npos ) {
if ( withPort )
return name;
return name.substr( 0 , name.find( ":" ) );
}
- if ( withPort ){
+ if ( withPort ) {
stringstream ss;
ss << name << ":" << CmdLine::ConfigServerPort;
return ss.str();
}
-
+
return name;
}
- void ConfigServer::logChange( const string& what , const string& ns , const BSONObj& detail ){
- assert( _primary.ok() );
+ /* must never throw */
+ void ConfigServer::logChange( const string& what , const string& ns , const BSONObj& detail ) {
+ string changeID;
- static bool createdCapped = false;
- static AtomicUInt num;
-
- ScopedDbConnection conn( _primary );
-
- if ( ! createdCapped ){
- try {
- conn->createCollection( "config.changelog" , 1024 * 1024 * 10 , true );
- }
- catch ( UserException& e ){
- log(1) << "couldn't create changelog (like race condition): " << e << endl;
- // don't care
+ try {
+ // get this entry's ID so we can use on the exception code path too
+ stringstream id;
+ static AtomicUInt num;
+ id << getHostNameCached() << "-" << terseCurrentTime() << "-" << num++;
+ changeID = id.str();
+
+ // send a copy of the message to the log in case it doesn't manage to reach config.changelog
+ Client* c = currentClient.get();
+ BSONObj msg = BSON( "_id" << changeID << "server" << getHostNameCached() << "clientAddr" << (c ? c->clientAddress(true) : "N/A")
+ << "time" << DATENOW << "what" << what << "ns" << ns << "details" << detail );
+ log() << "about to log metadata event: " << msg << endl;
+
+ assert( _primary.ok() );
+
+ ScopedDbConnection conn( _primary );
+
+ static bool createdCapped = false;
+ if ( ! createdCapped ) {
+ try {
+ conn->createCollection( "config.changelog" , 1024 * 1024 * 10 , true );
+ }
+ catch ( UserException& e ) {
+ log(1) << "couldn't create changelog (like race condition): " << e << endl;
+ // don't care
+ }
+ createdCapped = true;
}
- createdCapped = true;
+
+ conn->insert( "config.changelog" , msg );
+
+ conn.done();
+
}
-
- stringstream id;
- id << getHostNameCached() << "-" << terseCurrentTime() << "-" << num++;
- BSONObj msg = BSON( "_id" << id.str() << "server" << getHostNameCached() << "time" << DATENOW <<
- "what" << what << "ns" << ns << "details" << detail );
- log() << "config change: " << msg << endl;
+ catch ( std::exception& e ) {
+ // if we got here, it means the config change is only in the log; it didn't make it to config.changelog
+ log() << "not logging config change: " << changeID << " " << e.what() << endl;
+ }
+ }
+ void ConfigServer::replicaSetChange( const ReplicaSetMonitor * monitor ) {
try {
- conn->insert( "config.changelog" , msg );
+ ScopedDbConnection conn( configServer.getConnectionString() );
+ conn->update( ShardNS::shard , BSON( "_id" << monitor->getName() ) , BSON( "$set" << BSON( "host" << monitor->getServerAddress() ) ) );
+ conn.done();
}
- catch ( std::exception& e ){
- log() << "not logging config change: " << e.what() << endl;
+ catch ( DBException & ) {
+ error() << "RSChangeWatcher: could not update config db for set: " << monitor->getName() << " to: " << monitor->getServerAddress() << endl;
}
-
- conn.done();
}
- DBConfigPtr configServerPtr (new ConfigServer());
- ConfigServer& configServer = dynamic_cast<ConfigServer&>(*configServerPtr);
+ DBConfigPtr configServerPtr (new ConfigServer());
+ ConfigServer& configServer = dynamic_cast<ConfigServer&>(*configServerPtr);
-}
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-03 00:36:54 +0000