| Index: base/trace_event/trace_event_impl.cc
|
| diff --git a/base/trace_event/trace_event_impl.cc b/base/trace_event/trace_event_impl.cc
|
| index 5ae7fb2572f7b16653f0360a322f62298541829e..3d58d873ad52552cf7473e04c3bf505b7bb9cee2 100644
|
| --- a/base/trace_event/trace_event_impl.cc
|
| +++ b/base/trace_event/trace_event_impl.cc
|
| @@ -61,14 +61,6 @@ namespace {
|
| // trace.
|
| const int kOverheadReportThresholdInMicroseconds = 50;
|
|
|
| -// String options that can be used to initialize TraceOptions.
|
| -const char kRecordUntilFull[] = "record-until-full";
|
| -const char kRecordContinuously[] = "record-continuously";
|
| -const char kRecordAsMuchAsPossible[] = "record-as-much-as-possible";
|
| -const char kTraceToConsole[] = "trace-to-console";
|
| -const char kEnableSampling[] = "enable-sampling";
|
| -const char kEnableSystrace[] = "enable-systrace";
|
| -
|
| // Controls the number of trace events we will buffer in-memory
|
| // before throwing them away.
|
| const size_t kTraceBufferChunkSize = TraceBufferChunk::kTraceBufferChunkSize;
|
| @@ -89,8 +81,6 @@ const int kThreadFlushTimeoutMs = 3000;
|
| const char kEchoToConsoleCategoryFilter[] = "-ipc,-task";
|
| #endif
|
|
|
| -const char kSyntheticDelayCategoryFilterPrefix[] = "DELAY(";
|
| -
|
| #define MAX_CATEGORY_GROUPS 100
|
|
|
| // Parallel arrays g_category_groups and g_category_group_enabled are separate
|
| @@ -124,9 +114,8 @@ base::subtle::AtomicWord g_category_index = g_num_builtin_categories;
|
| LazyInstance<ThreadLocalPointer<const char> >::Leaky
|
| g_current_thread_name = LAZY_INSTANCE_INITIALIZER;
|
|
|
| -TimeTicks ThreadNow() {
|
| - return TimeTicks::IsThreadNowSupported() ?
|
| - TimeTicks::ThreadNow() : TimeTicks();
|
| +ThreadTicks ThreadNow() {
|
| + return ThreadTicks::IsSupported() ? ThreadTicks::Now() : ThreadTicks();
|
| }
|
|
|
| class TraceBufferRingBuffer : public TraceBuffer {
|
| @@ -383,7 +372,8 @@ void InitializeMetadataEvent(TraceEvent* trace_event,
|
| unsigned long long arg_value;
|
| ::trace_event_internal::SetTraceValue(value, &arg_type, &arg_value);
|
| trace_event->Initialize(thread_id,
|
| - TimeTicks(), TimeTicks(), TRACE_EVENT_PHASE_METADATA,
|
| + TraceTicks(), ThreadTicks(),
|
| + TRACE_EVENT_PHASE_METADATA,
|
| &g_category_group_enabled[g_category_metadata],
|
| metadata_name, ::trace_event_internal::kNoEventId,
|
| num_args, &arg_name, &arg_type, &arg_value, NULL,
|
| @@ -528,8 +518,8 @@ void TraceEvent::CopyFrom(const TraceEvent& other) {
|
|
|
| void TraceEvent::Initialize(
|
| int thread_id,
|
| - TimeTicks timestamp,
|
| - TimeTicks thread_timestamp,
|
| + TraceTicks timestamp,
|
| + ThreadTicks thread_timestamp,
|
| char phase,
|
| const unsigned char* category_group_enabled,
|
| const char* name,
|
| @@ -622,8 +612,8 @@ void TraceEvent::Reset() {
|
| convertable_values_[i] = NULL;
|
| }
|
|
|
| -void TraceEvent::UpdateDuration(const TimeTicks& now,
|
| - const TimeTicks& thread_now) {
|
| +void TraceEvent::UpdateDuration(const TraceTicks& now,
|
| + const ThreadTicks& thread_now) {
|
| DCHECK_EQ(duration_.ToInternalValue(), -1);
|
| duration_ = now - timestamp_;
|
| thread_duration_ = thread_now - thread_timestamp_;
|
| @@ -695,34 +685,45 @@ void TraceEvent::AppendValueAsJSON(unsigned char type,
|
| }
|
| }
|
|
|
| -void TraceEvent::AppendAsJSON(std::string* out) const {
|
| +void TraceEvent::AppendAsJSON(
|
| + std::string* out,
|
| + const ArgumentFilterPredicate& argument_filter_predicate) const {
|
| int64 time_int64 = timestamp_.ToInternalValue();
|
| int process_id = TraceLog::GetInstance()->process_id();
|
| + const char* category_group_name =
|
| + TraceLog::GetCategoryGroupName(category_group_enabled_);
|
| +
|
| // Category group checked at category creation time.
|
| DCHECK(!strchr(name_, '"'));
|
| - StringAppendF(out,
|
| - "{\"pid\":%i,\"tid\":%i,\"ts\":%" PRId64 ","
|
| - "\"ph\":\"%c\",\"cat\":\"%s\",\"name\":\"%s\",\"args\":{",
|
| - process_id,
|
| - thread_id_,
|
| - time_int64,
|
| - phase_,
|
| - TraceLog::GetCategoryGroupName(category_group_enabled_),
|
| - name_);
|
| + StringAppendF(out, "{\"pid\":%i,\"tid\":%i,\"ts\":%" PRId64
|
| + ","
|
| + "\"ph\":\"%c\",\"cat\":\"%s\",\"name\":\"%s\",\"args\":{",
|
| + process_id, thread_id_, time_int64, phase_, category_group_name,
|
| + name_);
|
|
|
| // Output argument names and values, stop at first NULL argument name.
|
| - for (int i = 0; i < kTraceMaxNumArgs && arg_names_[i]; ++i) {
|
| - if (i > 0)
|
| - *out += ",";
|
| - *out += "\"";
|
| - *out += arg_names_[i];
|
| - *out += "\":";
|
| -
|
| - if (arg_types_[i] == TRACE_VALUE_TYPE_CONVERTABLE)
|
| - convertable_values_[i]->AppendAsTraceFormat(out);
|
| - else
|
| - AppendValueAsJSON(arg_types_[i], arg_values_[i], out);
|
| + if (arg_names_[0]) {
|
| + bool allow_args = argument_filter_predicate.is_null() ||
|
| + argument_filter_predicate.Run(category_group_name, name_);
|
| +
|
| + if (allow_args) {
|
| + for (int i = 0; i < kTraceMaxNumArgs && arg_names_[i]; ++i) {
|
| + if (i > 0)
|
| + *out += ",";
|
| + *out += "\"";
|
| + *out += arg_names_[i];
|
| + *out += "\":";
|
| +
|
| + if (arg_types_[i] == TRACE_VALUE_TYPE_CONVERTABLE)
|
| + convertable_values_[i]->AppendAsTraceFormat(out);
|
| + else
|
| + AppendValueAsJSON(arg_types_[i], arg_values_[i], out);
|
| + }
|
| + } else {
|
| + *out += "\"stripped\":1";
|
| + }
|
| }
|
| +
|
| *out += "}";
|
|
|
| if (phase_ == TRACE_EVENT_PHASE_COMPLETE) {
|
| @@ -978,65 +979,6 @@ TraceBucketData::~TraceBucketData() {
|
|
|
| ////////////////////////////////////////////////////////////////////////////////
|
| //
|
| -// TraceOptions
|
| -//
|
| -////////////////////////////////////////////////////////////////////////////////
|
| -
|
| -bool TraceOptions::SetFromString(const std::string& options_string) {
|
| - record_mode = RECORD_UNTIL_FULL;
|
| - enable_sampling = false;
|
| - enable_systrace = false;
|
| -
|
| - std::vector<std::string> split;
|
| - std::vector<std::string>::iterator iter;
|
| - base::SplitString(options_string, ',', &split);
|
| - for (iter = split.begin(); iter != split.end(); ++iter) {
|
| - if (*iter == kRecordUntilFull) {
|
| - record_mode = RECORD_UNTIL_FULL;
|
| - } else if (*iter == kRecordContinuously) {
|
| - record_mode = RECORD_CONTINUOUSLY;
|
| - } else if (*iter == kTraceToConsole) {
|
| - record_mode = ECHO_TO_CONSOLE;
|
| - } else if (*iter == kRecordAsMuchAsPossible) {
|
| - record_mode = RECORD_AS_MUCH_AS_POSSIBLE;
|
| - } else if (*iter == kEnableSampling) {
|
| - enable_sampling = true;
|
| - } else if (*iter == kEnableSystrace) {
|
| - enable_systrace = true;
|
| - } else {
|
| - return false;
|
| - }
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -std::string TraceOptions::ToString() const {
|
| - std::string ret;
|
| - switch (record_mode) {
|
| - case RECORD_UNTIL_FULL:
|
| - ret = kRecordUntilFull;
|
| - break;
|
| - case RECORD_CONTINUOUSLY:
|
| - ret = kRecordContinuously;
|
| - break;
|
| - case ECHO_TO_CONSOLE:
|
| - ret = kTraceToConsole;
|
| - break;
|
| - case RECORD_AS_MUCH_AS_POSSIBLE:
|
| - ret = kRecordAsMuchAsPossible;
|
| - break;
|
| - default:
|
| - NOTREACHED();
|
| - }
|
| - if (enable_sampling)
|
| - ret = ret + "," + kEnableSampling;
|
| - if (enable_systrace)
|
| - ret = ret + "," + kEnableSystrace;
|
| - return ret;
|
| -}
|
| -
|
| -////////////////////////////////////////////////////////////////////////////////
|
| -//
|
| // TraceLog
|
| //
|
| ////////////////////////////////////////////////////////////////////////////////
|
| @@ -1049,8 +991,8 @@ class TraceLog::ThreadLocalEventBuffer
|
|
|
| TraceEvent* AddTraceEvent(TraceEventHandle* handle);
|
|
|
| - void ReportOverhead(const TimeTicks& event_timestamp,
|
| - const TimeTicks& event_thread_timestamp);
|
| + void ReportOverhead(const TraceTicks& event_timestamp,
|
| + const ThreadTicks& event_thread_timestamp);
|
|
|
| TraceEvent* GetEventByHandle(TraceEventHandle handle) {
|
| if (!chunk_ || handle.chunk_seq != chunk_->seq() ||
|
| @@ -1147,16 +1089,16 @@ TraceEvent* TraceLog::ThreadLocalEventBuffer::AddTraceEvent(
|
| }
|
|
|
| void TraceLog::ThreadLocalEventBuffer::ReportOverhead(
|
| - const TimeTicks& event_timestamp,
|
| - const TimeTicks& event_thread_timestamp) {
|
| + const TraceTicks& event_timestamp,
|
| + const ThreadTicks& event_thread_timestamp) {
|
| if (!g_category_group_enabled[g_category_trace_event_overhead])
|
| return;
|
|
|
| CheckThisIsCurrentBuffer();
|
|
|
| event_count_++;
|
| - TimeTicks thread_now = ThreadNow();
|
| - TimeTicks now = trace_log_->OffsetNow();
|
| + ThreadTicks thread_now = ThreadNow();
|
| + TraceTicks now = trace_log_->OffsetNow();
|
| TimeDelta overhead = now - event_timestamp;
|
| if (overhead.InMicroseconds() >= kOverheadReportThresholdInMicroseconds) {
|
| TraceEvent* trace_event = AddTraceEvent(NULL);
|
| @@ -1212,9 +1154,8 @@ TraceLog::TraceLog()
|
| watch_category_(0),
|
| trace_options_(kInternalRecordUntilFull),
|
| sampling_thread_handle_(0),
|
| - category_filter_(CategoryFilter::kDefaultCategoryFilterString),
|
| - event_callback_category_filter_(
|
| - CategoryFilter::kDefaultCategoryFilterString),
|
| + trace_config_(TraceConfig()),
|
| + event_callback_trace_config_(TraceConfig()),
|
| thread_shared_chunk_index_(0),
|
| generation_(0),
|
| use_worker_thread_(false) {
|
| @@ -1249,9 +1190,7 @@ TraceLog::TraceLog()
|
|
|
| LOG(ERROR) << "Start " << switches::kTraceToConsole
|
| << " with CategoryFilter '" << filter << "'.";
|
| - SetEnabled(CategoryFilter(filter),
|
| - RECORDING_MODE,
|
| - TraceOptions(ECHO_TO_CONSOLE));
|
| + SetEnabled(TraceConfig(filter, ECHO_TO_CONSOLE), RECORDING_MODE);
|
| }
|
| #endif
|
|
|
| @@ -1291,13 +1230,13 @@ void TraceLog::UpdateCategoryGroupEnabledFlag(size_t category_index) {
|
| unsigned char enabled_flag = 0;
|
| const char* category_group = g_category_groups[category_index];
|
| if (mode_ == RECORDING_MODE &&
|
| - category_filter_.IsCategoryGroupEnabled(category_group))
|
| + trace_config_.IsCategoryGroupEnabled(category_group))
|
| enabled_flag |= ENABLED_FOR_RECORDING;
|
| else if (mode_ == MONITORING_MODE &&
|
| - category_filter_.IsCategoryGroupEnabled(category_group))
|
| + trace_config_.IsCategoryGroupEnabled(category_group))
|
| enabled_flag |= ENABLED_FOR_MONITORING;
|
| if (event_callback_ &&
|
| - event_callback_category_filter_.IsCategoryGroupEnabled(category_group))
|
| + event_callback_trace_config_.IsCategoryGroupEnabled(category_group))
|
| enabled_flag |= ENABLED_FOR_EVENT_CALLBACK;
|
| #if defined(OS_WIN)
|
| if (base::trace_event::TraceEventETWExport::isETWExportEnabled())
|
| @@ -1313,11 +1252,11 @@ void TraceLog::UpdateCategoryGroupEnabledFlags() {
|
| UpdateCategoryGroupEnabledFlag(i);
|
| }
|
|
|
| -void TraceLog::UpdateSyntheticDelaysFromCategoryFilter() {
|
| +void TraceLog::UpdateSyntheticDelaysFromTraceConfig() {
|
| ResetTraceEventSyntheticDelays();
|
| - const CategoryFilter::StringList& delays =
|
| - category_filter_.GetSyntheticDelayValues();
|
| - CategoryFilter::StringList::const_iterator ci;
|
| + const TraceConfig::StringList& delays =
|
| + trace_config_.GetSyntheticDelayValues();
|
| + TraceConfig::StringList::const_iterator ci;
|
| for (ci = delays.begin(); ci != delays.end(); ++ci) {
|
| StringTokenizer tokens(*ci, ";");
|
| if (!tokens.GetNext())
|
| @@ -1381,7 +1320,7 @@ const unsigned char* TraceLog::GetCategoryGroupEnabledInternal(
|
| g_category_groups[category_index] = new_group;
|
| DCHECK(!g_category_group_enabled[category_index]);
|
| // Note that if both included and excluded patterns in the
|
| - // CategoryFilter are empty, we exclude nothing,
|
| + // TraceConfig are empty, we exclude nothing,
|
| // thereby enabling this category group.
|
| UpdateCategoryGroupEnabledFlag(category_index);
|
| category_group_enabled = &g_category_group_enabled[category_index];
|
| @@ -1404,9 +1343,7 @@ void TraceLog::GetKnownCategoryGroups(
|
| category_groups->push_back(g_category_groups[i]);
|
| }
|
|
|
| -void TraceLog::SetEnabled(const CategoryFilter& category_filter,
|
| - Mode mode,
|
| - const TraceOptions& options) {
|
| +void TraceLog::SetEnabled(const TraceConfig& trace_config, Mode mode) {
|
| std::vector<EnabledStateObserver*> observer_list;
|
| {
|
| AutoLock lock(lock_);
|
| @@ -1415,7 +1352,7 @@ void TraceLog::SetEnabled(const CategoryFilter& category_filter,
|
| DCHECK(!flush_task_runner_);
|
|
|
| InternalTraceOptions new_options =
|
| - GetInternalOptionsFromTraceOptions(options);
|
| + GetInternalOptionsFromTraceConfig(trace_config);
|
|
|
| InternalTraceOptions old_options = trace_options();
|
|
|
| @@ -1429,7 +1366,7 @@ void TraceLog::SetEnabled(const CategoryFilter& category_filter,
|
| DLOG(ERROR) << "Attempting to re-enable tracing with a different mode.";
|
| }
|
|
|
| - category_filter_.Merge(category_filter);
|
| + trace_config_.Merge(trace_config);
|
| UpdateCategoryGroupEnabledFlags();
|
| return;
|
| }
|
| @@ -1449,9 +1386,9 @@ void TraceLog::SetEnabled(const CategoryFilter& category_filter,
|
|
|
| num_traces_recorded_++;
|
|
|
| - category_filter_ = CategoryFilter(category_filter);
|
| + trace_config_ = TraceConfig(trace_config);
|
| UpdateCategoryGroupEnabledFlags();
|
| - UpdateSyntheticDelaysFromCategoryFilter();
|
| + UpdateSyntheticDelaysFromTraceConfig();
|
|
|
| if (new_options & kInternalEnableSampling) {
|
| sampling_thread_.reset(new TraceSamplingThread);
|
| @@ -1486,11 +1423,21 @@ void TraceLog::SetEnabled(const CategoryFilter& category_filter,
|
| }
|
| }
|
|
|
| -TraceLog::InternalTraceOptions TraceLog::GetInternalOptionsFromTraceOptions(
|
| - const TraceOptions& options) {
|
| +void TraceLog::SetArgumentFilterPredicate(
|
| + const TraceEvent::ArgumentFilterPredicate& argument_filter_predicate) {
|
| + AutoLock lock(lock_);
|
| + DCHECK(!argument_filter_predicate.is_null());
|
| + DCHECK(argument_filter_predicate_.is_null());
|
| + argument_filter_predicate_ = argument_filter_predicate;
|
| +}
|
| +
|
| +TraceLog::InternalTraceOptions TraceLog::GetInternalOptionsFromTraceConfig(
|
| + const TraceConfig& config) {
|
| InternalTraceOptions ret =
|
| - options.enable_sampling ? kInternalEnableSampling : kInternalNone;
|
| - switch (options.record_mode) {
|
| + config.IsSamplingEnabled() ? kInternalEnableSampling : kInternalNone;
|
| + if (config.IsArgumentFilterEnabled())
|
| + ret |= kInternalEnableArgumentFilter;
|
| + switch (config.GetTraceRecordMode()) {
|
| case RECORD_UNTIL_FULL:
|
| return ret | kInternalRecordUntilFull;
|
| case RECORD_CONTINUOUSLY:
|
| @@ -1504,26 +1451,9 @@ TraceLog::InternalTraceOptions TraceLog::GetInternalOptionsFromTraceOptions(
|
| return kInternalNone;
|
| }
|
|
|
| -CategoryFilter TraceLog::GetCurrentCategoryFilter() {
|
| +TraceConfig TraceLog::GetCurrentTraceConfig() const {
|
| AutoLock lock(lock_);
|
| - return category_filter_;
|
| -}
|
| -
|
| -TraceOptions TraceLog::GetCurrentTraceOptions() const {
|
| - TraceOptions ret;
|
| - InternalTraceOptions option = trace_options();
|
| - ret.enable_sampling = (option & kInternalEnableSampling) != 0;
|
| - if (option & kInternalRecordUntilFull)
|
| - ret.record_mode = RECORD_UNTIL_FULL;
|
| - else if (option & kInternalRecordContinuously)
|
| - ret.record_mode = RECORD_CONTINUOUSLY;
|
| - else if (option & kInternalEchoToConsole)
|
| - ret.record_mode = ECHO_TO_CONSOLE;
|
| - else if (option & kInternalRecordAsMuchAsPossible)
|
| - ret.record_mode = RECORD_AS_MUCH_AS_POSSIBLE;
|
| - else
|
| - NOTREACHED();
|
| - return ret;
|
| + return trace_config_;
|
| }
|
|
|
| void TraceLog::SetDisabled() {
|
| @@ -1555,7 +1485,7 @@ void TraceLog::SetDisabledWhileLocked() {
|
| sampling_thread_.reset();
|
| }
|
|
|
| - category_filter_.Clear();
|
| + trace_config_.Clear();
|
| subtle::NoBarrier_Store(&watch_category_, 0);
|
| watch_event_name_ = "";
|
| UpdateCategoryGroupEnabledFlags();
|
| @@ -1670,12 +1600,12 @@ void TraceLog::CheckIfBufferIsFullWhileLocked() {
|
| }
|
| }
|
|
|
| -void TraceLog::SetEventCallbackEnabled(const CategoryFilter& category_filter,
|
| +void TraceLog::SetEventCallbackEnabled(const TraceConfig& trace_config,
|
| EventCallback cb) {
|
| AutoLock lock(lock_);
|
| subtle::NoBarrier_Store(&event_callback_,
|
| reinterpret_cast<subtle::AtomicWord>(cb));
|
| - event_callback_category_filter_ = category_filter;
|
| + event_callback_trace_config_ = trace_config;
|
| UpdateCategoryGroupEnabledFlags();
|
| };
|
|
|
| @@ -1756,8 +1686,8 @@ void TraceLog::Flush(const TraceLog::OutputCallback& cb,
|
| // Usually it runs on a different thread.
|
| void TraceLog::ConvertTraceEventsToTraceFormat(
|
| scoped_ptr<TraceBuffer> logged_events,
|
| - const TraceLog::OutputCallback& flush_output_callback) {
|
| -
|
| + const OutputCallback& flush_output_callback,
|
| + const TraceEvent::ArgumentFilterPredicate& argument_filter_predicate) {
|
| if (flush_output_callback.is_null())
|
| return;
|
|
|
| @@ -1776,7 +1706,8 @@ void TraceLog::ConvertTraceEventsToTraceFormat(
|
| for (size_t j = 0; j < chunk->size(); ++j) {
|
| if (json_events_str_ptr->size())
|
| json_events_str_ptr->data().append(",\n");
|
| - chunk->GetEventAt(j)->AppendAsJSON(&(json_events_str_ptr->data()));
|
| + chunk->GetEventAt(j)->AppendAsJSON(&(json_events_str_ptr->data()),
|
| + argument_filter_predicate);
|
| }
|
| }
|
| flush_output_callback.Run(json_events_str_ptr, has_more_events);
|
| @@ -1786,6 +1717,7 @@ void TraceLog::ConvertTraceEventsToTraceFormat(
|
| void TraceLog::FinishFlush(int generation) {
|
| scoped_ptr<TraceBuffer> previous_logged_events;
|
| OutputCallback flush_output_callback;
|
| + TraceEvent::ArgumentFilterPredicate argument_filter_predicate;
|
|
|
| if (!CheckGeneration(generation))
|
| return;
|
| @@ -1800,20 +1732,25 @@ void TraceLog::FinishFlush(int generation) {
|
| flush_task_runner_ = NULL;
|
| flush_output_callback = flush_output_callback_;
|
| flush_output_callback_.Reset();
|
| +
|
| + if (trace_options() & kInternalEnableArgumentFilter) {
|
| + CHECK(!argument_filter_predicate_.is_null());
|
| + argument_filter_predicate = argument_filter_predicate_;
|
| + }
|
| }
|
|
|
| if (use_worker_thread_ &&
|
| WorkerPool::PostTask(
|
| - FROM_HERE,
|
| - Bind(&TraceLog::ConvertTraceEventsToTraceFormat,
|
| - Passed(&previous_logged_events),
|
| - flush_output_callback),
|
| + FROM_HERE, Bind(&TraceLog::ConvertTraceEventsToTraceFormat,
|
| + Passed(&previous_logged_events),
|
| + flush_output_callback, argument_filter_predicate),
|
| true)) {
|
| return;
|
| }
|
|
|
| ConvertTraceEventsToTraceFormat(previous_logged_events.Pass(),
|
| - flush_output_callback);
|
| + flush_output_callback,
|
| + argument_filter_predicate);
|
| }
|
|
|
| // Run in each thread holding a local event buffer.
|
| @@ -1863,6 +1800,7 @@ void TraceLog::OnFlushTimeout(int generation) {
|
| void TraceLog::FlushButLeaveBufferIntact(
|
| const TraceLog::OutputCallback& flush_output_callback) {
|
| scoped_ptr<TraceBuffer> previous_logged_events;
|
| + TraceEvent::ArgumentFilterPredicate argument_filter_predicate;
|
| {
|
| AutoLock lock(lock_);
|
| AddMetadataEventsWhileLocked();
|
| @@ -1872,10 +1810,16 @@ void TraceLog::FlushButLeaveBufferIntact(
|
| thread_shared_chunk_.Pass());
|
| }
|
| previous_logged_events = logged_events_->CloneForIteration().Pass();
|
| +
|
| + if (trace_options() & kInternalEnableArgumentFilter) {
|
| + CHECK(!argument_filter_predicate_.is_null());
|
| + argument_filter_predicate = argument_filter_predicate_;
|
| + }
|
| } // release lock
|
|
|
| ConvertTraceEventsToTraceFormat(previous_logged_events.Pass(),
|
| - flush_output_callback);
|
| + flush_output_callback,
|
| + argument_filter_predicate);
|
| }
|
|
|
| void TraceLog::UseNextTraceBuffer() {
|
| @@ -1897,7 +1841,7 @@ TraceEventHandle TraceLog::AddTraceEvent(
|
| const scoped_refptr<ConvertableToTraceFormat>* convertable_values,
|
| unsigned char flags) {
|
| int thread_id = static_cast<int>(base::PlatformThread::CurrentId());
|
| - base::TimeTicks now = base::TimeTicks::NowFromSystemTraceTime();
|
| + base::TraceTicks now = base::TraceTicks::Now();
|
| return AddTraceEventWithThreadIdAndTimestamp(phase, category_group_enabled,
|
| name, id, thread_id, now,
|
| num_args, arg_names,
|
| @@ -1911,7 +1855,7 @@ TraceEventHandle TraceLog::AddTraceEventWithThreadIdAndTimestamp(
|
| const char* name,
|
| unsigned long long id,
|
| int thread_id,
|
| - const TimeTicks& timestamp,
|
| + const TraceTicks& timestamp,
|
| int num_args,
|
| const char** arg_names,
|
| const unsigned char* arg_types,
|
| @@ -1936,10 +1880,10 @@ TraceEventHandle TraceLog::AddTraceEventWithThreadIdAndTimestamp(
|
| if (flags & TRACE_EVENT_FLAG_MANGLE_ID)
|
| id = MangleEventId(id);
|
|
|
| - TimeTicks offset_event_timestamp = OffsetTimestamp(timestamp);
|
| - TimeTicks now = flags & TRACE_EVENT_FLAG_EXPLICIT_TIMESTAMP ?
|
| + TraceTicks offset_event_timestamp = OffsetTimestamp(timestamp);
|
| + TraceTicks now = flags & TRACE_EVENT_FLAG_EXPLICIT_TIMESTAMP ?
|
| OffsetNow() : offset_event_timestamp;
|
| - TimeTicks thread_now = ThreadNow();
|
| + ThreadTicks thread_now = ThreadNow();
|
|
|
| ThreadLocalEventBuffer* thread_local_event_buffer = NULL;
|
| // A ThreadLocalEventBuffer needs the message loop
|
| @@ -2077,7 +2021,7 @@ TraceEventHandle TraceLog::AddTraceEventWithThreadIdAndTimestamp(
|
| // May be called when a COMPELETE event ends and the unfinished event has been
|
| // recycled (phase == TRACE_EVENT_PHASE_END and trace_event == NULL).
|
| std::string TraceLog::EventToConsoleMessage(unsigned char phase,
|
| - const TimeTicks& timestamp,
|
| + const TraceTicks& timestamp,
|
| TraceEvent* trace_event) {
|
| AutoLock thread_info_lock(thread_info_lock_);
|
|
|
| @@ -2157,8 +2101,8 @@ void TraceLog::UpdateTraceEventDuration(
|
|
|
| AutoThreadLocalBoolean thread_is_in_trace_event(&thread_is_in_trace_event_);
|
|
|
| - TimeTicks thread_now = ThreadNow();
|
| - TimeTicks now = OffsetNow();
|
| + ThreadTicks thread_now = ThreadNow();
|
| + TraceTicks now = OffsetNow();
|
|
|
| std::string console_message;
|
| if (*category_group_enabled & ENABLED_FOR_RECORDING) {
|
| @@ -2390,232 +2334,6 @@ void TraceLog::SetCurrentThreadBlocksMessageLoop() {
|
| }
|
| }
|
|
|
| -bool CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace(
|
| - const std::string& str) {
|
| - return str.empty() ||
|
| - str.at(0) == ' ' ||
|
| - str.at(str.length() - 1) == ' ';
|
| -}
|
| -
|
| -CategoryFilter::CategoryFilter(const std::string& filter_string) {
|
| - if (!filter_string.empty())
|
| - Initialize(filter_string);
|
| - else
|
| - Initialize(CategoryFilter::kDefaultCategoryFilterString);
|
| -}
|
| -
|
| -CategoryFilter::CategoryFilter() {
|
| - Initialize(CategoryFilter::kDefaultCategoryFilterString);
|
| -}
|
| -
|
| -CategoryFilter::CategoryFilter(const CategoryFilter& cf)
|
| - : included_(cf.included_),
|
| - disabled_(cf.disabled_),
|
| - excluded_(cf.excluded_),
|
| - delays_(cf.delays_) {
|
| -}
|
| -
|
| -CategoryFilter::~CategoryFilter() {
|
| -}
|
| -
|
| -CategoryFilter& CategoryFilter::operator=(const CategoryFilter& rhs) {
|
| - if (this == &rhs)
|
| - return *this;
|
| -
|
| - included_ = rhs.included_;
|
| - disabled_ = rhs.disabled_;
|
| - excluded_ = rhs.excluded_;
|
| - delays_ = rhs.delays_;
|
| - return *this;
|
| -}
|
| -
|
| -void CategoryFilter::Initialize(const std::string& filter_string) {
|
| - // Tokenize list of categories, delimited by ','.
|
| - StringTokenizer tokens(filter_string, ",");
|
| - // Add each token to the appropriate list (included_,excluded_).
|
| - while (tokens.GetNext()) {
|
| - std::string category = tokens.token();
|
| - // Ignore empty categories.
|
| - if (category.empty())
|
| - continue;
|
| - // Synthetic delays are of the form 'DELAY(delay;option;option;...)'.
|
| - if (category.find(kSyntheticDelayCategoryFilterPrefix) == 0 &&
|
| - category.at(category.size() - 1) == ')') {
|
| - category = category.substr(
|
| - strlen(kSyntheticDelayCategoryFilterPrefix),
|
| - category.size() - strlen(kSyntheticDelayCategoryFilterPrefix) - 1);
|
| - size_t name_length = category.find(';');
|
| - if (name_length != std::string::npos && name_length > 0 &&
|
| - name_length != category.size() - 1) {
|
| - delays_.push_back(category);
|
| - }
|
| - } else if (category.at(0) == '-') {
|
| - // Excluded categories start with '-'.
|
| - // Remove '-' from category string.
|
| - category = category.substr(1);
|
| - excluded_.push_back(category);
|
| - } else if (category.compare(0, strlen(TRACE_DISABLED_BY_DEFAULT("")),
|
| - TRACE_DISABLED_BY_DEFAULT("")) == 0) {
|
| - disabled_.push_back(category);
|
| - } else {
|
| - included_.push_back(category);
|
| - }
|
| - }
|
| -}
|
| -
|
| -void CategoryFilter::WriteString(const StringList& values,
|
| - std::string* out,
|
| - bool included) const {
|
| - bool prepend_comma = !out->empty();
|
| - int token_cnt = 0;
|
| - for (StringList::const_iterator ci = values.begin();
|
| - ci != values.end(); ++ci) {
|
| - if (token_cnt > 0 || prepend_comma)
|
| - StringAppendF(out, ",");
|
| - StringAppendF(out, "%s%s", (included ? "" : "-"), ci->c_str());
|
| - ++token_cnt;
|
| - }
|
| -}
|
| -
|
| -void CategoryFilter::WriteString(const StringList& delays,
|
| - std::string* out) const {
|
| - bool prepend_comma = !out->empty();
|
| - int token_cnt = 0;
|
| - for (StringList::const_iterator ci = delays.begin();
|
| - ci != delays.end(); ++ci) {
|
| - if (token_cnt > 0 || prepend_comma)
|
| - StringAppendF(out, ",");
|
| - StringAppendF(out, "%s%s)", kSyntheticDelayCategoryFilterPrefix,
|
| - ci->c_str());
|
| - ++token_cnt;
|
| - }
|
| -}
|
| -
|
| -std::string CategoryFilter::ToString() const {
|
| - std::string filter_string;
|
| - WriteString(included_, &filter_string, true);
|
| - WriteString(disabled_, &filter_string, true);
|
| - WriteString(excluded_, &filter_string, false);
|
| - WriteString(delays_, &filter_string);
|
| - return filter_string;
|
| -}
|
| -
|
| -bool CategoryFilter::IsCategoryGroupEnabled(
|
| - const char* category_group_name) const {
|
| - // TraceLog should call this method only as part of enabling/disabling
|
| - // categories.
|
| -
|
| - bool had_enabled_by_default = false;
|
| - DCHECK(category_group_name);
|
| - CStringTokenizer category_group_tokens(
|
| - category_group_name, category_group_name + strlen(category_group_name),
|
| - ",");
|
| - while (category_group_tokens.GetNext()) {
|
| - std::string category_group_token = category_group_tokens.token();
|
| - // Don't allow empty tokens, nor tokens with leading or trailing space.
|
| - DCHECK(!CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace(
|
| - category_group_token))
|
| - << "Disallowed category string";
|
| - if (IsCategoryEnabled(category_group_token.c_str())) {
|
| - return true;
|
| - }
|
| - if (!MatchPattern(category_group_token.c_str(),
|
| - TRACE_DISABLED_BY_DEFAULT("*")))
|
| - had_enabled_by_default = true;
|
| - }
|
| - // Do a second pass to check for explicitly disabled categories
|
| - // (those explicitly enabled have priority due to first pass).
|
| - category_group_tokens.Reset();
|
| - bool category_group_disabled = false;
|
| - while (category_group_tokens.GetNext()) {
|
| - std::string category_group_token = category_group_tokens.token();
|
| - for (StringList::const_iterator ci = excluded_.begin();
|
| - ci != excluded_.end(); ++ci) {
|
| - if (MatchPattern(category_group_token.c_str(), ci->c_str())) {
|
| - // Current token of category_group_name is present in excluded_list.
|
| - // Flag the exclusion and proceed further to check if any of the
|
| - // remaining categories of category_group_name is not present in the
|
| - // excluded_ list.
|
| - category_group_disabled = true;
|
| - break;
|
| - }
|
| - // One of the category of category_group_name is not present in
|
| - // excluded_ list. So, it has to be included_ list. Enable the
|
| - // category_group_name for recording.
|
| - category_group_disabled = false;
|
| - }
|
| - // One of the categories present in category_group_name is not present in
|
| - // excluded_ list. Implies this category_group_name group can be enabled
|
| - // for recording, since one of its groups is enabled for recording.
|
| - if (!category_group_disabled)
|
| - break;
|
| - }
|
| - // If the category group is not excluded, and there are no included patterns
|
| - // we consider this category group enabled, as long as it had categories
|
| - // other than disabled-by-default.
|
| - return !category_group_disabled &&
|
| - included_.empty() && had_enabled_by_default;
|
| -}
|
| -
|
| -bool CategoryFilter::IsCategoryEnabled(const char* category_name) const {
|
| - StringList::const_iterator ci;
|
| -
|
| - // Check the disabled- filters and the disabled-* wildcard first so that a
|
| - // "*" filter does not include the disabled.
|
| - for (ci = disabled_.begin(); ci != disabled_.end(); ++ci) {
|
| - if (MatchPattern(category_name, ci->c_str()))
|
| - return true;
|
| - }
|
| -
|
| - if (MatchPattern(category_name, TRACE_DISABLED_BY_DEFAULT("*")))
|
| - return false;
|
| -
|
| - for (ci = included_.begin(); ci != included_.end(); ++ci) {
|
| - if (MatchPattern(category_name, ci->c_str()))
|
| - return true;
|
| - }
|
| -
|
| - return false;
|
| -}
|
| -
|
| -bool CategoryFilter::HasIncludedPatterns() const {
|
| - return !included_.empty();
|
| -}
|
| -
|
| -void CategoryFilter::Merge(const CategoryFilter& nested_filter) {
|
| - // Keep included patterns only if both filters have an included entry.
|
| - // Otherwise, one of the filter was specifying "*" and we want to honour the
|
| - // broadest filter.
|
| - if (HasIncludedPatterns() && nested_filter.HasIncludedPatterns()) {
|
| - included_.insert(included_.end(),
|
| - nested_filter.included_.begin(),
|
| - nested_filter.included_.end());
|
| - } else {
|
| - included_.clear();
|
| - }
|
| -
|
| - disabled_.insert(disabled_.end(),
|
| - nested_filter.disabled_.begin(),
|
| - nested_filter.disabled_.end());
|
| - excluded_.insert(excluded_.end(),
|
| - nested_filter.excluded_.begin(),
|
| - nested_filter.excluded_.end());
|
| - delays_.insert(delays_.end(),
|
| - nested_filter.delays_.begin(),
|
| - nested_filter.delays_.end());
|
| -}
|
| -
|
| -void CategoryFilter::Clear() {
|
| - included_.clear();
|
| - disabled_.clear();
|
| - excluded_.clear();
|
| -}
|
| -
|
| -const CategoryFilter::StringList&
|
| - CategoryFilter::GetSyntheticDelayValues() const {
|
| - return delays_;
|
| -}
|
| -
|
| } // namespace trace_event
|
| } // namespace base
|
|
|
| @@ -2635,8 +2353,8 @@ ScopedTraceBinaryEfficient::ScopedTraceBinaryEfficient(
|
| TRACE_EVENT_PHASE_COMPLETE, category_group_enabled_, name,
|
| trace_event_internal::kNoEventId,
|
| static_cast<int>(base::PlatformThread::CurrentId()),
|
| - base::TimeTicks::NowFromSystemTraceTime(),
|
| - 0, NULL, NULL, NULL, NULL, TRACE_EVENT_FLAG_NONE);
|
| + base::TraceTicks::Now(), 0, NULL, NULL, NULL, NULL,
|
| + TRACE_EVENT_FLAG_NONE);
|
| }
|
| }
|
|
|
|
|