| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 import 'dart:async'; | 5 import 'dart:async'; |
| 6 import 'dart:mojo_bindings' as bindings; | 6 import 'dart:mojo_bindings' as bindings; |
| 7 import 'dart:mojo_core' as core; | 7 import 'dart:mojo_core' as core; |
| 8 import 'dart:typed_data'; | 8 import 'dart:typed_data'; |
| 9 | 9 |
| 10 import 'package:mojo/dart/embedder/test/dart_to_cpp.mojom.dart'; | 10 import 'package:mojo/dart/embedder/test/dart_to_cpp.mojom.dart'; |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 57 if (arg.si8 > 0) { | 57 if (arg.si8 > 0) { |
| 58 arg.si8 = BAD_VALUE; | 58 arg.si8 = BAD_VALUE; |
| 59 } | 59 } |
| 60 | 60 |
| 61 for (int i = 0; i < numIterations; ++i) { | 61 for (int i = 0; i < numIterations; ++i) { |
| 62 var dataPipe1 = new core.MojoDataPipe(ELEMENT_BYTES, CAPACITY_BYTES); | 62 var dataPipe1 = new core.MojoDataPipe(ELEMENT_BYTES, CAPACITY_BYTES); |
| 63 var dataPipe2 = new core.MojoDataPipe(ELEMENT_BYTES, CAPACITY_BYTES); | 63 var dataPipe2 = new core.MojoDataPipe(ELEMENT_BYTES, CAPACITY_BYTES); |
| 64 var messagePipe1 = new core.MojoMessagePipe(); | 64 var messagePipe1 = new core.MojoMessagePipe(); |
| 65 var messagePipe2 = new core.MojoMessagePipe(); | 65 var messagePipe2 = new core.MojoMessagePipe(); |
| 66 | 66 |
| 67 arg.dataHandle = dataPipe1.consumer.handle; | 67 arg.dataHandle = dataPipe1.consumer; |
| 68 arg.messageHandle = messagePipe1.endpoints[0].handle; | 68 arg.messageHandle = messagePipe1.endpoints[0]; |
| 69 | 69 |
| 70 var specialArg = new EchoArgs(); | 70 var specialArg = new EchoArgs(); |
| 71 specialArg.si64 = -1; | 71 specialArg.si64 = -1; |
| 72 specialArg.si32 = -1; | 72 specialArg.si32 = -1; |
| 73 specialArg.si16 = -1; | 73 specialArg.si16 = -1; |
| 74 specialArg.si8 = -1; | 74 specialArg.si8 = -1; |
| 75 specialArg.name = 'going'; | 75 specialArg.name = 'going'; |
| 76 specialArg.dataHandle = dataPipe2.consumer.handle; | 76 specialArg.dataHandle = dataPipe2.consumer; |
| 77 specialArg.messageHandle = messagePipe2.endpoints[0].handle; | 77 specialArg.messageHandle = messagePipe2.endpoints[0]; |
| 78 | 78 |
| 79 dataPipe1.producer.write(_sampleData.buffer.asByteData()); | 79 dataPipe1.producer.write(_sampleData.buffer.asByteData()); |
| 80 dataPipe2.producer.write(_sampleData.buffer.asByteData()); | 80 dataPipe2.producer.write(_sampleData.buffer.asByteData()); |
| 81 messagePipe1.endpoints[1].write(_sampleMessage.buffer.asByteData()); | 81 messagePipe1.endpoints[1].write(_sampleMessage.buffer.asByteData()); |
| 82 messagePipe2.endpoints[1].write(_sampleMessage.buffer.asByteData()); | 82 messagePipe2.endpoints[1].write(_sampleMessage.buffer.asByteData()); |
| 83 | 83 |
| 84 callEchoResponse(createEchoArgsList([arg, specialArg])); | 84 callEchoResponse(createEchoArgsList([arg, specialArg])); |
| 85 | 85 |
| 86 dataPipe1.producer.handle.close(); | 86 dataPipe1.producer.handle.close(); |
| 87 dataPipe2.producer.handle.close(); | 87 dataPipe2.producer.handle.close(); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 101 int mojoHandle = args[0]; | 101 int mojoHandle = args[0]; |
| 102 var rawHandle = new core.MojoHandle(mojoHandle); | 102 var rawHandle = new core.MojoHandle(mojoHandle); |
| 103 var endpoint = new core.MojoMessagePipeEndpoint(rawHandle); | 103 var endpoint = new core.MojoMessagePipeEndpoint(rawHandle); |
| 104 var dartSide = new DartSide(endpoint); | 104 var dartSide = new DartSide(endpoint); |
| 105 dartSide.listen(); | 105 dartSide.listen(); |
| 106 dartSide.callStartTest(); | 106 dartSide.callStartTest(); |
| 107 dartSide.future.then((_) { | 107 dartSide.future.then((_) { |
| 108 print('Success'); | 108 print('Success'); |
| 109 }); | 109 }); |
| 110 } | 110 } |
| OLD | NEW |