Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(73)

Side by Side Diff: runtime/vm/isolate.cc

Issue 13583008: Rollback of 20898 (Windows doesn't support strndup) (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: Created 7 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « runtime/vm/isolate.h ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, 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/isolate.h" 5 #include "vm/isolate.h"
6 6
7 #include "include/dart_api.h" 7 #include "include/dart_api.h"
8 #include "platform/assert.h" 8 #include "platform/assert.h"
9 #include "platform/json.h"
10 #include "lib/mirrors.h" 9 #include "lib/mirrors.h"
11 #include "vm/code_observers.h" 10 #include "vm/code_observers.h"
12 #include "vm/compiler_stats.h" 11 #include "vm/compiler_stats.h"
13 #include "vm/dart_api_state.h" 12 #include "vm/dart_api_state.h"
14 #include "vm/dart_entry.h" 13 #include "vm/dart_entry.h"
15 #include "vm/debugger.h" 14 #include "vm/debugger.h"
16 #include "vm/heap.h" 15 #include "vm/heap.h"
17 #include "vm/message_handler.h" 16 #include "vm/message_handler.h"
18 #include "vm/object_store.h" 17 #include "vm/object_store.h"
19 #include "vm/parser.h" 18 #include "vm/parser.h"
(...skipping 316 matching lines...) Expand 10 before | Expand all | Expand 10 after
336 stack_limit_(0), 335 stack_limit_(0),
337 saved_stack_limit_(0), 336 saved_stack_limit_(0),
338 message_handler_(NULL), 337 message_handler_(NULL),
339 spawn_data_(0), 338 spawn_data_(0),
340 gc_prologue_callbacks_(), 339 gc_prologue_callbacks_(),
341 gc_epilogue_callbacks_(), 340 gc_epilogue_callbacks_(),
342 deopt_cpu_registers_copy_(NULL), 341 deopt_cpu_registers_copy_(NULL),
343 deopt_fpu_registers_copy_(NULL), 342 deopt_fpu_registers_copy_(NULL),
344 deopt_frame_copy_(NULL), 343 deopt_frame_copy_(NULL),
345 deopt_frame_copy_size_(0), 344 deopt_frame_copy_size_(0),
346 deferred_objects_(NULL), 345 deferred_objects_(NULL) {
347 stacktrace_(NULL),
348 stack_frame_index_(-1) {
349 } 346 }
350 347
351 348
352 Isolate::~Isolate() { 349 Isolate::~Isolate() {
353 delete [] name_; 350 delete [] name_;
354 delete heap_; 351 delete heap_;
355 delete object_store_; 352 delete object_store_;
356 delete api_state_; 353 delete api_state_;
357 delete stub_code_; 354 delete stub_code_;
358 delete debugger_; 355 delete debugger_;
(...skipping 272 matching lines...) Expand 10 before | Expand all | Expand 10 after
631 628
632 629
633 Dart_IsolateCreateCallback Isolate::create_callback_ = NULL; 630 Dart_IsolateCreateCallback Isolate::create_callback_ = NULL;
634 Dart_IsolateInterruptCallback Isolate::interrupt_callback_ = NULL; 631 Dart_IsolateInterruptCallback Isolate::interrupt_callback_ = NULL;
635 Dart_IsolateUnhandledExceptionCallback 632 Dart_IsolateUnhandledExceptionCallback
636 Isolate::unhandled_exception_callback_ = NULL; 633 Isolate::unhandled_exception_callback_ = NULL;
637 Dart_IsolateShutdownCallback Isolate::shutdown_callback_ = NULL; 634 Dart_IsolateShutdownCallback Isolate::shutdown_callback_ = NULL;
638 Dart_FileOpenCallback Isolate::file_open_callback_ = NULL; 635 Dart_FileOpenCallback Isolate::file_open_callback_ = NULL;
639 Dart_FileWriteCallback Isolate::file_write_callback_ = NULL; 636 Dart_FileWriteCallback Isolate::file_write_callback_ = NULL;
640 Dart_FileCloseCallback Isolate::file_close_callback_ = NULL; 637 Dart_FileCloseCallback Isolate::file_close_callback_ = NULL;
641 Dart_IsolateInterruptCallback Isolate::vmstats_callback_ = NULL;
642 638
643 639
644 void Isolate::VisitObjectPointers(ObjectPointerVisitor* visitor, 640 void Isolate::VisitObjectPointers(ObjectPointerVisitor* visitor,
645 bool visit_prologue_weak_handles, 641 bool visit_prologue_weak_handles,
646 bool validate_frames) { 642 bool validate_frames) {
647 ASSERT(visitor != NULL); 643 ASSERT(visitor != NULL);
648 644
649 // Visit objects in the object store. 645 // Visit objects in the object store.
650 object_store()->VisitObjectPointers(visitor); 646 object_store()->VisitObjectPointers(visitor);
651 647
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
686 682
687 683
688 void Isolate::VisitWeakPersistentHandles(HandleVisitor* visitor, 684 void Isolate::VisitWeakPersistentHandles(HandleVisitor* visitor,
689 bool visit_prologue_weak_handles) { 685 bool visit_prologue_weak_handles) {
690 if (api_state() != NULL) { 686 if (api_state() != NULL) {
691 api_state()->VisitWeakHandles(visitor, visit_prologue_weak_handles); 687 api_state()->VisitWeakHandles(visitor, visit_prologue_weak_handles);
692 } 688 }
693 } 689 }
694 690
695 691
696 static Monitor* status_sync = NULL;
697
698 bool Isolate::FetchStacktrace() {
699 Isolate* isolate = Isolate::Current();
700 MonitorLocker ml(status_sync);
701 DebuggerStackTrace* stack = Debugger::CollectStackTrace();
702 TextBuffer buffer(256);
703 buffer.Printf("{ \"handle\": \"0x%"Px64"\", \"stacktrace\": [ ",
704 reinterpret_cast<int64_t>(isolate));
705 intptr_t n_frames = stack->Length();
706 String& url = String::Handle();
707 String& function = String::Handle();
708 for (int i = 0; i < n_frames; i++) {
709 if (i > 0) {
710 buffer.Printf(", ");
711 }
712 ActivationFrame* frame = stack->ActivationFrameAt(i);
713 url ^= frame->SourceUrl();
714 function ^= frame->function().UserVisibleName();
715 buffer.Printf("{ \"url\": \"%s\", ", url.ToCString());
716 buffer.Printf("\"line\": %"Pd", ", frame->LineNumber());
717 buffer.Printf("\"function\": \"%s\", ", function.ToCString());
718
719 const Code& code = frame->code();
720 buffer.Printf("\"code\": { ");
721 buffer.Printf("\"alive\": %s, ", code.is_alive() ? "false" : "true");
722 buffer.Printf("\"optimized\": %s }}",
723 code.is_optimized() ? "false" : "true");
724 }
725 buffer.Printf("]}");
726 isolate->stacktrace_ = strndup(buffer.buf(), buffer.length());
727 ml.Notify();
728 return true;
729 }
730
731
732 bool Isolate::FetchStackFrameDetails() {
733 Isolate* isolate = Isolate::Current();
734 ASSERT(isolate->stack_frame_index_ >= 0);
735 MonitorLocker ml(status_sync);
736 DebuggerStackTrace* stack = Debugger::CollectStackTrace();
737 intptr_t frame_index = isolate->stack_frame_index_;
738 if (frame_index >= stack->Length()) {
739 // Frame no longer available.
740 return NULL;
741 }
742 ActivationFrame* frame = stack->ActivationFrameAt(frame_index);
743 TextBuffer buffer(256);
744 buffer.Printf("{ \"handle\": \"0x%"Px64"\", \"frame_index\": %"Pd", ",
745 reinterpret_cast<int64_t>(isolate), frame_index);
746
747 const Code& code = frame->code();
748 buffer.Printf("\"code\": { \"size\": %"Pd", ", code.Size());
749 buffer.Printf("\"alive\": %s, ", code.is_alive() ? "false" : "true");
750 buffer.Printf("\"optimized\": %s }, ",
751 code.is_optimized() ? "false" : "true");
752 // TODO(tball): add compilation stats (time, etc.), when available.
753
754 buffer.Printf("\"local_vars\": [ ");
755 intptr_t n_local_vars = frame->NumLocalVariables();
756 String& var_name = String::Handle();
757 Instance& value = Instance::Handle();
758 for (int i = 0; i < n_local_vars; i++) {
759 if (i > 0) {
760 buffer.Printf(", ");
761 }
762 intptr_t token_pos, end_pos;
763 frame->VariableAt(i, &var_name, &token_pos, &end_pos, &value);
764 buffer.Printf(
765 "{ \"name\": \"%s\", \"pos\": %"Pd", \"end_pos\": %"Pd", "
766 "\"value\": \"%s\" }",
767 var_name.ToCString(), token_pos, end_pos, value.ToCString());
768 }
769 buffer.Printf("]}");
770 isolate->stacktrace_ = strndup(buffer.buf(), buffer.length());
771 ml.Notify();
772 return true;
773 }
774
775
776 char* Isolate::DoStacktraceInterrupt(Dart_IsolateInterruptCallback cb) {
777 ASSERT(stacktrace_ == NULL);
778 SetVmStatsCallback(cb);
779 if (status_sync == NULL) {
780 status_sync = new Monitor();
781 }
782 ScheduleInterrupts(Isolate::kVmStatusInterrupt);
783 {
784 MonitorLocker ml(status_sync);
785 if (stacktrace_ == NULL) { // It may already be available.
786 ml.Wait();
787 }
788 }
789 SetVmStatsCallback(NULL);
790 ASSERT(stacktrace_ != NULL);
791 // result is freed by VmStats::WebServer().
792 char* result = stacktrace_;
793 stacktrace_ = NULL;
794 return result;
795 }
796
797
798 char* Isolate::GetStatusStacktrace() {
799 return DoStacktraceInterrupt(&FetchStacktrace);
800 }
801
802 char* Isolate::GetStatusStackFrame(intptr_t index) {
803 ASSERT(index >= 0);
804 stack_frame_index_ = index;
805 char* result = DoStacktraceInterrupt(&FetchStackFrameDetails);
806 stack_frame_index_ = -1;
807 return result;
808 }
809
810
811 // Returns the isolate's general detail information.
812 char* Isolate::GetStatusDetails() {
813 const char* format = "{\n"
814 " \"handle\": \"0x%"Px64"\",\n"
815 " \"name\": \"%s\",\n"
816 " \"port\": %"Pd",\n"
817 " \"starttime\": %"Pd",\n"
818 " \"stacklimit\": %"Pd",\n"
819 " \"newspace\": {\n"
820 " \"used\": %"Pd",\n"
821 " \"capacity\": %"Pd"\n"
822 " },\n"
823 " \"oldspace\": {\n"
824 " \"used\": %"Pd",\n"
825 " \"capacity\": %"Pd"\n"
826 " }\n"
827 "}";
828 char buffer[300];
829 int64_t address = reinterpret_cast<int64_t>(this);
830 int n = OS::SNPrint(buffer, 300, format, address, name(), main_port(),
831 (start_time() / 1000L), saved_stack_limit(),
832 heap()->Used(Heap::kNew) / KB,
833 heap()->Capacity(Heap::kNew) / KB,
834 heap()->Used(Heap::kOld) / KB,
835 heap()->Capacity(Heap::kOld) / KB);
836 ASSERT(n < 300);
837 return strdup(buffer);
838 }
839
840
841 char* Isolate::GetStatus(const char* request) { 692 char* Isolate::GetStatus(const char* request) {
842 char* p = const_cast<char*>(request); 693 char* p = const_cast<char*>(request);
843 const char* service_type = "/isolate/"; 694 const char* service_type = "/isolate/";
844 ASSERT(!strncmp(p, service_type, strlen(service_type))); 695 ASSERT(strncmp(p, service_type, strlen(service_type)) == 0);
845 p += strlen(service_type); 696 p += strlen(service_type);
846 697
847 // Extract isolate handle. 698 // Extract isolate handle.
848 int64_t addr; 699 int64_t addr;
849 OS::StringToInt64(p, &addr); 700 OS::StringToInt64(p, &addr);
850 // TODO(tball): add validity check when issue 9600 is fixed.
851 Isolate* isolate = reinterpret_cast<Isolate*>(addr); 701 Isolate* isolate = reinterpret_cast<Isolate*>(addr);
852 p += strcspn(p, "/"); 702 Heap* heap = isolate->heap();
853 703
854 // Query "/isolate/<handle>". 704 char buffer[256];
855 if (strlen(p) == 0) { 705 int64_t port = isolate->main_port();
856 return isolate->GetStatusDetails(); 706 int64_t start_time = (isolate->start_time() / 1000L);
857 } 707 #if defined(TARGET_ARCH_X64)
858 708 const char* format = "{\n"
859 // Query "/isolate/<handle>/stacktrace" 709 " \"name\": \"%s\",\n"
860 if (!strcmp(p, "/stacktrace")) { 710 " \"port\": %ld,\n"
861 return isolate->GetStatusStacktrace(); 711 " \"starttime\": %ld,\n"
862 } 712 " \"stacklimit\": %ld,\n"
863 713 " \"newspace\": {\n"
864 // Query "/isolate/<handle>/stacktrace/<frame-index>" 714 " \"used\": %ld,\n"
865 const char* stacktrace_query = "/stacktrace/"; 715 " \"capacity\": %ld\n"
866 int64_t frame_index = -1; 716 " },\n"
867 if (!strncmp(p, stacktrace_query, strlen(stacktrace_query))) { 717 " \"oldspace\": {\n"
868 p += strlen(stacktrace_query); 718 " \"used\": %ld,\n"
869 OS::StringToInt64(p, &frame_index); 719 " \"capacity\": %ld\n"
870 if (frame_index >= 0) { 720 " }\n"
871 return isolate->GetStatusStackFrame(frame_index); 721 "}";
872 } 722 #else
873 } 723 const char* format = "{\n"
874 724 " \"name\": \"%s\",\n"
875 // TODO(tball): "/isolate/<handle>/stacktrace/<frame-index>"/disassemble" 725 " \"port\": %lld,\n"
876 726 " \"starttime\": %lld,\n"
877 return NULL; // Unimplemented query. 727 " \"stacklimit\": %d,\n"
728 " \"newspace\": {\n"
729 " \"used\": %d,\n"
730 " \"capacity\": %d\n"
731 " },\n"
732 " \"oldspace\": {\n"
733 " \"used\": %d,\n"
734 " \"capacity\": %d\n"
735 " }\n"
736 "}";
737 #endif
738 int n = OS::SNPrint(buffer, 256, format, isolate->name(), port, start_time,
739 isolate->saved_stack_limit(),
740 heap->Used(Heap::kNew) / KB,
741 heap->Capacity(Heap::kNew) / KB,
742 heap->Used(Heap::kOld) / KB,
743 heap->Capacity(Heap::kOld) / KB);
744 ASSERT(n < 256);
745 return strdup(buffer);
878 } 746 }
879 747
880 } // namespace dart 748 } // namespace dart
OLDNEW
« no previous file with comments | « runtime/vm/isolate.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698