| OLD | NEW |
| 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 "platform/globals.h" | 5 #include "platform/globals.h" |
| 6 #if defined(TARGET_OS_WINDOWS) | 6 #if defined(TARGET_OS_WINDOWS) |
| 7 | 7 |
| 8 #include "vm/isolate.h" | 8 #include "vm/isolate.h" |
| 9 #include "vm/profiler.h" | 9 #include "vm/profiler.h" |
| 10 | 10 |
| 11 namespace dart { | 11 namespace dart { |
| 12 | 12 |
| 13 #define kThreadError -1 | 13 #define kThreadError -1 |
| 14 | 14 |
| 15 DECLARE_FLAG(bool, profile); | 15 DECLARE_FLAG(bool, profile); |
| 16 | 16 |
| 17 static void CollectSample(IsolateProfilerData* profiler_data, | 17 static void CollectSample(IsolateProfilerData* profiler_data, |
| 18 uintptr_t pc, | 18 uintptr_t pc, |
| 19 uintptr_t fp, | 19 uintptr_t fp, |
| 20 uintptr_t stack_lower, | 20 uintptr_t stack_lower, |
| 21 uintptr_t stack_upper) { | 21 uintptr_t stack_upper) { |
| 22 uintptr_t sp = stack_lower; | 22 uintptr_t sp = stack_lower; |
| 23 ASSERT(profiler_data != NULL); |
| 23 SampleBuffer* sample_buffer = profiler_data->sample_buffer(); | 24 SampleBuffer* sample_buffer = profiler_data->sample_buffer(); |
| 25 ASSERT(sample_buffer != NULL); |
| 24 Sample* sample = sample_buffer->ReserveSample(); | 26 Sample* sample = sample_buffer->ReserveSample(); |
| 25 ASSERT(sample != NULL); | 27 ASSERT(sample != NULL); |
| 26 sample->timestamp = OS::GetCurrentTimeMicros(); | 28 sample->timestamp = OS::GetCurrentTimeMicros(); |
| 27 // TODO(johnmccutchan): Make real use of vm_tags and runtime_tags. | 29 // TODO(johnmccutchan): Make real use of vm_tags and runtime_tags. |
| 28 // Issue # 14777 | 30 // Issue # 14777 |
| 29 sample->vm_tags = Sample::kExecuting; | 31 sample->vm_tags = Sample::kExecuting; |
| 30 sample->runtime_tags = 0; | 32 sample->runtime_tags = 0; |
| 31 int64_t cpu_usage; | 33 int64_t cpu_usage; |
| 32 Thread::GetThreadCpuUsage(profiler_data->thread_id(), &cpu_usage); | 34 Thread::GetThreadCpuUsage(profiler_data->thread_id(), &cpu_usage); |
| 33 sample->cpu_usage = profiler_data->ComputeDeltaAndSetCpuUsage(cpu_usage); | 35 sample->cpu_usage = profiler_data->ComputeDeltaAndSetCpuUsage(cpu_usage); |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 94 int64_t ProfilerManager::SampleAndRescheduleIsolates(int64_t current_time) { | 96 int64_t ProfilerManager::SampleAndRescheduleIsolates(int64_t current_time) { |
| 95 if (isolates_size_ == 0) { | 97 if (isolates_size_ == 0) { |
| 96 return 0; | 98 return 0; |
| 97 } | 99 } |
| 98 static const int64_t max_time = 0x7fffffffffffffffLL; | 100 static const int64_t max_time = 0x7fffffffffffffffLL; |
| 99 int64_t lowest = max_time; | 101 int64_t lowest = max_time; |
| 100 for (intptr_t i = 0; i < isolates_size_; i++) { | 102 for (intptr_t i = 0; i < isolates_size_; i++) { |
| 101 Isolate* isolate = isolates_[i]; | 103 Isolate* isolate = isolates_[i]; |
| 102 ScopedMutex isolate_lock(isolate->profiler_data_mutex()); | 104 ScopedMutex isolate_lock(isolate->profiler_data_mutex()); |
| 103 IsolateProfilerData* profiler_data = isolate->profiler_data(); | 105 IsolateProfilerData* profiler_data = isolate->profiler_data(); |
| 104 ASSERT(profiler_data != NULL); | 106 if ((profiler_data == NULL) || !profiler_data->CanExpire() || |
| 107 (profiler_data->sample_buffer() == NULL)) { |
| 108 // Descheduled. |
| 109 continue; |
| 110 } |
| 105 if (profiler_data->ShouldSample(current_time)) { | 111 if (profiler_data->ShouldSample(current_time)) { |
| 106 SuspendAndSample(isolate, profiler_data); | 112 SuspendAndSample(isolate, profiler_data); |
| 107 Reschedule(profiler_data); | 113 Reschedule(profiler_data); |
| 108 } | 114 } |
| 109 if (profiler_data->CanExpire()) { | 115 if (profiler_data->CanExpire()) { |
| 110 int64_t isolate_time_left = | 116 int64_t isolate_time_left = |
| 111 profiler_data->TimeUntilExpiration(current_time); | 117 profiler_data->TimeUntilExpiration(current_time); |
| 112 if (isolate_time_left < 0) { | 118 if (isolate_time_left < 0) { |
| 113 continue; | 119 continue; |
| 114 } | 120 } |
| (...skipping 21 matching lines...) Expand all Loading... |
| 136 while (!shutdown_) { | 142 while (!shutdown_) { |
| 137 int64_t current_time = OS::GetCurrentTimeMicros(); | 143 int64_t current_time = OS::GetCurrentTimeMicros(); |
| 138 int64_t next_sample = SampleAndRescheduleIsolates(current_time); | 144 int64_t next_sample = SampleAndRescheduleIsolates(current_time); |
| 139 lock.WaitMicros(next_sample); | 145 lock.WaitMicros(next_sample); |
| 140 } | 146 } |
| 141 } | 147 } |
| 142 | 148 |
| 143 } // namespace dart | 149 } // namespace dart |
| 144 | 150 |
| 145 #endif // defined(TARGET_OS_WINDOWS) | 151 #endif // defined(TARGET_OS_WINDOWS) |
| OLD | NEW |