| OLD | NEW |
| 1 // Copyright 2012 the V8 project authors. All rights reserved. | 1 // Copyright 2012 the V8 project authors. All rights reserved. |
| 2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
| 3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
| 4 // met: | 4 // met: |
| 5 // | 5 // |
| 6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
| 7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
| 8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
| 9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
| 10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
| (...skipping 728 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 739 | 739 |
| 740 class SamplerThread : public Thread { | 740 class SamplerThread : public Thread { |
| 741 public: | 741 public: |
| 742 static const int kSamplerThreadStackSize = 64 * KB; | 742 static const int kSamplerThreadStackSize = 64 * KB; |
| 743 | 743 |
| 744 explicit SamplerThread(int interval) | 744 explicit SamplerThread(int interval) |
| 745 : Thread(Thread::Options("SamplerThread", kSamplerThreadStackSize)), | 745 : Thread(Thread::Options("SamplerThread", kSamplerThreadStackSize)), |
| 746 interval_(interval) {} | 746 interval_(interval) {} |
| 747 | 747 |
| 748 static void AddActiveSampler(Sampler* sampler) { | 748 static void AddActiveSampler(Sampler* sampler) { |
| 749 ScopedLock lock(mutex_); | 749 ScopedLock lock(mutex_.Pointer()); |
| 750 SamplerRegistry::AddActiveSampler(sampler); | 750 SamplerRegistry::AddActiveSampler(sampler); |
| 751 if (instance_ == NULL) { | 751 if (instance_ == NULL) { |
| 752 instance_ = new SamplerThread(sampler->interval()); | 752 instance_ = new SamplerThread(sampler->interval()); |
| 753 instance_->Start(); | 753 instance_->Start(); |
| 754 } else { | 754 } else { |
| 755 ASSERT(instance_->interval_ == sampler->interval()); | 755 ASSERT(instance_->interval_ == sampler->interval()); |
| 756 } | 756 } |
| 757 } | 757 } |
| 758 | 758 |
| 759 static void RemoveActiveSampler(Sampler* sampler) { | 759 static void RemoveActiveSampler(Sampler* sampler) { |
| 760 ScopedLock lock(mutex_); | 760 ScopedLock lock(mutex_.Pointer()); |
| 761 SamplerRegistry::RemoveActiveSampler(sampler); | 761 SamplerRegistry::RemoveActiveSampler(sampler); |
| 762 if (SamplerRegistry::GetState() == SamplerRegistry::HAS_NO_SAMPLERS) { | 762 if (SamplerRegistry::GetState() == SamplerRegistry::HAS_NO_SAMPLERS) { |
| 763 RuntimeProfiler::StopRuntimeProfilerThreadBeforeShutdown(instance_); | 763 RuntimeProfiler::StopRuntimeProfilerThreadBeforeShutdown(instance_); |
| 764 delete instance_; | 764 delete instance_; |
| 765 instance_ = NULL; | 765 instance_ = NULL; |
| 766 } | 766 } |
| 767 } | 767 } |
| 768 | 768 |
| 769 // Implement Thread::Run(). | 769 // Implement Thread::Run(). |
| 770 virtual void Run() { | 770 virtual void Run() { |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 847 sampler->SampleStack(sample); | 847 sampler->SampleStack(sample); |
| 848 sampler->Tick(sample); | 848 sampler->Tick(sample); |
| 849 } | 849 } |
| 850 thread_resume(profiled_thread); | 850 thread_resume(profiled_thread); |
| 851 } | 851 } |
| 852 | 852 |
| 853 const int interval_; | 853 const int interval_; |
| 854 RuntimeProfilerRateLimiter rate_limiter_; | 854 RuntimeProfilerRateLimiter rate_limiter_; |
| 855 | 855 |
| 856 // Protects the process wide state below. | 856 // Protects the process wide state below. |
| 857 static Mutex* mutex_; | 857 static LazyMutex mutex_; |
| 858 static SamplerThread* instance_; | 858 static SamplerThread* instance_; |
| 859 | 859 |
| 860 private: | 860 private: |
| 861 DISALLOW_COPY_AND_ASSIGN(SamplerThread); | 861 DISALLOW_COPY_AND_ASSIGN(SamplerThread); |
| 862 }; | 862 }; |
| 863 | 863 |
| 864 #undef REGISTER_FIELD | 864 #undef REGISTER_FIELD |
| 865 | 865 |
| 866 | 866 |
| 867 Mutex* SamplerThread::mutex_ = OS::CreateMutex(); | 867 LazyMutex SamplerThread::mutex_ = LAZY_MUTEX_INITIALIZER; |
| 868 SamplerThread* SamplerThread::instance_ = NULL; | 868 SamplerThread* SamplerThread::instance_ = NULL; |
| 869 | 869 |
| 870 | 870 |
| 871 Sampler::Sampler(Isolate* isolate, int interval) | 871 Sampler::Sampler(Isolate* isolate, int interval) |
| 872 : isolate_(isolate), | 872 : isolate_(isolate), |
| 873 interval_(interval), | 873 interval_(interval), |
| 874 profiling_(false), | 874 profiling_(false), |
| 875 active_(false), | 875 active_(false), |
| 876 samples_taken_(0) { | 876 samples_taken_(0) { |
| 877 data_ = new PlatformData; | 877 data_ = new PlatformData; |
| (...skipping 14 matching lines...) Expand all Loading... |
| 892 | 892 |
| 893 | 893 |
| 894 void Sampler::Stop() { | 894 void Sampler::Stop() { |
| 895 ASSERT(IsActive()); | 895 ASSERT(IsActive()); |
| 896 SamplerThread::RemoveActiveSampler(this); | 896 SamplerThread::RemoveActiveSampler(this); |
| 897 SetActive(false); | 897 SetActive(false); |
| 898 } | 898 } |
| 899 | 899 |
| 900 | 900 |
| 901 } } // namespace v8::internal | 901 } } // namespace v8::internal |
| OLD | NEW |