| OLD | NEW |
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, 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/pages.h" | 5 #include "vm/pages.h" |
| 6 | 6 |
| 7 #include "platform/address_sanitizer.h" | 7 #include "platform/address_sanitizer.h" |
| 8 #include "platform/assert.h" | 8 #include "platform/assert.h" |
| 9 #include "vm/compiler_stats.h" | 9 #include "vm/compiler_stats.h" |
| 10 #include "vm/gc_marker.h" | 10 #include "vm/gc_marker.h" |
| (...skipping 831 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 842 } | 842 } |
| 843 } | 843 } |
| 844 } | 844 } |
| 845 | 845 |
| 846 | 846 |
| 847 void PageSpace::MarkSweep(bool invoke_api_callbacks) { | 847 void PageSpace::MarkSweep(bool invoke_api_callbacks) { |
| 848 Thread* thread = Thread::Current(); | 848 Thread* thread = Thread::Current(); |
| 849 Isolate* isolate = heap_->isolate(); | 849 Isolate* isolate = heap_->isolate(); |
| 850 ASSERT(isolate == Isolate::Current()); | 850 ASSERT(isolate == Isolate::Current()); |
| 851 | 851 |
| 852 const int64_t pre_wait_for_sweepers = OS::GetCurrentMonotonicMicros(); |
| 853 |
| 852 // Wait for pending tasks to complete and then account for the driver task. | 854 // Wait for pending tasks to complete and then account for the driver task. |
| 853 { | 855 { |
| 854 MonitorLocker locker(tasks_lock()); | 856 MonitorLocker locker(tasks_lock()); |
| 855 while (tasks() > 0) { | 857 while (tasks() > 0) { |
| 856 locker.WaitWithSafepointCheck(thread); | 858 locker.WaitWithSafepointCheck(thread); |
| 857 } | 859 } |
| 858 set_tasks(1); | 860 set_tasks(1); |
| 859 } | 861 } |
| 862 |
| 863 const int64_t pre_safe_point = OS::GetCurrentMonotonicMicros(); |
| 864 |
| 860 // Ensure that all threads for this isolate are at a safepoint (either | 865 // Ensure that all threads for this isolate are at a safepoint (either |
| 861 // stopped or in native code). We have guards around Newgen GC and oldgen GC | 866 // stopped or in native code). We have guards around Newgen GC and oldgen GC |
| 862 // to ensure that if two threads are racing to collect at the same time the | 867 // to ensure that if two threads are racing to collect at the same time the |
| 863 // loser skips collection and goes straight to allocation. | 868 // loser skips collection and goes straight to allocation. |
| 864 { | 869 { |
| 865 SafepointOperationScope safepoint_scope(thread); | 870 SafepointOperationScope safepoint_scope(thread); |
| 866 | 871 |
| 872 const int64_t start = OS::GetCurrentMonotonicMicros(); |
| 873 |
| 867 // Perform various cleanup that relies on no tasks interfering. | 874 // Perform various cleanup that relies on no tasks interfering. |
| 868 isolate->class_table()->FreeOldTables(); | 875 isolate->class_table()->FreeOldTables(); |
| 869 | 876 |
| 870 NoSafepointScope no_safepoints; | 877 NoSafepointScope no_safepoints; |
| 871 | 878 |
| 872 if (FLAG_print_free_list_before_gc) { | 879 if (FLAG_print_free_list_before_gc) { |
| 873 OS::Print("Data Freelist (before GC):\n"); | 880 OS::Print("Data Freelist (before GC):\n"); |
| 874 freelist_[HeapPage::kData].Print(); | 881 freelist_[HeapPage::kData].Print(); |
| 875 OS::Print("Executable Freelist (before GC):\n"); | 882 OS::Print("Executable Freelist (before GC):\n"); |
| 876 freelist_[HeapPage::kExecutable].Print(); | 883 freelist_[HeapPage::kExecutable].Print(); |
| 877 } | 884 } |
| 878 | 885 |
| 879 if (FLAG_verify_before_gc) { | 886 if (FLAG_verify_before_gc) { |
| 880 OS::PrintErr("Verifying before marking..."); | 887 OS::PrintErr("Verifying before marking..."); |
| 881 heap_->VerifyGC(); | 888 heap_->VerifyGC(); |
| 882 OS::PrintErr(" done.\n"); | 889 OS::PrintErr(" done.\n"); |
| 883 } | 890 } |
| 884 | 891 |
| 885 const int64_t start = OS::GetCurrentMonotonicMicros(); | |
| 886 | |
| 887 // Make code pages writable. | 892 // Make code pages writable. |
| 888 WriteProtectCode(false); | 893 WriteProtectCode(false); |
| 889 | 894 |
| 890 // Save old value before GCMarker visits the weak persistent handles. | 895 // Save old value before GCMarker visits the weak persistent handles. |
| 891 SpaceUsage usage_before = GetCurrentUsage(); | 896 SpaceUsage usage_before = GetCurrentUsage(); |
| 892 | 897 |
| 893 // Mark all reachable old-gen objects. | 898 // Mark all reachable old-gen objects. |
| 894 bool collect_code = FLAG_collect_code && ShouldCollectCode() && | 899 bool collect_code = FLAG_collect_code && ShouldCollectCode() && |
| 895 !isolate->HasAttemptedReload(); | 900 !isolate->HasAttemptedReload(); |
| 896 GCMarker marker(heap_); | 901 GCMarker marker(heap_); |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 984 | 989 |
| 985 // Make code pages read-only. | 990 // Make code pages read-only. |
| 986 WriteProtectCode(true); | 991 WriteProtectCode(true); |
| 987 | 992 |
| 988 int64_t end = OS::GetCurrentMonotonicMicros(); | 993 int64_t end = OS::GetCurrentMonotonicMicros(); |
| 989 | 994 |
| 990 // Record signals for growth control. Include size of external allocations. | 995 // Record signals for growth control. Include size of external allocations. |
| 991 page_space_controller_.EvaluateGarbageCollection( | 996 page_space_controller_.EvaluateGarbageCollection( |
| 992 usage_before, GetCurrentUsage(), start, end); | 997 usage_before, GetCurrentUsage(), start, end); |
| 993 | 998 |
| 999 heap_->RecordTime(kConcurrentSweep, pre_safe_point - pre_wait_for_sweepers); |
| 1000 heap_->RecordTime(kSafePoint, start - pre_safe_point); |
| 994 heap_->RecordTime(kMarkObjects, mid1 - start); | 1001 heap_->RecordTime(kMarkObjects, mid1 - start); |
| 995 heap_->RecordTime(kResetFreeLists, mid2 - mid1); | 1002 heap_->RecordTime(kResetFreeLists, mid2 - mid1); |
| 996 heap_->RecordTime(kSweepPages, mid3 - mid2); | 1003 heap_->RecordTime(kSweepPages, mid3 - mid2); |
| 997 heap_->RecordTime(kSweepLargePages, end - mid3); | 1004 heap_->RecordTime(kSweepLargePages, end - mid3); |
| 998 | 1005 |
| 999 if (FLAG_print_free_list_after_gc) { | 1006 if (FLAG_print_free_list_after_gc) { |
| 1000 OS::Print("Data Freelist (after GC):\n"); | 1007 OS::Print("Data Freelist (after GC):\n"); |
| 1001 freelist_[HeapPage::kData].Print(); | 1008 freelist_[HeapPage::kData].Print(); |
| 1002 OS::Print("Executable Freelist (after GC):\n"); | 1009 OS::Print("Executable Freelist (after GC):\n"); |
| 1003 freelist_[HeapPage::kExecutable].Print(); | 1010 freelist_[HeapPage::kExecutable].Print(); |
| (...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1295 return 0; | 1302 return 0; |
| 1296 } else { | 1303 } else { |
| 1297 ASSERT(total_time >= gc_time); | 1304 ASSERT(total_time >= gc_time); |
| 1298 int result = static_cast<int>( | 1305 int result = static_cast<int>( |
| 1299 (static_cast<double>(gc_time) / static_cast<double>(total_time)) * 100); | 1306 (static_cast<double>(gc_time) / static_cast<double>(total_time)) * 100); |
| 1300 return result; | 1307 return result; |
| 1301 } | 1308 } |
| 1302 } | 1309 } |
| 1303 | 1310 |
| 1304 } // namespace dart | 1311 } // namespace dart |
| OLD | NEW |