Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1935)

Unified Diff: base/trace_event/trace_event_impl.cc

Issue 1180693002: Update from https://crrev.com/333737 (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: rebased Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « base/trace_event/trace_event_impl.h ('k') | base/trace_event/trace_event_impl_constants.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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);
}
}
« no previous file with comments | « base/trace_event/trace_event_impl.h ('k') | base/trace_event/trace_event_impl_constants.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698