diff options
author | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 00:22:50 -0400 |
---|---|---|
committer | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 10:56:02 -0400 |
commit | 9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch) | |
tree | 3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/dbtests/directclienttests.cpp | |
parent | 01965cf52bce6976637ecb8f4a622aeb05ab256a (diff) | |
download | mongo-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.cpp | 305 |
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; } |