OLD | NEW |
| (Empty) |
1 // Copyright (c) 2015, the Dartino project authors. Please see the AUTHORS file | |
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.md file. | |
4 | |
5 #include "struct.h" | |
6 | |
7 #include <stdlib.h> | |
8 #include <stddef.h> | |
9 | |
10 #include "unicode.h" | |
11 | |
12 static const int HEADER_SIZE = 56; | |
13 | |
14 char* pointerToArgument(char* buffer, int offset) { | |
15 return buffer + HEADER_SIZE + offset; | |
16 } | |
17 | |
18 int64_t* pointerToInt64Argument(char* buffer, int offset) { | |
19 return reinterpret_cast<int64_t*>(pointerToArgument(buffer, offset)); | |
20 } | |
21 | |
22 int64_t* pointerToResult(char* buffer) { | |
23 return pointerToInt64Argument(buffer, 0); | |
24 } | |
25 | |
26 int64_t* pointerToSegments(char* buffer) { | |
27 return pointerToInt64Argument(buffer, -8); | |
28 } | |
29 | |
30 void** pointerToCallbackFunction(char* buffer) { | |
31 return reinterpret_cast<void**>(pointerToArgument(buffer, -16)); | |
32 } | |
33 | |
34 void** pointerToCallbackData(char* buffer) { | |
35 return reinterpret_cast<void**>(pointerToArgument(buffer, -24)); | |
36 } | |
37 | |
38 MessageBuilder::MessageBuilder(int space) | |
39 : first_(this, 0, space), | |
40 last_(&first_), | |
41 segments_(1) { | |
42 } | |
43 | |
44 int MessageBuilder::ComputeUsed() const { | |
45 int result = 0; | |
46 const BuilderSegment* current = &first_; | |
47 while (current != NULL) { | |
48 result += current->used(); | |
49 current = current->next(); | |
50 } | |
51 return result; | |
52 } | |
53 | |
54 Builder MessageBuilder::InternalInitRoot(int size) { | |
55 // Return value and arguments use the same space. Therefore, | |
56 // the size of any struct needs to be at least 8 bytes in order | |
57 // to have room for the return address. | |
58 if (size == 0) size = 8; | |
59 int offset = first_.Allocate(HEADER_SIZE + size); | |
60 if (offset < 0) abort(); | |
61 return Builder(&first_, offset + HEADER_SIZE); | |
62 } | |
63 | |
64 BuilderSegment* MessageBuilder::FindSegmentForBytes(int bytes) { | |
65 if (last_->HasSpaceForBytes(bytes)) return last_; | |
66 int capacity = (bytes > 8192) ? bytes : 8192; | |
67 BuilderSegment* segment = new BuilderSegment(this, segments_++, capacity); | |
68 last_->set_next(segment); | |
69 last_ = segment; | |
70 return segment; | |
71 } | |
72 | |
73 void MessageBuilder::DeleteMessage(char* buffer) { | |
74 int64_t segments = *pointerToSegments(buffer); | |
75 for (int i = 0; i < segments; i++) { | |
76 int64_t address = *pointerToInt64Argument(buffer, 8 + (i * 16)); | |
77 char* memory = reinterpret_cast<char*>(address); | |
78 free(memory); | |
79 } | |
80 free(buffer); | |
81 } | |
82 | |
83 MessageReader::MessageReader(int segments, char* memory) | |
84 : segment_count_(segments), | |
85 segments_(new Segment*[segments]) { | |
86 for (int i = 0; i < segments; i++) { | |
87 int64_t address = *reinterpret_cast<int64_t*>(memory + (i * 16)); | |
88 int size = *reinterpret_cast<int*>(memory + 8 + (i * 16)); | |
89 segments_[i] = new Segment(this, reinterpret_cast<char*>(address), size); | |
90 } | |
91 } | |
92 | |
93 MessageReader::~MessageReader() { | |
94 for (int i = 0; i < segment_count_; ++i) { | |
95 delete segments_[i]; | |
96 } | |
97 delete[] segments_; | |
98 } | |
99 | |
100 Segment* MessageReader::GetRootSegment(char* memory) { | |
101 int32_t segments = *reinterpret_cast<int32_t*>(memory); | |
102 if (segments == 0) { | |
103 int32_t size = *reinterpret_cast<int32_t*>(memory + 4); | |
104 return new Segment(memory, size); | |
105 } else { | |
106 MessageReader* reader = new MessageReader(segments, memory + 8); | |
107 free(memory); | |
108 return new Segment(reader); | |
109 } | |
110 } | |
111 | |
112 Segment::Segment(char* memory, int size) | |
113 : reader_(NULL), | |
114 memory_(memory), | |
115 size_(size), | |
116 is_root_(false) { | |
117 } | |
118 | |
119 Segment::Segment(MessageReader* reader, char* memory, int size) | |
120 : reader_(reader), | |
121 memory_(memory), | |
122 size_(size), | |
123 is_root_(false) { | |
124 } | |
125 | |
126 Segment::Segment(MessageReader* reader) | |
127 : reader_(reader), | |
128 is_root_(true) { | |
129 Segment* first = reader->GetSegment(0); | |
130 memory_ = first->memory(); | |
131 size_ = first->size(); | |
132 } | |
133 | |
134 Segment::~Segment() { | |
135 if (is_root_) { | |
136 delete reader_; | |
137 } else { | |
138 free(memory_); | |
139 } | |
140 } | |
141 | |
142 BuilderSegment::BuilderSegment(MessageBuilder* builder, int id, int capacity) | |
143 : Segment(reinterpret_cast<char*>(calloc(capacity, 1)), capacity), | |
144 builder_(builder), | |
145 id_(id), | |
146 next_(NULL), | |
147 used_(0) { | |
148 } | |
149 | |
150 BuilderSegment::~BuilderSegment() { | |
151 if (next_ != NULL) { | |
152 delete next_; | |
153 next_ = NULL; | |
154 } | |
155 } | |
156 | |
157 int BuilderSegment::Allocate(int bytes) { | |
158 if (!HasSpaceForBytes(bytes)) return -1; | |
159 int result = used_; | |
160 used_ += bytes; | |
161 return result; | |
162 } | |
163 | |
164 void BuilderSegment::Detach() { | |
165 Segment::Detach(); | |
166 if (next_ != NULL) next_->Detach(); | |
167 } | |
168 | |
169 static int ComputeStructBuffer(BuilderSegment* segment, | |
170 char** buffer) { | |
171 if (segment->HasNext()) { | |
172 // Build a segmented message. The segmented message has the | |
173 // usual 48-byte header, room for a result, and then a list | |
174 // of all the segments in the message. The segments in the | |
175 // message are extracted and freed on return from the service | |
176 // call. | |
177 int segments = segment->builder()->segments(); | |
178 int size = HEADER_SIZE + 8 + (segments * 16); | |
179 *buffer = reinterpret_cast<char*>(malloc(size)); | |
180 int offset = HEADER_SIZE + 8; | |
181 do { | |
182 *reinterpret_cast<void**>(*buffer + offset) = segment->At(0); | |
183 *reinterpret_cast<int*>(*buffer + offset + 8) = segment->used(); | |
184 segment = segment->next(); | |
185 offset += 16; | |
186 } while (segment != NULL); | |
187 | |
188 // Mark the request as being segmented. | |
189 *pointerToSegments(*buffer) = segments; | |
190 return size; | |
191 } | |
192 | |
193 *buffer = reinterpret_cast<char*>(segment->At(0)); | |
194 int size = segment->used(); | |
195 // Mark the request as being non-segmented. | |
196 *pointerToSegments(*buffer) = 0; | |
197 return size; | |
198 } | |
199 | |
200 int64_t Builder::InvokeMethod(ServiceId service, MethodId method) { | |
201 BuilderSegment* segment = this->segment(); | |
202 char* buffer; | |
203 int size = ComputeStructBuffer(segment, &buffer); | |
204 segment->Detach(); | |
205 ServiceApiInvoke(service, method, buffer, size); | |
206 int64_t result = *pointerToResult(buffer); | |
207 MessageBuilder::DeleteMessage(buffer); | |
208 return result; | |
209 } | |
210 | |
211 void Builder::InvokeMethodAsync(ServiceId service, | |
212 MethodId method, | |
213 ServiceApiCallback api_callback, | |
214 void* callback_function, | |
215 void* callback_data) { | |
216 BuilderSegment* segment = this->segment(); | |
217 char* buffer; | |
218 int size = ComputeStructBuffer(segment, &buffer); | |
219 segment->Detach(); | |
220 // Set the callback function (the user supplied callback). | |
221 *pointerToCallbackFunction(buffer) = callback_function; | |
222 *pointerToCallbackData(buffer) = callback_data; | |
223 ServiceApiInvokeAsync(service, method, api_callback, buffer, size); | |
224 } | |
225 | |
226 Builder Builder::NewStruct(int offset, int size) { | |
227 offset += this->offset(); | |
228 BuilderSegment* segment = this->segment(); | |
229 while (true) { | |
230 int* lo = reinterpret_cast<int*>(segment->At(offset + 0)); | |
231 int* hi = reinterpret_cast<int*>(segment->At(offset + 4)); | |
232 int result = segment->Allocate(size); | |
233 if (result >= 0) { | |
234 *lo = (result << 2) | 1; | |
235 *hi = 0; | |
236 return Builder(segment, result); | |
237 } | |
238 | |
239 BuilderSegment* other = segment->builder()->FindSegmentForBytes(size + 8); | |
240 int target = other->Allocate(8); | |
241 *lo = (target << 2) | 3; | |
242 *hi = other->id(); | |
243 | |
244 segment = other; | |
245 offset = target; | |
246 } | |
247 } | |
248 | |
249 Reader Builder::NewList(int offset, int length, int size) { | |
250 offset += this->offset(); | |
251 size *= length; | |
252 BuilderSegment* segment = this->segment(); | |
253 while (true) { | |
254 int* lo = reinterpret_cast<int*>(segment->At(offset + 0)); | |
255 int* hi = reinterpret_cast<int*>(segment->At(offset + 4)); | |
256 int result = segment->Allocate(size); | |
257 if (result >= 0) { | |
258 *lo = (result << 2) | 2; | |
259 *hi = length; | |
260 return Reader(segment, result); | |
261 } | |
262 | |
263 BuilderSegment* other = segment->builder()->FindSegmentForBytes(size + 8); | |
264 int target = other->Allocate(8); | |
265 *lo = (target << 2) | 3; | |
266 *hi = other->id(); | |
267 | |
268 segment = other; | |
269 offset = target; | |
270 } | |
271 } | |
272 | |
273 void Builder::NewString(int offset, const char* value) { | |
274 size_t value_len = strlen(value); | |
275 Utf8::Type type; | |
276 intptr_t len = Utf8::CodeUnitCount(value, value_len, &type); | |
277 Reader reader = NewList(offset, len, 2); | |
278 uint16_t* dst = | |
279 reinterpret_cast<uint16_t*>(reader.segment()->memory() + reader.offset()); | |
280 Utf8::DecodeToUTF16(value, value_len, dst, len); | |
281 } | |
282 | |
283 int Reader::ComputeUsed() const { | |
284 MessageReader* reader = segment_->reader(); | |
285 int used = 0; | |
286 for (int i = 0; i < reader->segment_count(); i++) { | |
287 used += reader->GetSegment(i)->size(); | |
288 } | |
289 return used; | |
290 } | |
291 | |
292 char* Reader::ReadString(int offset) const { | |
293 List<uint16_t> data = ReadList<uint16_t>(offset); | |
294 intptr_t len = Utf8::Length(data); | |
295 char* result = reinterpret_cast<char*>(malloc(len + 1)); | |
296 Utf8::Encode(data, result, len); | |
297 result[len] = 0; | |
298 return result; | |
299 } | |
OLD | NEW |