Files
sdk/runtime/vm/native_message_handler.cc
T
turnidge@google.com 2803d78dfd Change the zone allocation api.
Instead of passing a size in bytes to the allocation function, we now
have a templatized Alloc function:

  zone->Alloc<Type>(len)

This is better for security, as we can check for integer overflow in
the size computation before performing the allocation.  Before, we
often failed to check this.
Review URL: https://chromiumcodereview.appspot.com//10836061

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@10254 260f80e4-7a28-3924-810f-c04153c831b5
2012-08-03 21:51:44 +00:00

65 lines
1.8 KiB
C++

// Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
#include "vm/native_message_handler.h"
#include "vm/dart_api_message.h"
#include "vm/isolate.h"
#include "vm/message.h"
#include "vm/snapshot.h"
#include "vm/thread.h"
namespace dart {
NativeMessageHandler::NativeMessageHandler(const char* name,
Dart_NativeMessageHandler func)
: name_(strdup(name)),
func_(func) {
// A NativeMessageHandler always has one live port.
increment_live_ports();
}
NativeMessageHandler::~NativeMessageHandler() {
free(name_);
}
#if defined(DEBUG)
void NativeMessageHandler::CheckAccess() {
ASSERT(Isolate::Current() == NULL);
}
#endif
static uint8_t* zone_allocator(uint8_t* ptr,
intptr_t old_size,
intptr_t new_size) {
ApiZone* zone = ApiNativeScope::Current()->zone();
return zone->Realloc<uint8_t>(ptr, old_size, new_size);
}
bool NativeMessageHandler::HandleMessage(Message* message) {
if (message->IsOOB()) {
// We currently do not use OOB messages for native ports.
UNREACHABLE();
}
// Enter a native scope for handling the message. This will create a
// zone for allocating the objects for decoding the message.
ApiNativeScope scope;
int32_t length = reinterpret_cast<int32_t*>(
message->data())[Snapshot::kLengthIndex];
ApiMessageReader reader(message->data() + Snapshot::kHeaderSize,
length,
zone_allocator);
Dart_CObject* object = reader.ReadMessage();
(*func())(message->dest_port(), message->reply_port(), object);
delete message;
return true;
}
} // namespace dart