public class TwoThreadSocketConnectionTest extends Object
TwoThreadSocketConnection
class.Constructor and Description |
---|
TwoThreadSocketConnectionTest() |
public static void setUpBeforeClass() throws IOException
IOException
- On a failure to start the Mock MongoDB server.public static void tearDownAfterClass() throws IOException
IOException
- On a failure to stop the Mock MongoDB server.public void setUp()
Server
.public void tearDown() throws IOException
IOException
- On a failure to shutdown the test connection.public void testClose() throws IOException
TwoThreadSocketConnection.close()
.IOException
- On a failure connecting to the Mock MongoDB server.public void testConnectionLost() throws IOException, InterruptedException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure to sleep.public void testGetLastError() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testGetLastErrorWithFsync() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testGetLastErrorWithJ() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testGetLastErrorWithW() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testGetMore() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testInsertMulti() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testInsertSingle() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testKillCursor() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testMultiDelete() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQuery() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryAwaitData() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryExhaust() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryNoCursorTimeout() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryPartial() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQuerySecondaryPreference() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryTailable() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testQueryWithFields() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testRaiseError() throws IOException, InterruptedException
TwoThreadSocketConnection.raiseErrors(MongoDbException)
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure to sleep.public void testRead() throws IOException, InterruptedException, ExecutionException, TimeoutException
TwoThreadSocketConnection
.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.public void testRead2() throws IOException, InterruptedException, ExecutionException, TimeoutException
SocketConnection
.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.public void testReadGarbage() throws IOException, InterruptedException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure to sleep.public void testReadNonReply() throws IOException, InterruptedException, TimeoutException
TwoThreadSocketConnection
.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.public void testReadStuff() throws IOException, InterruptedException, ExecutionException, TimeoutException
TwoThreadSocketConnection
.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.public void testSendError() throws IOException, InterruptedException
TwoThreadSocketConnection.close()
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure waiting for the threads to close.public void testSendFailureClose() throws IOException, InterruptedException
TwoThreadSocketConnection.close()
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure waiting for the threads to close.public void testSendRuntimeException() throws IOException, InterruptedException
TwoThreadSocketConnection.close()
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure waiting for the threads to close.public void testServerClose() throws IOException, InterruptedException
TwoThreadSocketConnection.close()
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure waiting for the threads to close.public void testShutdown() throws IOException, InterruptedException
AbstractSocketConnection.shutdown(boolean)
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure to sleep.public void testSingleDelete() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testSocketConnectNotifiesFactoryOfConnect() throws IOException
SocketConnection.SocketConnection(Server, MongoClientConfiguration)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testSocketConnectNotifiesFactoryOfConnectWhichThrows() throws IOException
SocketConnection.SocketConnection(Server, MongoClientConfiguration)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testStop() throws IOException, InterruptedException
AbstractSocketConnection.stop()
.IOException
- On a failure connecting to the Mock MongoDB server.InterruptedException
- On a failure to sleep.public void testTwoThreadSocketConnection() throws IOException
TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testTwoThreadSocketConnectionFailure() throws IOException
TwoThreadSocketConnection.TwoThreadSocketConnection(Server, MongoClientConfiguration)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testUpdate() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testUpdateMulti() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.public void testUpdateUpsert() throws IOException
TwoThreadSocketConnection.send(com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.Message, com.allanbank.mongodb.client.callback.ReplyCallback)
.IOException
- On a failure connecting to the Mock MongoDB server.Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.