summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/documentsourcetests.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/dbtests/documentsourcetests.cpp')
-rw-r--r--src/mongo/dbtests/documentsourcetests.cpp30
1 files changed, 0 insertions, 30 deletions
diff --git a/src/mongo/dbtests/documentsourcetests.cpp b/src/mongo/dbtests/documentsourcetests.cpp
index 58b0f957906..6972e8d7262 100644
--- a/src/mongo/dbtests/documentsourcetests.cpp
+++ b/src/mongo/dbtests/documentsourcetests.cpp
@@ -295,36 +295,6 @@ namespace DocumentSourceTests {
mutable boost::condition _condition;
};
- /** A writer client will be registered for the lifetime of an object of this class. */
- class WriterClientScope {
- public:
- WriterClientScope() :
- _state( Initial ),
- _dummyWriter( stdx::bind( &WriterClientScope::runDummyWriter, this ) ) {
- _state.await( Ready );
- }
- ~WriterClientScope() {
- // Terminate the writer thread even on exception.
- _state.set( Finished );
- DESTRUCTOR_GUARD( _dummyWriter.join() );
- }
- private:
- enum State {
- Initial,
- Ready,
- Finished
- };
- void runDummyWriter() {
- Client::initThread( "dummy writer" );
- scoped_ptr<Acquiring> a( new Acquiring( 0 , cc().lockState() ) );
- _state.set( Ready );
- _state.await( Finished );
- a.reset(0);
- cc().shutdown();
- }
- PendingValue _state;
- boost::thread _dummyWriter;
- };
/** Test coalescing a limit into a cursor */
class LimitCoalesce : public Base {