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

Change replset tests to use non-static applyOperation

Browse Source
This commit is contained in:
Kristina 2011-11-12 11:06:30 -05:00
parent f511d1d300
commit 9b2d7f9c4c
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
dbtests/repltests.cpp
View File

@ -109,12 +109,6 @@ namespace ReplTests {
return count;
}
static void applyAllOperations() {
class Applier : public ReplSource {
public:
static void apply( const BSONObj &op ) {
ReplSource::applyOperation( op );
}
};
dblock lk;
vector< BSONObj > ops;
{
@ -124,8 +118,13 @@ namespace ReplTests {
}
{
Client::Context ctx( ns() );
for( vector< BSONObj >::iterator i = ops.begin(); i != ops.end(); ++i )
Applier::apply( *i );
BSONObjBuilder b;
b.append("host", "localhost");
b.appendTimestamp("syncedTo", 0);
ReplSource a(b.obj());
for( vector< BSONObj >::iterator i = ops.begin(); i != ops.end(); ++i ) {
a.applyOperation( *i );
}
}
}
static void printAll( const char *ns ) {
@ -1016,7 +1015,7 @@ namespace ReplTests {
ASSERT( !one( BSON( "_id" << 2 ) ).isEmpty() );
}
};
class DatabaseIgnorerBasic {
public:
void run() {
@ -1049,10 +1048,10 @@ namespace ReplTests {
d.doIgnoreUntilAfter( "a", OpTime( 5, 0 ) );
ASSERT( d.ignoreAt( "a", OpTime( 5, 5 ) ) );
ASSERT( d.ignoreAt( "a", OpTime( 6, 0 ) ) );
ASSERT( !d.ignoreAt( "a", OpTime( 6, 1 ) ) );
ASSERT( !d.ignoreAt( "a", OpTime( 6, 1 ) ) );
}
};
/**
* Check against oldest document in the oplog before scanning backward
* from the newest document.
@ -1077,7 +1076,7 @@ namespace ReplTests {
ASSERT_EQUALS( 0, fsc.cursor()->current()[ "o" ].Obj()[ "_id" ].Int() );
}
};
/** Check unsuccessful yield recovery with FindingStartCursor */
class FindingStartCursorYield : public Base {
public: