1 files changed, 0 insertions, 132 deletions
diff --git a/src/mongo/client/examples/rs.cpp b/src/mongo/client/examples/rs.cpp
deleted file mode 100644
index db82509a7e8..00000000000
--- a/src/mongo/client/examples/rs.cpp
+++ /dev/null
@@ -1,132 +0,0 @@
-// rs.cpp
-
-/*    Copyright 2009 10gen Inc.
- *
- *    Licensed under the Apache License, Version 2.0 (the "License");
- *    you may not use this file except in compliance with the License.
- *    You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- *    Unless required by applicable law or agreed to in writing, software
- *    distributed under the License is distributed on an "AS IS" BASIS,
- *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *    See the License for the specific language governing permissions and
- *    limitations under the License.
- */
-
-/**
- * example of using replica sets from c++
- */
-
-#include <iostream>
-#include <vector>
-#include <boost/thread/thread.hpp>
-
-#include "mongo/client/dbclient.h"
-
-using namespace mongo;
-using namespace std;
-
-void workerThread( string collName , bool print , DBClientReplicaSet * conn ) {
-
-    while ( true ) {
-        try {
-            conn->update( collName , BSONObj() , BSON( "$inc" << BSON( "x" << 1 ) ) , true );
-            
-            BSONObj x = conn->findOne( collName , BSONObj() );
-
-            if ( print ) {
-                cout << x << endl;
-            }
-            
-            BSONObj a = conn->slaveConn().findOne( collName , BSONObj() , 0 , QueryOption_SlaveOk );
-            BSONObj b = conn->findOne( collName , BSONObj() , 0 , QueryOption_SlaveOk );
-            
-            if ( print ) {
-                cout << "\t A " << a << endl;
-                cout << "\t B " << b << endl;
-            }
-        }
-        catch ( std::exception& e ) {
-            cout << "ERROR: " << e.what() << endl;
-        }
-        sleepmillis( 10 );
-    }
-}
-
-int main( int argc , const char ** argv ) {
-    
-    unsigned nThreads = 1;
-    bool print = false;
-    bool testTimeout = false;
-
-    for ( int i=1; i<argc; i++ ) {
-        if ( mongoutils::str::equals( "--threads" , argv[i] ) ) {
-            nThreads = atoi( argv[++i] );
-        }
-        else if ( mongoutils::str::equals( "--print" , argv[i] ) ) {
-            print = true;
-        }
-        // Run a special mode to demonstrate the DBClientReplicaSet so_timeout option.
-        else if ( mongoutils::str::equals( "--testTimeout" , argv[i] ) ) {
-            testTimeout = true;
-        }
-        else {
-            cerr << "unknown option: " << argv[i] << endl;
-            return EXIT_FAILURE;
-        }
-            
-    }
-
-    Status status = client::initialize();
-    if ( !status.isOK() ) {
-        std::cout << "failed to initialize the client driver: " << status.toString() << endl;
-        return EXIT_FAILURE;
-    }
-
-    string errmsg;
-    ConnectionString cs = ConnectionString::parse( "foo/127.0.0.1" , errmsg );
-    if ( ! cs.isValid() ) {
-        cout << "error parsing url: " << errmsg << endl;
-        return EXIT_FAILURE;
-    }
-
-    DBClientReplicaSet * conn = static_cast<DBClientReplicaSet*>( cs.connect( errmsg, testTimeout ? 10 : 0 ) );
-    if ( ! conn ) {
-        cout << "error connecting: " << errmsg << endl;
-        return EXIT_FAILURE;
-    }
-
-    string collName = "test.rs1";
-
-    conn->dropCollection( collName );
-
-    if ( testTimeout ) {
-        conn->insert( collName, BSONObj() );
-        try {
-            conn->count( collName, BSON( "$where" << "sleep(40000)" ) );
-        } catch( DBException& ) {
-            return EXIT_SUCCESS;
-        }
-        cout << "expected socket exception" << endl;
-        return EXIT_FAILURE;
-    }
-    
-    vector<boost::shared_ptr<boost::thread> > threads;
-    for ( unsigned i=0; i<nThreads; i++ ) {
-        string errmsg;
-        threads.push_back( boost::shared_ptr<boost::thread>( 
-                               new boost::thread( 
-                                   boost::bind( workerThread , 
-                                                collName , 
-                                                print , 
-                                                static_cast<DBClientReplicaSet*>( cs.connect(errmsg) ) ) ) ) );
-    }
-    
-    for ( unsigned i=0; i<threads.size(); i++ ) {
-        threads[i]->join();
-    }
-
-    return EXIT_SUCCESS;
-}