mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 00:56:44 +01:00
Code Issues Releases Activity

lock on setting AND getting rs state to prevent sporadic test failure

Browse Source
This commit is contained in:
Kristina 2011-07-29 15:08:18 -04:00
parent b02f72021a
commit d7dd936cb3
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
db/repl/rs.h
View File

@ -242,13 +242,19 @@ namespace mongo {
const Member *primary;
};
const SP get() {
scoped_lock lk(m);
rwlock lk(m, false);
return sp;
}
MemberState getState() const { return sp.state; }
const Member* getPrimary() const { return sp.primary; }
MemberState getState() const {
rwlock lk(m, false);
return sp.state;
}
const Member* getPrimary() const {
rwlock lk(m, false);
return sp.primary;
}
void change(MemberState s, const Member *self) {
scoped_lock lk(m);
rwlock lk(m, true);
if( sp.state != s ) {
log() << "replSet " << s.toString() << rsLog;
}
@ -262,24 +268,25 @@ namespace mongo {
}
}
void set(MemberState s, const Member *p) {
scoped_lock lk(m);
sp.state = s; sp.primary = p;
rwlock lk(m, true);
sp.state = s;
sp.primary = p;
}
void setSelfPrimary(const Member *self) { change(MemberState::RS_PRIMARY, self); }
void setOtherPrimary(const Member *mem) {
scoped_lock lk(m);
rwlock lk(m, true);
assert( !sp.state.primary() );
sp.primary = mem;
}
void noteRemoteIsPrimary(const Member *remote) {
scoped_lock lk(m);
rwlock lk(m, true);
if( !sp.state.secondary() && !sp.state.fatal() )
sp.state = MemberState::RS_RECOVERING;
sp.primary = remote;
}
StateBox() : m("StateBox") { }
private:
mongo::mutex m;
RWLock m;
SP sp;
};