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 2a3da5bc627f2fcd9f3a65642f378103184e4bed..e3afb8164a8b24f43e3f0673bae8d86f36b4f710 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 |
@@ -177,21 +177,21 @@ public class CoreImplTest extends MojoTestCase { |
Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(); |
addHandlePairToClose(handles); |
- List<Pair<Handle, Core.WaitFlags>> handlesToWaitOn = new ArrayList< |
- Pair<Handle, Core.WaitFlags>>(); |
+ List<Pair<Handle, Core.HandleSignals>> handlesToWaitOn = new ArrayList< |
+ Pair<Handle, Core.HandleSignals>>(); |
handlesToWaitOn.add( |
- new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE)); |
+ new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); |
handlesToWaitOn.add( |
- new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE)); |
+ new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); |
WaitManyResult result = core.waitMany(handlesToWaitOn, 0); |
assertEquals(MojoResult.OK, result.getMojoResult()); |
assertEquals(1, result.getHandleIndex()); |
handlesToWaitOn.clear(); |
handlesToWaitOn.add( |
- new Pair<Handle, Core.WaitFlags>(handles.first, Core.WaitFlags.WRITABLE)); |
+ new Pair<Handle, Core.HandleSignals>(handles.first, Core.HandleSignals.WRITABLE)); |
handlesToWaitOn.add( |
- new Pair<Handle, Core.WaitFlags>(handles.second, Core.WaitFlags.READABLE)); |
+ new Pair<Handle, Core.HandleSignals>(handles.second, Core.HandleSignals.READABLE)); |
result = core.waitMany(handlesToWaitOn, 0); |
assertEquals(MojoResult.OK, result.getMojoResult()); |
assertEquals(0, result.getHandleIndex()); |
@@ -231,10 +231,12 @@ public class CoreImplTest extends MojoTestCase { |
Pair<MessagePipeHandle, MessagePipeHandle> handles = core.createMessagePipe(); |
addHandlePairToClose(handles); |
// Testing wait. |
- assertEquals(MojoResult.OK, handles.first.wait(Core.WaitFlags.all(), 0)); |
- assertEquals(MojoResult.OK, handles.first.wait(Core.WaitFlags.WRITABLE, 0)); |
+ assertEquals(MojoResult.OK, |
+ handles.first.wait(Core.HandleSignals.none().setReadable(true).setWritable(true), |
+ 0)); |
+ assertEquals(MojoResult.OK, handles.first.wait(Core.HandleSignals.WRITABLE, 0)); |
assertEquals(MojoResult.DEADLINE_EXCEEDED, |
- handles.first.wait(Core.WaitFlags.READABLE, 0)); |
+ handles.first.wait(Core.HandleSignals.READABLE, 0)); |
// Testing read on an empty pipe. |
MessagePipeHandle.ReadMessageResult result = handles.first.readMessage(null, 0, |
@@ -244,7 +246,7 @@ public class CoreImplTest extends MojoTestCase { |
// Closing a pipe while waiting. |
WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS); |
assertEquals(MojoResult.CANCELLED, |
- handles.first.wait(Core.WaitFlags.READABLE, 1000000L)); |
+ handles.first.wait(Core.HandleSignals.READABLE, 1000000L)); |
handles = core.createMessagePipe(); |
addHandlePairToClose(handles); |
@@ -252,13 +254,13 @@ public class CoreImplTest extends MojoTestCase { |
// Closing the other pipe while waiting. |
WORKER.schedule(new CloseHandle(handles.first), 10, TimeUnit.MILLISECONDS); |
assertEquals(MojoResult.FAILED_PRECONDITION, |
- handles.second.wait(Core.WaitFlags.READABLE, 1000000L)); |
+ handles.second.wait(Core.HandleSignals.READABLE, 1000000L)); |
// Waiting on a closed pipe. |
assertEquals(MojoResult.FAILED_PRECONDITION, |
- handles.second.wait(Core.WaitFlags.READABLE, 0)); |
+ handles.second.wait(Core.HandleSignals.READABLE, 0)); |
assertEquals(MojoResult.FAILED_PRECONDITION, |
- handles.second.wait(Core.WaitFlags.WRITABLE, 0)); |
+ handles.second.wait(Core.HandleSignals.WRITABLE, 0)); |
} |
/** |
@@ -483,7 +485,7 @@ public class CoreImplTest extends MojoTestCase { |
// Checking wait. |
boolean exception = false; |
try { |
- core.wait(handle, Core.WaitFlags.all(), 0); |
+ core.wait(handle, Core.HandleSignals.WRITABLE, 0); |
} catch (MojoException e) { |
assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult()); |
exception = true; |
@@ -493,9 +495,9 @@ public class CoreImplTest extends MojoTestCase { |
// Checking waitMany. |
exception = false; |
try { |
- List<Pair<Handle, Core.WaitFlags>> handles = new ArrayList< |
- Pair<Handle, Core.WaitFlags>>(); |
- handles.add(Pair.create(handle, Core.WaitFlags.all())); |
+ List<Pair<Handle, Core.HandleSignals>> handles = new ArrayList< |
+ Pair<Handle, Core.HandleSignals>>(); |
+ handles.add(Pair.create(handle, Core.HandleSignals.WRITABLE)); |
core.waitMany(handles, 0); |
} catch (MojoException e) { |
assertEquals(MojoResult.INVALID_ARGUMENT, e.getMojoResult()); |
@@ -571,7 +573,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
- core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.HandleSignals.READABLE, |
Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -598,7 +600,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
- core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.HandleSignals.READABLE, |
Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -628,7 +630,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
- core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.HandleSignals.READABLE, |
Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -660,7 +662,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(null, asyncWaiterResult.getException()); |
handles.first.close(); |
- core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.HandleSignals.READABLE, |
Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -683,7 +685,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
- core.getDefaultAsyncWaiter().asyncWait(InvalidHandle.INSTANCE, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(InvalidHandle.INSTANCE, Core.HandleSignals.READABLE, |
Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -709,7 +711,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
- core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.WaitFlags.READABLE, |
+ core.getDefaultAsyncWaiter().asyncWait(handles.first, Core.HandleSignals.READABLE, |
RUN_LOOP_TIMEOUT_MS, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -735,7 +737,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(null, asyncWaiterResult.getException()); |
Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first, |
- Core.WaitFlags.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult); |
+ Core.HandleSignals.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
@@ -772,7 +774,7 @@ public class CoreImplTest extends MojoTestCase { |
assertEquals(null, asyncWaiterResult.getException()); |
Cancellable cancellable = core.getDefaultAsyncWaiter().asyncWait(handles.first, |
- Core.WaitFlags.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult); |
+ Core.HandleSignals.READABLE, Core.DEADLINE_INFINITE, asyncWaiterResult); |
assertEquals(Integer.MIN_VALUE, asyncWaiterResult.getResult()); |
assertEquals(null, asyncWaiterResult.getException()); |
cancellable.cancel(); |