Dart: Simplifies the handle watcher. Various cleanups and bugfixes.

mojo/dart/test/core_test.dart

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 import 'dart:mojo_core';
 import 'dart:typed_data';
 
 import 'package:mojo/dart/testing/expect.dart';
 
 
 invalidHandleTest() {
   RawMojoHandle invalidHandle = new RawMojoHandle(RawMojoHandle.INVALID);
 
   // Close.
   MojoResult result = invalidHandle.close();
   Expect.isTrue(result.isInvalidArgument);
 
   // Wait.
-  result = invalidHandle.wait(MojoHandleSignals.READWRITE, 1000000);
+  result = invalidHandle.wait(MojoHandleSignals.kReadWrite, 1000000);
   Expect.isTrue(result.isInvalidArgument);
 
   int res = RawMojoHandle.waitMany([invalidHandle.h],
-                                   [MojoHandleSignals.READWRITE],
+                                   [MojoHandleSignals.kReadWrite],
                                    RawMojoHandle.DEADLINE_INDEFINITE);
   Expect.equals(res, MojoResult.kInvalidArgument);
 
   // Message pipe.
   MojoMessagePipe pipe = new MojoMessagePipe();
   Expect.isNotNull(pipe);
   ByteData bd = new ByteData(10);
   pipe.endpoints[0].handle.close();
   pipe.endpoints[1].handle.close();
   result = pipe.endpoints[0].write(bd);
@@ skipping 46 matching lines @@
   Expect.isNotNull(pipe);
   Expect.isTrue(pipe.status.isOk);
   Expect.isNotNull(pipe.endpoints);
 
   MojoMessagePipeEndpoint end0 = pipe.endpoints[0];
   MojoMessagePipeEndpoint end1 = pipe.endpoints[1];
   Expect.isTrue(end0.handle.isValid);
   Expect.isTrue(end1.handle.isValid);
 
   // Not readable, yet.
-  MojoResult result = end0.handle.wait(MojoHandleSignals.READABLE, 0);
+  MojoResult result = end0.handle.wait(MojoHandleSignals.kReadable, 0);
   Expect.isTrue(result.isDeadlineExceeded);
 
   // Should be writable.
-  result = end0.handle.wait(MojoHandleSignals.WRITABLE, 0);
+  result = end0.handle.wait(MojoHandleSignals.kWritable, 0);
   Expect.isTrue(result.isOk);
 
   // Try to read.
   ByteData data = new ByteData(10);
   end0.read(data);
   Expect.isTrue(end0.status.isShouldWait);
 
   // Write end1.
   String hello = "hello";
   ByteData helloData =
       new ByteData.view((new Uint8List.fromList(hello.codeUnits)).buffer);
   result = end1.write(helloData);
   Expect.isTrue(result.isOk);
 
   // end0 should now be readable.
   int res = RawMojoHandle.waitMany([end0.handle.h],
-                                   [MojoHandleSignals.READABLE],
+                                   [MojoHandleSignals.kReadable],
                                    RawMojoHandle.DEADLINE_INDEFINITE);
   Expect.equals(res, MojoResult.kOk);
 
   // Read from end0.
   MojoMessagePipeReadResult readResult = end0.read(data);
   Expect.isNotNull(readResult);
   Expect.isTrue(readResult.status.isOk);
   Expect.equals(readResult.bytesRead, helloData.lengthInBytes);
   Expect.equals(readResult.handlesRead, 0);
 
   String hello_result = new String.fromCharCodes(
       data.buffer.asUint8List().sublist(0, readResult.bytesRead).toList());
   Expect.equals(hello_result, "hello");
 
   // end0 should no longer be readable.
-  result = end0.handle.wait(MojoHandleSignals.READABLE, 10);
+  result = end0.handle.wait(MojoHandleSignals.kReadable, 10);
   Expect.isTrue(result.isDeadlineExceeded);
 
   // Close end0's handle.
   result = end0.handle.close();
   Expect.isTrue(result.isOk);
 
   // end1 should no longer be readable or writable.
-  result = end1.handle.wait(MojoHandleSignals.READWRITE, 1000);
+  result = end1.handle.wait(MojoHandleSignals.kReadWrite, 1000);
   Expect.isTrue(result.isFailedPrecondition);
 
   result = end1.handle.close();
   Expect.isTrue(result.isOk);
 }
 
 
 basicDataPipeTest() {
   MojoDataPipe pipe = new MojoDataPipe();
   Expect.isNotNull(pipe);
   Expect.isTrue(pipe.status.isOk);
   Expect.isTrue(pipe.consumer.handle.isValid);
   Expect.isTrue(pipe.producer.handle.isValid);
 
   MojoDataPipeProducer producer = pipe.producer;
   MojoDataPipeConsumer consumer = pipe.consumer;
   Expect.isTrue(producer.handle.isValid);
   Expect.isTrue(consumer.handle.isValid);
 
   // Consumer should not be readable.
-  MojoResult result = consumer.handle.wait(MojoHandleSignals.READABLE, 0);
+  MojoResult result = consumer.handle.wait(MojoHandleSignals.kReadable, 0);
   Expect.isTrue(result.isDeadlineExceeded);
 
   // Producer should be writable.
-  result = producer.handle.wait(MojoHandleSignals.WRITABLE, 0);
+  result = producer.handle.wait(MojoHandleSignals.kWritable, 0);
   Expect.isTrue(result.isOk);
 
   // Try to read from consumer.
   ByteData buffer = new ByteData(20);
   consumer.read(buffer, buffer.lengthInBytes, MojoDataPipeConsumer.FLAG_NONE);
   Expect.isTrue(consumer.status.isShouldWait);
 
   // Try to begin a two-phase read from consumer.
   ByteData b = consumer.beginRead(20, MojoDataPipeConsumer.FLAG_NONE);
   Expect.isNull(b);
   Expect.isTrue(consumer.status.isShouldWait);
 
   // Write to producer.
   String hello = "hello ";
   ByteData helloData =
       new ByteData.view((new Uint8List.fromList(hello.codeUnits)).buffer);
   int written = producer.write(
       helloData, helloData.lengthInBytes, MojoDataPipeProducer.FLAG_NONE);
   Expect.isTrue(producer.status.isOk);
   Expect.equals(written, helloData.lengthInBytes);
 
   // Now that we have written, the consumer should be readable.
   int res = RawMojoHandle.waitMany([consumer.handle.h],
-                                   [MojoHandleSignals.READABLE],
+                                   [MojoHandleSignals.kReadable],
                                    RawMojoHandle.DEADLINE_INDEFINITE);
   Expect.equals(res, MojoResult.kOk);
 
   // Do a two-phase write to the producer.
   ByteData twoPhaseWrite = producer.beginWrite(
       20, MojoDataPipeProducer.FLAG_NONE);
   Expect.isTrue(producer.status.isOk);
   Expect.isNotNull(twoPhaseWrite);
   Expect.isTrue(twoPhaseWrite.lengthInBytes >= 20);
 
   String world = "world";
   twoPhaseWrite.buffer.asUint8List().setAll(0, world.codeUnits);
   producer.endWrite(Uint8List.BYTES_PER_ELEMENT * world.codeUnits.length);
   Expect.isTrue(producer.status.isOk);
 
   // Read one character from consumer.
   int read = consumer.read(buffer, 1, MojoDataPipeConsumer.FLAG_NONE);
   Expect.isTrue(consumer.status.isOk);
   Expect.equals(read, 1);
 
   // Close the producer.
   result = producer.handle.close();
   Expect.isTrue(result.isOk);
 
   // Consumer should still be readable.
-  result = consumer.handle.wait(MojoHandleSignals.READABLE, 0);
+  result = consumer.handle.wait(MojoHandleSignals.kReadable, 0);
   Expect.isTrue(result.isOk);
 
   // Get the number of remaining bytes.
   int remaining = consumer.read(
       null, 0, MojoDataPipeConsumer.FLAG_QUERY);
   Expect.isTrue(consumer.status.isOk);
   Expect.equals(remaining, "hello world".length - 1);
 
   // Do a two-phase read.
   ByteData twoPhaseRead = consumer.beginRead(
@@ skipping 77 matching lines @@
   duplicate = null;
 }
 
 
 main() {
   invalidHandleTest();
   basicMessagePipeTest();
   basicDataPipeTest();
   basicSharedBufferTest();
 }