Add dart:developer.postEvent for posting events to the service protocol from Dart code

runtime/vm/service.cc

 // 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/service.h"
 
 #include "include/dart_api.h"
 #include "include/dart_native_api.h"
 #include "platform/globals.h"
 
@@ skipping 95 matching lines @@
 Dart_GetVMServiceAssetsArchive Service::get_service_assets_callback_ = NULL;
 
 // These are the set of streams known to the core VM.
 StreamInfo Service::vm_stream("VM");
 StreamInfo Service::isolate_stream("Isolate");
 StreamInfo Service::debug_stream("Debug");
 StreamInfo Service::gc_stream("GC");
 StreamInfo Service::echo_stream("_Echo");
 StreamInfo Service::graph_stream("_Graph");
 StreamInfo Service::logging_stream("_Logging");
+StreamInfo Service::extension_stream("Extension");
 
 static StreamInfo* streams_[] = {
   &Service::vm_stream,
   &Service::isolate_stream,
   &Service::debug_stream,
   &Service::gc_stream,
   &Service::echo_stream,
   &Service::graph_stream,
   &Service::logging_stream,
+  &Service::extension_stream,
 };
 
 
 bool Service::ListenStream(const char* stream_id) {
   if (FLAG_trace_service) {
     OS::Print("vm-service: starting stream '%s'\n",
               stream_id);
   }
   intptr_t num_streams = sizeof(streams_) /
                          sizeof(streams_[0]);
@@ skipping 2810 matching lines @@
 
 void Service::SendLogEvent(Isolate* isolate,
                            int64_t sequence_number,
                            int64_t timestamp,
                            intptr_t level,
                            const String& name,
                            const String& message,
                            const Instance& zone,
                            const Object& error,
                            const Instance& stack_trace) {
+  if (!Service::logging_stream.enabled()) {
+    return;
+  }
   ServiceEvent::LogRecord log_record;
   log_record.sequence_number = sequence_number;
   log_record.timestamp = timestamp;
   log_record.level = level;
   log_record.name = &name;
   log_record.message = &message;
   log_record.zone = &zone;
   log_record.error = &error;
   log_record.stack_trace = &stack_trace;
   ServiceEvent event(isolate, ServiceEvent::kLogging);
   event.set_log_record(log_record);
   Service::HandleEvent(&event);
 }
 
 
+void Service::SendExtensionEvent(Isolate* isolate,
+                                 const String& event_kind,
+                                 const String& event_data) {
+  if (!Service::extension_stream.enabled()) {
+    return;
+  }
+  ServiceEvent::ExtensionEvent extension_event;
+  extension_event.event_kind = &event_kind;
+  extension_event.event_data = &event_data;
+  ServiceEvent event(isolate, ServiceEvent::kExtension);
+  event.set_extension_event(extension_event);
+  Service::HandleEvent(&event);
+}
+
+
 class ContainsAddressVisitor : public FindObjectVisitor {
  public:
   ContainsAddressVisitor(Isolate* isolate, uword addr)
       : FindObjectVisitor(isolate), addr_(addr) { }
   virtual ~ContainsAddressVisitor() { }
 
   virtual uword filter_addr() const { return addr_; }
 
   virtual bool FindObject(RawObject* obj) const {
     // Free list elements are not real objects, so skip them.
@@ skipping 595 matching lines @@
     const ServiceMethodDescriptor& method = service_methods_[i];
     if (strcmp(method_name, method.name) == 0) {
       return &method;
     }
   }
   return NULL;
 }
 
 
 }  // namespace dart