| Index: mojo/android/javatests/src/org/chromium/mojo/bindings/ReadAndDispatchMessageTest.java
|
| diff --git a/mojo/android/javatests/src/org/chromium/mojo/bindings/MessageWithHeaderTest.java b/mojo/android/javatests/src/org/chromium/mojo/bindings/ReadAndDispatchMessageTest.java
|
| similarity index 75%
|
| rename from mojo/android/javatests/src/org/chromium/mojo/bindings/MessageWithHeaderTest.java
|
| rename to mojo/android/javatests/src/org/chromium/mojo/bindings/ReadAndDispatchMessageTest.java
|
| index 7f4244593e6c264054a35b3269308bae44cf32b4..0ff0d3db5e0670d179fa323064eb1bac28604d5d 100644
|
| --- a/mojo/android/javatests/src/org/chromium/mojo/bindings/MessageWithHeaderTest.java
|
| +++ b/mojo/android/javatests/src/org/chromium/mojo/bindings/ReadAndDispatchMessageTest.java
|
| @@ -23,9 +23,9 @@ import java.util.Arrays;
|
| import java.util.List;
|
|
|
| /**
|
| - * Testing {@link MessageWithHeader}.
|
| + * Testing {@link Connector#readAndDispatchMessage}.
|
| */
|
| -public class MessageWithHeaderTest extends MojoTestCase {
|
| +public class ReadAndDispatchMessageTest extends MojoTestCase {
|
|
|
| private static final int DATA_SIZE = 1024;
|
|
|
| @@ -42,7 +42,7 @@ public class MessageWithHeaderTest extends MojoTestCase {
|
| protected void setUp() throws Exception {
|
| super.setUp();
|
| Core core = CoreImpl.getInstance();
|
| - mData = BindingsTestUtils.newRandomMessageWithHeader(DATA_SIZE).getMessage().buffer;
|
| + mData = BindingsTestUtils.newRandomMessageWithHeader(DATA_SIZE).getData();
|
| mMessageReceiver = new RecordingMessageReceiver();
|
| mHandles = core.createMessagePipe(new MessagePipeHandle.CreateOptions());
|
| Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> datapipe = core.createDataPipe(null);
|
| @@ -63,43 +63,43 @@ public class MessageWithHeaderTest extends MojoTestCase {
|
| }
|
|
|
| /**
|
| - * Testing {@link MessageWithHeader#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| + * Testing {@link Connector#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| */
|
| @SmallTest
|
| public void testReadAndDispatchMessage() {
|
| mHandles.first.writeMessage(mData, mHandlesToSend, MessagePipeHandle.WriteFlags.NONE);
|
| assertEquals(MojoResult.OK,
|
| - MessageWithHeader.readAndDispatchMessage(mHandles.second, mMessageReceiver));
|
| + Connector.readAndDispatchMessage(mHandles.second, mMessageReceiver));
|
| assertEquals(1, mMessageReceiver.messages.size());
|
| - MessageWithHeader message = mMessageReceiver.messages.get(0);
|
| - mHandlesToClose.addAll(message.getMessage().handles);
|
| - assertEquals(mData, message.getMessage().buffer);
|
| - assertEquals(2, message.getMessage().handles.size());
|
| - for (Handle handle : message.getMessage().handles) {
|
| + Message message = mMessageReceiver.messages.get(0);
|
| + mHandlesToClose.addAll(message.getHandles());
|
| + assertEquals(mData, message.getData());
|
| + assertEquals(2, message.getHandles().size());
|
| + for (Handle handle : message.getHandles()) {
|
| assertTrue(handle.isValid());
|
| }
|
| }
|
|
|
| /**
|
| - * Testing {@link MessageWithHeader#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| + * Testing {@link Connector#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| * with no message available.
|
| */
|
| @SmallTest
|
| public void testReadAndDispatchMessageOnEmptyHandle() {
|
| assertEquals(MojoResult.SHOULD_WAIT,
|
| - MessageWithHeader.readAndDispatchMessage(mHandles.second, mMessageReceiver));
|
| + Connector.readAndDispatchMessage(mHandles.second, mMessageReceiver));
|
| assertEquals(0, mMessageReceiver.messages.size());
|
| }
|
|
|
| /**
|
| - * Testing {@link MessageWithHeader#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| + * Testing {@link Connector#readAndDispatchMessage(MessagePipeHandle, MessageReceiver)}
|
| * on closed handle.
|
| */
|
| @SmallTest
|
| public void testReadAndDispatchMessageOnClosedHandle() {
|
| mHandles.first.close();
|
| try {
|
| - MessageWithHeader.readAndDispatchMessage(mHandles.second, mMessageReceiver);
|
| + Connector.readAndDispatchMessage(mHandles.second, mMessageReceiver);
|
| fail("MojoException should have been thrown");
|
| } catch (MojoException expected) {
|
| assertEquals(MojoResult.FAILED_PRECONDITION, expected.getMojoResult());
|
|
|