| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, 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 "vm/bootstrap_natives.h" | 5 #include "vm/bootstrap_natives.h" |
| 6 #include "vm/dart_api_impl.h" | 6 #include "vm/dart_api_impl.h" |
| 7 #include "vm/datastream.h" | 7 #include "vm/datastream.h" |
| 8 #include "vm/exceptions.h" | 8 #include "vm/exceptions.h" |
| 9 #include "vm/flags.h" | 9 #include "vm/flags.h" |
| 10 #include "vm/growable_array.h" | 10 #include "vm/growable_array.h" |
| 11 #include "vm/message.h" | 11 #include "vm/message.h" |
| 12 #include "vm/message_handler.h" | 12 #include "vm/message_handler.h" |
| 13 #include "vm/native_entry.h" | 13 #include "vm/native_entry.h" |
| 14 #include "vm/object.h" | 14 #include "vm/object.h" |
| 15 #include "vm/port.h" | 15 #include "vm/port.h" |
| 16 #include "vm/service_event.h" | 16 #include "vm/service_event.h" |
| 17 #include "vm/service_isolate.h" | 17 #include "vm/service_isolate.h" |
| 18 #include "vm/symbols.h" | 18 #include "vm/symbols.h" |
| 19 | 19 |
| 20 namespace dart { | 20 namespace dart { |
| 21 | 21 |
| 22 DECLARE_FLAG(bool, trace_service); | 22 DECLARE_FLAG(bool, trace_service); |
| 23 | 23 |
| 24 static uint8_t* allocator(uint8_t* ptr, intptr_t old_size, intptr_t new_size) { | 24 static uint8_t* malloc_allocator(uint8_t* ptr, |
| 25 intptr_t old_size, |
| 26 intptr_t new_size) { |
| 25 void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size); | 27 void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size); |
| 26 return reinterpret_cast<uint8_t*>(new_ptr); | 28 return reinterpret_cast<uint8_t*>(new_ptr); |
| 27 } | 29 } |
| 28 | 30 |
| 31 static void malloc_deallocator(uint8_t* ptr) { |
| 32 free(reinterpret_cast<void*>(ptr)); |
| 33 } |
| 34 |
| 29 | 35 |
| 30 #ifndef PRODUCT | 36 #ifndef PRODUCT |
| 31 class RegisterRunningIsolatesVisitor : public IsolateVisitor { | 37 class RegisterRunningIsolatesVisitor : public IsolateVisitor { |
| 32 public: | 38 public: |
| 33 explicit RegisterRunningIsolatesVisitor(Thread* thread) | 39 explicit RegisterRunningIsolatesVisitor(Thread* thread) |
| 34 : IsolateVisitor(), | 40 : IsolateVisitor(), |
| 35 register_function_(Function::Handle(thread->zone())), | 41 register_function_(Function::Handle(thread->zone())), |
| 36 service_isolate_(thread->isolate()) { | 42 service_isolate_(thread->isolate()) { |
| 37 ASSERT(ServiceIsolate::IsServiceIsolate(Isolate::Current())); | 43 ASSERT(ServiceIsolate::IsServiceIsolate(Isolate::Current())); |
| 38 // Get library. | 44 // Get library. |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 88 } | 94 } |
| 89 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, sp, arguments->NativeArgAt(0)); | 95 GET_NON_NULL_NATIVE_ARGUMENT(SendPort, sp, arguments->NativeArgAt(0)); |
| 90 GET_NON_NULL_NATIVE_ARGUMENT(Array, message, arguments->NativeArgAt(1)); | 96 GET_NON_NULL_NATIVE_ARGUMENT(Array, message, arguments->NativeArgAt(1)); |
| 91 | 97 |
| 92 // Set the type of the OOB message. | 98 // Set the type of the OOB message. |
| 93 message.SetAt(0, | 99 message.SetAt(0, |
| 94 Smi::Handle(thread->zone(), Smi::New(Message::kServiceOOBMsg))); | 100 Smi::Handle(thread->zone(), Smi::New(Message::kServiceOOBMsg))); |
| 95 | 101 |
| 96 // Serialize message. | 102 // Serialize message. |
| 97 uint8_t* data = NULL; | 103 uint8_t* data = NULL; |
| 98 MessageWriter writer(&data, &allocator, false); | 104 MessageWriter writer(&data, &malloc_allocator, &malloc_deallocator, false); |
| 99 writer.WriteMessage(message); | 105 writer.WriteMessage(message); |
| 100 | 106 |
| 101 // TODO(turnidge): Throw an exception when the return value is false? | 107 // TODO(turnidge): Throw an exception when the return value is false? |
| 102 bool result = PortMap::PostMessage( | 108 bool result = PortMap::PostMessage( |
| 103 new Message(sp.Id(), data, writer.BytesWritten(), Message::kOOBPriority)); | 109 new Message(sp.Id(), data, writer.BytesWritten(), Message::kOOBPriority)); |
| 104 return Bool::Get(result).raw(); | 110 return Bool::Get(result).raw(); |
| 105 } | 111 } |
| 106 | 112 |
| 107 | 113 |
| 108 DEFINE_NATIVE_ENTRY(VMService_SendRootServiceMessage, 1) { | 114 DEFINE_NATIVE_ENTRY(VMService_SendRootServiceMessage, 1) { |
| (...skipping 356 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 465 ServiceEvent spawn_event(NULL, ServiceEvent::kIsolateSpawn); | 471 ServiceEvent spawn_event(NULL, ServiceEvent::kIsolateSpawn); |
| 466 spawn_event.set_spawn_token(&token); | 472 spawn_event.set_spawn_token(&token); |
| 467 spawn_event.set_spawn_error(&String::Cast(result)); | 473 spawn_event.set_spawn_error(&String::Cast(result)); |
| 468 Service::HandleEvent(&spawn_event); | 474 Service::HandleEvent(&spawn_event); |
| 469 } | 475 } |
| 470 #endif // PRODUCT | 476 #endif // PRODUCT |
| 471 return Object::null(); | 477 return Object::null(); |
| 472 } | 478 } |
| 473 | 479 |
| 474 } // namespace dart | 480 } // namespace dart |
| OLD | NEW |