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" |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
74 name ^= String::New(":"); | 74 name ^= String::New(":"); |
75 str ^= String::Concat(str, name); | 75 str ^= String::Concat(str, name); |
76 name ^= String::NewSymbol(class_name); | 76 name ^= String::NewSymbol(class_name); |
77 str ^= String::Concat(str, name); | 77 str ^= String::Concat(str, name); |
78 GrowableArray<const Object*> arguments(1); | 78 GrowableArray<const Object*> arguments(1); |
79 arguments.Add(&str); | 79 arguments.Add(&str); |
80 Exceptions::ThrowByType(type, arguments); | 80 Exceptions::ThrowByType(type, arguments); |
81 } | 81 } |
82 | 82 |
83 | 83 |
84 // TODO(turnidge): Move to DartLibraryCalls. | 84 RawInstance* ReceivePortCreate(intptr_t port_id) { |
85 RawObject* ReceivePortCreate(intptr_t port_id) { | |
86 const String& class_name = | 85 const String& class_name = |
87 String::Handle(String::NewSymbol("ReceivePortImpl")); | 86 String::Handle(String::NewSymbol("ReceivePortImpl")); |
88 const String& function_name = | 87 const String& function_name = |
89 String::Handle(String::NewSymbol("_get_or_create")); | 88 String::Handle(String::NewSymbol("_get_or_create")); |
90 const int kNumArguments = 1; | 89 const int kNumArguments = 1; |
91 const Array& kNoArgumentNames = Array::Handle(); | 90 const Array& kNoArgumentNames = Array::Handle(); |
92 const Function& function = Function::Handle( | 91 const Function& function = Function::Handle( |
93 Resolver::ResolveStatic(Library::Handle(Library::CoreLibrary()), | 92 Resolver::ResolveStatic(Library::Handle(Library::CoreLibrary()), |
94 class_name, | 93 class_name, |
95 function_name, | 94 function_name, |
96 kNumArguments, | 95 kNumArguments, |
97 kNoArgumentNames, | 96 kNoArgumentNames, |
98 Resolver::kIsQualified)); | 97 Resolver::kIsQualified)); |
99 GrowableArray<const Object*> arguments(kNumArguments); | 98 GrowableArray<const Object*> arguments(kNumArguments); |
100 arguments.Add(&Integer::Handle(Integer::New(port_id))); | 99 arguments.Add(&Integer::Handle(Integer::New(port_id))); |
101 const Object& result = Object::Handle( | 100 const Instance& result = Instance::Handle( |
102 DartEntry::InvokeStatic(function, arguments, kNoArgumentNames)); | 101 DartEntry::InvokeStatic(function, arguments, kNoArgumentNames)); |
103 if (!result.IsError()) { | 102 if (result.IsError()) { |
| 103 ProcessError(result); |
| 104 } else { |
104 PortMap::SetLive(port_id); | 105 PortMap::SetLive(port_id); |
105 } | 106 } |
106 return result.raw(); | 107 return result.raw(); |
107 } | 108 } |
108 | 109 |
109 | 110 |
110 // TODO(turnidge): Move to DartLibraryCalls. | 111 static RawInstance* SendPortCreate(intptr_t port_id) { |
111 static RawObject* SendPortCreate(intptr_t port_id) { | |
112 const String& class_name = String::Handle(String::NewSymbol("SendPortImpl")); | 112 const String& class_name = String::Handle(String::NewSymbol("SendPortImpl")); |
113 const String& function_name = String::Handle(String::NewSymbol("_create")); | 113 const String& function_name = String::Handle(String::NewSymbol("_create")); |
114 const int kNumArguments = 1; | 114 const int kNumArguments = 1; |
115 const Array& kNoArgumentNames = Array::Handle(); | 115 const Array& kNoArgumentNames = Array::Handle(); |
116 const Function& function = Function::Handle( | 116 const Function& function = Function::Handle( |
117 Resolver::ResolveStatic(Library::Handle(Library::CoreLibrary()), | 117 Resolver::ResolveStatic(Library::Handle(Library::CoreLibrary()), |
118 class_name, | 118 class_name, |
119 function_name, | 119 function_name, |
120 kNumArguments, | 120 kNumArguments, |
121 kNoArgumentNames, | 121 kNoArgumentNames, |
122 Resolver::kIsQualified)); | 122 Resolver::kIsQualified)); |
123 GrowableArray<const Object*> arguments(kNumArguments); | 123 GrowableArray<const Object*> arguments(kNumArguments); |
124 arguments.Add(&Integer::Handle(Integer::New(port_id))); | 124 arguments.Add(&Integer::Handle(Integer::New(port_id))); |
125 const Object& result = Object::Handle( | 125 const Instance& result = Instance::Handle( |
126 DartEntry::InvokeStatic(function, arguments, kNoArgumentNames)); | 126 DartEntry::InvokeStatic(function, arguments, kNoArgumentNames)); |
127 return result.raw(); | 127 return result.raw(); |
128 } | 128 } |
129 | 129 |
130 | 130 |
131 static void RunIsolate(uword parameter) { | 131 static void RunIsolate(uword parameter) { |
132 IsolateStartData* data = reinterpret_cast<IsolateStartData*>(parameter); | 132 IsolateStartData* data = reinterpret_cast<IsolateStartData*>(parameter); |
133 Isolate* isolate = data->isolate_; | 133 Isolate* isolate = data->isolate_; |
134 char* library_url = data->library_url_; | 134 char* library_url = data->library_url_; |
135 char* class_name = data->class_name_; | 135 char* class_name = data->class_name_; |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
177 } | 177 } |
178 ASSERT(result.IsNull()); | 178 ASSERT(result.IsNull()); |
179 } | 179 } |
180 | 180 |
181 // Invoke the "_run" method. | 181 // Invoke the "_run" method. |
182 const Function& target_function = Function::Handle(Resolver::ResolveDynamic( | 182 const Function& target_function = Function::Handle(Resolver::ResolveDynamic( |
183 target, String::Handle(String::NewSymbol("_run")), 2, 0)); | 183 target, String::Handle(String::NewSymbol("_run")), 2, 0)); |
184 // TODO(iposva): Proper error checking here. | 184 // TODO(iposva): Proper error checking here. |
185 ASSERT(!target_function.IsNull()); | 185 ASSERT(!target_function.IsNull()); |
186 // TODO(iposva): Allocate the proper port number here. | 186 // TODO(iposva): Allocate the proper port number here. |
187 const Object& local_port = Object::Handle(ReceivePortCreate(port_id)); | 187 const Instance& local_port = Instance::Handle(ReceivePortCreate(port_id)); |
188 if (local_port.IsError()) { | |
189 ProcessError(local_port); | |
190 } | |
191 GrowableArray<const Object*> arguments(1); | 188 GrowableArray<const Object*> arguments(1); |
192 arguments.Add(&local_port); | 189 arguments.Add(&local_port); |
193 const Array& kNoArgumentNames = Array::Handle(); | 190 const Array& kNoArgumentNames = Array::Handle(); |
194 result = DartEntry::InvokeDynamic(target, | 191 result = DartEntry::InvokeDynamic(target, |
195 target_function, | 192 target_function, |
196 arguments, | 193 arguments, |
197 kNoArgumentNames); | 194 kNoArgumentNames); |
198 if (result.IsError()) { | 195 if (result.IsError()) { |
199 ProcessError(result); | 196 ProcessError(result); |
200 } | 197 } |
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
323 | 320 |
324 // Switch back to the original isolate and return. | 321 // Switch back to the original isolate and return. |
325 Isolate::SetCurrent(preserved_isolate); | 322 Isolate::SetCurrent(preserved_isolate); |
326 if (spawned_isolate == NULL) { | 323 if (spawned_isolate == NULL) { |
327 // Unable to spawn isolate correctly, throw exception. | 324 // Unable to spawn isolate correctly, throw exception. |
328 ThrowErrorException(Exceptions::kIllegalArgument, | 325 ThrowErrorException(Exceptions::kIllegalArgument, |
329 error, | 326 error, |
330 library_url, | 327 library_url, |
331 class_name); | 328 class_name); |
332 } | 329 } |
333 | 330 const Instance& port = Instance::Handle(SendPortCreate(port_id)); |
334 // TODO(turnidge): Move this code up before we launch the new | |
335 // thread. That way we won't have a thread hanging around that we | |
336 // can't talk to. | |
337 const Object& port = Object::Handle(SendPortCreate(port_id)); | |
338 if (port.IsError()) { | 331 if (port.IsError()) { |
339 Exceptions::PropagateError(port); | 332 if (port.IsUnhandledException()) { |
| 333 ThrowErrorException(Exceptions::kInternalError, |
| 334 "Unable to create send port to isolate", |
| 335 library_url, |
| 336 class_name); |
| 337 } else { |
| 338 ProcessError(port); |
| 339 } |
340 } | 340 } |
341 arguments->SetReturn(port); | 341 arguments->SetReturn(port); |
342 } | 342 } |
343 | 343 |
344 | 344 |
345 DEFINE_NATIVE_ENTRY(ReceivePortImpl_factory, 1) { | 345 DEFINE_NATIVE_ENTRY(ReceivePortImpl_factory, 1) { |
346 ASSERT(AbstractTypeArguments::CheckedHandle(arguments->At(0)).IsNull()); | 346 ASSERT(AbstractTypeArguments::CheckedHandle(arguments->At(0)).IsNull()); |
347 intptr_t port_id = | 347 intptr_t port_id = |
348 PortMap::CreatePort(arguments->isolate()->message_handler()); | 348 PortMap::CreatePort(arguments->isolate()->message_handler()); |
349 const Object& port = Object::Handle(ReceivePortCreate(port_id)); | 349 const Instance& port = Instance::Handle(ReceivePortCreate(port_id)); |
350 if (port.IsError()) { | |
351 Exceptions::PropagateError(port); | |
352 } | |
353 arguments->SetReturn(port); | 350 arguments->SetReturn(port); |
354 } | 351 } |
355 | 352 |
356 | 353 |
357 DEFINE_NATIVE_ENTRY(ReceivePortImpl_closeInternal, 1) { | 354 DEFINE_NATIVE_ENTRY(ReceivePortImpl_closeInternal, 1) { |
358 intptr_t id = Smi::CheckedHandle(arguments->At(0)).Value(); | 355 intptr_t id = Smi::CheckedHandle(arguments->At(0)).Value(); |
359 PortMap::ClosePort(id); | 356 PortMap::ClosePort(id); |
360 } | 357 } |
361 | 358 |
362 | 359 |
363 DEFINE_NATIVE_ENTRY(SendPortImpl_sendInternal_, 3) { | 360 DEFINE_NATIVE_ENTRY(SendPortImpl_sendInternal_, 3) { |
364 intptr_t send_id = Smi::CheckedHandle(arguments->At(0)).Value(); | 361 intptr_t send_id = Smi::CheckedHandle(arguments->At(0)).Value(); |
365 intptr_t reply_id = Smi::CheckedHandle(arguments->At(1)).Value(); | 362 intptr_t reply_id = Smi::CheckedHandle(arguments->At(1)).Value(); |
366 // TODO(iposva): Allow for arbitrary messages to be sent. | 363 // TODO(iposva): Allow for arbitrary messages to be sent. |
367 uint8_t* data = SerializeObject(Instance::CheckedHandle(arguments->At(2))); | 364 uint8_t* data = SerializeObject(Instance::CheckedHandle(arguments->At(2))); |
368 | 365 |
369 // TODO(turnidge): Throw an exception when the return value is false? | 366 // TODO(turnidge): Throw an exception when the return value is false? |
370 PortMap::PostMessage(new Message( | 367 PortMap::PostMessage(new Message( |
371 send_id, reply_id, data, Message::kNormalPriority)); | 368 send_id, reply_id, data, Message::kNormalPriority)); |
372 } | 369 } |
373 | 370 |
374 } // namespace dart | 371 } // namespace dart |
OLD | NEW |