| Index: tests/isolate/typed_data_message_test.dart
|
| diff --git a/tests/isolate/typed_data_message_test.dart b/tests/isolate/typed_data_message_test.dart
|
| deleted file mode 100644
|
| index b725b1c9a6c80360f96fea43bb6c78106ba31548..0000000000000000000000000000000000000000
|
| --- a/tests/isolate/typed_data_message_test.dart
|
| +++ /dev/null
|
| @@ -1,97 +0,0 @@
|
| -// Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
|
| -// for details. All rights reserved. Use of this source code is governed by a
|
| -// BSD-style license that can be found in the LICENSE file.
|
| -
|
| -// Dart test program for testing serialization of messages.
|
| -// VMOptions=--enable_type_checks --enable_asserts
|
| -
|
| -library TypedDataMessageTest;
|
| -import 'dart:isolate';
|
| -import 'dart:typed_data';
|
| -import '../../pkg/unittest/lib/unittest.dart';
|
| -
|
| -// ---------------------------------------------------------------------------
|
| -// Message passing test.
|
| -// ---------------------------------------------------------------------------
|
| -
|
| -List elements;
|
| -
|
| -void initializeList() {
|
| - elements = new List(3);
|
| - elements[0] = new Int8List(10);
|
| - for (int j = 0; j < 10; j++) {
|
| - elements[0][j] = j;
|
| - }
|
| - elements[1] = new ByteData.view(elements[0].buffer, 0, 10);
|
| - for (int j = 0; j < 10; j++) {
|
| - elements[1].setInt8(j, j + 100);
|
| - }
|
| - elements[2] = new Int8List.view(new Int8List(100).buffer, 50, 10);
|
| - for (int j = 0; j < 10; j++) {
|
| - elements[2][j] = j + 250;
|
| - }
|
| -}
|
| -
|
| -void VerifyList(List expected, List actual) {
|
| - for (int i = 0; i < expected.length; i++) {
|
| - expect(actual[i], expected[i]);
|
| - }
|
| -}
|
| -
|
| -void VerifyBytedata(ByteData expected, ByteData actual) {
|
| - for (int i = 0; i < expected.length; i++) {
|
| - expect(actual.getInt8(i), expected.getInt8(i));
|
| - }
|
| -}
|
| -
|
| -void VerifyObject(int index, var actual) {
|
| - var expected = elements[index];
|
| - if (expected is List) {
|
| - expect(actual, isList);
|
| - VerifyList(expected, actual);
|
| - } else {
|
| - expect(true, actual is ByteData);
|
| - VerifyBytedata(expected, actual);
|
| - }
|
| - expect(actual.length, expected.length);
|
| -}
|
| -
|
| -pingPong() {
|
| - initializeList();
|
| - int count = 0;
|
| - port.receive((var message, SendPort replyTo) {
|
| - if (message == -1) {
|
| - port.close();
|
| - replyTo.send(count, null);
|
| - } else {
|
| - // Check if the received object is correct.
|
| - if (count < elements.length) {
|
| - VerifyObject(count, message);
|
| - }
|
| - // Bounce the received object back so that the sender
|
| - // can make sure that the object matches.
|
| - replyTo.send(message, null);
|
| - count++;
|
| - }
|
| - });
|
| -}
|
| -
|
| -main() {
|
| - initializeList();
|
| - test("send objects and receive them back", () {
|
| - SendPort remote = spawnFunction(pingPong);
|
| - // Send objects and receive them back.
|
| - for (int i = 0; i < elements.length; i++) {
|
| - var sentObject = elements[i];
|
| - var idx = i;
|
| - remote.call(sentObject).then(expectAsync1((var receivedObject) {
|
| - VerifyObject(idx, receivedObject);
|
| - }));
|
| - }
|
| -
|
| - // Shutdown the MessageServer.
|
| - remote.call(-1).then(expectAsync1((int message) {
|
| - expect(message, elements.length);
|
| - }));
|
| - });
|
| -}
|
|
|