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

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

Issue 2608463002: Added isolate + thread high watermark tracking to Observatory (Closed)
Patch Set: Added tracking of memory usage inside of threads. In addition, the max memory usage is kept track o… Created 3 years, 11 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
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 #ifndef RUNTIME_VM_ISOLATE_H_ 5 #ifndef RUNTIME_VM_ISOLATE_H_
6 #define RUNTIME_VM_ISOLATE_H_ 6 #define RUNTIME_VM_ISOLATE_H_
7 7
8 #include "include/dart_api.h" 8 #include "include/dart_api.h"
9 #include "platform/assert.h" 9 #include "platform/assert.h"
10 #include "vm/atomic.h" 10 #include "vm/atomic.h"
(...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after
171 // Visits weak object pointers. 171 // Visits weak object pointers.
172 void VisitWeakPersistentHandles(HandleVisitor* visitor); 172 void VisitWeakPersistentHandles(HandleVisitor* visitor);
173 173
174 // Prepares all threads in an isolate for Garbage Collection. 174 // Prepares all threads in an isolate for Garbage Collection.
175 void PrepareForGC(); 175 void PrepareForGC();
176 176
177 StoreBuffer* store_buffer() { return store_buffer_; } 177 StoreBuffer* store_buffer() { return store_buffer_; }
178 178
179 ThreadRegistry* thread_registry() const { return thread_registry_; } 179 ThreadRegistry* thread_registry() const { return thread_registry_; }
180 SafepointHandler* safepoint_handler() const { return safepoint_handler_; } 180 SafepointHandler* safepoint_handler() const { return safepoint_handler_; }
181 181 intptr_t GetIsolateHighWatermark() const {
182 return isolate_memory_high_watermark_;
183 }
182 ClassTable* class_table() { return &class_table_; } 184 ClassTable* class_table() { return &class_table_; }
183 static intptr_t class_table_offset() { 185 static intptr_t class_table_offset() {
184 return OFFSET_OF(Isolate, class_table_); 186 return OFFSET_OF(Isolate, class_table_);
185 } 187 }
186 188
187 // Prefers old classes when we are in the middle of a reload. 189 // Prefers old classes when we are in the middle of a reload.
188 RawClass* GetClassForHeapWalkAt(intptr_t cid); 190 RawClass* GetClassForHeapWalkAt(intptr_t cid);
189 191
190 static intptr_t ic_miss_code_offset() { 192 static intptr_t ic_miss_code_offset() {
191 return OFFSET_OF(Isolate, ic_miss_code_); 193 return OFFSET_OF(Isolate, ic_miss_code_);
(...skipping 495 matching lines...) Expand 10 before | Expand all | Expand 10 after
687 } 689 }
688 void set_registered_service_extension_handlers( 690 void set_registered_service_extension_handlers(
689 const GrowableObjectArray& value); 691 const GrowableObjectArray& value);
690 692
691 Monitor* threads_lock() const; 693 Monitor* threads_lock() const;
692 Thread* ScheduleThread(bool is_mutator, bool bypass_safepoint = false); 694 Thread* ScheduleThread(bool is_mutator, bool bypass_safepoint = false);
693 void UnscheduleThread(Thread* thread, 695 void UnscheduleThread(Thread* thread,
694 bool is_mutator, 696 bool is_mutator,
695 bool bypass_safepoint = false); 697 bool bypass_safepoint = false);
696 698
699 // Updates the maximum memory usage in bytes of all zones in all threads of
700 // the current isolate.
701 void UpdateIsolateHighWatermark();
702
697 // DEPRECATED: Use Thread's methods instead. During migration, these default 703 // DEPRECATED: Use Thread's methods instead. During migration, these default
698 // to using the mutator thread (which must also be the current thread). 704 // to using the mutator thread (which must also be the current thread).
699 Zone* current_zone() const { 705 Zone* current_zone() const {
700 ASSERT(Thread::Current() == mutator_thread()); 706 ASSERT(Thread::Current() == mutator_thread());
701 return mutator_thread()->zone(); 707 return mutator_thread()->zone();
702 } 708 }
703 709
704 // Accessed from generated code: 710 // Accessed from generated code:
705 StoreBuffer* store_buffer_; 711 StoreBuffer* store_buffer_;
706 Heap* heap_; 712 Heap* heap_;
707 uword user_tag_; 713 uword user_tag_;
708 RawUserTag* current_tag_; 714 RawUserTag* current_tag_;
709 RawUserTag* default_tag_; 715 RawUserTag* default_tag_;
710 RawCode* ic_miss_code_; 716 RawCode* ic_miss_code_;
711 ObjectStore* object_store_; 717 ObjectStore* object_store_;
712 ClassTable class_table_; 718 ClassTable class_table_;
713 bool single_step_; 719 bool single_step_;
714 720
715 ThreadRegistry* thread_registry_; 721 ThreadRegistry* thread_registry_;
716 SafepointHandler* safepoint_handler_; 722 SafepointHandler* safepoint_handler_;
723 intptr_t isolate_memory_high_watermark_;
717 Dart_MessageNotifyCallback message_notify_callback_; 724 Dart_MessageNotifyCallback message_notify_callback_;
718 char* name_; 725 char* name_;
719 char* debugger_name_; 726 char* debugger_name_;
720 int64_t start_time_micros_; 727 int64_t start_time_micros_;
721 Dart_Port main_port_; 728 Dart_Port main_port_;
722 Dart_Port origin_id_; // Isolates created by spawnFunc have some origin id. 729 Dart_Port origin_id_; // Isolates created by spawnFunc have some origin id.
723 uint64_t pause_capability_; 730 uint64_t pause_capability_;
724 uint64_t terminate_capability_; 731 uint64_t terminate_capability_;
725 bool errors_fatal_; 732 bool errors_fatal_;
726 void* init_callback_data_; 733 void* init_callback_data_;
(...skipping 266 matching lines...) Expand 10 before | Expand all | Expand 10 after
993 intptr_t* spawn_count_; 1000 intptr_t* spawn_count_;
994 1001
995 Dart_IsolateFlags isolate_flags_; 1002 Dart_IsolateFlags isolate_flags_;
996 bool paused_; 1003 bool paused_;
997 bool errors_are_fatal_; 1004 bool errors_are_fatal_;
998 }; 1005 };
999 1006
1000 } // namespace dart 1007 } // namespace dart
1001 1008
1002 #endif // RUNTIME_VM_ISOLATE_H_ 1009 #endif // RUNTIME_VM_ISOLATE_H_
OLDNEW
« no previous file with comments | « runtime/observatory/tests/service/get_zone_memory_info_rpc_test.dart ('k') | runtime/vm/isolate.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698