Skip to content

GitLab

T
tangled
Commit a1de169a authored by qsr@chromium.org's avatar qsr@chromium.org
Browse files
Options

Small cleanup for the mojo java classes. 

R=rmcilroy@chromium.org, viettrungluu@chromium.org

Review URL: https://codereview.chromium.org/310073002

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@274840 0039d316-1c4b-4281-b951-d872f2087c98
parent d33d2224
Hide whitespace changes
Inline Side-by-side
Showing with 61 additions and 74 deletions
mojo/android/javatests/src/org/chromium/mojo/MojoTestCase.java
View file @ a1de169a
...@@ -14,7 +14,7 @@ import org.chromium.base.library_loader.LibraryLoader; ...@@ -14,7 +14,7 @@ import org.chromium.base.library_loader.LibraryLoader;
* Base class to test mojo. Setup the environment. * Base class to test mojo. Setup the environment.
*/ */
@JNINamespace("mojo::android") @JNINamespace("mojo::android")
public class MojoTestCase extends InstrumentationTestCase { public class MojoTestCase extends InstrumentationTestCase {
private long mTestEnvironmentPointer; private long mTestEnvironmentPointer;
......
mojo/android/javatests/src/org/chromium/mojo/system/impl/CoreImplTest.java
View file @ a1de169a
...@@ -11,20 +11,15 @@ import org.chromium.mojo.system.AsyncWaiter; ...@@ -11,20 +11,15 @@ import org.chromium.mojo.system.AsyncWaiter;
import org.chromium.mojo.system.AsyncWaiter.Callback; import org.chromium.mojo.system.AsyncWaiter.Callback;
import org.chromium.mojo.system.AsyncWaiter.Cancellable; import org.chromium.mojo.system.AsyncWaiter.Cancellable;
import org.chromium.mojo.system.Core; import org.chromium.mojo.system.Core;
import org.chromium.mojo.system.Core.WaitFlags;
import org.chromium.mojo.system.Core.WaitManyResult; import org.chromium.mojo.system.Core.WaitManyResult;
import org.chromium.mojo.system.DataPipe; import org.chromium.mojo.system.DataPipe;
import org.chromium.mojo.system.Handle; import org.chromium.mojo.system.Handle;
import org.chromium.mojo.system.InvalidHandle; import org.chromium.mojo.system.InvalidHandle;
import org.chromium.mojo.system.MessagePipeHandle; import org.chromium.mojo.system.MessagePipeHandle;
import org.chromium.mojo.system.MessagePipeHandle.ReadFlags;
import org.chromium.mojo.system.MessagePipeHandle.ReadMessageResult;
import org.chromium.mojo.system.MessagePipeHandle.WriteFlags;
import org.chromium.mojo.system.MojoException; import org.chromium.mojo.system.MojoException;
import org.chromium.mojo.system.MojoResult; import org.chromium.mojo.system.MojoResult;
import org.chromium.mojo.system.Pair; import org.chromium.mojo.system.Pair;
import org.chromium.mojo.system.SharedBufferHandle; import org.chromium.mojo.system.SharedBufferHandle;
import org.chromium.mojo.system.SharedBufferHandle.MapFlags;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.ArrayList; import java.util.ArrayList;
...@@ -70,20 +65,19 @@ public class CoreImplTest extends MojoTestCase { ...@@ -70,20 +65,19 @@ public class CoreImplTest extends MojoTestCase {
random.nextBytes(bytes); random.nextBytes(bytes);
ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length); ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length);
buffer.put(bytes); buffer.put(bytes);
in.writeMessage(buffer, null, MessagePipeHandle.WriteFlags.none()); in.writeMessage(buffer, null, MessagePipeHandle.WriteFlags.NONE);
// Try to read into a small buffer. // Try to read into a small buffer.
ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length / 2); ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length / 2);
MessagePipeHandle.ReadMessageResult result = out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadMessageResult result = out.readMessage(
MessagePipeHandle.ReadFlags.none()); receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE);
assertEquals(MojoResult.RESOURCE_EXHAUSTED, result.getMojoResult()); assertEquals(MojoResult.RESOURCE_EXHAUSTED, result.getMojoResult());
assertEquals(bytes.length, result.getMessageSize()); assertEquals(bytes.length, result.getMessageSize());
assertEquals(0, result.getHandlesCount()); assertEquals(0, result.getHandlesCount());
// Read into a correct buffer. // Read into a correct buffer.
receiveBuffer = ByteBuffer.allocateDirect(bytes.length); receiveBuffer = ByteBuffer.allocateDirect(bytes.length);
result = out.readMessage(receiveBuffer, 0, result = out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE);
MessagePipeHandle.ReadFlags.none());
assertEquals(MojoResult.OK, result.getMojoResult()); assertEquals(MojoResult.OK, result.getMojoResult());
assertEquals(bytes.length, result.getMessageSize()); assertEquals(bytes.length, result.getMessageSize());
assertEquals(0, result.getHandlesCount()); assertEquals(0, result.getHandlesCount());
...@@ -104,24 +98,22 @@ public class CoreImplTest extends MojoTestCase { ...@@ -104,24 +98,22 @@ public class CoreImplTest extends MojoTestCase {
Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(); Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
try { try {
List<Pair<Handle, WaitFlags>> handlesToWaitOn = new ArrayList< List<Pair<Handle, Core.WaitFlags>> handlesToWaitOn = new ArrayList<
Pair<Handle, WaitFlags>>(); Pair<Handle, Core.WaitFlags>>();
handlesToWaitOn.add( handlesToWaitOn.add(
new Pair<Handle, WaitFlags>(handles.second, new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE));
WaitFlags.none().setReadable(true)));
handlesToWaitOn.add( handlesToWaitOn.add(
new Pair<Handle, WaitFlags>(handles.first, WaitFlags.none().setWritable(true))); new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE));
WaitManyResult result = core.waitMany(handlesToWaitOn, 0); WaitManyResult result = core.waitMany(handlesToWaitOn, 0);
assertEquals(MojoResult.OK, result.getMojoResult()); assertEquals(MojoResult.OK, result.getMojoResult());
assertEquals(1, result.getHandleIndex()); assertEquals(1, result.getHandleIndex());
handlesToWaitOn.clear(); handlesToWaitOn.clear();
handlesToWaitOn.add( handlesToWaitOn.add(
new Pair<Handle, WaitFlags>(handles.first, WaitFlags.none().setWritable(true))); new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE));
handlesToWaitOn.add( handlesToWaitOn.add(
new Pair<Handle, WaitFlags>(handles.second, new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE));
WaitFlags.none().setReadable(true)));
result = core.waitMany(handlesToWaitOn, 0); result = core.waitMany(handlesToWaitOn, 0);
assertEquals(MojoResult.OK, result.getMojoResult()); assertEquals(MojoResult.OK, result.getMojoResult());
assertEquals(0, result.getHandleIndex()); assertEquals(0, result.getHandleIndex());
...@@ -141,20 +133,20 @@ public class CoreImplTest extends MojoTestCase { ...@@ -141,20 +133,20 @@ public class CoreImplTest extends MojoTestCase {
try { try {
// Testing wait. // Testing wait.
assertEquals(MojoResult.OK, handles.first.wait(WaitFlags.all(), 0)); assertEquals(MojoResult.OK, handles.first.wait(Core.WaitFlags.all(), 0));
assertEquals(MojoResult.OK, handles.first.wait(WaitFlags.none().setWritable(true), 0)); assertEquals(MojoResult.OK, handles.first.wait(Core.WaitFlags.WRITABLE, 0));
assertEquals(MojoResult.DEADLINE_EXCEEDED, assertEquals(MojoResult.DEADLINE_EXCEEDED,
handles.first.wait(WaitFlags.none().setReadable(true), 0)); handles.first.wait(Core.WaitFlags.READABLE, 0));
// Testing read on an empty pipe. // Testing read on an empty pipe.
ReadMessageResult result = handles.first.readMessage(null, 0, MessagePipeHandle.ReadMessageResult result = handles.first.readMessage(null, 0,
MessagePipeHandle.ReadFlags.none()); MessagePipeHandle.ReadFlags.NONE);
assertEquals(MojoResult.SHOULD_WAIT, result.getMojoResult()); assertEquals(MojoResult.SHOULD_WAIT, result.getMojoResult());
// Closing a pipe while waiting. // Closing a pipe while waiting.
WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS); WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS);
assertEquals(MojoResult.CANCELLED, assertEquals(MojoResult.CANCELLED,
handles.first.wait(WaitFlags.none().setReadable(true), 1000000L)); handles.first.wait(Core.WaitFlags.READABLE, 1000000L));
} finally { } finally {
handles.first.close(); handles.first.close();
handles.second.close(); handles.second.close();
...@@ -166,13 +158,13 @@ public class CoreImplTest extends MojoTestCase { ...@@ -166,13 +158,13 @@ public class CoreImplTest extends MojoTestCase {
// Closing the other pipe while waiting. // Closing the other pipe while waiting.
WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS); WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS);
assertEquals(MojoResult.FAILED_PRECONDITION, assertEquals(MojoResult.FAILED_PRECONDITION,
handles.second.wait(WaitFlags.none().setReadable(true), 1000000L)); handles.second.wait(Core.WaitFlags.READABLE, 1000000L));
// Waiting on a closed pipe. // Waiting on a closed pipe.
assertEquals(MojoResult.FAILED_PRECONDITION, assertEquals(MojoResult.FAILED_PRECONDITION,
handles.second.wait(WaitFlags.none().setReadable(true), 0)); handles.second.wait(Core.WaitFlags.READABLE, 0));
assertEquals(MojoResult.FAILED_PRECONDITION, assertEquals(MojoResult.FAILED_PRECONDITION,
handles.second.wait(WaitFlags.none().setWritable(true), 0)); handles.second.wait(Core.WaitFlags.WRITABLE, 0));
} finally { } finally {
handles.first.close(); handles.first.close();
handles.second.close(); handles.second.close();
...@@ -212,12 +204,11 @@ public class CoreImplTest extends MojoTestCase { ...@@ -212,12 +204,11 @@ public class CoreImplTest extends MojoTestCase {
random.nextBytes(bytes); random.nextBytes(bytes);
ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length); ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length);
buffer.put(bytes); buffer.put(bytes);
handles.first.writeMessage(buffer, null, MessagePipeHandle.WriteFlags.none()); handles.first.writeMessage(buffer, null, MessagePipeHandle.WriteFlags.NONE);
ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(1); ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(1);
MessagePipeHandle.ReadMessageResult result = handles.second.readMessage(receiveBuffer, MessagePipeHandle.ReadMessageResult result = handles.second
0, .readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE);
MessagePipeHandle.ReadFlags.none());
assertEquals(MojoResult.RESOURCE_EXHAUSTED, result.getMojoResult()); assertEquals(MojoResult.RESOURCE_EXHAUSTED, result.getMojoResult());
assertEquals(bytes.length, result.getMessageSize()); assertEquals(bytes.length, result.getMessageSize());
assertEquals(0, result.getHandlesCount()); assertEquals(0, result.getHandlesCount());
...@@ -239,10 +230,10 @@ public class CoreImplTest extends MojoTestCase { ...@@ -239,10 +230,10 @@ public class CoreImplTest extends MojoTestCase {
try { try {
handles.first.writeMessage(null, handles.first.writeMessage(null,
Collections.<Handle> singletonList(handlesToShare.second), Collections.<Handle> singletonList(handlesToShare.second),
WriteFlags.none()); MessagePipeHandle.WriteFlags.NONE);
assertFalse(handlesToShare.second.isValid()); assertFalse(handlesToShare.second.isValid());
ReadMessageResult readMessageResult = handles.second.readMessage(null, 1, MessagePipeHandle.ReadMessageResult readMessageResult =
ReadFlags.none()); handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE);
assertEquals(1, readMessageResult.getHandlesCount()); assertEquals(1, readMessageResult.getHandlesCount());
MessagePipeHandle newHandle = readMessageResult.getHandles().get(0) MessagePipeHandle newHandle = readMessageResult.getHandles().get(0)
.toMessagePipeHandle(); .toMessagePipeHandle();
...@@ -303,18 +294,16 @@ public class CoreImplTest extends MojoTestCase { ...@@ -303,18 +294,16 @@ public class CoreImplTest extends MojoTestCase {
random.nextBytes(bytes); random.nextBytes(bytes);
ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length); ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length);
buffer.put(bytes); buffer.put(bytes);
int result = handles.first.writeData(buffer, DataPipe.WriteFlags.none()); int result = handles.first.writeData(buffer, DataPipe.WriteFlags.NONE);
assertEquals(bytes.length, result); assertEquals(bytes.length, result);
// Query number of bytes available. // Query number of bytes available.
result = handles.second.readData(null, result = handles.second.readData(null, DataPipe.ReadFlags.none().query(true));
DataPipe.ReadFlags.none().query(true));
assertEquals(bytes.length, result); assertEquals(bytes.length, result);
// Read into a buffer. // Read into a buffer.
ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length); ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length);
result = handles.second.readData(receiveBuffer, result = handles.second.readData(receiveBuffer, DataPipe.ReadFlags.NONE);
DataPipe.ReadFlags.none());
assertEquals(bytes.length, result); assertEquals(bytes.length, result);
assertEquals(0, receiveBuffer.position()); assertEquals(0, receiveBuffer.position());
assertEquals(bytes.length, receiveBuffer.limit()); assertEquals(bytes.length, receiveBuffer.limit());
...@@ -341,14 +330,14 @@ public class CoreImplTest extends MojoTestCase { ...@@ -341,14 +330,14 @@ public class CoreImplTest extends MojoTestCase {
byte[] bytes = new byte[8]; byte[] bytes = new byte[8];
random.nextBytes(bytes); random.nextBytes(bytes);
ByteBuffer buffer = handles.first.beginWriteData(bytes.length, ByteBuffer buffer = handles.first.beginWriteData(bytes.length,
DataPipe.WriteFlags.none()); DataPipe.WriteFlags.NONE);
assertTrue(buffer.capacity() >= bytes.length); assertTrue(buffer.capacity() >= bytes.length);
buffer.put(bytes); buffer.put(bytes);
handles.first.endWriteData(bytes.length); handles.first.endWriteData(bytes.length);
// Read into a buffer. // Read into a buffer.
ByteBuffer receiveBuffer = handles.second.beginReadData(bytes.length, ByteBuffer receiveBuffer = handles.second.beginReadData(bytes.length,
DataPipe.ReadFlags.none()); DataPipe.ReadFlags.NONE);
assertEquals(0, receiveBuffer.position()); assertEquals(0, receiveBuffer.position());
assertEquals(bytes.length, receiveBuffer.limit()); assertEquals(bytes.length, receiveBuffer.limit());
byte[] receivedBytes = new byte[bytes.length]; byte[] receivedBytes = new byte[bytes.length];
...@@ -376,18 +365,17 @@ public class CoreImplTest extends MojoTestCase { ...@@ -376,18 +365,17 @@ public class CoreImplTest extends MojoTestCase {
random.nextBytes(bytes); random.nextBytes(bytes);
ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length); ByteBuffer buffer = ByteBuffer.allocateDirect(bytes.length);
buffer.put(bytes); buffer.put(bytes);
int result = handles.first.writeData(buffer, DataPipe.WriteFlags.none()); int result = handles.first.writeData(buffer, DataPipe.WriteFlags.NONE);
assertEquals(bytes.length, result); assertEquals(bytes.length, result);
// Discard bytes. // Discard bytes.
final int nbBytesToDiscard = 4; final int nbBytesToDiscard = 4;
assertEquals(nbBytesToDiscard, assertEquals(nbBytesToDiscard,
handles.second.discardData(nbBytesToDiscard, DataPipe.ReadFlags.none())); handles.second.discardData(nbBytesToDiscard, DataPipe.ReadFlags.NONE));
// Read into a buffer. // Read into a buffer.
ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length - nbBytesToDiscard); ByteBuffer receiveBuffer = ByteBuffer.allocateDirect(bytes.length - nbBytesToDiscard);
result = handles.second.readData(receiveBuffer, result = handles.second.readData(receiveBuffer, DataPipe.ReadFlags.NONE);
DataPipe.ReadFlags.none());
assertEquals(bytes.length - nbBytesToDiscard, result); assertEquals(bytes.length - nbBytesToDiscard, result);
assertEquals(0, receiveBuffer.position()); assertEquals(0, receiveBuffer.position());
assertEquals(bytes.length - nbBytesToDiscard, receiveBuffer.limit()); assertEquals(bytes.length - nbBytesToDiscard, receiveBuffer.limit());
...@@ -441,9 +429,9 @@ public class CoreImplTest extends MojoTestCase { ...@@ -441,9 +429,9 @@ public class CoreImplTest extends MojoTestCase {
SharedBufferHandle newHandle = handle.duplicate(null); SharedBufferHandle newHandle = handle.duplicate(null);
try { try {
ByteBuffer buffer1 = handle.map(0, 8, MapFlags.none()); ByteBuffer buffer1 = handle.map(0, 8, SharedBufferHandle.MapFlags.NONE);
assertEquals(8, buffer1.capacity()); assertEquals(8, buffer1.capacity());
ByteBuffer buffer2 = newHandle.map(0, 8, MapFlags.none()); ByteBuffer buffer2 = newHandle.map(0, 8, SharedBufferHandle.MapFlags.NONE);
assertEquals(8, buffer2.capacity()); assertEquals(8, buffer2.capacity());
byte[] bytes = new byte[8]; byte[] bytes = new byte[8];
...@@ -474,7 +462,7 @@ public class CoreImplTest extends MojoTestCase { ...@@ -474,7 +462,7 @@ public class CoreImplTest extends MojoTestCase {
// Checking wait. // Checking wait.
boolean exception = false; boolean exception = false;
try { try {
core.wait(handle, WaitFlags.all(), 0); core.wait(handle, Core.WaitFlags.all(), 0);
} catch (MojoException e) { } catch (MojoException e) {
assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult()); assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult());
exception = true; exception = true;
...@@ -484,8 +472,9 @@ public class CoreImplTest extends MojoTestCase { ...@@ -484,8 +472,9 @@ public class CoreImplTest extends MojoTestCase {
// Checking waitMany. // Checking waitMany.
exception = false; exception = false;
try { try {
List<Pair<Handle, WaitFlags>> handles = new ArrayList<Pair<Handle, WaitFlags>>(); List<Pair<Handle, Core.WaitFlags>> handles = new ArrayList<
handles.add(Pair.create(handle, WaitFlags.all())); Pair<Handle, Core.WaitFlags>>();
handles.add(Pair.create(handle, Core.WaitFlags.all()));
core.waitMany(handles, 0); core.waitMany(handles, 0);
} catch (MojoException e) { } catch (MojoException e) {
assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult()); assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult());
...@@ -499,11 +488,10 @@ public class CoreImplTest extends MojoTestCase { ...@@ -499,11 +488,10 @@ public class CoreImplTest extends MojoTestCase {
// - Receive an invalid handle on the other side. // - Receive an invalid handle on the other side.
Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(); Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe();
try { try {
handles.first.writeMessage(null, handles.first.writeMessage(null, Collections.<Handle> singletonList(handle),
Collections.<Handle> singletonList(handle), MessagePipeHandle.WriteFlags.NONE);
WriteFlags.none()); MessagePipeHandle.ReadMessageResult readMessageResult =
ReadMessageResult readMessageResult = handles.second.readMessage(null, 1, handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE);
ReadFlags.none());
assertEquals(1, readMessageResult.getHandlesCount()); assertEquals(1, readMessageResult.getHandlesCount());
assertFalse(readMessageResult.getHandles().get(0).isValid()); assertFalse(readMessageResult.getHandles().get(0).isValid());
} catch (MojoException e) { } catch (MojoException e) {
...@@ -564,13 +552,13 @@ public class CoreImplTest extends MojoTestCase { ...@@ -564,13 +552,13 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
core.getDefaultAsyncWaiter().asyncWait(handles.first, core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
handles.second.writeMessage(ByteBuffer.allocateDirect(1), null, handles.second.writeMessage(ByteBuffer.allocateDirect(1), null,
MessagePipeHandle.WriteFlags.none()); MessagePipeHandle.WriteFlags.NONE);
nativeRunLoop(RUN_LOOP_TIMEOUT_MS); nativeRunLoop(RUN_LOOP_TIMEOUT_MS);
assertNull(asyncWaiterResult.getException()); assertNull(asyncWaiterResult.getException());
assertEquals(MojoResult.OK, asyncWaiterResult.getResult()); assertEquals(MojoResult.OK, asyncWaiterResult.getResult());
...@@ -594,8 +582,8 @@ public class CoreImplTest extends MojoTestCase { ...@@ -594,8 +582,8 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
core.getDefaultAsyncWaiter().asyncWait(handles.first, core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -627,8 +615,8 @@ public class CoreImplTest extends MojoTestCase { ...@@ -627,8 +615,8 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
core.getDefaultAsyncWaiter().asyncWait(handles.first, core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -662,8 +650,8 @@ public class CoreImplTest extends MojoTestCase { ...@@ -662,8 +650,8 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
handles.first.close(); handles.first.close();
core.getDefaultAsyncWaiter().asyncWait(handles.first, core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -689,15 +677,14 @@ public class CoreImplTest extends MojoTestCase { ...@@ -689,15 +677,14 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
core.getDefaultAsyncWaiter().asyncWait(new InvalidHandle(), core.getDefaultAsyncWaiter().asyncWait(new InvalidHandle(), Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
nativeRunLoop(RUN_LOOP_TIMEOUT_MS); nativeRunLoop(RUN_LOOP_TIMEOUT_MS);
assertNotNull(asyncWaiterResult.getException()); assertNotNull(asyncWaiterResult.getException());
assertEquals(MojoResult.INVALID_ARGUMENT, assertEquals(MojoResult.INVALID_ARGUMENT, asyncWaiterResult.getException().getMojoResult());
asyncWaiterResult.getException().getMojoResult());
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
} }
...@@ -715,8 +702,8 @@ public class CoreImplTest extends MojoTestCase { ...@@ -715,8 +702,8 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
core.getDefaultAsyncWaiter().asyncWait(handles.first, core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE,
WaitFlags.none().setReadable(true), RUN_LOOP_TIMEOUT_MS, asyncWaiterResult); RUN_LOOP_TIMEOUT_MS, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -744,7 +731,7 @@ public class CoreImplTest extends MojoTestCase { ...@@ -744,7 +731,7 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first, Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.WaitFlags.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -758,7 +745,7 @@ public class CoreImplTest extends MojoTestCase { ...@@ -758,7 +745,7 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
handles.second.writeMessage(ByteBuffer.allocateDirect(1), null, handles.second.writeMessage(ByteBuffer.allocateDirect(1), null,
MessagePipeHandle.WriteFlags.none()); MessagePipeHandle.WriteFlags.NONE);
nativeRunLoop(RUN_LOOP_TIMEOUT_MS); nativeRunLoop(RUN_LOOP_TIMEOUT_MS);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
...@@ -784,7 +771,7 @@ public class CoreImplTest extends MojoTestCase { ...@@ -784,7 +771,7 @@ public class CoreImplTest extends MojoTestCase {
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first, Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first,
WaitFlags.none().setReadable(true), Core.DEADLINE_INFINITE, asyncWaiterResult); Core.WaitFlags.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult);
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult());
assertEquals(null, asyncWaiterResult.getException()); assertEquals(null, asyncWaiterResult.getException());
cancellable.cancel(); cancellable.cancel();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment