Index: runtime/vm/service.cc |
diff --git a/runtime/vm/service.cc b/runtime/vm/service.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..6a27c19c85e6d08c67202e44d3ffb31221c8ea4b |
--- /dev/null |
+++ b/runtime/vm/service.cc |
@@ -0,0 +1,53 @@ |
+// Copyright (c) 2013, 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/isolate.h" |
+#include "vm/message.h" |
+#include "vm/object.h" |
+#include "vm/port.h" |
+#include "vm/service.h" |
+ |
+namespace dart { |
+ |
+static uint8_t* allocator(uint8_t* ptr, intptr_t old_size, intptr_t new_size) { |
+ void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size); |
+ return reinterpret_cast<uint8_t*>(new_ptr); |
+} |
+ |
+ |
+static void PostReply(const String& reply, Dart_Port reply_port) { |
+ uint8_t* data = NULL; |
+ MessageWriter writer(&data, &allocator); |
+ writer.WriteMessage(reply); |
+ PortMap::PostMessage(new Message(reply_port, Message::kIllegalPort, data, |
+ writer.BytesWritten(), |
+ Message::kNormalPriority)); |
+} |
+ |
+ |
+static RawString* HandleIdMessage(Isolate* isolate, Dart_Port reply_port) { |
+ TextBuffer buffer(256); |
+ buffer.Printf("{ \"id\": \"%s\" }", isolate->name()); |
+ return String::New(buffer.buf()); |
+} |
+ |
+ |
+void Service::HandleServiceMessage(Isolate* isolate, Dart_Port reply_port, |
+ const Instance& message) { |
+ ASSERT(isolate != NULL); |
+ ASSERT(reply_port != ILLEGAL_PORT); |
+ ASSERT(!message.IsNull()); |
+ ASSERT(message.IsString()); |
+ |
+ String& reply = String::Handle(); |
+ |
+ // For now, assume service message is always an id check. |
+ reply = HandleIdMessage(isolate, reply_port); |
+ |
+ ASSERT(!reply.IsNull()); |
+ |
+ PostReply(reply, reply_port); |
+} |
+ |
+} // namespace dart |