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 |