com.allanbank.mongodb.client.connection.socket

Class TwoThreadSocketConnectionTest

java.lang.Object

com.allanbank.mongodb.client.connection.socket.TwoThreadSocketConnectionTest

public class TwoThreadSocketConnectionTest
extends Object

TwoThreadSocketConnectionTest provides tests for the TwoThreadSocketConnection class.

Copyright ©:

2011-2014, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

Constructor and Description
TwoThreadSocketConnectionTest()

Method Summary

Methods

Modifier and Type	Method and Description
void	setUp() Sets up a test Server.
static void	setUpBeforeClass() Starts a Mock MongoDB server.
void	tearDown() Cleans up the test connection.
static void	tearDownAfterClass() Stops a Mock MongoDB server.
void	testClose() Test method for TwoThreadSocketConnection.close().
void	testConnectionLost() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testGetLastError() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testGetLastErrorWithFsync() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testGetLastErrorWithJ() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testGetLastErrorWithW() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testGetMore() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testInsertMulti() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testInsertSingle() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testKillCursor() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testMultiDelete() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQuery() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryAwaitData() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryExhaust() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryNoCursorTimeout() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryPartial() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQuerySecondaryPreference() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryTailable() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testQueryWithFields() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testRaiseError() Test method for TwoThreadSocketConnection.raiseErrors(MongoDbException) .
void	testRead() Test method for TwoThreadSocketConnection.
void	testRead2() Test method for SocketConnection.
void	testReadGarbage() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testReadNonReply() Test method for TwoThreadSocketConnection.
void	testReadStuff() Test method for TwoThreadSocketConnection.
void	testSendError() Test method for TwoThreadSocketConnection.close().
void	testSendFailureClose() Test method for TwoThreadSocketConnection.close().
void	testSendRuntimeException() Test method for TwoThreadSocketConnection.close().
void	testServerClose() Test method for TwoThreadSocketConnection.close().
void	testShutdown() Test method for AbstractSocketConnection.shutdown(boolean) .
void	testSingleDelete() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testSocketConnectNotifiesFactoryOfConnect() Test method for SocketConnection.SocketConnection(Server, MongoClientConfiguration) .
void	testSocketConnectNotifiesFactoryOfConnectWhichThrows() Test method for SocketConnection.SocketConnection(Server, MongoClientConfiguration) .
void	testStop() Test method for AbstractSocketConnection.stop() .
void	testTwoThreadSocketConnection() Test method for TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration) .
void	testTwoThreadSocketConnectionFailure() Test method for TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration) .
void	testUpdate() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testUpdateMulti() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .
void	testUpdateUpsert() Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TwoThreadSocketConnectionTest

public TwoThreadSocketConnectionTest()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws IOException

Starts a Mock MongoDB server.

Throws:

IOException - On a failure to start the Mock MongoDB server.

tearDownAfterClass

public static void tearDownAfterClass()
                               throws IOException

Stops a Mock MongoDB server.

Throws:

IOException - On a failure to stop the Mock MongoDB server.

setUp

public void setUp()

Sets up a test Server.

tearDown

public void tearDown()
              throws IOException

Cleans up the test connection.

Throws:

IOException - On a failure to shutdown the test connection.

testClose

public void testClose()
               throws IOException

Test method for TwoThreadSocketConnection.close().

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testConnectionLost

public void testConnectionLost()
                        throws IOException,
                               InterruptedException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure to sleep.

testGetLastError

public void testGetLastError()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testGetLastErrorWithFsync

public void testGetLastErrorWithFsync()
                               throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testGetLastErrorWithJ

public void testGetLastErrorWithJ()
                           throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testGetLastErrorWithW

public void testGetLastErrorWithW()
                           throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testGetMore

public void testGetMore()
                 throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testInsertMulti

public void testInsertMulti()
                     throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testInsertSingle

public void testInsertSingle()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testKillCursor

public void testKillCursor()
                    throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testMultiDelete

public void testMultiDelete()
                     throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQuery

public void testQuery()
               throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryAwaitData

public void testQueryAwaitData()
                        throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryExhaust

public void testQueryExhaust()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryNoCursorTimeout

public void testQueryNoCursorTimeout()
                              throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryPartial

public void testQueryPartial()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQuerySecondaryPreference

public void testQuerySecondaryPreference()
                                  throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryTailable

public void testQueryTailable()
                       throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testQueryWithFields

public void testQueryWithFields()
                         throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testRaiseError

public void testRaiseError()
                    throws IOException,
                           InterruptedException

Test method for TwoThreadSocketConnection.raiseErrors(MongoDbException) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure to sleep.

testRead

public void testRead()
              throws IOException,
                     InterruptedException,
                     ExecutionException,
                     TimeoutException

Test method for TwoThreadSocketConnection.

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

ExecutionException - On a failure waiting for a reply.

InterruptedException - On a failure waiting for a reply.

TimeoutException - On a failure waiting for a reply.

testRead2

public void testRead2()
               throws IOException,
                      InterruptedException,
                      ExecutionException,
                      TimeoutException

Test method for SocketConnection.

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

ExecutionException - On a failure waiting for a reply.

InterruptedException - On a failure waiting for a reply.

TimeoutException - On a failure waiting for a reply.

testReadGarbage

public void testReadGarbage()
                     throws IOException,
                            InterruptedException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure to sleep.

testReadNonReply

public void testReadNonReply()
                      throws IOException,
                             InterruptedException,
                             TimeoutException

Test method for TwoThreadSocketConnection.

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

TimeoutException - On a failure waiting for a reply.

InterruptedException - On a failure waiting for a reply.

testReadStuff

public void testReadStuff()
                   throws IOException,
                          InterruptedException,
                          ExecutionException,
                          TimeoutException

Test method for TwoThreadSocketConnection.

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

TimeoutException - On a failure waiting for a reply.

ExecutionException - On a failure waiting for a reply.

InterruptedException - On a failure waiting for a reply.

testSendError

public void testSendError()
                   throws IOException,
                          InterruptedException

Test method for TwoThreadSocketConnection.close().

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure waiting for the threads to close.

testSendFailureClose

public void testSendFailureClose()
                          throws IOException,
                                 InterruptedException

Test method for TwoThreadSocketConnection.close().

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure waiting for the threads to close.

testSendRuntimeException

public void testSendRuntimeException()
                              throws IOException,
                                     InterruptedException

Test method for TwoThreadSocketConnection.close().

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure waiting for the threads to close.

testServerClose

public void testServerClose()
                     throws IOException,
                            InterruptedException

Test method for TwoThreadSocketConnection.close().

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure waiting for the threads to close.

testShutdown

public void testShutdown()
                  throws IOException,
                         InterruptedException

Test method for AbstractSocketConnection.shutdown(boolean) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure to sleep.

testSingleDelete

public void testSingleDelete()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testSocketConnectNotifiesFactoryOfConnect

public void testSocketConnectNotifiesFactoryOfConnect()
                                               throws IOException

Test method for SocketConnection.SocketConnection(Server, MongoClientConfiguration) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testSocketConnectNotifiesFactoryOfConnectWhichThrows

public void testSocketConnectNotifiesFactoryOfConnectWhichThrows()
                                                          throws IOException

Test method for SocketConnection.SocketConnection(Server, MongoClientConfiguration) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testStop

public void testStop()
              throws IOException,
                     InterruptedException

Test method for AbstractSocketConnection.stop() .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

InterruptedException - On a failure to sleep.

testTwoThreadSocketConnection

public void testTwoThreadSocketConnection()
                                   throws IOException

Test method for TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testTwoThreadSocketConnectionFailure

public void testTwoThreadSocketConnectionFailure()
                                          throws IOException

Test method for TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testUpdate

public void testUpdate()
                throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testUpdateMulti

public void testUpdateMulti()
                     throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.

testUpdateUpsert

public void testUpdateUpsert()
                      throws IOException

Test method for TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback) .

Throws:

IOException - On a failure connecting to the Mock MongoDB server.