summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/directclienttests.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 00:22:50 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 10:56:02 -0400
commit9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch)
tree3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/dbtests/directclienttests.cpp
parent01965cf52bce6976637ecb8f4a622aeb05ab256a (diff)
downloadmongo-9c2ed42daa8fbbef4a919c21ec564e2db55e8d60.tar.gz
SERVER-18579: Clang-Format - reformat code, no comment reflow
Diffstat (limited to 'src/mongo/dbtests/directclienttests.cpp')
-rw-r--r--src/mongo/dbtests/directclienttests.cpp305
1 files changed, 153 insertions, 152 deletions
diff --git a/src/mongo/dbtests/directclienttests.cpp b/src/mongo/dbtests/directclienttests.cpp
index e7503413b9e..98e94d705ec 100644
--- a/src/mongo/dbtests/directclienttests.cpp
+++ b/src/mongo/dbtests/directclienttests.cpp
@@ -44,159 +44,160 @@
namespace DirectClientTests {
- using std::unique_ptr;
- using std::vector;
-
- class ClientBase {
- public:
- ClientBase() {
- mongo::LastError::get(cc()).reset();
- }
- virtual ~ClientBase() {
- mongo::LastError::get(cc()).reset();
- }
- };
-
- const char *ns = "a.b";
-
- class Capped : public ClientBase {
- public:
- virtual void run() {
- OperationContextImpl txn;
- DBDirectClient client(&txn);
- for( int pass=0; pass < 3; pass++ ) {
- client.createCollection(ns, 1024 * 1024, true, 999);
- for( int j =0; j < pass*3; j++ )
- client.insert(ns, BSON("x" << j));
-
- // test truncation of a capped collection
- if( pass ) {
- BSONObj info;
- BSONObj cmd = BSON( "captrunc" << "b" << "n" << 1 << "inc" << true );
- //cout << cmd.toString() << endl;
- bool ok = client.runCommand("a", cmd, info);
- //cout << info.toString() << endl;
- verify(ok);
- }
-
- verify( client.dropCollection(ns) );
+using std::unique_ptr;
+using std::vector;
+
+class ClientBase {
+public:
+ ClientBase() {
+ mongo::LastError::get(cc()).reset();
+ }
+ virtual ~ClientBase() {
+ mongo::LastError::get(cc()).reset();
+ }
+};
+
+const char* ns = "a.b";
+
+class Capped : public ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+ for (int pass = 0; pass < 3; pass++) {
+ client.createCollection(ns, 1024 * 1024, true, 999);
+ for (int j = 0; j < pass * 3; j++)
+ client.insert(ns, BSON("x" << j));
+
+ // test truncation of a capped collection
+ if (pass) {
+ BSONObj info;
+ BSONObj cmd = BSON("captrunc"
+ << "b"
+ << "n" << 1 << "inc" << true);
+ // cout << cmd.toString() << endl;
+ bool ok = client.runCommand("a", cmd, info);
+ // cout << info.toString() << endl;
+ verify(ok);
}
- }
- };
-
- class InsertMany : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- vector<BSONObj> objs;
- objs.push_back(BSON("_id" << 1));
- objs.push_back(BSON("_id" << 1));
- objs.push_back(BSON("_id" << 2));
-
- client.dropCollection(ns);
- client.insert(ns, objs);
- ASSERT_EQUALS(client.getLastErrorDetailed()["code"].numberInt(), 11000);
- ASSERT_EQUALS((int)client.count(ns), 1);
-
- client.dropCollection(ns);
- client.insert(ns, objs, InsertOption_ContinueOnError);
- ASSERT_EQUALS(client.getLastErrorDetailed()["code"].numberInt(), 11000);
- ASSERT_EQUALS((int)client.count(ns), 2);
- }
-
- };
-
- class BadNSCmd : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- BSONObj result;
- BSONObj cmdObj = BSON( "count" << "" );
- ASSERT_THROWS( client.runCommand( "", cmdObj, result ), UserException );
- }
- };
-
- class BadNSQuery : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- unique_ptr<DBClientCursor> cursor = client.query( "", Query(), 1 );
- ASSERT(cursor->more());
- BSONObj result = cursor->next().getOwned();
- ASSERT( result.hasField( "$err" ));
- ASSERT_EQUALS(result["code"].Int(), 16256);
+ verify(client.dropCollection(ns));
}
- };
-
- class BadNSGetMore : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- unique_ptr<DBClientCursor> cursor = client.getMore("", 1, 1);
- ASSERT(cursor->more());
- BSONObj result = cursor->next().getOwned();
- ASSERT(result.hasField("$err"));
- ASSERT_EQUALS(result["code"].Int(), 16258);
- }
- };
-
- class BadNSInsert : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- client.insert( "", BSONObj(), 0 );
- ASSERT( !client.getLastError().empty() );
- }
- };
-
- class BadNSUpdate : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- client.update( "", Query(), BSON( "$set" << BSON( "x" << 1 )) );
- ASSERT( !client.getLastError().empty() );
- }
- };
-
- class BadNSRemove : ClientBase {
- public:
- virtual void run(){
- OperationContextImpl txn;
- DBDirectClient client(&txn);
-
- client.remove( "", Query() );
- ASSERT( !client.getLastError().empty() );
- }
- };
-
- class All : public Suite {
- public:
- All() : Suite( "directclient" ) {
- }
- void setupTests() {
- add< Capped >();
- add< InsertMany >();
- add< BadNSCmd >();
- add< BadNSQuery >();
- add< BadNSGetMore >();
- add< BadNSInsert >();
- add< BadNSUpdate >();
- add< BadNSRemove >();
- }
- };
-
- SuiteInstance<All> myall;
+ }
+};
+
+class InsertMany : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ vector<BSONObj> objs;
+ objs.push_back(BSON("_id" << 1));
+ objs.push_back(BSON("_id" << 1));
+ objs.push_back(BSON("_id" << 2));
+
+
+ client.dropCollection(ns);
+ client.insert(ns, objs);
+ ASSERT_EQUALS(client.getLastErrorDetailed()["code"].numberInt(), 11000);
+ ASSERT_EQUALS((int)client.count(ns), 1);
+
+ client.dropCollection(ns);
+ client.insert(ns, objs, InsertOption_ContinueOnError);
+ ASSERT_EQUALS(client.getLastErrorDetailed()["code"].numberInt(), 11000);
+ ASSERT_EQUALS((int)client.count(ns), 2);
+ }
+};
+
+class BadNSCmd : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ BSONObj result;
+ BSONObj cmdObj = BSON("count"
+ << "");
+ ASSERT_THROWS(client.runCommand("", cmdObj, result), UserException);
+ }
+};
+
+class BadNSQuery : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ unique_ptr<DBClientCursor> cursor = client.query("", Query(), 1);
+ ASSERT(cursor->more());
+ BSONObj result = cursor->next().getOwned();
+ ASSERT(result.hasField("$err"));
+ ASSERT_EQUALS(result["code"].Int(), 16256);
+ }
+};
+
+class BadNSGetMore : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ unique_ptr<DBClientCursor> cursor = client.getMore("", 1, 1);
+ ASSERT(cursor->more());
+ BSONObj result = cursor->next().getOwned();
+ ASSERT(result.hasField("$err"));
+ ASSERT_EQUALS(result["code"].Int(), 16258);
+ }
+};
+
+class BadNSInsert : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ client.insert("", BSONObj(), 0);
+ ASSERT(!client.getLastError().empty());
+ }
+};
+
+class BadNSUpdate : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ client.update("", Query(), BSON("$set" << BSON("x" << 1)));
+ ASSERT(!client.getLastError().empty());
+ }
+};
+
+class BadNSRemove : ClientBase {
+public:
+ virtual void run() {
+ OperationContextImpl txn;
+ DBDirectClient client(&txn);
+
+ client.remove("", Query());
+ ASSERT(!client.getLastError().empty());
+ }
+};
+
+class All : public Suite {
+public:
+ All() : Suite("directclient") {}
+ void setupTests() {
+ add<Capped>();
+ add<InsertMany>();
+ add<BadNSCmd>();
+ add<BadNSQuery>();
+ add<BadNSGetMore>();
+ add<BadNSInsert>();
+ add<BadNSUpdate>();
+ add<BadNSRemove>();
+ }
+};
+
+SuiteInstance<All> myall;
}