Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(412)

Side by Side Diff: mojo/public/dart/src/proxy.dart

Issue 968243003: Dart: Adds optional named arguments for creating bindings. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Format Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « mojo/public/dart/src/event_stream.dart ('k') | mojo/public/dart/src/stub.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 part of bindings; 5 part of bindings;
6 6
7 abstract class Proxy extends core.MojoEventStreamListener { 7 abstract class Proxy extends core.MojoEventStreamListener {
8 Map<int, Completer> _completerMap; 8 Map<int, Completer> _completerMap;
9 int _nextId = 0; 9 int _nextId = 0;
10 10
11 Proxy(core.MojoMessagePipeEndpoint endpoint) : 11 Proxy.fromEndpoint(core.MojoMessagePipeEndpoint endpoint, {bool doListen:
12 _completerMap = {}, 12 true, Function onClosed})
13 super(endpoint); 13 : _completerMap = {},
14 super.fromEndpoint(endpoint, doListen: doListen, onClosed: onClosed);
14 15
15 Proxy.fromHandle(core.MojoHandle handle) : 16 Proxy.fromHandle(core.MojoHandle handle, {bool doListen: true,
16 _completerMap = {}, 17 Function onClosed})
17 super.fromHandle(handle); 18 : _completerMap = {},
19 super.fromHandle(handle, doListen: doListen, onClosed: onClosed);
18 20
19 Proxy.unbound() : 21 Proxy.unbound()
20 _completerMap = {}, 22 : _completerMap = {},
21 super.unbound(); 23 super.unbound();
22 24
23 void handleResponse(ServiceMessage reader); 25 void handleResponse(ServiceMessage reader);
24 26
25 void handleRead() { 27 void handleRead() {
26 // Query how many bytes are available. 28 // Query how many bytes are available.
27 var result = endpoint.query(); 29 var result = endpoint.query();
28 assert(result.status.isOk || result.status.isResourceExhausted); 30 assert(result.status.isOk || result.status.isResourceExhausted);
29 31
30 // Read the data. 32 // Read the data.
31 var bytes = new ByteData(result.bytesRead); 33 var bytes = new ByteData(result.bytesRead);
32 var handles = new List<core.MojoHandle>(result.handlesRead); 34 var handles = new List<core.MojoHandle>(result.handlesRead);
33 result = endpoint.read(bytes, result.bytesRead, handles); 35 result = endpoint.read(bytes, result.bytesRead, handles);
34 assert(result.status.isOk || result.status.isResourceExhausted); 36 assert(result.status.isOk || result.status.isResourceExhausted);
35 var message = new ServiceMessage.fromMessage(new Message(bytes, handles)); 37 var message = new ServiceMessage.fromMessage(new Message(bytes, handles));
36 handleResponse(message); 38 handleResponse(message);
37 } 39 }
38 40
39 void handleWrite() { 41 void handleWrite() {
40 throw 'Unexpected write signal in proxy.'; 42 throw 'Unexpected write signal in proxy.';
41 } 43 }
42 44
43 void sendMessage(Struct message, int name) { 45 void sendMessage(Struct message, int name) {
44 if (!isOpen) { 46 if (!isOpen) {
45 listen(); 47 listen();
46 } 48 }
47 var header = new MessageHeader(name); 49 var header = new MessageHeader(name);
48 var serviceMessage = message.serializeWithHeader(header); 50 var serviceMessage = message.serializeWithHeader(header);
49 endpoint.write(serviceMessage.buffer, 51 endpoint.write(
50 serviceMessage.buffer.lengthInBytes, 52 serviceMessage.buffer,
51 serviceMessage.handles); 53 serviceMessage.buffer.lengthInBytes,
54 serviceMessage.handles);
52 if (!endpoint.status.isOk) { 55 if (!endpoint.status.isOk) {
53 throw "message pipe write failed - ${endpoint.status}"; 56 throw "message pipe write failed - ${endpoint.status}";
54 } 57 }
55 } 58 }
56 59
57 Future sendMessageWithRequestId( 60 Future sendMessageWithRequestId(Struct message, int name, int id, int flags) {
58 Struct message, int name, int id, int flags) {
59 if (!isOpen) { 61 if (!isOpen) {
60 listen(); 62 listen();
61 } 63 }
62 if (id == -1) { 64 if (id == -1) {
63 id = _nextId++; 65 id = _nextId++;
64 } 66 }
65 67
66 var header = new MessageHeader.withRequestId(name, flags, id); 68 var header = new MessageHeader.withRequestId(name, flags, id);
67 var serviceMessage = message.serializeWithHeader(header); 69 var serviceMessage = message.serializeWithHeader(header);
68 endpoint.write(serviceMessage.buffer, 70 endpoint.write(
69 serviceMessage.buffer.lengthInBytes, 71 serviceMessage.buffer,
70 serviceMessage.handles); 72 serviceMessage.buffer.lengthInBytes,
73 serviceMessage.handles);
71 if (!endpoint.status.isOk) { 74 if (!endpoint.status.isOk) {
72 throw "message pipe write failed - ${endpoint.status}"; 75 throw "message pipe write failed - ${endpoint.status}";
73 } 76 }
74 77
75 var completer = new Completer(); 78 var completer = new Completer();
76 _completerMap[id] = completer; 79 _completerMap[id] = completer;
77 return completer.future; 80 return completer.future;
78 } 81 }
79 82
80 // Need a getter for this for access in subclasses. 83 // Need a getter for this for access in subclasses.
81 Map<int, Completer> get completerMap => _completerMap; 84 Map<int, Completer> get completerMap => _completerMap;
82 } 85 }
83 86
84 87
85 // Generated Proxy classes implement this interface. 88 // Generated Proxy classes implement this interface.
86 abstract class ProxyBase { 89 abstract class ProxyBase {
87 final Proxy impl; 90 final Proxy impl;
88 final String name; 91 final String name;
89 } 92 }
OLDNEW
« no previous file with comments | « mojo/public/dart/src/event_stream.dart ('k') | mojo/public/dart/src/stub.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698