| Index: src/log.cc
|
| diff --git a/src/log.cc b/src/log.cc
|
| index ff67d10868afa578561d4097d7d8f7fec0b7e08d..77bb9b3e99270f961602bd4f830f91c6a9f9070c 100644
|
| --- a/src/log.cc
|
| +++ b/src/log.cc
|
| @@ -556,21 +556,20 @@ class Profiler: public Thread {
|
| } else {
|
| buffer_[head_] = *sample;
|
| head_ = Succ(head_);
|
| - buffer_semaphore_->Signal(); // Tell we have an element.
|
| + buffer_semaphore_.Signal(); // Tell we have an element.
|
| }
|
| }
|
|
|
| virtual void Run();
|
|
|
| // Pause and Resume TickSample data collection.
|
| - bool paused() const { return paused_; }
|
| void pause() { paused_ = true; }
|
| void resume() { paused_ = false; }
|
|
|
| private:
|
| // Waits for a signal and removes profiling data.
|
| bool Remove(TickSample* sample) {
|
| - buffer_semaphore_->Wait(); // Wait for an element.
|
| + buffer_semaphore_.Wait(); // Wait for an element.
|
| *sample = buffer_[tail_];
|
| bool result = overflow_;
|
| tail_ = Succ(tail_);
|
| @@ -590,7 +589,7 @@ class Profiler: public Thread {
|
| int tail_; // Index to the buffer tail.
|
| bool overflow_; // Tell whether a buffer overflow has occurred.
|
| // Sempahore used for buffer synchronization.
|
| - SmartPointer<Semaphore> buffer_semaphore_;
|
| + Semaphore buffer_semaphore_;
|
|
|
| // Tells whether profiler is engaged, that is, processing thread is stated.
|
| bool engaged_;
|
| @@ -623,13 +622,13 @@ class Ticker: public Sampler {
|
| ASSERT(profiler_ == NULL);
|
| profiler_ = profiler;
|
| IncreaseProfilingDepth();
|
| - if (!FLAG_prof_lazy && !IsActive()) Start();
|
| + if (!IsActive()) Start();
|
| }
|
|
|
| void ClearProfiler() {
|
| - DecreaseProfilingDepth();
|
| profiler_ = NULL;
|
| if (IsActive()) Stop();
|
| + DecreaseProfilingDepth();
|
| }
|
|
|
| private:
|
| @@ -646,7 +645,7 @@ Profiler::Profiler(Isolate* isolate)
|
| head_(0),
|
| tail_(0),
|
| overflow_(false),
|
| - buffer_semaphore_(OS::CreateSemaphore(0)),
|
| + buffer_semaphore_(0),
|
| engaged_(false),
|
| running_(false),
|
| paused_(false) {
|
| @@ -710,14 +709,12 @@ Logger::Logger(Isolate* isolate)
|
| ticker_(NULL),
|
| profiler_(NULL),
|
| log_events_(NULL),
|
| - logging_nesting_(0),
|
| - cpu_profiler_nesting_(0),
|
| + is_logging_(false),
|
| log_(new Log(this)),
|
| ll_logger_(NULL),
|
| jit_logger_(NULL),
|
| listeners_(5),
|
| - is_initialized_(false),
|
| - epoch_(0) {
|
| + is_initialized_(false) {
|
| }
|
|
|
|
|
| @@ -868,7 +865,7 @@ void Logger::CodeDeoptEvent(Code* code) {
|
| if (!log_->IsEnabled()) return;
|
| ASSERT(FLAG_log_internal_timer_events);
|
| Log::MessageBuilder msg(log_);
|
| - int since_epoch = static_cast<int>(OS::Ticks() - epoch_);
|
| + int since_epoch = static_cast<int>(timer_.Elapsed().InMicroseconds());
|
| msg.Append("code-deopt,%ld,%d\n", since_epoch, code->CodeSize());
|
| msg.WriteToLogFile();
|
| }
|
| @@ -878,7 +875,7 @@ void Logger::TimerEvent(StartEnd se, const char* name) {
|
| if (!log_->IsEnabled()) return;
|
| ASSERT(FLAG_log_internal_timer_events);
|
| Log::MessageBuilder msg(log_);
|
| - int since_epoch = static_cast<int>(OS::Ticks() - epoch_);
|
| + int since_epoch = static_cast<int>(timer_.Elapsed().InMicroseconds());
|
| const char* format = (se == START) ? "timer-event-start,\"%s\",%ld\n"
|
| : "timer-event-end,\"%s\",%ld\n";
|
| msg.Append(format, name, since_epoch);
|
| @@ -1501,7 +1498,7 @@ void Logger::TickEvent(TickSample* sample, bool overflow) {
|
| Log::MessageBuilder msg(log_);
|
| msg.Append("%s,", kLogEventsNames[TICK_EVENT]);
|
| msg.AppendAddress(sample->pc);
|
| - msg.Append(",%ld", static_cast<int>(OS::Ticks() - epoch_));
|
| + msg.Append(",%ld", static_cast<int>(timer_.Elapsed().InMicroseconds()));
|
| if (sample->has_external_callback) {
|
| msg.Append(",1,");
|
| msg.AppendAddress(sample->external_callback);
|
| @@ -1522,43 +1519,11 @@ void Logger::TickEvent(TickSample* sample, bool overflow) {
|
| }
|
|
|
|
|
| -bool Logger::IsProfilerPaused() {
|
| - return profiler_ == NULL || profiler_->paused();
|
| -}
|
| -
|
| -
|
| -void Logger::PauseProfiler() {
|
| +void Logger::StopProfiler() {
|
| if (!log_->IsEnabled()) return;
|
| if (profiler_ != NULL) {
|
| - // It is OK to have negative nesting.
|
| - if (--cpu_profiler_nesting_ == 0) {
|
| - profiler_->pause();
|
| - if (FLAG_prof_lazy) {
|
| - ticker_->Stop();
|
| - FLAG_log_code = false;
|
| - LOG(ISOLATE, UncheckedStringEvent("profiler", "pause"));
|
| - }
|
| - --logging_nesting_;
|
| - }
|
| - }
|
| -}
|
| -
|
| -
|
| -void Logger::ResumeProfiler() {
|
| - if (!log_->IsEnabled()) return;
|
| - if (profiler_ != NULL) {
|
| - if (cpu_profiler_nesting_++ == 0) {
|
| - ++logging_nesting_;
|
| - if (FLAG_prof_lazy) {
|
| - profiler_->Engage();
|
| - LOG(ISOLATE, UncheckedStringEvent("profiler", "resume"));
|
| - FLAG_log_code = true;
|
| - LogCompiledFunctions();
|
| - LogAccessorCallbacks();
|
| - if (!ticker_->IsActive()) ticker_->Start();
|
| - }
|
| - profiler_->resume();
|
| - }
|
| + profiler_->pause();
|
| + is_logging_ = false;
|
| }
|
| }
|
|
|
| @@ -1566,7 +1531,7 @@ void Logger::ResumeProfiler() {
|
| // This function can be called when Log's mutex is acquired,
|
| // either from main or Profiler's thread.
|
| void Logger::LogFailure() {
|
| - PauseProfiler();
|
| + StopProfiler();
|
| }
|
|
|
|
|
| @@ -1866,11 +1831,6 @@ bool Logger::SetUp(Isolate* isolate) {
|
| FLAG_log_snapshot_positions = true;
|
| }
|
|
|
| - // --prof_lazy controls --log-code.
|
| - if (FLAG_prof_lazy) {
|
| - FLAG_log_code = false;
|
| - }
|
| -
|
| SmartArrayPointer<const char> log_file_name =
|
| PrepareLogFileName(FLAG_logfile);
|
| log_->Initialize(*log_file_name);
|
| @@ -1883,20 +1843,16 @@ bool Logger::SetUp(Isolate* isolate) {
|
| ticker_ = new Ticker(isolate, kSamplingIntervalMs);
|
|
|
| if (Log::InitLogAtStart()) {
|
| - logging_nesting_ = 1;
|
| + is_logging_ = true;
|
| }
|
|
|
| if (FLAG_prof) {
|
| profiler_ = new Profiler(isolate);
|
| - if (FLAG_prof_lazy) {
|
| - profiler_->pause();
|
| - } else {
|
| - logging_nesting_ = 1;
|
| - profiler_->Engage();
|
| - }
|
| + is_logging_ = true;
|
| + profiler_->Engage();
|
| }
|
|
|
| - if (FLAG_log_internal_timer_events || FLAG_prof) epoch_ = OS::Ticks();
|
| + if (FLAG_log_internal_timer_events || FLAG_prof) timer_.Start();
|
|
|
| return true;
|
| }
|
|
|