| Index: mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java
|
| diff --git a/mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java b/mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java
|
| index e3afb8164a8b24f43e3f0673bae8d86f36b4f710..abe7fa37d7251bbdf9eb3f68d3915e9846d755a2 100644
|
| --- a/mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java
|
| +++ b/mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java
|
| @@ -174,7 +174,7 @@ public class CoreImplTest extends MojoTestCase {
|
| @SmallTest
|
| public void testWaitMany() {
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| List<Pair<Handle, Core.HandleSignals>> handlesToWaitOn = new ArrayList<
|
| @@ -204,7 +204,7 @@ public class CoreImplTest extends MojoTestCase {
|
| public void testGetCore() {
|
| Core core = CoreImpl.getInstance();
|
|
|
| - Pair<? extends Handle, ? extends Handle> handles = core.createMessagePipe();
|
| + Pair<? extends Handle, ? extends Handle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
| assertEquals(core, handles.first.getCore());
|
| assertEquals(core, handles.second.getCore());
|
| @@ -222,13 +222,31 @@ public class CoreImplTest extends MojoTestCase {
|
| assertEquals(core, handle2.getCore());
|
| }
|
|
|
| + private static void createAndCloseMessagePipe(MessagePipeHandle.CreateOptions options) {
|
| + Core core = CoreImpl.getInstance();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(options);
|
| + handles.first.close();
|
| + handles.second.close();
|
| + }
|
| +
|
| + /**
|
| + * Testing {@link MessagePipeHandle} creation.
|
| + */
|
| + @SmallTest
|
| + public void testMessagePipeCreation() {
|
| + // Test creation with null options.
|
| + createAndCloseMessagePipe(null);
|
| + // Test creation with default options.
|
| + createAndCloseMessagePipe(new MessagePipeHandle.CreateOptions());
|
| + }
|
| +
|
| /**
|
| * Testing {@link MessagePipeHandle}.
|
| */
|
| @SmallTest
|
| public void testMessagePipeEmpty() {
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
| // Testing wait.
|
| assertEquals(MojoResult.OK,
|
| @@ -248,7 +266,7 @@ public class CoreImplTest extends MojoTestCase {
|
| assertEquals(MojoResult.CANCELLED,
|
| handles.first.wait(Core.HandleSignals.READABLE, 1000000L));
|
|
|
| - handles = core.createMessagePipe();
|
| + handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| // Closing the other pipe while waiting.
|
| @@ -269,7 +287,7 @@ public class CoreImplTest extends MojoTestCase {
|
| @SmallTest
|
| public void testMessagePipeSend() {
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| checkSendingMessage(handles.first, handles.second);
|
| @@ -283,7 +301,7 @@ public class CoreImplTest extends MojoTestCase {
|
| public void testMessagePipeReceiveOnSmallBuffer() {
|
| Random random = new Random();
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| // Writing a random 8 bytes message.
|
| @@ -307,8 +325,8 @@ public class CoreImplTest extends MojoTestCase {
|
| @SmallTest
|
| public void testMessagePipeSendHandles() {
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handlesToShare = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handlesToShare = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
| addHandlePairToClose(handlesToShare);
|
|
|
| @@ -509,7 +527,7 @@ public class CoreImplTest extends MojoTestCase {
|
| // Until the behavior is changed on the C++ side, handle gracefully 2 different use case:
|
| // - Receive a INVALID_ARGUMENT exception
|
| // - Receive an invalid handle on the other side.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
| try {
|
| handles.first.writeMessage(null, Collections.<Handle> singletonList(handle),
|
| @@ -567,7 +585,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Checking a correct result.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
|
| @@ -593,7 +611,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -623,7 +641,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -654,7 +672,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -704,7 +722,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -729,7 +747,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -765,7 +783,7 @@ public class CoreImplTest extends MojoTestCase {
|
| Core core = CoreImpl.getInstance();
|
|
|
| // Closing the peer handle.
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| final AsyncWaiterResult asyncWaiterResult = new AsyncWaiterResult();
|
| @@ -790,7 +808,7 @@ public class CoreImplTest extends MojoTestCase {
|
| @SmallTest
|
| public void testMessagePipeHandlePass() {
|
| Core core = CoreImpl.getInstance();
|
| - Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
|
| + Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(null);
|
| addHandlePairToClose(handles);
|
|
|
| assertTrue(handles.first.isValid());
|
|
|