1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
part of core;
class _MojoDataPipeNatives {
static List MojoCreateDataPipe(
int element_bytes, int capacity_bytes, int flags)
native "MojoDataPipe_Create";
static List MojoWriteData(int handle, ByteData data, int num_bytes, int flags)
native "MojoDataPipe_WriteData";
static List MojoBeginWriteData(int handle, int buffer_bytes, int flags)
native "MojoDataPipe_BeginWriteData";
static int MojoEndWriteData(int handle, int bytes_written)
native "MojoDataPipe_EndWriteData";
static List MojoReadData(int handle, ByteData data, int num_bytes, int flags)
native "MojoDataPipe_ReadData";
static List MojoBeginReadData(int handle, int buffer_bytes, int flags)
native "MojoDataPipe_BeginReadData";
static int MojoEndReadData(int handle, int bytes_read)
native "MojoDataPipe_EndReadData";
}
class MojoDataPipeProducer {
static const int FLAG_NONE = 0;
static const int FLAG_ALL_OR_NONE = 1 << 0;
MojoHandle handle;
MojoResult status;
final int element_bytes;
MojoDataPipeProducer(this.handle,
this.status,
this.element_bytes);
int write(ByteData data, [int num_bytes = -1, int flags = 0]) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
int data_num_bytes = (num_bytes == -1) ? data.lengthInBytes : num_bytes;
List result = _MojoDataPipeNatives.MojoWriteData(
handle.h, data, data_num_bytes, flags);
if (result == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
assert((result is List) && (result.length == 2));
status = new MojoResult(result[0]);
return result[1];
}
ByteData beginWrite(int buffer_bytes, [int flags = 0]) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return null;
}
List result = _MojoDataPipeNatives.MojoBeginWriteData(
handle.h, buffer_bytes, flags);
if (result == null) {
status = MojoResult.INVALID_ARGUMENT;
return null;
}
assert((result is List) && (result.length == 2));
status = new MojoResult(result[0]);
return result[1];
}
MojoResult endWrite(int bytes_written) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
int result = _MojoDataPipeNatives.MojoEndWriteData(handle.h, bytes_written);
status = new MojoResult(result);
return status;
}
}
class MojoDataPipeConsumer {
static const int FLAG_NONE = 0;
static const int FLAG_ALL_OR_NONE = 1 << 0;
static const int FLAG_MAY_DISCARD = 1 << 1;
static const int FLAG_QUERY = 1 << 2;
static const int FLAG_PEEK = 1 << 3;
MojoHandle handle;
MojoResult status;
final int element_bytes;
MojoDataPipeConsumer(
this.handle, [this.status = MojoResult.OK, this.element_bytes = 1]);
int read(ByteData data, [int num_bytes = -1, int flags = 0]) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
int data_num_bytes = (num_bytes == -1) ? data.lengthInBytes : num_bytes;
List result = _MojoDataPipeNatives.MojoReadData(
handle.h, data, data_num_bytes, flags);
if (result == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
assert((result is List) && (result.length == 2));
status = new MojoResult(result[0]);
return result[1];
}
ByteData beginRead([int buffer_bytes = 0, int flags = 0]) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return null;
}
List result = _MojoDataPipeNatives.MojoBeginReadData(
handle.h, buffer_bytes, flags);
if (result == null) {
status = MojoResult.INVALID_ARGUMENT;
return null;
}
assert((result is List) && (result.length == 2));
status = new MojoResult(result[0]);
return result[1];
}
MojoResult endRead(int bytes_read) {
if (handle == null) {
status = MojoResult.INVALID_ARGUMENT;
return status;
}
int result = _MojoDataPipeNatives.MojoEndReadData(handle.h, bytes_read);
status = new MojoResult(result);
return status;
}
int query() => read(null, 0, FLAG_QUERY);
}
class MojoDataPipe {
static const int FLAG_NONE = 0;
static const int FLAG_MAY_DISCARD = 1 << 0;
static const int DEFAULT_ELEMENT_SIZE = 1;
static const int DEFAULT_CAPACITY = 0;
MojoDataPipeProducer producer;
MojoDataPipeConsumer consumer;
MojoResult status;
MojoDataPipe._internal() {
producer = null;
consumer = null;
status = MojoResult.OK;
}
factory MojoDataPipe([int element_bytes = DEFAULT_ELEMENT_SIZE,
int capacity_bytes = DEFAULT_CAPACITY,
int flags = FLAG_NONE]) {
List result = _MojoDataPipeNatives.MojoCreateDataPipe(
element_bytes, capacity_bytes, flags);
if (result == null) {
return null;
}
assert((result is List) && (result.length == 3));
MojoHandle producer_handle = new MojoHandle(result[1]);
MojoHandle consumer_handle = new MojoHandle(result[2]);
MojoDataPipe pipe = new MojoDataPipe._internal();
pipe.producer = new MojoDataPipeProducer(
producer_handle, new MojoResult(result[0]), element_bytes);
pipe.consumer = new MojoDataPipeConsumer(
consumer_handle, new MojoResult(result[0]), element_bytes);
pipe.status = new MojoResult(result[0]);
return pipe;
}
}
|
