OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 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 file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #include "platform/assert.h" | 5 #include "platform/assert.h" |
6 #include "vm/bootstrap_natives.h" | 6 #include "vm/bootstrap_natives.h" |
7 #include "vm/class_finalizer.h" | 7 #include "vm/class_finalizer.h" |
8 #include "vm/dart.h" | 8 #include "vm/dart.h" |
9 #include "vm/dart_api_impl.h" | 9 #include "vm/dart_api_impl.h" |
10 #include "vm/dart_entry.h" | 10 #include "vm/dart_entry.h" |
11 #include "vm/exceptions.h" | 11 #include "vm/exceptions.h" |
12 #include "vm/lockers.h" | 12 #include "vm/lockers.h" |
13 #include "vm/longjump.h" | 13 #include "vm/longjump.h" |
14 #include "vm/message_handler.h" | 14 #include "vm/message_handler.h" |
15 #include "vm/object.h" | 15 #include "vm/object.h" |
16 #include "vm/object_store.h" | 16 #include "vm/object_store.h" |
17 #include "vm/port.h" | 17 #include "vm/port.h" |
18 #include "vm/resolver.h" | 18 #include "vm/resolver.h" |
19 #include "vm/snapshot.h" | 19 #include "vm/snapshot.h" |
20 #include "vm/symbols.h" | 20 #include "vm/symbols.h" |
21 #include "vm/unicode.h" | |
22 | 21 |
23 namespace dart { | 22 namespace dart { |
24 | 23 |
25 static uint8_t* allocator(uint8_t* ptr, intptr_t old_size, intptr_t new_size) { | 24 static uint8_t* allocator(uint8_t* ptr, intptr_t old_size, intptr_t new_size) { |
26 void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size); | 25 void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size); |
27 return reinterpret_cast<uint8_t*>(new_ptr); | 26 return reinterpret_cast<uint8_t*>(new_ptr); |
28 } | 27 } |
29 | 28 |
30 | 29 |
31 DEFINE_NATIVE_ENTRY(CapabilityImpl_factory, 1) { | 30 DEFINE_NATIVE_ENTRY(CapabilityImpl_factory, 1) { |
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
147 if (callback == NULL) { | 146 if (callback == NULL) { |
148 *error = strdup("Null callback specified for isolate creation\n"); | 147 *error = strdup("Null callback specified for isolate creation\n"); |
149 Isolate::SetCurrent(parent_isolate); | 148 Isolate::SetCurrent(parent_isolate); |
150 return false; | 149 return false; |
151 } | 150 } |
152 | 151 |
153 void* init_data = parent_isolate->init_callback_data(); | 152 void* init_data = parent_isolate->init_callback_data(); |
154 Isolate* child_isolate = reinterpret_cast<Isolate*>( | 153 Isolate* child_isolate = reinterpret_cast<Isolate*>( |
155 (callback)(state->script_url(), | 154 (callback)(state->script_url(), |
156 state->function_name(), | 155 state->function_name(), |
157 state->package_root(), | |
158 init_data, | 156 init_data, |
159 error)); | 157 error)); |
160 if (child_isolate == NULL) { | 158 if (child_isolate == NULL) { |
161 Isolate::SetCurrent(parent_isolate); | 159 Isolate::SetCurrent(parent_isolate); |
162 return false; | 160 return false; |
163 } | 161 } |
164 state->set_isolate(reinterpret_cast<Isolate*>(child_isolate)); | 162 state->set_isolate(reinterpret_cast<Isolate*>(child_isolate)); |
165 | 163 |
166 Isolate::SetCurrent(parent_isolate); | 164 Isolate::SetCurrent(parent_isolate); |
167 return true; | 165 return true; |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
211 return Spawn(isolate, new IsolateSpawnState(port.Id(), func, message)); | 209 return Spawn(isolate, new IsolateSpawnState(port.Id(), func, message)); |
212 } | 210 } |
213 } | 211 } |
214 const String& msg = String::Handle(String::New( | 212 const String& msg = String::Handle(String::New( |
215 "Isolate.spawn expects to be passed a static or top-level function")); | 213 "Isolate.spawn expects to be passed a static or top-level function")); |
216 Exceptions::ThrowArgumentError(msg); | 214 Exceptions::ThrowArgumentError(msg); |
217 return Object::null(); | 215 return Object::null(); |
218 } | 216 } |
219 | 217 |
220 | 218 |
221 DEFINE_NATIVE_ENTRY(Isolate_spawnUri, 5) { | 219 DEFINE_NATIVE_ENTRY(Isolate_spawnUri, 4) { |
222 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, port, arguments->NativeArgAt(0)); | 220 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, port, arguments->NativeArgAt(0)); |
223 GET_NON_NULL_NATIVE_ARGUMENT(String, uri, arguments->NativeArgAt(1)); | 221 GET_NON_NULL_NATIVE_ARGUMENT(String, uri, arguments->NativeArgAt(1)); |
224 GET_NON_NULL_NATIVE_ARGUMENT(Instance, args, arguments->NativeArgAt(2)); | 222 GET_NON_NULL_NATIVE_ARGUMENT(Instance, args, arguments->NativeArgAt(2)); |
225 GET_NON_NULL_NATIVE_ARGUMENT(Instance, message, arguments->NativeArgAt(3)); | 223 GET_NON_NULL_NATIVE_ARGUMENT(Instance, message, arguments->NativeArgAt(3)); |
226 GET_NATIVE_ARGUMENT(String, package_root, arguments->NativeArgAt(4)); | |
227 | 224 |
228 // Canonicalize the uri with respect to the current isolate. | 225 // Canonicalize the uri with respect to the current isolate. |
229 char* error = NULL; | 226 char* error = NULL; |
230 char* canonical_uri = NULL; | 227 char* canonical_uri = NULL; |
231 const Library& root_lib = | 228 const Library& root_lib = |
232 Library::Handle(arguments->isolate()->object_store()->root_library()); | 229 Library::Handle(arguments->isolate()->object_store()->root_library()); |
233 if (!CanonicalizeUri(arguments->isolate(), root_lib, uri, | 230 if (!CanonicalizeUri(arguments->isolate(), root_lib, uri, |
234 &canonical_uri, &error)) { | 231 &canonical_uri, &error)) { |
235 const String& msg = String::Handle(String::New(error)); | 232 const String& msg = String::Handle(String::New(error)); |
236 ThrowIsolateSpawnException(msg); | 233 ThrowIsolateSpawnException(msg); |
237 } | 234 } |
238 | 235 |
239 char* utf8_package_root = NULL; | 236 return Spawn(isolate, new IsolateSpawnState(port.Id(), canonical_uri, |
240 if (!package_root.IsNull()) { | 237 args, message)); |
241 const intptr_t len = Utf8::Length(package_root); | |
242 Zone* zone = isolate->current_zone(); | |
243 utf8_package_root = zone->Alloc<char>(len + 1); | |
244 package_root.ToUTF8(reinterpret_cast<uint8_t*>(utf8_package_root), len); | |
245 utf8_package_root[len] = '\0'; | |
246 } | |
247 | |
248 return Spawn(isolate, new IsolateSpawnState( | |
249 port.Id(), canonical_uri, utf8_package_root, args, message)); | |
250 } | 238 } |
251 | 239 |
252 | 240 |
253 DEFINE_NATIVE_ENTRY(Isolate_sendOOB, 2) { | 241 DEFINE_NATIVE_ENTRY(Isolate_sendOOB, 2) { |
254 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, port, arguments->NativeArgAt(0)); | 242 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, port, arguments->NativeArgAt(0)); |
255 GET_NON_NULL_NATIVE_ARGUMENT(Array, msg, arguments->NativeArgAt(1)); | 243 GET_NON_NULL_NATIVE_ARGUMENT(Array, msg, arguments->NativeArgAt(1)); |
256 | 244 |
257 // Make sure to route this request to the isolate library OOB mesage handler. | 245 // Make sure to route this request to the isolate library OOB mesage handler. |
258 msg.SetAt(0, Smi::Handle(Smi::New(Message::kIsolateLibOOBMsg))); | 246 msg.SetAt(0, Smi::Handle(Smi::New(Message::kIsolateLibOOBMsg))); |
259 | 247 |
260 uint8_t* data = NULL; | 248 uint8_t* data = NULL; |
261 MessageWriter writer(&data, &allocator); | 249 MessageWriter writer(&data, &allocator); |
262 writer.WriteMessage(msg); | 250 writer.WriteMessage(msg); |
263 | 251 |
264 PortMap::PostMessage(new Message(port.Id(), | 252 PortMap::PostMessage(new Message(port.Id(), |
265 data, writer.BytesWritten(), | 253 data, writer.BytesWritten(), |
266 Message::kOOBPriority)); | 254 Message::kOOBPriority)); |
267 return Object::null(); | 255 return Object::null(); |
268 } | 256 } |
269 | 257 |
270 } // namespace dart | 258 } // namespace dart |
OLD | NEW |