| OLD | NEW |
| 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, 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 // IsolateStubs=MintMakerFullyIsolatedTest.dart:Mint,Purse,PowerfulPurse | 5 // IsolateStubs=MintMakerFullyIsolatedTest.dart:Mint,Purse,PowerfulPurse |
| 6 | 6 |
| 7 #import("../../isolate/src/TestFramework.dart"); | 7 #import("../../isolate/src/TestFramework.dart"); |
| 8 | 8 |
| 9 /* class = Purse (tests/stub-generator/src/MintMakerFullyIsolatedTest.dart/MintM
akerFullyIsolatedTest.dart: 9) */ | 9 /* class = Purse (tests/stub-generator/src/MintMakerFullyIsolatedTest.dart/MintM
akerFullyIsolatedTest.dart: 9) */ |
| 10 | 10 |
| 11 interface Purse$Proxy extends Proxy { | 11 interface Purse$Proxy { |
| 12 Promise<int> queryBalance(); | 12 Promise<int> queryBalance(); |
| 13 | 13 |
| 14 Purse$Proxy sproutPurse(); | 14 Purse$Proxy sproutPurse(); |
| 15 | 15 |
| 16 Promise<int> deposit(int amount, Purse$Proxy source); | 16 Promise<int> deposit(int amount, Purse$Proxy source); |
| 17 } | 17 } |
| 18 | 18 |
| 19 class Purse$ProxyImpl extends ProxyImpl implements Purse$Proxy { | 19 class Purse$ProxyImpl extends Proxy implements Purse$Proxy { |
| 20 Purse$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } | 20 Purse$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } |
| 21 Purse$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.call([null]
)) { } | 21 Purse$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.call([null]
)) { } |
| 22 factory Purse$ProxyImpl.createIsolate() { | 22 factory Purse$ProxyImpl.createIsolate() { |
| 23 Proxy isolate = new Proxy.forIsolate(new Purse$Dispatcher$Isolate()); | 23 Proxy isolate = new Proxy.forIsolate(new Purse$Dispatcher$Isolate()); |
| 24 return new Purse$ProxyImpl.forIsolate(isolate); | 24 return new Purse$ProxyImpl.forIsolate(isolate); |
| 25 } | 25 } |
| 26 factory Purse$ProxyImpl.localProxy(Purse obj) { | 26 factory Purse$ProxyImpl.localProxy(Purse obj) { |
| 27 return new Purse$ProxyImpl(new Promise<SendPort>.fromValue(Dispatcher.serve(
new Purse$Dispatcher(obj)))); | 27 return new Purse$ProxyImpl(new Promise<SendPort>.fromValue(Dispatcher.serve(
new Purse$Dispatcher(obj)))); |
| 28 } | 28 } |
| 29 | 29 |
| 30 Promise<int> queryBalance() { | 30 Promise<int> queryBalance() { |
| 31 return this.call(["queryBalance"]); | 31 return this.call(["queryBalance"]); |
| 32 } | 32 } |
| 33 | 33 |
| 34 Purse$Proxy sproutPurse() { | 34 Purse$Proxy sproutPurse() { |
| 35 return new Purse$ProxyImpl(new PromiseProxy<SendPort>(this.call(["sproutPurs
e"]))); | 35 return new Purse$ProxyImpl(this.call(["sproutPurse"])); |
| 36 } | 36 } |
| 37 | 37 |
| 38 Promise<int> deposit(int amount, Purse$Proxy source) { | 38 Promise<int> deposit(int amount, Purse$Proxy source) { |
| 39 return new PromiseProxy<int>(this.call(["deposit", amount, source])); | 39 return this.call(["deposit", amount, source]); |
| 40 } | 40 } |
| 41 } | 41 } |
| 42 | 42 |
| 43 class Purse$Dispatcher extends Dispatcher<Purse> { | 43 class Purse$Dispatcher extends Dispatcher<Purse> { |
| 44 Purse$Dispatcher(Purse thing) : super(thing) { } | 44 Purse$Dispatcher(Purse thing) : super(thing) { } |
| 45 | 45 |
| 46 void process(var message, void reply(var response)) { | 46 void process(var message, void reply(var response)) { |
| 47 String command = message[0]; | 47 String command = message[0]; |
| 48 if (command == "Purse") { | 48 if (command == "Purse") { |
| 49 } else if (command == "queryBalance") { | 49 } else if (command == "queryBalance") { |
| 50 int queryBalance = target.queryBalance(); | 50 int queryBalance = target.queryBalance(); |
| 51 reply(queryBalance); | 51 reply(queryBalance); |
| 52 } else if (command == "sproutPurse") { | 52 } else if (command == "sproutPurse") { |
| 53 Purse$Proxy sproutPurse = target.sproutPurse(); | 53 Purse$Proxy sproutPurse = target.sproutPurse(); |
| 54 reply(sproutPurse); | 54 reply(sproutPurse); |
| 55 } else if (command == "deposit") { | 55 } else if (command == "deposit") { |
| 56 int amount = message[1]; | 56 int amount = message[1]; |
| 57 List<Promise<SendPort>> promises = new List<Promise<SendPort>>(); | 57 Purse$Proxy source = new Purse$ProxyImpl(new Promise<SendPort>.fromValue(m
essage[2])); |
| 58 promises.add(new PromiseProxy<SendPort>(new Promise<SendPort>.fromValue(me
ssage[2]))); | |
| 59 Purse$Proxy source = new Purse$ProxyImpl(promises[0]); | |
| 60 Promise<int> deposit = target.deposit(amount, source); | 58 Promise<int> deposit = target.deposit(amount, source); |
| 61 reply(deposit); | 59 reply(deposit); |
| 62 } else { | 60 } else { |
| 63 // TODO(kasperl,benl): Somehow throw an exception instead. | 61 // TODO(kasperl,benl): Somehow throw an exception instead. |
| 64 reply("Exception: command '" + command + "' not understood by Purse."); | 62 reply("Exception: command '" + command + "' not understood by Purse."); |
| 65 } | 63 } |
| 66 } | 64 } |
| 67 } | 65 } |
| 68 | 66 |
| 69 class Purse$Dispatcher$Isolate extends Isolate { | 67 class Purse$Dispatcher$Isolate extends Isolate { |
| 70 Purse$Dispatcher$Isolate() : super() { } | 68 Purse$Dispatcher$Isolate() : super() { } |
| 71 | 69 |
| 72 void main() { | 70 void main() { |
| 73 this.port.receive(void _(var message, SendPort replyTo) { | 71 this.port.receive(void _(var message, SendPort replyTo) { |
| 74 Purse thing = new Purse(); | 72 Purse thing = new Purse(); |
| 75 SendPort port = Dispatcher.serve(new Purse$Dispatcher(thing)); | 73 SendPort port = Dispatcher.serve(new Purse$Dispatcher(thing)); |
| 76 Proxy proxy = new Proxy.forPort(replyTo); | 74 Proxy proxy = new Proxy.forPort(replyTo); |
| 77 proxy.send([port]); | 75 proxy.send([port]); |
| 78 }); | 76 }); |
| 79 } | 77 } |
| 80 } | 78 } |
| 81 | 79 |
| 82 /* class = PowerfulPurse (tests/stub-generator/src/MintMakerFullyIsolatedTest.da
rt/MintMakerFullyIsolatedTest.dart: 18) */ | 80 /* class = PowerfulPurse (tests/stub-generator/src/MintMakerFullyIsolatedTest.da
rt/MintMakerFullyIsolatedTest.dart: 18) */ |
| 83 | 81 |
| 84 interface PowerfulPurse$Proxy extends Proxy { | 82 interface PowerfulPurse$Proxy { |
| 85 void init(Mint$Proxy mint, int balance); | 83 void init(Mint$Proxy mint, int balance); |
| 86 | 84 |
| 87 Promise<int> grab(int amount); | 85 Promise<int> grab(int amount); |
| 88 | 86 |
| 89 Purse$Proxy weak(); | 87 Purse$Proxy weak(); |
| 90 } | 88 } |
| 91 | 89 |
| 92 class PowerfulPurse$ProxyImpl extends ProxyImpl implements PowerfulPurse$Proxy { | 90 class PowerfulPurse$ProxyImpl extends Proxy implements PowerfulPurse$Proxy { |
| 93 PowerfulPurse$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } | 91 PowerfulPurse$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } |
| 94 PowerfulPurse$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.cal
l([null])) { } | 92 PowerfulPurse$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.cal
l([null])) { } |
| 95 factory PowerfulPurse$ProxyImpl.createIsolate() { | 93 factory PowerfulPurse$ProxyImpl.createIsolate() { |
| 96 Proxy isolate = new Proxy.forIsolate(new PowerfulPurse$Dispatcher$Isolate())
; | 94 Proxy isolate = new Proxy.forIsolate(new PowerfulPurse$Dispatcher$Isolate())
; |
| 97 return new PowerfulPurse$ProxyImpl.forIsolate(isolate); | 95 return new PowerfulPurse$ProxyImpl.forIsolate(isolate); |
| 98 } | 96 } |
| 99 factory PowerfulPurse$ProxyImpl.localProxy(PowerfulPurse obj) { | 97 factory PowerfulPurse$ProxyImpl.localProxy(PowerfulPurse obj) { |
| 100 return new PowerfulPurse$ProxyImpl(new Promise<SendPort>.fromValue(Dispatche
r.serve(new PowerfulPurse$Dispatcher(obj)))); | 98 return new PowerfulPurse$ProxyImpl(new Promise<SendPort>.fromValue(Dispatche
r.serve(new PowerfulPurse$Dispatcher(obj)))); |
| 101 } | 99 } |
| 102 | 100 |
| (...skipping 10 matching lines...) Expand all Loading... |
| 113 } | 111 } |
| 114 } | 112 } |
| 115 | 113 |
| 116 class PowerfulPurse$Dispatcher extends Dispatcher<PowerfulPurse> { | 114 class PowerfulPurse$Dispatcher extends Dispatcher<PowerfulPurse> { |
| 117 PowerfulPurse$Dispatcher(PowerfulPurse thing) : super(thing) { } | 115 PowerfulPurse$Dispatcher(PowerfulPurse thing) : super(thing) { } |
| 118 | 116 |
| 119 void process(var message, void reply(var response)) { | 117 void process(var message, void reply(var response)) { |
| 120 String command = message[0]; | 118 String command = message[0]; |
| 121 if (command == "PowerfulPurse") { | 119 if (command == "PowerfulPurse") { |
| 122 } else if (command == "init") { | 120 } else if (command == "init") { |
| 123 List<Promise<SendPort>> promises = new List<Promise<SendPort>>(); | 121 Mint$Proxy mint = new Mint$ProxyImpl(new Promise<SendPort>.fromValue(messa
ge[1])); |
| 124 promises.add(new PromiseProxy<SendPort>(new Promise<SendPort>.fromValue(me
ssage[1]))); | |
| 125 int balance = message[2]; | 122 int balance = message[2]; |
| 126 Mint$Proxy mint = new Mint$ProxyImpl(promises[0]); | |
| 127 target.init(mint, balance); | 123 target.init(mint, balance); |
| 128 } else if (command == "grab") { | 124 } else if (command == "grab") { |
| 129 int amount = message[1]; | 125 int amount = message[1]; |
| 130 int grab = target.grab(amount); | 126 int grab = target.grab(amount); |
| 131 reply(grab); | 127 reply(grab); |
| 132 } else if (command == "weak") { | 128 } else if (command == "weak") { |
| 133 Purse weak = target.weak(); | 129 Purse weak = target.weak(); |
| 134 SendPort port = Dispatcher.serve(new Purse$Dispatcher(weak)); | 130 SendPort port = Dispatcher.serve(new Purse$Dispatcher(weak)); |
| 135 reply(port); | 131 reply(port); |
| 136 } else { | 132 } else { |
| (...skipping 11 matching lines...) Expand all Loading... |
| 148 PowerfulPurse thing = new PowerfulPurse(); | 144 PowerfulPurse thing = new PowerfulPurse(); |
| 149 SendPort port = Dispatcher.serve(new PowerfulPurse$Dispatcher(thing)); | 145 SendPort port = Dispatcher.serve(new PowerfulPurse$Dispatcher(thing)); |
| 150 Proxy proxy = new Proxy.forPort(replyTo); | 146 Proxy proxy = new Proxy.forPort(replyTo); |
| 151 proxy.send([port]); | 147 proxy.send([port]); |
| 152 }); | 148 }); |
| 153 } | 149 } |
| 154 } | 150 } |
| 155 | 151 |
| 156 /* class = Mint (tests/stub-generator/src/MintMakerFullyIsolatedTest.dart/MintMa
kerFullyIsolatedTest.dart: 28) */ | 152 /* class = Mint (tests/stub-generator/src/MintMakerFullyIsolatedTest.dart/MintMa
kerFullyIsolatedTest.dart: 28) */ |
| 157 | 153 |
| 158 interface Mint$Proxy extends Proxy { | 154 interface Mint$Proxy { |
| 159 Purse$Proxy createPurse(int balance); | 155 Purse$Proxy createPurse(int balance); |
| 160 | 156 |
| 161 Promise<PowerfulPurse$Proxy> promote(Purse$Proxy purse); | 157 Promise<PowerfulPurse$Proxy> promote(Purse$Proxy purse); |
| 162 } | 158 } |
| 163 | 159 |
| 164 class Mint$ProxyImpl extends ProxyImpl implements Mint$Proxy { | 160 class Mint$ProxyImpl extends Proxy implements Mint$Proxy { |
| 165 Mint$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } | 161 Mint$ProxyImpl(Promise<SendPort> port) : super.forReply(port) { } |
| 166 Mint$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.call([null])
) { } | 162 Mint$ProxyImpl.forIsolate(Proxy isolate) : super.forReply(isolate.call([null])
) { } |
| 167 factory Mint$ProxyImpl.createIsolate() { | 163 factory Mint$ProxyImpl.createIsolate() { |
| 168 Proxy isolate = new Proxy.forIsolate(new Mint$Dispatcher$Isolate()); | 164 Proxy isolate = new Proxy.forIsolate(new Mint$Dispatcher$Isolate()); |
| 169 return new Mint$ProxyImpl.forIsolate(isolate); | 165 return new Mint$ProxyImpl.forIsolate(isolate); |
| 170 } | 166 } |
| 171 factory Mint$ProxyImpl.localProxy(Mint obj) { | 167 factory Mint$ProxyImpl.localProxy(Mint obj) { |
| 172 return new Mint$ProxyImpl(new Promise<SendPort>.fromValue(Dispatcher.serve(n
ew Mint$Dispatcher(obj)))); | 168 return new Mint$ProxyImpl(new Promise<SendPort>.fromValue(Dispatcher.serve(n
ew Mint$Dispatcher(obj)))); |
| 173 } | 169 } |
| 174 | 170 |
| 175 Purse$Proxy createPurse(int balance) { | 171 Purse$Proxy createPurse(int balance) { |
| 176 return new Purse$ProxyImpl(new PromiseProxy<SendPort>(this.call(["createPurs
e", balance]))); | 172 return new Purse$ProxyImpl(this.call(["createPurse", balance])); |
| 177 } | 173 } |
| 178 | 174 |
| 179 Promise<PowerfulPurse$Proxy> promote(Purse$Proxy purse) { | 175 Promise<PowerfulPurse$Proxy> promote(Purse$Proxy purse) { |
| 180 return new Promise<PowerfulPurse$Proxy>.fromValue(new PowerfulPurse$ProxyImp
l(new PromiseProxy<SendPort>(new PromiseProxy<SendPort>(this.call(["promote", pu
rse]))))); | 176 return this.call(["promote", purse]); |
| 181 } | 177 } |
| 182 } | 178 } |
| 183 | 179 |
| 184 class Mint$Dispatcher extends Dispatcher<Mint> { | 180 class Mint$Dispatcher extends Dispatcher<Mint> { |
| 185 Mint$Dispatcher(Mint thing) : super(thing) { } | 181 Mint$Dispatcher(Mint thing) : super(thing) { } |
| 186 | 182 |
| 187 void process(var message, void reply(var response)) { | 183 void process(var message, void reply(var response)) { |
| 188 String command = message[0]; | 184 String command = message[0]; |
| 189 if (command == "Mint") { | 185 if (command == "Mint") { |
| 190 } else if (command == "createPurse") { | 186 } else if (command == "createPurse") { |
| 191 int balance = message[1]; | 187 int balance = message[1]; |
| 192 Purse$Proxy createPurse = target.createPurse(balance); | 188 Purse$Proxy createPurse = target.createPurse(balance); |
| 193 reply(createPurse); | 189 reply(createPurse); |
| 194 } else if (command == "promote") { | 190 } else if (command == "promote") { |
| 195 List<Promise<SendPort>> promises = new List<Promise<SendPort>>(); | 191 Purse$Proxy purse = new Purse$ProxyImpl(new Promise<SendPort>.fromValue(me
ssage[1])); |
| 196 promises.add(new PromiseProxy<SendPort>(new Promise<SendPort>.fromValue(me
ssage[1]))); | |
| 197 Purse$Proxy purse = new Purse$ProxyImpl(promises[0]); | |
| 198 Promise<PowerfulPurse$Proxy> promote = target.promote(purse); | 192 Promise<PowerfulPurse$Proxy> promote = target.promote(purse); |
| 199 reply(promote); | 193 reply(promote); |
| 200 } else { | 194 } else { |
| 201 // TODO(kasperl,benl): Somehow throw an exception instead. | 195 // TODO(kasperl,benl): Somehow throw an exception instead. |
| 202 reply("Exception: command '" + command + "' not understood by Mint."); | 196 reply("Exception: command '" + command + "' not understood by Mint."); |
| 203 } | 197 } |
| 204 } | 198 } |
| 205 } | 199 } |
| 206 | 200 |
| 207 class Mint$Dispatcher$Isolate extends Isolate { | 201 class Mint$Dispatcher$Isolate extends Isolate { |
| (...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 499 expect.succeeded(); | 493 expect.succeeded(); |
| 500 print("##DONE##"); | 494 print("##DONE##"); |
| 501 }); | 495 }); |
| 502 } | 496 } |
| 503 | 497 |
| 504 } | 498 } |
| 505 | 499 |
| 506 main() { | 500 main() { |
| 507 runTests([MintMakerFullyIsolatedTest.testMain]); | 501 runTests([MintMakerFullyIsolatedTest.testMain]); |
| 508 } | 502 } |
| OLD | NEW |