mirror of
https://github.com/dart-lang/sdk
synced 2024-09-15 21:20:36 +00:00
Add another isolate message passing test.
Review URL: https://chromereviews.googleplex.com/3572012 git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@200 260f80e4-7a28-3924-810f-c04153c831b5
This commit is contained in:
parent
de889ee719
commit
697b7b46b8
|
@ -9,6 +9,7 @@ ConstructorTest: Fail # Bug 5246195
|
|||
MandelIsolateTest: Fail # Bug 5246195
|
||||
SpawnTest: Fail # Bug 5246195
|
||||
MessageTest: Fail # Bug 5246195
|
||||
Message2Test: Fail # Bug 5246195
|
||||
IsolateComplexMessagesTest: Fail # Bug 5246195
|
||||
CountTest: Fail # Bug 5246195
|
||||
PromiseBasedTest: Fail # Bug 5246195
|
||||
|
|
76
tests/isolate/src/Message2Test.dart
Normal file
76
tests/isolate/src/Message2Test.dart
Normal file
|
@ -0,0 +1,76 @@
|
|||
// Copyright (c) 2011, 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('Message2Test');
|
||||
#import("TestFramework.dart");
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Message passing test 2.
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
class MessageTest {
|
||||
static void mapEqualsDeep(Map expected, Map actual) {
|
||||
Expect.equals(true, expected is Map);
|
||||
Expect.equals(true, actual is Map);
|
||||
Expect.equals(expected.length, actual.length);
|
||||
testForEachMap(key, value) {
|
||||
if (value is List) {
|
||||
listEqualsDeep(value, actual[key]);
|
||||
} else {
|
||||
Expect.equals(value, actual[key]);
|
||||
}
|
||||
}
|
||||
expected.forEach(testForEachMap);
|
||||
}
|
||||
|
||||
static void listEqualsDeep(List expected, List actual) {
|
||||
for (int i = 0; i < expected.length; i++) {
|
||||
if (expected[i] is List) {
|
||||
listEqualsDeep(expected[i], actual[i]);
|
||||
} else if (expected[i] is Map) {
|
||||
mapEqualsDeep(expected[i], actual[i]);
|
||||
} else {
|
||||
Expect.equals(expected[i], actual[i]);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
class PingPongServer extends Isolate {
|
||||
PingPongServer() : super.heavy();
|
||||
|
||||
void main() {
|
||||
this.port.receive((var message, SendPort replyTo) {
|
||||
if (message == -1) {
|
||||
this.port.close();
|
||||
} else {
|
||||
// Bounce the received object back so that the sender
|
||||
// can make sure that the object matches.
|
||||
replyTo.send(message, null);
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
void test(TestExpectation expect) {
|
||||
expect.completes(new PingPongServer().spawn()).then((SendPort remote) {
|
||||
Map m = new Map();
|
||||
m[1] = "eins";
|
||||
m[2] = "deux";
|
||||
m[3] = "tre";
|
||||
m[4] = "four";
|
||||
remote.call(m).receive(expect.runs2((var received, SendPort replyTo) {
|
||||
MessageTest.mapEqualsDeep(m, received);
|
||||
remote.send(-1, null);
|
||||
expect.succeeded();
|
||||
}));
|
||||
});
|
||||
}
|
||||
|
||||
main() {
|
||||
runTests([test]);
|
||||
}
|
Loading…
Reference in a new issue