Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library dart.pkg.isolate.test.registry; | 5 library dart.pkg.isolate.test.registry; |
| 6 | 6 |
| 7 import "package:isolate/isolaterunner.dart"; | 7 import "package:isolate/isolaterunner.dart"; |
| 8 import "package:isolate/registry.dart"; | 8 import "package:isolate/registry.dart"; |
| 9 import "dart:async"; | 9 import "dart:async"; |
| 10 import "dart:isolate"; | 10 import "dart:isolate"; |
| (...skipping 16 matching lines...) Expand all Loading... | |
| 27 class Oddity { | 27 class Oddity { |
| 28 static const int EVEN = 0; | 28 static const int EVEN = 0; |
| 29 static const int ODD = 1; | 29 static const int ODD = 1; |
| 30 } | 30 } |
| 31 | 31 |
| 32 Future<List> waitAll(int n, Future action(int n)) { | 32 Future<List> waitAll(int n, Future action(int n)) { |
| 33 return Future.wait(new Iterable.generate(n, action)); | 33 return Future.wait(new Iterable.generate(n, action)); |
| 34 } | 34 } |
| 35 | 35 |
| 36 void testLookup() { | 36 void testLookup() { |
| 37 | |
| 38 test("lookupAll", () { | 37 test("lookupAll", () { |
| 39 RegistryManager regman = new RegistryManager(); | 38 RegistryManager regman = new RegistryManager(); |
| 40 Registry registry = regman.registry; | 39 Registry registry = regman.registry; |
| 41 return waitAll(10, (i) { | 40 return waitAll(10, (i) { |
| 42 var element = new Element(i); | 41 var element = new Element(i); |
| 43 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; | 42 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; |
| 44 return registry.add(element, tags: [tag]); | 43 return registry.add(element, tags: [tag]); |
| 45 }) | 44 }).then((_) => registry.lookup()).then((all) { |
|
Lasse Reichstein Nielsen
2015/02/26 10:59:15
Less clear which operations are performed. The reg
| |
| 46 .then((_) => registry.lookup()) | |
| 47 .then((all) { | |
| 48 expect(all.length, 10); | 45 expect(all.length, 10); |
| 49 expect(all.map((v) => v.id).toList()..sort(), | 46 expect(all.map((v) => v.id).toList()..sort(), |
| 50 [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]); | 47 [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]); |
| 51 }) | 48 }).then((_) { |
| 52 .then((_) { regman.close(); }); | 49 regman.close(); |
| 50 }); | |
| 53 }); | 51 }); |
| 54 | 52 |
| 55 test("lookupOdd", () { | 53 test("lookupOdd", () { |
| 56 RegistryManager regman = new RegistryManager(); | 54 RegistryManager regman = new RegistryManager(); |
| 57 Registry registry = regman.registry; | 55 Registry registry = regman.registry; |
| 58 return waitAll(10, (i) { | 56 return waitAll(10, (i) { |
| 59 var element = new Element(i); | 57 var element = new Element(i); |
| 60 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; | 58 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; |
| 61 return registry.add(element, tags: [tag]); | 59 return registry.add(element, tags: [tag]); |
| 62 }) | 60 }).then((_) => registry.lookup(tags: [Oddity.ODD])).then((all) { |
| 63 .then((_) =>registry.lookup(tags:[Oddity.ODD])) | |
| 64 .then((all) { | |
| 65 expect(all.length, 5); | 61 expect(all.length, 5); |
| 66 expect(all.map((v) => v.id).toList()..sort(), | 62 expect(all.map((v) => v.id).toList()..sort(), [1, 3, 5, 7, 9]); |
| 67 [1, 3, 5, 7, 9]); | 63 }).then((_) { |
| 68 }) | 64 regman.close(); |
| 69 .then((_) { regman.close(); }); | 65 }); |
| 70 }); | 66 }); |
| 71 | 67 |
| 72 test("lookupMax", () { | 68 test("lookupMax", () { |
| 73 RegistryManager regman = new RegistryManager(); | 69 RegistryManager regman = new RegistryManager(); |
| 74 Registry registry = regman.registry; | 70 Registry registry = regman.registry; |
| 75 return waitAll(10, (i) { | 71 return waitAll(10, (i) { |
| 76 var element = new Element(i); | 72 var element = new Element(i); |
| 77 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; | 73 var tag = i.isEven ? Oddity.EVEN : Oddity.ODD; |
| 78 return registry.add(element, tags: [tag]); | 74 return registry.add(element, tags: [tag]); |
| 79 }) | 75 }).then((_) => registry.lookup(max: 5)).then((all) { |
| 80 .then((_) => registry.lookup(max: 5)) | |
| 81 .then((all) { | |
| 82 expect(all.length, 5); | 76 expect(all.length, 5); |
| 83 }) | 77 }).then((_) { |
| 84 .then((_) { regman.close(); }); | 78 regman.close(); |
| 79 }); | |
| 85 }); | 80 }); |
| 86 | 81 |
| 87 test("lookupMultiTag", () { | 82 test("lookupMultiTag", () { |
| 88 RegistryManager regman = new RegistryManager(); | 83 RegistryManager regman = new RegistryManager(); |
| 89 Registry registry = regman.registry; | 84 Registry registry = regman.registry; |
| 90 return waitAll(25, (i) { | 85 return waitAll(25, (i) { |
| 91 var element = new Element(i); | 86 var element = new Element(i); |
| 92 // Collect all numbers dividing i. | 87 // Collect all numbers dividing i. |
| 93 var tags = [i]; | 88 var tags = [i]; |
| 94 for (int j = 2; j < 25; j++) { | 89 for (int j = 2; j < 25; j++) { |
| 95 if (i % j == 0) tags.add(j); | 90 if (i % j == 0) tags.add(j); |
| 96 } | 91 } |
| 97 return registry.add(element, tags: tags); | 92 return registry.add(element, tags: tags); |
| 98 }) | 93 }).then((_) => registry.lookup(tags: [2, 3])).then((all) { |
| 99 .then((_) => registry.lookup(tags: [2, 3])) | |
| 100 .then((all) { | |
| 101 expect(all.length, 5); | 94 expect(all.length, 5); |
| 102 expect(all.map((v) => v.id).toList()..sort(), | 95 expect(all.map((v) => v.id).toList()..sort(), [0, 6, 12, 18, 24]); |
| 103 [0, 6, 12, 18, 24]); | 96 }).then((_) { |
| 104 }) | 97 regman.close(); |
| 105 .then((_) { regman.close(); }); | 98 }); |
| 106 }); | 99 }); |
| 107 | 100 |
| 108 test("lookupMultiTagMax", () { | 101 test("lookupMultiTagMax", () { |
| 109 RegistryManager regman = new RegistryManager(); | 102 RegistryManager regman = new RegistryManager(); |
| 110 Registry registry = regman.registry; | 103 Registry registry = regman.registry; |
| 111 return waitAll(25, (i) { | 104 return waitAll(25, (i) { |
| 112 var element = new Element(i); | 105 var element = new Element(i); |
| 113 // Collect all numbers dividing i. | 106 // Collect all numbers dividing i. |
| 114 var tags = [i]; | 107 var tags = [i]; |
| 115 for (int j = 2; j < 25; j++) { | 108 for (int j = 2; j < 25; j++) { |
| 116 if (i % j == 0) tags.add(j); | 109 if (i % j == 0) tags.add(j); |
| 117 } | 110 } |
| 118 return registry.add(element, tags: tags); | 111 return registry.add(element, tags: tags); |
| 119 }) | 112 }).then((_) => registry.lookup(tags: [2, 3], max: 3)).then((all) { |
| 120 .then((_) => registry.lookup(tags: [2, 3], max: 3)) | |
| 121 .then((all) { | |
| 122 expect(all.length, 3); | 113 expect(all.length, 3); |
| 123 expect(all.every((v) => (v.id % 6) == 0), isTrue); | 114 expect(all.every((v) => (v.id % 6) == 0), isTrue); |
| 124 }) | 115 }).then((_) { |
| 125 .then((_) { regman.close(); }); | 116 regman.close(); |
| 117 }); | |
| 126 }); | 118 }); |
| 127 } | 119 } |
| 128 | 120 |
| 129 void testAddLookup() { | 121 void testAddLookup() { |
| 130 test("Add-lookup-identical", () { | 122 test("Add-lookup-identical", () { |
| 131 RegistryManager regman = new RegistryManager(); | 123 RegistryManager regman = new RegistryManager(); |
| 132 Registry registry = regman.registry; | 124 Registry registry = regman.registry; |
| 133 var object = new Object(); | 125 var object = new Object(); |
| 134 return registry.add(object).then((_) { | 126 return registry.add(object).then((_) { |
| 135 return registry.lookup().then((entries) { | 127 return registry.lookup().then((entries) { |
| 136 expect(entries, hasLength(1)); | 128 expect(entries, hasLength(1)); |
| 137 expect(entries.first, same(object)); | 129 expect(entries.first, same(object)); |
| 138 }); | 130 }); |
| 139 }).whenComplete(regman.close); | 131 }).whenComplete(regman.close); |
| 140 }); | 132 }); |
| 141 | 133 |
| 142 test("Add-multiple-identical", () { | 134 test("Add-multiple-identical", () { |
| 143 RegistryManager regman = new RegistryManager(); | 135 RegistryManager regman = new RegistryManager(); |
| 144 Registry registry = regman.registry; | 136 Registry registry = regman.registry; |
| 145 var object1 = new Object(); | 137 var object1 = new Object(); |
| 146 var object2 = new Object(); | 138 var object2 = new Object(); |
| 147 var object3 = new Object(); | 139 var object3 = new Object(); |
| 148 var objects = [object1, object2, object3]; | 140 var objects = [object1, object2, object3]; |
| 149 return Future.wait(objects.map(registry.add)) | 141 return Future.wait(objects.map(registry.add)).then((_) { |
| 150 .then((_) { | |
| 151 return registry.lookup().then((entries) { | 142 return registry.lookup().then((entries) { |
| 152 expect(entries, hasLength(3)); | 143 expect(entries, hasLength(3)); |
| 153 for (var entry in entries) { | 144 for (var entry in entries) { |
| 154 expect(entry, isIn(objects)); | 145 expect(entry, isIn(objects)); |
| 155 } | 146 } |
| 156 }); | 147 }); |
| 157 }).whenComplete(regman.close); | 148 }).whenComplete(regman.close); |
| 158 }); | 149 }); |
| 159 | 150 |
| 160 test("Add-twice", () { | 151 test("Add-twice", () { |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 209 expect(entries.first, same(object)); | 200 expect(entries.first, same(object)); |
| 210 }).whenComplete(regman.close); | 201 }).whenComplete(regman.close); |
| 211 }); | 202 }); |
| 212 | 203 |
| 213 test("Add-multiple-tags", () { | 204 test("Add-multiple-tags", () { |
| 214 RegistryManager regman = new RegistryManager(); | 205 RegistryManager regman = new RegistryManager(); |
| 215 Registry registry = regman.registry; | 206 Registry registry = regman.registry; |
| 216 var object1 = new Object(); | 207 var object1 = new Object(); |
| 217 var object2 = new Object(); | 208 var object2 = new Object(); |
| 218 var object3 = new Object(); | 209 var object3 = new Object(); |
| 219 return registry.add(object1, tags: [1, 3, 5, 7]).then((_){ | 210 return registry.add(object1, tags: [1, 3, 5, 7]).then((_) { |
| 220 return registry.add(object2, tags: [2, 3, 6, 7]); | 211 return registry.add(object2, tags: [2, 3, 6, 7]); |
| 221 }).then((_) { | 212 }).then((_) { |
| 222 return registry.add(object3, tags: [4, 5, 6, 7]); | 213 return registry.add(object3, tags: [4, 5, 6, 7]); |
| 223 }).then((_) { | 214 }).then((_) { |
| 224 return registry.lookup(tags: [3]).then((entries) { | 215 return registry.lookup(tags: [3]).then((entries) { |
| 225 expect(entries, hasLength(2)); | 216 expect(entries, hasLength(2)); |
| 226 expect(entries.first == object1 || entries.last == object1, isTrue); | 217 expect(entries.first == object1 || entries.last == object1, isTrue); |
| 227 expect(entries.first == object2 || entries.last == object2, isTrue); | 218 expect(entries.first == object2 || entries.last == object2, isTrue); |
| 228 }); | 219 }); |
| 229 }).then((_) { | 220 }).then((_) { |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 323 }).whenComplete(regman.close); | 314 }).whenComplete(regman.close); |
| 324 }); | 315 }); |
| 325 | 316 |
| 326 test("Add-remove-multiple", () { | 317 test("Add-remove-multiple", () { |
| 327 RegistryManager regman = new RegistryManager(); | 318 RegistryManager regman = new RegistryManager(); |
| 328 Registry registry = regman.registry; | 319 Registry registry = regman.registry; |
| 329 var object1 = new Object(); | 320 var object1 = new Object(); |
| 330 var object2 = new Object(); | 321 var object2 = new Object(); |
| 331 var object3 = new Object(); | 322 var object3 = new Object(); |
| 332 var objects = [object1, object2, object3]; | 323 var objects = [object1, object2, object3]; |
| 333 return Future.wait(objects.map(registry.add)).then((_){ | 324 return Future.wait(objects.map(registry.add)).then((_) { |
| 334 return registry.addTags([object1, object2], ["x", "y"]); | 325 return registry.addTags([object1, object2], ["x", "y"]); |
| 335 }).then((_) { | 326 }).then((_) { |
| 336 return registry.addTags([object1, object3], ["z", "w"]); | 327 return registry.addTags([object1, object3], ["z", "w"]); |
| 337 }).then((_) { | 328 }).then((_) { |
| 338 return registry.lookup(tags: ["x", "z"]); | 329 return registry.lookup(tags: ["x", "z"]); |
| 339 }).then((entries) { | 330 }).then((entries) { |
| 340 expect(entries, hasLength(1)); | 331 expect(entries, hasLength(1)); |
| 341 expect(entries.first, same(object1)); | 332 expect(entries.first, same(object1)); |
| 342 return registry.removeTags([object1, object2], ["x", "z"]); | 333 return registry.removeTags([object1, object2], ["x", "z"]); |
| 343 }).then((_) { | 334 }).then((_) { |
| 344 return registry.lookup(tags: ["z"]); | 335 return registry.lookup(tags: ["z"]); |
| 345 }).then((entries) { | 336 }).then((entries) { |
| 346 expect(entries, hasLength(1)); | 337 expect(entries, hasLength(1)); |
| 347 expect(entries.first, same(object3)); | 338 expect(entries.first, same(object3)); |
| 348 }).whenComplete(regman.close); | 339 }).whenComplete(regman.close); |
| 349 }); | 340 }); |
| 350 | 341 |
| 351 test("Remove-wrong-object", () { | 342 test("Remove-wrong-object", () { |
| 352 RegistryManager regman = new RegistryManager(); | 343 RegistryManager regman = new RegistryManager(); |
| 353 Registry registry = regman.registry; | 344 Registry registry = regman.registry; |
| 354 expect(() => registry.removeTags([new Object()], ["x"]), | 345 expect(() => registry.removeTags([new Object()], ["x"]), throws); |
| 355 throws); | |
| 356 regman.close(); | 346 regman.close(); |
| 357 }); | 347 }); |
| 358 } | 348 } |
| 359 | 349 |
| 360 var _regmen = {}; | 350 var _regmen = {}; |
| 361 Registry createRegMan(id) { | 351 Registry createRegMan(id) { |
| 362 var regman = new RegistryManager(); | 352 var regman = new RegistryManager(); |
| 363 _regmen[id] = regman; | 353 _regmen[id] = regman; |
| 364 return regman.registry; | 354 return regman.registry; |
| 365 } | 355 } |
| 366 void closeRegMan(id) { | 356 void closeRegMan(id) { |
| 367 _regmen.remove(id).close(); | 357 _regmen.remove(id).close(); |
| 368 } | 358 } |
| 369 | 359 |
| 370 void testCrossIsolate() { | 360 void testCrossIsolate() { |
| 371 var object = new Object(); | 361 var object = new Object(); |
| 372 test("regman-other-isolate", () { | 362 test("regman-other-isolate", () { |
| 373 // Add, lookup and remove object in other isolate. | 363 // Add, lookup and remove object in other isolate. |
| 374 return IsolateRunner.spawn().then((isolate) { | 364 return IsolateRunner.spawn().then((isolate) { |
| 375 isolate.run(createRegMan, 1).then((registry) { | 365 isolate.run(createRegMan, 1).then((registry) { |
| 376 return registry.add(object, tags: ["a", "b"]) | 366 return registry.add(object, tags: ["a", "b"]).then((removeCapability) { |
| 377 .then((removeCapability) { | |
| 378 return registry.lookup(tags: ["a"]).then((entries) { | 367 return registry.lookup(tags: ["a"]).then((entries) { |
| 379 expect(entries, hasLength(1)); | 368 expect(entries, hasLength(1)); |
| 380 expect(entries.first, same(object)); | 369 expect(entries.first, same(object)); |
| 381 return registry.remove(entries.first, removeCapability); | 370 return registry.remove(entries.first, removeCapability); |
| 382 }).then((removeSuccess) { | 371 }).then((removeSuccess) { |
| 383 expect(removeSuccess, isTrue); | 372 expect(removeSuccess, isTrue); |
| 384 }); | 373 }); |
| 385 }); | 374 }); |
| 386 }).whenComplete(() { | 375 }).whenComplete(() { |
| 387 return isolate.run(closeRegMan, 1); | 376 return isolate.run(closeRegMan, 1); |
| (...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 528 testObject(new Element(42)); | 517 testObject(new Element(42)); |
| 529 testObject(#symbol); | 518 testObject(#symbol); |
| 530 testObject(#_privateSymbol); | 519 testObject(#_privateSymbol); |
| 531 testObject(new Capability()); | 520 testObject(new Capability()); |
| 532 } | 521 } |
| 533 | 522 |
| 534 class Element { | 523 class Element { |
| 535 final int id; | 524 final int id; |
| 536 Element(this.id); | 525 Element(this.id); |
| 537 int get hashCode => id; | 526 int get hashCode => id; |
| 538 bool operator==(Object other) => other is Element && id == other.id; | 527 bool operator ==(Object other) => other is Element && id == other.id; |
| 539 } | 528 } |
| OLD | NEW |