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

BUG SERVER-53 handle case where another mongod instance is treating our node as a peer even though our node is not configured for pairing

Browse Source
This commit is contained in:
Aaron 2009-05-27 13:55:30 -04:00
parent b8c3d46986
commit 8423cdf30f
1 changed files with 23 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
db/repl.cpp
View File

@ -327,6 +327,17 @@ namespace mongo {
{ ok:1, you_are:..., i_am:... }
*/
class CmdNegotiateMaster : public Command {
private:
static bool negotiating_;
struct ReentranceChecker {
ReentranceChecker() {
massert( "Another mongod instance believes incorrectly that this node is its peer", !CmdNegotiateMaster::negotiating_ );
CmdNegotiateMaster::negotiating_ = true;
}
~ReentranceChecker() {
CmdNegotiateMaster::negotiating_ = false;
}
};
public:
CmdNegotiateMaster() : Command("negotiatemaster") { }
virtual bool slaveOk() {
@ -337,6 +348,7 @@ namespace mongo {
}
virtual bool run(const char *ns, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool) {
ReentranceChecker c;
if ( replPair == 0 ) {
// assume that we are an arbiter and should forward the request
string host = cmdObj.getStringField("your_name");
@ -349,12 +361,16 @@ namespace mongo {
stringstream ss;
ss << host << ":" << port;
string remote = ss.str();
auto_ptr<DBClientConnection> conn( new DBClientConnection() );
if ( !conn->connect( remote.c_str(), errmsg ) ) {
result.append( "you_are", ReplPair::State_Master );
return true;
BSONObj ret;
{
dbtemprelease t;
auto_ptr<DBClientConnection> conn( new DBClientConnection() );
if ( !conn->connect( remote.c_str(), errmsg ) ) {
result.append( "you_are", ReplPair::State_Master );
return true;
}
ret = conn->findOne( "admin.$cmd", cmdObj );
}
BSONObj ret = conn->findOne( "admin.$cmd", cmdObj );
BSONObjIterator i( ret );
while( i.more() ) {
BSONElement e = i.next();
@ -401,6 +417,8 @@ namespace mongo {
}
} cmdnegotiatemaster;
bool CmdNegotiateMaster::negotiating_ = false;
int ReplPair::negotiate(DBClientConnection *conn, string method) {
BSONObjBuilder b;
b.append("negotiatemaster",1);