OLD | NEW |
| (Empty) |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "base/debug/trace_event_unittest.h" | |
6 | |
7 #include <math.h> | |
8 #include <cstdlib> | |
9 | |
10 #include "base/bind.h" | |
11 #include "base/command_line.h" | |
12 #include "base/debug/trace_event.h" | |
13 #include "base/debug/trace_event_synthetic_delay.h" | |
14 #include "base/json/json_reader.h" | |
15 #include "base/json/json_writer.h" | |
16 #include "base/memory/ref_counted_memory.h" | |
17 #include "base/memory/scoped_ptr.h" | |
18 #include "base/memory/singleton.h" | |
19 #include "base/process/process_handle.h" | |
20 #include "base/strings/stringprintf.h" | |
21 #include "base/synchronization/waitable_event.h" | |
22 #include "base/threading/platform_thread.h" | |
23 #include "base/threading/thread.h" | |
24 #include "base/time/time.h" | |
25 #include "base/values.h" | |
26 #include "testing/gmock/include/gmock/gmock.h" | |
27 #include "testing/gtest/include/gtest/gtest.h" | |
28 | |
29 namespace base { | |
30 namespace debug { | |
31 | |
32 namespace { | |
33 | |
34 enum CompareOp { | |
35 IS_EQUAL, | |
36 IS_NOT_EQUAL, | |
37 }; | |
38 | |
39 struct JsonKeyValue { | |
40 const char* key; | |
41 const char* value; | |
42 CompareOp op; | |
43 }; | |
44 | |
45 const int kThreadId = 42; | |
46 const int kAsyncId = 5; | |
47 const char kAsyncIdStr[] = "0x5"; | |
48 const int kAsyncId2 = 6; | |
49 const char kAsyncId2Str[] = "0x6"; | |
50 | |
51 class TraceEventTestFixture : public testing::Test { | |
52 public: | |
53 void OnTraceDataCollected( | |
54 WaitableEvent* flush_complete_event, | |
55 const scoped_refptr<base::RefCountedString>& events_str, | |
56 bool has_more_events); | |
57 void OnWatchEventMatched() { | |
58 ++event_watch_notification_; | |
59 } | |
60 DictionaryValue* FindMatchingTraceEntry(const JsonKeyValue* key_values); | |
61 DictionaryValue* FindNamePhase(const char* name, const char* phase); | |
62 DictionaryValue* FindNamePhaseKeyValue(const char* name, | |
63 const char* phase, | |
64 const char* key, | |
65 const char* value); | |
66 void DropTracedMetadataRecords(); | |
67 bool FindMatchingValue(const char* key, | |
68 const char* value); | |
69 bool FindNonMatchingValue(const char* key, | |
70 const char* value); | |
71 void Clear() { | |
72 trace_parsed_.Clear(); | |
73 json_output_.json_output.clear(); | |
74 } | |
75 | |
76 void BeginTrace() { | |
77 BeginSpecificTrace("*"); | |
78 } | |
79 | |
80 void BeginSpecificTrace(const std::string& filter) { | |
81 event_watch_notification_ = 0; | |
82 TraceLog::GetInstance()->SetEnabled( | |
83 CategoryFilter(filter), | |
84 TraceLog::RECORDING_MODE, | |
85 TraceOptions()); | |
86 } | |
87 | |
88 void EndTraceAndFlush() { | |
89 WaitableEvent flush_complete_event(false, false); | |
90 EndTraceAndFlushAsync(&flush_complete_event); | |
91 flush_complete_event.Wait(); | |
92 } | |
93 | |
94 // Used when testing thread-local buffers which requires the thread initiating | |
95 // flush to have a message loop. | |
96 void EndTraceAndFlushInThreadWithMessageLoop() { | |
97 WaitableEvent flush_complete_event(false, false); | |
98 Thread flush_thread("flush"); | |
99 flush_thread.Start(); | |
100 flush_thread.message_loop()->PostTask(FROM_HERE, | |
101 base::Bind(&TraceEventTestFixture::EndTraceAndFlushAsync, | |
102 base::Unretained(this), | |
103 &flush_complete_event)); | |
104 flush_complete_event.Wait(); | |
105 } | |
106 | |
107 void EndTraceAndFlushAsync(WaitableEvent* flush_complete_event) { | |
108 TraceLog::GetInstance()->SetDisabled(); | |
109 TraceLog::GetInstance()->Flush( | |
110 base::Bind(&TraceEventTestFixture::OnTraceDataCollected, | |
111 base::Unretained(static_cast<TraceEventTestFixture*>(this)), | |
112 base::Unretained(flush_complete_event))); | |
113 } | |
114 | |
115 void FlushMonitoring() { | |
116 WaitableEvent flush_complete_event(false, false); | |
117 FlushMonitoring(&flush_complete_event); | |
118 flush_complete_event.Wait(); | |
119 } | |
120 | |
121 void FlushMonitoring(WaitableEvent* flush_complete_event) { | |
122 TraceLog::GetInstance()->FlushButLeaveBufferIntact( | |
123 base::Bind(&TraceEventTestFixture::OnTraceDataCollected, | |
124 base::Unretained(static_cast<TraceEventTestFixture*>(this)), | |
125 base::Unretained(flush_complete_event))); | |
126 } | |
127 | |
128 void SetUp() override { | |
129 const char* name = PlatformThread::GetName(); | |
130 old_thread_name_ = name ? strdup(name) : NULL; | |
131 | |
132 TraceLog::DeleteForTesting(); | |
133 TraceLog* tracelog = TraceLog::GetInstance(); | |
134 ASSERT_TRUE(tracelog); | |
135 ASSERT_FALSE(tracelog->IsEnabled()); | |
136 trace_buffer_.SetOutputCallback(json_output_.GetCallback()); | |
137 event_watch_notification_ = 0; | |
138 } | |
139 void TearDown() override { | |
140 if (TraceLog::GetInstance()) | |
141 EXPECT_FALSE(TraceLog::GetInstance()->IsEnabled()); | |
142 PlatformThread::SetName(old_thread_name_ ? old_thread_name_ : ""); | |
143 free(old_thread_name_); | |
144 old_thread_name_ = NULL; | |
145 // We want our singleton torn down after each test. | |
146 TraceLog::DeleteForTesting(); | |
147 } | |
148 | |
149 char* old_thread_name_; | |
150 ListValue trace_parsed_; | |
151 TraceResultBuffer trace_buffer_; | |
152 TraceResultBuffer::SimpleOutput json_output_; | |
153 int event_watch_notification_; | |
154 | |
155 private: | |
156 // We want our singleton torn down after each test. | |
157 ShadowingAtExitManager at_exit_manager_; | |
158 Lock lock_; | |
159 }; | |
160 | |
161 void TraceEventTestFixture::OnTraceDataCollected( | |
162 WaitableEvent* flush_complete_event, | |
163 const scoped_refptr<base::RefCountedString>& events_str, | |
164 bool has_more_events) { | |
165 AutoLock lock(lock_); | |
166 json_output_.json_output.clear(); | |
167 trace_buffer_.Start(); | |
168 trace_buffer_.AddFragment(events_str->data()); | |
169 trace_buffer_.Finish(); | |
170 | |
171 scoped_ptr<Value> root; | |
172 root.reset(base::JSONReader::Read(json_output_.json_output, | |
173 JSON_PARSE_RFC | JSON_DETACHABLE_CHILDREN)); | |
174 | |
175 if (!root.get()) { | |
176 LOG(ERROR) << json_output_.json_output; | |
177 } | |
178 | |
179 ListValue* root_list = NULL; | |
180 ASSERT_TRUE(root.get()); | |
181 ASSERT_TRUE(root->GetAsList(&root_list)); | |
182 | |
183 // Move items into our aggregate collection | |
184 while (root_list->GetSize()) { | |
185 scoped_ptr<Value> item; | |
186 root_list->Remove(0, &item); | |
187 trace_parsed_.Append(item.release()); | |
188 } | |
189 | |
190 if (!has_more_events) | |
191 flush_complete_event->Signal(); | |
192 } | |
193 | |
194 static bool CompareJsonValues(const std::string& lhs, | |
195 const std::string& rhs, | |
196 CompareOp op) { | |
197 switch (op) { | |
198 case IS_EQUAL: | |
199 return lhs == rhs; | |
200 case IS_NOT_EQUAL: | |
201 return lhs != rhs; | |
202 default: | |
203 CHECK(0); | |
204 } | |
205 return false; | |
206 } | |
207 | |
208 static bool IsKeyValueInDict(const JsonKeyValue* key_value, | |
209 DictionaryValue* dict) { | |
210 Value* value = NULL; | |
211 std::string value_str; | |
212 if (dict->Get(key_value->key, &value) && | |
213 value->GetAsString(&value_str) && | |
214 CompareJsonValues(value_str, key_value->value, key_value->op)) | |
215 return true; | |
216 | |
217 // Recurse to test arguments | |
218 DictionaryValue* args_dict = NULL; | |
219 dict->GetDictionary("args", &args_dict); | |
220 if (args_dict) | |
221 return IsKeyValueInDict(key_value, args_dict); | |
222 | |
223 return false; | |
224 } | |
225 | |
226 static bool IsAllKeyValueInDict(const JsonKeyValue* key_values, | |
227 DictionaryValue* dict) { | |
228 // Scan all key_values, they must all be present and equal. | |
229 while (key_values && key_values->key) { | |
230 if (!IsKeyValueInDict(key_values, dict)) | |
231 return false; | |
232 ++key_values; | |
233 } | |
234 return true; | |
235 } | |
236 | |
237 DictionaryValue* TraceEventTestFixture::FindMatchingTraceEntry( | |
238 const JsonKeyValue* key_values) { | |
239 // Scan all items | |
240 size_t trace_parsed_count = trace_parsed_.GetSize(); | |
241 for (size_t i = 0; i < trace_parsed_count; i++) { | |
242 Value* value = NULL; | |
243 trace_parsed_.Get(i, &value); | |
244 if (!value || value->GetType() != Value::TYPE_DICTIONARY) | |
245 continue; | |
246 DictionaryValue* dict = static_cast<DictionaryValue*>(value); | |
247 | |
248 if (IsAllKeyValueInDict(key_values, dict)) | |
249 return dict; | |
250 } | |
251 return NULL; | |
252 } | |
253 | |
254 void TraceEventTestFixture::DropTracedMetadataRecords() { | |
255 scoped_ptr<ListValue> old_trace_parsed(trace_parsed_.DeepCopy()); | |
256 size_t old_trace_parsed_size = old_trace_parsed->GetSize(); | |
257 trace_parsed_.Clear(); | |
258 | |
259 for (size_t i = 0; i < old_trace_parsed_size; i++) { | |
260 Value* value = NULL; | |
261 old_trace_parsed->Get(i, &value); | |
262 if (!value || value->GetType() != Value::TYPE_DICTIONARY) { | |
263 trace_parsed_.Append(value->DeepCopy()); | |
264 continue; | |
265 } | |
266 DictionaryValue* dict = static_cast<DictionaryValue*>(value); | |
267 std::string tmp; | |
268 if (dict->GetString("ph", &tmp) && tmp == "M") | |
269 continue; | |
270 | |
271 trace_parsed_.Append(value->DeepCopy()); | |
272 } | |
273 } | |
274 | |
275 DictionaryValue* TraceEventTestFixture::FindNamePhase(const char* name, | |
276 const char* phase) { | |
277 JsonKeyValue key_values[] = { | |
278 {"name", name, IS_EQUAL}, | |
279 {"ph", phase, IS_EQUAL}, | |
280 {0, 0, IS_EQUAL} | |
281 }; | |
282 return FindMatchingTraceEntry(key_values); | |
283 } | |
284 | |
285 DictionaryValue* TraceEventTestFixture::FindNamePhaseKeyValue( | |
286 const char* name, | |
287 const char* phase, | |
288 const char* key, | |
289 const char* value) { | |
290 JsonKeyValue key_values[] = { | |
291 {"name", name, IS_EQUAL}, | |
292 {"ph", phase, IS_EQUAL}, | |
293 {key, value, IS_EQUAL}, | |
294 {0, 0, IS_EQUAL} | |
295 }; | |
296 return FindMatchingTraceEntry(key_values); | |
297 } | |
298 | |
299 bool TraceEventTestFixture::FindMatchingValue(const char* key, | |
300 const char* value) { | |
301 JsonKeyValue key_values[] = { | |
302 {key, value, IS_EQUAL}, | |
303 {0, 0, IS_EQUAL} | |
304 }; | |
305 return FindMatchingTraceEntry(key_values); | |
306 } | |
307 | |
308 bool TraceEventTestFixture::FindNonMatchingValue(const char* key, | |
309 const char* value) { | |
310 JsonKeyValue key_values[] = { | |
311 {key, value, IS_NOT_EQUAL}, | |
312 {0, 0, IS_EQUAL} | |
313 }; | |
314 return FindMatchingTraceEntry(key_values); | |
315 } | |
316 | |
317 bool IsStringInDict(const char* string_to_match, const DictionaryValue* dict) { | |
318 for (DictionaryValue::Iterator it(*dict); !it.IsAtEnd(); it.Advance()) { | |
319 if (it.key().find(string_to_match) != std::string::npos) | |
320 return true; | |
321 | |
322 std::string value_str; | |
323 it.value().GetAsString(&value_str); | |
324 if (value_str.find(string_to_match) != std::string::npos) | |
325 return true; | |
326 } | |
327 | |
328 // Recurse to test arguments | |
329 const DictionaryValue* args_dict = NULL; | |
330 dict->GetDictionary("args", &args_dict); | |
331 if (args_dict) | |
332 return IsStringInDict(string_to_match, args_dict); | |
333 | |
334 return false; | |
335 } | |
336 | |
337 const DictionaryValue* FindTraceEntry( | |
338 const ListValue& trace_parsed, | |
339 const char* string_to_match, | |
340 const DictionaryValue* match_after_this_item = NULL) { | |
341 // Scan all items | |
342 size_t trace_parsed_count = trace_parsed.GetSize(); | |
343 for (size_t i = 0; i < trace_parsed_count; i++) { | |
344 const Value* value = NULL; | |
345 trace_parsed.Get(i, &value); | |
346 if (match_after_this_item) { | |
347 if (value == match_after_this_item) | |
348 match_after_this_item = NULL; | |
349 continue; | |
350 } | |
351 if (!value || value->GetType() != Value::TYPE_DICTIONARY) | |
352 continue; | |
353 const DictionaryValue* dict = static_cast<const DictionaryValue*>(value); | |
354 | |
355 if (IsStringInDict(string_to_match, dict)) | |
356 return dict; | |
357 } | |
358 return NULL; | |
359 } | |
360 | |
361 std::vector<const DictionaryValue*> FindTraceEntries( | |
362 const ListValue& trace_parsed, | |
363 const char* string_to_match) { | |
364 std::vector<const DictionaryValue*> hits; | |
365 size_t trace_parsed_count = trace_parsed.GetSize(); | |
366 for (size_t i = 0; i < trace_parsed_count; i++) { | |
367 const Value* value = NULL; | |
368 trace_parsed.Get(i, &value); | |
369 if (!value || value->GetType() != Value::TYPE_DICTIONARY) | |
370 continue; | |
371 const DictionaryValue* dict = static_cast<const DictionaryValue*>(value); | |
372 | |
373 if (IsStringInDict(string_to_match, dict)) | |
374 hits.push_back(dict); | |
375 } | |
376 return hits; | |
377 } | |
378 | |
379 const char kControlCharacters[] = "\001\002\003\n\r"; | |
380 | |
381 void TraceWithAllMacroVariants(WaitableEvent* task_complete_event) { | |
382 { | |
383 TRACE_EVENT_BEGIN_ETW("TRACE_EVENT_BEGIN_ETW call", 0x1122, "extrastring1"); | |
384 TRACE_EVENT_END_ETW("TRACE_EVENT_END_ETW call", 0x3344, "extrastring2"); | |
385 TRACE_EVENT_INSTANT_ETW("TRACE_EVENT_INSTANT_ETW call", | |
386 0x5566, "extrastring3"); | |
387 | |
388 TRACE_EVENT0("all", "TRACE_EVENT0 call"); | |
389 TRACE_EVENT1("all", "TRACE_EVENT1 call", "name1", "value1"); | |
390 TRACE_EVENT2("all", "TRACE_EVENT2 call", | |
391 "name1", "\"value1\"", | |
392 "name2", "value\\2"); | |
393 | |
394 TRACE_EVENT_INSTANT0("all", "TRACE_EVENT_INSTANT0 call", | |
395 TRACE_EVENT_SCOPE_GLOBAL); | |
396 TRACE_EVENT_INSTANT1("all", "TRACE_EVENT_INSTANT1 call", | |
397 TRACE_EVENT_SCOPE_PROCESS, "name1", "value1"); | |
398 TRACE_EVENT_INSTANT2("all", "TRACE_EVENT_INSTANT2 call", | |
399 TRACE_EVENT_SCOPE_THREAD, | |
400 "name1", "value1", | |
401 "name2", "value2"); | |
402 | |
403 TRACE_EVENT_BEGIN0("all", "TRACE_EVENT_BEGIN0 call"); | |
404 TRACE_EVENT_BEGIN1("all", "TRACE_EVENT_BEGIN1 call", "name1", "value1"); | |
405 TRACE_EVENT_BEGIN2("all", "TRACE_EVENT_BEGIN2 call", | |
406 "name1", "value1", | |
407 "name2", "value2"); | |
408 | |
409 TRACE_EVENT_END0("all", "TRACE_EVENT_END0 call"); | |
410 TRACE_EVENT_END1("all", "TRACE_EVENT_END1 call", "name1", "value1"); | |
411 TRACE_EVENT_END2("all", "TRACE_EVENT_END2 call", | |
412 "name1", "value1", | |
413 "name2", "value2"); | |
414 | |
415 TRACE_EVENT_ASYNC_BEGIN0("all", "TRACE_EVENT_ASYNC_BEGIN0 call", kAsyncId); | |
416 TRACE_EVENT_ASYNC_BEGIN1("all", "TRACE_EVENT_ASYNC_BEGIN1 call", kAsyncId, | |
417 "name1", "value1"); | |
418 TRACE_EVENT_ASYNC_BEGIN2("all", "TRACE_EVENT_ASYNC_BEGIN2 call", kAsyncId, | |
419 "name1", "value1", | |
420 "name2", "value2"); | |
421 | |
422 TRACE_EVENT_ASYNC_STEP_INTO0("all", "TRACE_EVENT_ASYNC_STEP_INTO0 call", | |
423 kAsyncId, "step_begin1"); | |
424 TRACE_EVENT_ASYNC_STEP_INTO1("all", "TRACE_EVENT_ASYNC_STEP_INTO1 call", | |
425 kAsyncId, "step_begin2", "name1", "value1"); | |
426 | |
427 TRACE_EVENT_ASYNC_END0("all", "TRACE_EVENT_ASYNC_END0 call", kAsyncId); | |
428 TRACE_EVENT_ASYNC_END1("all", "TRACE_EVENT_ASYNC_END1 call", kAsyncId, | |
429 "name1", "value1"); | |
430 TRACE_EVENT_ASYNC_END2("all", "TRACE_EVENT_ASYNC_END2 call", kAsyncId, | |
431 "name1", "value1", | |
432 "name2", "value2"); | |
433 | |
434 TRACE_EVENT_BEGIN_ETW("TRACE_EVENT_BEGIN_ETW0 call", kAsyncId, NULL); | |
435 TRACE_EVENT_BEGIN_ETW("TRACE_EVENT_BEGIN_ETW1 call", kAsyncId, "value"); | |
436 TRACE_EVENT_END_ETW("TRACE_EVENT_END_ETW0 call", kAsyncId, NULL); | |
437 TRACE_EVENT_END_ETW("TRACE_EVENT_END_ETW1 call", kAsyncId, "value"); | |
438 TRACE_EVENT_INSTANT_ETW("TRACE_EVENT_INSTANT_ETW0 call", kAsyncId, NULL); | |
439 TRACE_EVENT_INSTANT_ETW("TRACE_EVENT_INSTANT_ETW1 call", kAsyncId, "value"); | |
440 | |
441 TRACE_COUNTER1("all", "TRACE_COUNTER1 call", 31415); | |
442 TRACE_COUNTER2("all", "TRACE_COUNTER2 call", | |
443 "a", 30000, | |
444 "b", 1415); | |
445 | |
446 TRACE_COUNTER_ID1("all", "TRACE_COUNTER_ID1 call", 0x319009, 31415); | |
447 TRACE_COUNTER_ID2("all", "TRACE_COUNTER_ID2 call", 0x319009, | |
448 "a", 30000, "b", 1415); | |
449 | |
450 TRACE_EVENT_COPY_BEGIN_WITH_ID_TID_AND_TIMESTAMP0("all", | |
451 "TRACE_EVENT_COPY_BEGIN_WITH_ID_TID_AND_TIMESTAMP0 call", | |
452 kAsyncId, kThreadId, 12345); | |
453 TRACE_EVENT_COPY_END_WITH_ID_TID_AND_TIMESTAMP0("all", | |
454 "TRACE_EVENT_COPY_END_WITH_ID_TID_AND_TIMESTAMP0 call", | |
455 kAsyncId, kThreadId, 23456); | |
456 | |
457 TRACE_EVENT_BEGIN_WITH_ID_TID_AND_TIMESTAMP0("all", | |
458 "TRACE_EVENT_BEGIN_WITH_ID_TID_AND_TIMESTAMP0 call", | |
459 kAsyncId2, kThreadId, 34567); | |
460 TRACE_EVENT_ASYNC_STEP_PAST0("all", "TRACE_EVENT_ASYNC_STEP_PAST0 call", | |
461 kAsyncId2, "step_end1"); | |
462 TRACE_EVENT_ASYNC_STEP_PAST1("all", "TRACE_EVENT_ASYNC_STEP_PAST1 call", | |
463 kAsyncId2, "step_end2", "name1", "value1"); | |
464 | |
465 TRACE_EVENT_END_WITH_ID_TID_AND_TIMESTAMP0("all", | |
466 "TRACE_EVENT_END_WITH_ID_TID_AND_TIMESTAMP0 call", | |
467 kAsyncId2, kThreadId, 45678); | |
468 | |
469 TRACE_EVENT_OBJECT_CREATED_WITH_ID("all", "tracked object 1", 0x42); | |
470 TRACE_EVENT_OBJECT_SNAPSHOT_WITH_ID( | |
471 "all", "tracked object 1", 0x42, "hello"); | |
472 TRACE_EVENT_OBJECT_DELETED_WITH_ID("all", "tracked object 1", 0x42); | |
473 | |
474 TraceScopedTrackableObject<int> trackable("all", "tracked object 2", | |
475 0x2128506); | |
476 trackable.snapshot("world"); | |
477 | |
478 TRACE_EVENT1(kControlCharacters, kControlCharacters, | |
479 kControlCharacters, kControlCharacters); | |
480 } // Scope close causes TRACE_EVENT0 etc to send their END events. | |
481 | |
482 if (task_complete_event) | |
483 task_complete_event->Signal(); | |
484 } | |
485 | |
486 void ValidateAllTraceMacrosCreatedData(const ListValue& trace_parsed) { | |
487 const DictionaryValue* item = NULL; | |
488 | |
489 #define EXPECT_FIND_(string) \ | |
490 item = FindTraceEntry(trace_parsed, string); \ | |
491 EXPECT_TRUE(item); | |
492 #define EXPECT_NOT_FIND_(string) \ | |
493 item = FindTraceEntry(trace_parsed, string); \ | |
494 EXPECT_FALSE(item); | |
495 #define EXPECT_SUB_FIND_(string) \ | |
496 if (item) \ | |
497 EXPECT_TRUE(IsStringInDict(string, item)); | |
498 | |
499 EXPECT_FIND_("ETW Trace Event"); | |
500 EXPECT_FIND_("all"); | |
501 EXPECT_FIND_("TRACE_EVENT_BEGIN_ETW call"); | |
502 { | |
503 std::string str_val; | |
504 EXPECT_TRUE(item && item->GetString("args.id", &str_val)); | |
505 EXPECT_STREQ("0x1122", str_val.c_str()); | |
506 } | |
507 EXPECT_SUB_FIND_("extrastring1"); | |
508 EXPECT_FIND_("TRACE_EVENT_END_ETW call"); | |
509 EXPECT_FIND_("TRACE_EVENT_INSTANT_ETW call"); | |
510 EXPECT_FIND_("TRACE_EVENT0 call"); | |
511 { | |
512 std::string ph; | |
513 std::string ph_end; | |
514 EXPECT_TRUE((item = FindTraceEntry(trace_parsed, "TRACE_EVENT0 call"))); | |
515 EXPECT_TRUE((item && item->GetString("ph", &ph))); | |
516 EXPECT_EQ("X", ph); | |
517 item = FindTraceEntry(trace_parsed, "TRACE_EVENT0 call", item); | |
518 EXPECT_FALSE(item); | |
519 } | |
520 EXPECT_FIND_("TRACE_EVENT1 call"); | |
521 EXPECT_SUB_FIND_("name1"); | |
522 EXPECT_SUB_FIND_("value1"); | |
523 EXPECT_FIND_("TRACE_EVENT2 call"); | |
524 EXPECT_SUB_FIND_("name1"); | |
525 EXPECT_SUB_FIND_("\"value1\""); | |
526 EXPECT_SUB_FIND_("name2"); | |
527 EXPECT_SUB_FIND_("value\\2"); | |
528 | |
529 EXPECT_FIND_("TRACE_EVENT_INSTANT0 call"); | |
530 { | |
531 std::string scope; | |
532 EXPECT_TRUE((item && item->GetString("s", &scope))); | |
533 EXPECT_EQ("g", scope); | |
534 } | |
535 EXPECT_FIND_("TRACE_EVENT_INSTANT1 call"); | |
536 { | |
537 std::string scope; | |
538 EXPECT_TRUE((item && item->GetString("s", &scope))); | |
539 EXPECT_EQ("p", scope); | |
540 } | |
541 EXPECT_SUB_FIND_("name1"); | |
542 EXPECT_SUB_FIND_("value1"); | |
543 EXPECT_FIND_("TRACE_EVENT_INSTANT2 call"); | |
544 { | |
545 std::string scope; | |
546 EXPECT_TRUE((item && item->GetString("s", &scope))); | |
547 EXPECT_EQ("t", scope); | |
548 } | |
549 EXPECT_SUB_FIND_("name1"); | |
550 EXPECT_SUB_FIND_("value1"); | |
551 EXPECT_SUB_FIND_("name2"); | |
552 EXPECT_SUB_FIND_("value2"); | |
553 | |
554 EXPECT_FIND_("TRACE_EVENT_BEGIN0 call"); | |
555 EXPECT_FIND_("TRACE_EVENT_BEGIN1 call"); | |
556 EXPECT_SUB_FIND_("name1"); | |
557 EXPECT_SUB_FIND_("value1"); | |
558 EXPECT_FIND_("TRACE_EVENT_BEGIN2 call"); | |
559 EXPECT_SUB_FIND_("name1"); | |
560 EXPECT_SUB_FIND_("value1"); | |
561 EXPECT_SUB_FIND_("name2"); | |
562 EXPECT_SUB_FIND_("value2"); | |
563 | |
564 EXPECT_FIND_("TRACE_EVENT_END0 call"); | |
565 EXPECT_FIND_("TRACE_EVENT_END1 call"); | |
566 EXPECT_SUB_FIND_("name1"); | |
567 EXPECT_SUB_FIND_("value1"); | |
568 EXPECT_FIND_("TRACE_EVENT_END2 call"); | |
569 EXPECT_SUB_FIND_("name1"); | |
570 EXPECT_SUB_FIND_("value1"); | |
571 EXPECT_SUB_FIND_("name2"); | |
572 EXPECT_SUB_FIND_("value2"); | |
573 | |
574 EXPECT_FIND_("TRACE_EVENT_ASYNC_BEGIN0 call"); | |
575 EXPECT_SUB_FIND_("id"); | |
576 EXPECT_SUB_FIND_(kAsyncIdStr); | |
577 EXPECT_FIND_("TRACE_EVENT_ASYNC_BEGIN1 call"); | |
578 EXPECT_SUB_FIND_("id"); | |
579 EXPECT_SUB_FIND_(kAsyncIdStr); | |
580 EXPECT_SUB_FIND_("name1"); | |
581 EXPECT_SUB_FIND_("value1"); | |
582 EXPECT_FIND_("TRACE_EVENT_ASYNC_BEGIN2 call"); | |
583 EXPECT_SUB_FIND_("id"); | |
584 EXPECT_SUB_FIND_(kAsyncIdStr); | |
585 EXPECT_SUB_FIND_("name1"); | |
586 EXPECT_SUB_FIND_("value1"); | |
587 EXPECT_SUB_FIND_("name2"); | |
588 EXPECT_SUB_FIND_("value2"); | |
589 | |
590 EXPECT_FIND_("TRACE_EVENT_ASYNC_STEP_INTO0 call"); | |
591 EXPECT_SUB_FIND_("id"); | |
592 EXPECT_SUB_FIND_(kAsyncIdStr); | |
593 EXPECT_SUB_FIND_("step_begin1"); | |
594 EXPECT_FIND_("TRACE_EVENT_ASYNC_STEP_INTO1 call"); | |
595 EXPECT_SUB_FIND_("id"); | |
596 EXPECT_SUB_FIND_(kAsyncIdStr); | |
597 EXPECT_SUB_FIND_("step_begin2"); | |
598 EXPECT_SUB_FIND_("name1"); | |
599 EXPECT_SUB_FIND_("value1"); | |
600 | |
601 EXPECT_FIND_("TRACE_EVENT_ASYNC_END0 call"); | |
602 EXPECT_SUB_FIND_("id"); | |
603 EXPECT_SUB_FIND_(kAsyncIdStr); | |
604 EXPECT_FIND_("TRACE_EVENT_ASYNC_END1 call"); | |
605 EXPECT_SUB_FIND_("id"); | |
606 EXPECT_SUB_FIND_(kAsyncIdStr); | |
607 EXPECT_SUB_FIND_("name1"); | |
608 EXPECT_SUB_FIND_("value1"); | |
609 EXPECT_FIND_("TRACE_EVENT_ASYNC_END2 call"); | |
610 EXPECT_SUB_FIND_("id"); | |
611 EXPECT_SUB_FIND_(kAsyncIdStr); | |
612 EXPECT_SUB_FIND_("name1"); | |
613 EXPECT_SUB_FIND_("value1"); | |
614 EXPECT_SUB_FIND_("name2"); | |
615 EXPECT_SUB_FIND_("value2"); | |
616 | |
617 EXPECT_FIND_("TRACE_EVENT_BEGIN_ETW0 call"); | |
618 EXPECT_SUB_FIND_("id"); | |
619 EXPECT_SUB_FIND_(kAsyncIdStr); | |
620 EXPECT_SUB_FIND_("extra"); | |
621 EXPECT_SUB_FIND_("NULL"); | |
622 EXPECT_FIND_("TRACE_EVENT_BEGIN_ETW1 call"); | |
623 EXPECT_SUB_FIND_("id"); | |
624 EXPECT_SUB_FIND_(kAsyncIdStr); | |
625 EXPECT_SUB_FIND_("extra"); | |
626 EXPECT_SUB_FIND_("value"); | |
627 EXPECT_FIND_("TRACE_EVENT_END_ETW0 call"); | |
628 EXPECT_SUB_FIND_("id"); | |
629 EXPECT_SUB_FIND_(kAsyncIdStr); | |
630 EXPECT_SUB_FIND_("extra"); | |
631 EXPECT_SUB_FIND_("NULL"); | |
632 EXPECT_FIND_("TRACE_EVENT_END_ETW1 call"); | |
633 EXPECT_SUB_FIND_("id"); | |
634 EXPECT_SUB_FIND_(kAsyncIdStr); | |
635 EXPECT_SUB_FIND_("extra"); | |
636 EXPECT_SUB_FIND_("value"); | |
637 EXPECT_FIND_("TRACE_EVENT_INSTANT_ETW0 call"); | |
638 EXPECT_SUB_FIND_("id"); | |
639 EXPECT_SUB_FIND_(kAsyncIdStr); | |
640 EXPECT_SUB_FIND_("extra"); | |
641 EXPECT_SUB_FIND_("NULL"); | |
642 EXPECT_FIND_("TRACE_EVENT_INSTANT_ETW1 call"); | |
643 EXPECT_SUB_FIND_("id"); | |
644 EXPECT_SUB_FIND_(kAsyncIdStr); | |
645 EXPECT_SUB_FIND_("extra"); | |
646 EXPECT_SUB_FIND_("value"); | |
647 | |
648 EXPECT_FIND_("TRACE_COUNTER1 call"); | |
649 { | |
650 std::string ph; | |
651 EXPECT_TRUE((item && item->GetString("ph", &ph))); | |
652 EXPECT_EQ("C", ph); | |
653 | |
654 int value; | |
655 EXPECT_TRUE((item && item->GetInteger("args.value", &value))); | |
656 EXPECT_EQ(31415, value); | |
657 } | |
658 | |
659 EXPECT_FIND_("TRACE_COUNTER2 call"); | |
660 { | |
661 std::string ph; | |
662 EXPECT_TRUE((item && item->GetString("ph", &ph))); | |
663 EXPECT_EQ("C", ph); | |
664 | |
665 int value; | |
666 EXPECT_TRUE((item && item->GetInteger("args.a", &value))); | |
667 EXPECT_EQ(30000, value); | |
668 | |
669 EXPECT_TRUE((item && item->GetInteger("args.b", &value))); | |
670 EXPECT_EQ(1415, value); | |
671 } | |
672 | |
673 EXPECT_FIND_("TRACE_COUNTER_ID1 call"); | |
674 { | |
675 std::string id; | |
676 EXPECT_TRUE((item && item->GetString("id", &id))); | |
677 EXPECT_EQ("0x319009", id); | |
678 | |
679 std::string ph; | |
680 EXPECT_TRUE((item && item->GetString("ph", &ph))); | |
681 EXPECT_EQ("C", ph); | |
682 | |
683 int value; | |
684 EXPECT_TRUE((item && item->GetInteger("args.value", &value))); | |
685 EXPECT_EQ(31415, value); | |
686 } | |
687 | |
688 EXPECT_FIND_("TRACE_COUNTER_ID2 call"); | |
689 { | |
690 std::string id; | |
691 EXPECT_TRUE((item && item->GetString("id", &id))); | |
692 EXPECT_EQ("0x319009", id); | |
693 | |
694 std::string ph; | |
695 EXPECT_TRUE((item && item->GetString("ph", &ph))); | |
696 EXPECT_EQ("C", ph); | |
697 | |
698 int value; | |
699 EXPECT_TRUE((item && item->GetInteger("args.a", &value))); | |
700 EXPECT_EQ(30000, value); | |
701 | |
702 EXPECT_TRUE((item && item->GetInteger("args.b", &value))); | |
703 EXPECT_EQ(1415, value); | |
704 } | |
705 | |
706 EXPECT_FIND_("TRACE_EVENT_COPY_BEGIN_WITH_ID_TID_AND_TIMESTAMP0 call"); | |
707 { | |
708 int val; | |
709 EXPECT_TRUE((item && item->GetInteger("ts", &val))); | |
710 EXPECT_EQ(12345, val); | |
711 EXPECT_TRUE((item && item->GetInteger("tid", &val))); | |
712 EXPECT_EQ(kThreadId, val); | |
713 std::string id; | |
714 EXPECT_TRUE((item && item->GetString("id", &id))); | |
715 EXPECT_EQ(kAsyncIdStr, id); | |
716 } | |
717 | |
718 EXPECT_FIND_("TRACE_EVENT_COPY_END_WITH_ID_TID_AND_TIMESTAMP0 call"); | |
719 { | |
720 int val; | |
721 EXPECT_TRUE((item && item->GetInteger("ts", &val))); | |
722 EXPECT_EQ(23456, val); | |
723 EXPECT_TRUE((item && item->GetInteger("tid", &val))); | |
724 EXPECT_EQ(kThreadId, val); | |
725 std::string id; | |
726 EXPECT_TRUE((item && item->GetString("id", &id))); | |
727 EXPECT_EQ(kAsyncIdStr, id); | |
728 } | |
729 | |
730 EXPECT_FIND_("TRACE_EVENT_BEGIN_WITH_ID_TID_AND_TIMESTAMP0 call"); | |
731 { | |
732 int val; | |
733 EXPECT_TRUE((item && item->GetInteger("ts", &val))); | |
734 EXPECT_EQ(34567, val); | |
735 EXPECT_TRUE((item && item->GetInteger("tid", &val))); | |
736 EXPECT_EQ(kThreadId, val); | |
737 std::string id; | |
738 EXPECT_TRUE((item && item->GetString("id", &id))); | |
739 EXPECT_EQ(kAsyncId2Str, id); | |
740 } | |
741 | |
742 EXPECT_FIND_("TRACE_EVENT_ASYNC_STEP_PAST0 call"); | |
743 { | |
744 EXPECT_SUB_FIND_("id"); | |
745 EXPECT_SUB_FIND_(kAsyncId2Str); | |
746 EXPECT_SUB_FIND_("step_end1"); | |
747 EXPECT_FIND_("TRACE_EVENT_ASYNC_STEP_PAST1 call"); | |
748 EXPECT_SUB_FIND_("id"); | |
749 EXPECT_SUB_FIND_(kAsyncId2Str); | |
750 EXPECT_SUB_FIND_("step_end2"); | |
751 EXPECT_SUB_FIND_("name1"); | |
752 EXPECT_SUB_FIND_("value1"); | |
753 } | |
754 | |
755 EXPECT_FIND_("TRACE_EVENT_END_WITH_ID_TID_AND_TIMESTAMP0 call"); | |
756 { | |
757 int val; | |
758 EXPECT_TRUE((item && item->GetInteger("ts", &val))); | |
759 EXPECT_EQ(45678, val); | |
760 EXPECT_TRUE((item && item->GetInteger("tid", &val))); | |
761 EXPECT_EQ(kThreadId, val); | |
762 std::string id; | |
763 EXPECT_TRUE((item && item->GetString("id", &id))); | |
764 EXPECT_EQ(kAsyncId2Str, id); | |
765 } | |
766 | |
767 EXPECT_FIND_("tracked object 1"); | |
768 { | |
769 std::string phase; | |
770 std::string id; | |
771 std::string snapshot; | |
772 | |
773 EXPECT_TRUE((item && item->GetString("ph", &phase))); | |
774 EXPECT_EQ("N", phase); | |
775 EXPECT_TRUE((item && item->GetString("id", &id))); | |
776 EXPECT_EQ("0x42", id); | |
777 | |
778 item = FindTraceEntry(trace_parsed, "tracked object 1", item); | |
779 EXPECT_TRUE(item); | |
780 EXPECT_TRUE(item && item->GetString("ph", &phase)); | |
781 EXPECT_EQ("O", phase); | |
782 EXPECT_TRUE(item && item->GetString("id", &id)); | |
783 EXPECT_EQ("0x42", id); | |
784 EXPECT_TRUE(item && item->GetString("args.snapshot", &snapshot)); | |
785 EXPECT_EQ("hello", snapshot); | |
786 | |
787 item = FindTraceEntry(trace_parsed, "tracked object 1", item); | |
788 EXPECT_TRUE(item); | |
789 EXPECT_TRUE(item && item->GetString("ph", &phase)); | |
790 EXPECT_EQ("D", phase); | |
791 EXPECT_TRUE(item && item->GetString("id", &id)); | |
792 EXPECT_EQ("0x42", id); | |
793 } | |
794 | |
795 EXPECT_FIND_("tracked object 2"); | |
796 { | |
797 std::string phase; | |
798 std::string id; | |
799 std::string snapshot; | |
800 | |
801 EXPECT_TRUE(item && item->GetString("ph", &phase)); | |
802 EXPECT_EQ("N", phase); | |
803 EXPECT_TRUE(item && item->GetString("id", &id)); | |
804 EXPECT_EQ("0x2128506", id); | |
805 | |
806 item = FindTraceEntry(trace_parsed, "tracked object 2", item); | |
807 EXPECT_TRUE(item); | |
808 EXPECT_TRUE(item && item->GetString("ph", &phase)); | |
809 EXPECT_EQ("O", phase); | |
810 EXPECT_TRUE(item && item->GetString("id", &id)); | |
811 EXPECT_EQ("0x2128506", id); | |
812 EXPECT_TRUE(item && item->GetString("args.snapshot", &snapshot)); | |
813 EXPECT_EQ("world", snapshot); | |
814 | |
815 item = FindTraceEntry(trace_parsed, "tracked object 2", item); | |
816 EXPECT_TRUE(item); | |
817 EXPECT_TRUE(item && item->GetString("ph", &phase)); | |
818 EXPECT_EQ("D", phase); | |
819 EXPECT_TRUE(item && item->GetString("id", &id)); | |
820 EXPECT_EQ("0x2128506", id); | |
821 } | |
822 | |
823 EXPECT_FIND_(kControlCharacters); | |
824 EXPECT_SUB_FIND_(kControlCharacters); | |
825 } | |
826 | |
827 void TraceManyInstantEvents(int thread_id, int num_events, | |
828 WaitableEvent* task_complete_event) { | |
829 for (int i = 0; i < num_events; i++) { | |
830 TRACE_EVENT_INSTANT2("all", "multi thread event", | |
831 TRACE_EVENT_SCOPE_THREAD, | |
832 "thread", thread_id, | |
833 "event", i); | |
834 } | |
835 | |
836 if (task_complete_event) | |
837 task_complete_event->Signal(); | |
838 } | |
839 | |
840 void ValidateInstantEventPresentOnEveryThread(const ListValue& trace_parsed, | |
841 int num_threads, | |
842 int num_events) { | |
843 std::map<int, std::map<int, bool> > results; | |
844 | |
845 size_t trace_parsed_count = trace_parsed.GetSize(); | |
846 for (size_t i = 0; i < trace_parsed_count; i++) { | |
847 const Value* value = NULL; | |
848 trace_parsed.Get(i, &value); | |
849 if (!value || value->GetType() != Value::TYPE_DICTIONARY) | |
850 continue; | |
851 const DictionaryValue* dict = static_cast<const DictionaryValue*>(value); | |
852 std::string name; | |
853 dict->GetString("name", &name); | |
854 if (name != "multi thread event") | |
855 continue; | |
856 | |
857 int thread = 0; | |
858 int event = 0; | |
859 EXPECT_TRUE(dict->GetInteger("args.thread", &thread)); | |
860 EXPECT_TRUE(dict->GetInteger("args.event", &event)); | |
861 results[thread][event] = true; | |
862 } | |
863 | |
864 EXPECT_FALSE(results[-1][-1]); | |
865 for (int thread = 0; thread < num_threads; thread++) { | |
866 for (int event = 0; event < num_events; event++) { | |
867 EXPECT_TRUE(results[thread][event]); | |
868 } | |
869 } | |
870 } | |
871 | |
872 } // namespace | |
873 | |
874 void HighResSleepForTraceTest(base::TimeDelta elapsed) { | |
875 base::TimeTicks end_time = base::TimeTicks::HighResNow() + elapsed; | |
876 do { | |
877 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(1)); | |
878 } while (base::TimeTicks::HighResNow() < end_time); | |
879 } | |
880 | |
881 // Simple Test for emitting data and validating it was received. | |
882 TEST_F(TraceEventTestFixture, DataCaptured) { | |
883 TraceLog::GetInstance()->SetEnabled( | |
884 CategoryFilter("*"), | |
885 TraceLog::RECORDING_MODE, | |
886 TraceOptions()); | |
887 | |
888 TraceWithAllMacroVariants(NULL); | |
889 | |
890 EndTraceAndFlush(); | |
891 | |
892 ValidateAllTraceMacrosCreatedData(trace_parsed_); | |
893 } | |
894 | |
895 class MockEnabledStateChangedObserver : | |
896 public TraceLog::EnabledStateObserver { | |
897 public: | |
898 MOCK_METHOD0(OnTraceLogEnabled, void()); | |
899 MOCK_METHOD0(OnTraceLogDisabled, void()); | |
900 }; | |
901 | |
902 TEST_F(TraceEventTestFixture, EnabledObserverFiresOnEnable) { | |
903 MockEnabledStateChangedObserver observer; | |
904 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
905 | |
906 EXPECT_CALL(observer, OnTraceLogEnabled()) | |
907 .Times(1); | |
908 TraceLog::GetInstance()->SetEnabled( | |
909 CategoryFilter("*"), | |
910 TraceLog::RECORDING_MODE, | |
911 TraceOptions()); | |
912 testing::Mock::VerifyAndClear(&observer); | |
913 EXPECT_TRUE(TraceLog::GetInstance()->IsEnabled()); | |
914 | |
915 // Cleanup. | |
916 TraceLog::GetInstance()->RemoveEnabledStateObserver(&observer); | |
917 TraceLog::GetInstance()->SetDisabled(); | |
918 } | |
919 | |
920 TEST_F(TraceEventTestFixture, EnabledObserverDoesntFireOnSecondEnable) { | |
921 TraceLog::GetInstance()->SetEnabled( | |
922 CategoryFilter("*"), | |
923 TraceLog::RECORDING_MODE, | |
924 TraceOptions()); | |
925 | |
926 testing::StrictMock<MockEnabledStateChangedObserver> observer; | |
927 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
928 | |
929 EXPECT_CALL(observer, OnTraceLogEnabled()) | |
930 .Times(0); | |
931 EXPECT_CALL(observer, OnTraceLogDisabled()) | |
932 .Times(0); | |
933 TraceLog::GetInstance()->SetEnabled( | |
934 CategoryFilter("*"), | |
935 TraceLog::RECORDING_MODE, | |
936 TraceOptions()); | |
937 testing::Mock::VerifyAndClear(&observer); | |
938 EXPECT_TRUE(TraceLog::GetInstance()->IsEnabled()); | |
939 | |
940 // Cleanup. | |
941 TraceLog::GetInstance()->RemoveEnabledStateObserver(&observer); | |
942 TraceLog::GetInstance()->SetDisabled(); | |
943 TraceLog::GetInstance()->SetDisabled(); | |
944 } | |
945 | |
946 TEST_F(TraceEventTestFixture, EnabledObserverFiresOnFirstDisable) { | |
947 CategoryFilter cf_inc_all("*"); | |
948 TraceLog::GetInstance()->SetEnabled( | |
949 cf_inc_all, | |
950 TraceLog::RECORDING_MODE, | |
951 TraceOptions()); | |
952 TraceLog::GetInstance()->SetEnabled( | |
953 cf_inc_all, | |
954 TraceLog::RECORDING_MODE, | |
955 TraceOptions()); | |
956 | |
957 testing::StrictMock<MockEnabledStateChangedObserver> observer; | |
958 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
959 | |
960 EXPECT_CALL(observer, OnTraceLogEnabled()) | |
961 .Times(0); | |
962 EXPECT_CALL(observer, OnTraceLogDisabled()) | |
963 .Times(1); | |
964 TraceLog::GetInstance()->SetDisabled(); | |
965 testing::Mock::VerifyAndClear(&observer); | |
966 | |
967 // Cleanup. | |
968 TraceLog::GetInstance()->RemoveEnabledStateObserver(&observer); | |
969 TraceLog::GetInstance()->SetDisabled(); | |
970 } | |
971 | |
972 TEST_F(TraceEventTestFixture, EnabledObserverFiresOnDisable) { | |
973 TraceLog::GetInstance()->SetEnabled( | |
974 CategoryFilter("*"), | |
975 TraceLog::RECORDING_MODE, | |
976 TraceOptions()); | |
977 | |
978 MockEnabledStateChangedObserver observer; | |
979 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
980 | |
981 EXPECT_CALL(observer, OnTraceLogDisabled()) | |
982 .Times(1); | |
983 TraceLog::GetInstance()->SetDisabled(); | |
984 testing::Mock::VerifyAndClear(&observer); | |
985 | |
986 // Cleanup. | |
987 TraceLog::GetInstance()->RemoveEnabledStateObserver(&observer); | |
988 } | |
989 | |
990 // Tests the IsEnabled() state of TraceLog changes before callbacks. | |
991 class AfterStateChangeEnabledStateObserver | |
992 : public TraceLog::EnabledStateObserver { | |
993 public: | |
994 AfterStateChangeEnabledStateObserver() {} | |
995 virtual ~AfterStateChangeEnabledStateObserver() {} | |
996 | |
997 // TraceLog::EnabledStateObserver overrides: | |
998 void OnTraceLogEnabled() override { | |
999 EXPECT_TRUE(TraceLog::GetInstance()->IsEnabled()); | |
1000 } | |
1001 | |
1002 void OnTraceLogDisabled() override { | |
1003 EXPECT_FALSE(TraceLog::GetInstance()->IsEnabled()); | |
1004 } | |
1005 }; | |
1006 | |
1007 TEST_F(TraceEventTestFixture, ObserversFireAfterStateChange) { | |
1008 AfterStateChangeEnabledStateObserver observer; | |
1009 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
1010 | |
1011 TraceLog::GetInstance()->SetEnabled( | |
1012 CategoryFilter("*"), | |
1013 TraceLog::RECORDING_MODE, | |
1014 TraceOptions()); | |
1015 EXPECT_TRUE(TraceLog::GetInstance()->IsEnabled()); | |
1016 | |
1017 TraceLog::GetInstance()->SetDisabled(); | |
1018 EXPECT_FALSE(TraceLog::GetInstance()->IsEnabled()); | |
1019 | |
1020 TraceLog::GetInstance()->RemoveEnabledStateObserver(&observer); | |
1021 } | |
1022 | |
1023 // Tests that a state observer can remove itself during a callback. | |
1024 class SelfRemovingEnabledStateObserver | |
1025 : public TraceLog::EnabledStateObserver { | |
1026 public: | |
1027 SelfRemovingEnabledStateObserver() {} | |
1028 virtual ~SelfRemovingEnabledStateObserver() {} | |
1029 | |
1030 // TraceLog::EnabledStateObserver overrides: | |
1031 void OnTraceLogEnabled() override {} | |
1032 | |
1033 void OnTraceLogDisabled() override { | |
1034 TraceLog::GetInstance()->RemoveEnabledStateObserver(this); | |
1035 } | |
1036 }; | |
1037 | |
1038 TEST_F(TraceEventTestFixture, SelfRemovingObserver) { | |
1039 ASSERT_EQ(0u, TraceLog::GetInstance()->GetObserverCountForTest()); | |
1040 | |
1041 SelfRemovingEnabledStateObserver observer; | |
1042 TraceLog::GetInstance()->AddEnabledStateObserver(&observer); | |
1043 EXPECT_EQ(1u, TraceLog::GetInstance()->GetObserverCountForTest()); | |
1044 | |
1045 TraceLog::GetInstance()->SetEnabled( | |
1046 CategoryFilter("*"), | |
1047 TraceLog::RECORDING_MODE, | |
1048 TraceOptions()); | |
1049 TraceLog::GetInstance()->SetDisabled(); | |
1050 // The observer removed itself on disable. | |
1051 EXPECT_EQ(0u, TraceLog::GetInstance()->GetObserverCountForTest()); | |
1052 } | |
1053 | |
1054 bool IsNewTrace() { | |
1055 bool is_new_trace; | |
1056 TRACE_EVENT_IS_NEW_TRACE(&is_new_trace); | |
1057 return is_new_trace; | |
1058 } | |
1059 | |
1060 TEST_F(TraceEventTestFixture, NewTraceRecording) { | |
1061 ASSERT_FALSE(IsNewTrace()); | |
1062 TraceLog::GetInstance()->SetEnabled( | |
1063 CategoryFilter("*"), | |
1064 TraceLog::RECORDING_MODE, | |
1065 TraceOptions()); | |
1066 // First call to IsNewTrace() should succeed. But, the second shouldn't. | |
1067 ASSERT_TRUE(IsNewTrace()); | |
1068 ASSERT_FALSE(IsNewTrace()); | |
1069 EndTraceAndFlush(); | |
1070 | |
1071 // IsNewTrace() should definitely be false now. | |
1072 ASSERT_FALSE(IsNewTrace()); | |
1073 | |
1074 // Start another trace. IsNewTrace() should become true again, briefly, as | |
1075 // before. | |
1076 TraceLog::GetInstance()->SetEnabled( | |
1077 CategoryFilter("*"), | |
1078 TraceLog::RECORDING_MODE, | |
1079 TraceOptions()); | |
1080 ASSERT_TRUE(IsNewTrace()); | |
1081 ASSERT_FALSE(IsNewTrace()); | |
1082 | |
1083 // Cleanup. | |
1084 EndTraceAndFlush(); | |
1085 } | |
1086 | |
1087 | |
1088 // Test that categories work. | |
1089 TEST_F(TraceEventTestFixture, Categories) { | |
1090 // Test that categories that are used can be retrieved whether trace was | |
1091 // enabled or disabled when the trace event was encountered. | |
1092 TRACE_EVENT_INSTANT0("c1", "name", TRACE_EVENT_SCOPE_THREAD); | |
1093 TRACE_EVENT_INSTANT0("c2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1094 BeginTrace(); | |
1095 TRACE_EVENT_INSTANT0("c3", "name", TRACE_EVENT_SCOPE_THREAD); | |
1096 TRACE_EVENT_INSTANT0("c4", "name", TRACE_EVENT_SCOPE_THREAD); | |
1097 // Category groups containing more than one category. | |
1098 TRACE_EVENT_INSTANT0("c5,c6", "name", TRACE_EVENT_SCOPE_THREAD); | |
1099 TRACE_EVENT_INSTANT0("c7,c8", "name", TRACE_EVENT_SCOPE_THREAD); | |
1100 TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("c9"), "name", | |
1101 TRACE_EVENT_SCOPE_THREAD); | |
1102 | |
1103 EndTraceAndFlush(); | |
1104 std::vector<std::string> cat_groups; | |
1105 TraceLog::GetInstance()->GetKnownCategoryGroups(&cat_groups); | |
1106 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1107 cat_groups.end(), "c1") != cat_groups.end()); | |
1108 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1109 cat_groups.end(), "c2") != cat_groups.end()); | |
1110 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1111 cat_groups.end(), "c3") != cat_groups.end()); | |
1112 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1113 cat_groups.end(), "c4") != cat_groups.end()); | |
1114 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1115 cat_groups.end(), "c5,c6") != cat_groups.end()); | |
1116 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1117 cat_groups.end(), "c7,c8") != cat_groups.end()); | |
1118 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1119 cat_groups.end(), | |
1120 "disabled-by-default-c9") != cat_groups.end()); | |
1121 // Make sure metadata isn't returned. | |
1122 EXPECT_TRUE(std::find(cat_groups.begin(), | |
1123 cat_groups.end(), "__metadata") == cat_groups.end()); | |
1124 | |
1125 const std::vector<std::string> empty_categories; | |
1126 std::vector<std::string> included_categories; | |
1127 std::vector<std::string> excluded_categories; | |
1128 | |
1129 // Test that category filtering works. | |
1130 | |
1131 // Include nonexistent category -> no events | |
1132 Clear(); | |
1133 included_categories.clear(); | |
1134 TraceLog::GetInstance()->SetEnabled( | |
1135 CategoryFilter("not_found823564786"), | |
1136 TraceLog::RECORDING_MODE, | |
1137 TraceOptions()); | |
1138 TRACE_EVENT_INSTANT0("cat1", "name", TRACE_EVENT_SCOPE_THREAD); | |
1139 TRACE_EVENT_INSTANT0("cat2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1140 EndTraceAndFlush(); | |
1141 DropTracedMetadataRecords(); | |
1142 EXPECT_TRUE(trace_parsed_.empty()); | |
1143 | |
1144 // Include existent category -> only events of that category | |
1145 Clear(); | |
1146 included_categories.clear(); | |
1147 TraceLog::GetInstance()->SetEnabled( | |
1148 CategoryFilter("inc"), | |
1149 TraceLog::RECORDING_MODE, | |
1150 TraceOptions()); | |
1151 TRACE_EVENT_INSTANT0("inc", "name", TRACE_EVENT_SCOPE_THREAD); | |
1152 TRACE_EVENT_INSTANT0("inc2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1153 EndTraceAndFlush(); | |
1154 DropTracedMetadataRecords(); | |
1155 EXPECT_TRUE(FindMatchingValue("cat", "inc")); | |
1156 EXPECT_FALSE(FindNonMatchingValue("cat", "inc")); | |
1157 | |
1158 // Include existent wildcard -> all categories matching wildcard | |
1159 Clear(); | |
1160 included_categories.clear(); | |
1161 TraceLog::GetInstance()->SetEnabled( | |
1162 CategoryFilter("inc_wildcard_*,inc_wildchar_?_end"), | |
1163 TraceLog::RECORDING_MODE, | |
1164 TraceOptions()); | |
1165 TRACE_EVENT_INSTANT0("inc_wildcard_abc", "included", | |
1166 TRACE_EVENT_SCOPE_THREAD); | |
1167 TRACE_EVENT_INSTANT0("inc_wildcard_", "included", TRACE_EVENT_SCOPE_THREAD); | |
1168 TRACE_EVENT_INSTANT0("inc_wildchar_x_end", "included", | |
1169 TRACE_EVENT_SCOPE_THREAD); | |
1170 TRACE_EVENT_INSTANT0("inc_wildchar_bla_end", "not_inc", | |
1171 TRACE_EVENT_SCOPE_THREAD); | |
1172 TRACE_EVENT_INSTANT0("cat1", "not_inc", TRACE_EVENT_SCOPE_THREAD); | |
1173 TRACE_EVENT_INSTANT0("cat2", "not_inc", TRACE_EVENT_SCOPE_THREAD); | |
1174 TRACE_EVENT_INSTANT0("inc_wildcard_category,other_category", "included", | |
1175 TRACE_EVENT_SCOPE_THREAD); | |
1176 TRACE_EVENT_INSTANT0( | |
1177 "non_included_category,inc_wildcard_category", "included", | |
1178 TRACE_EVENT_SCOPE_THREAD); | |
1179 EndTraceAndFlush(); | |
1180 EXPECT_TRUE(FindMatchingValue("cat", "inc_wildcard_abc")); | |
1181 EXPECT_TRUE(FindMatchingValue("cat", "inc_wildcard_")); | |
1182 EXPECT_TRUE(FindMatchingValue("cat", "inc_wildchar_x_end")); | |
1183 EXPECT_FALSE(FindMatchingValue("name", "not_inc")); | |
1184 EXPECT_TRUE(FindMatchingValue("cat", "inc_wildcard_category,other_category")); | |
1185 EXPECT_TRUE(FindMatchingValue("cat", | |
1186 "non_included_category,inc_wildcard_category")); | |
1187 | |
1188 included_categories.clear(); | |
1189 | |
1190 // Exclude nonexistent category -> all events | |
1191 Clear(); | |
1192 TraceLog::GetInstance()->SetEnabled( | |
1193 CategoryFilter("-not_found823564786"), | |
1194 TraceLog::RECORDING_MODE, | |
1195 TraceOptions()); | |
1196 TRACE_EVENT_INSTANT0("cat1", "name", TRACE_EVENT_SCOPE_THREAD); | |
1197 TRACE_EVENT_INSTANT0("cat2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1198 TRACE_EVENT_INSTANT0("category1,category2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1199 EndTraceAndFlush(); | |
1200 EXPECT_TRUE(FindMatchingValue("cat", "cat1")); | |
1201 EXPECT_TRUE(FindMatchingValue("cat", "cat2")); | |
1202 EXPECT_TRUE(FindMatchingValue("cat", "category1,category2")); | |
1203 | |
1204 // Exclude existent category -> only events of other categories | |
1205 Clear(); | |
1206 TraceLog::GetInstance()->SetEnabled( | |
1207 CategoryFilter("-inc"), | |
1208 TraceLog::RECORDING_MODE, | |
1209 TraceOptions()); | |
1210 TRACE_EVENT_INSTANT0("inc", "name", TRACE_EVENT_SCOPE_THREAD); | |
1211 TRACE_EVENT_INSTANT0("inc2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1212 TRACE_EVENT_INSTANT0("inc2,inc", "name", TRACE_EVENT_SCOPE_THREAD); | |
1213 TRACE_EVENT_INSTANT0("inc,inc2", "name", TRACE_EVENT_SCOPE_THREAD); | |
1214 EndTraceAndFlush(); | |
1215 EXPECT_TRUE(FindMatchingValue("cat", "inc2")); | |
1216 EXPECT_FALSE(FindMatchingValue("cat", "inc")); | |
1217 EXPECT_FALSE(FindMatchingValue("cat", "inc2,inc")); | |
1218 EXPECT_FALSE(FindMatchingValue("cat", "inc,inc2")); | |
1219 | |
1220 // Exclude existent wildcard -> all categories not matching wildcard | |
1221 Clear(); | |
1222 TraceLog::GetInstance()->SetEnabled( | |
1223 CategoryFilter("-inc_wildcard_*,-inc_wildchar_?_end"), | |
1224 TraceLog::RECORDING_MODE, | |
1225 TraceOptions()); | |
1226 TRACE_EVENT_INSTANT0("inc_wildcard_abc", "not_inc", | |
1227 TRACE_EVENT_SCOPE_THREAD); | |
1228 TRACE_EVENT_INSTANT0("inc_wildcard_", "not_inc", | |
1229 TRACE_EVENT_SCOPE_THREAD); | |
1230 TRACE_EVENT_INSTANT0("inc_wildchar_x_end", "not_inc", | |
1231 TRACE_EVENT_SCOPE_THREAD); | |
1232 TRACE_EVENT_INSTANT0("inc_wildchar_bla_end", "included", | |
1233 TRACE_EVENT_SCOPE_THREAD); | |
1234 TRACE_EVENT_INSTANT0("cat1", "included", TRACE_EVENT_SCOPE_THREAD); | |
1235 TRACE_EVENT_INSTANT0("cat2", "included", TRACE_EVENT_SCOPE_THREAD); | |
1236 EndTraceAndFlush(); | |
1237 EXPECT_TRUE(FindMatchingValue("cat", "inc_wildchar_bla_end")); | |
1238 EXPECT_TRUE(FindMatchingValue("cat", "cat1")); | |
1239 EXPECT_TRUE(FindMatchingValue("cat", "cat2")); | |
1240 EXPECT_FALSE(FindMatchingValue("name", "not_inc")); | |
1241 } | |
1242 | |
1243 | |
1244 // Test EVENT_WATCH_NOTIFICATION | |
1245 TEST_F(TraceEventTestFixture, EventWatchNotification) { | |
1246 // Basic one occurrence. | |
1247 BeginTrace(); | |
1248 TraceLog::WatchEventCallback callback = | |
1249 base::Bind(&TraceEventTestFixture::OnWatchEventMatched, | |
1250 base::Unretained(this)); | |
1251 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1252 TRACE_EVENT_INSTANT0("cat", "event", TRACE_EVENT_SCOPE_THREAD); | |
1253 EndTraceAndFlush(); | |
1254 EXPECT_EQ(event_watch_notification_, 1); | |
1255 | |
1256 // Auto-reset after end trace. | |
1257 BeginTrace(); | |
1258 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1259 EndTraceAndFlush(); | |
1260 BeginTrace(); | |
1261 TRACE_EVENT_INSTANT0("cat", "event", TRACE_EVENT_SCOPE_THREAD); | |
1262 EndTraceAndFlush(); | |
1263 EXPECT_EQ(event_watch_notification_, 0); | |
1264 | |
1265 // Multiple occurrence. | |
1266 BeginTrace(); | |
1267 int num_occurrences = 5; | |
1268 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1269 for (int i = 0; i < num_occurrences; ++i) | |
1270 TRACE_EVENT_INSTANT0("cat", "event", TRACE_EVENT_SCOPE_THREAD); | |
1271 EndTraceAndFlush(); | |
1272 EXPECT_EQ(event_watch_notification_, num_occurrences); | |
1273 | |
1274 // Wrong category. | |
1275 BeginTrace(); | |
1276 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1277 TRACE_EVENT_INSTANT0("wrong_cat", "event", TRACE_EVENT_SCOPE_THREAD); | |
1278 EndTraceAndFlush(); | |
1279 EXPECT_EQ(event_watch_notification_, 0); | |
1280 | |
1281 // Wrong name. | |
1282 BeginTrace(); | |
1283 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1284 TRACE_EVENT_INSTANT0("cat", "wrong_event", TRACE_EVENT_SCOPE_THREAD); | |
1285 EndTraceAndFlush(); | |
1286 EXPECT_EQ(event_watch_notification_, 0); | |
1287 | |
1288 // Canceled. | |
1289 BeginTrace(); | |
1290 TraceLog::GetInstance()->SetWatchEvent("cat", "event", callback); | |
1291 TraceLog::GetInstance()->CancelWatchEvent(); | |
1292 TRACE_EVENT_INSTANT0("cat", "event", TRACE_EVENT_SCOPE_THREAD); | |
1293 EndTraceAndFlush(); | |
1294 EXPECT_EQ(event_watch_notification_, 0); | |
1295 } | |
1296 | |
1297 // Test ASYNC_BEGIN/END events | |
1298 TEST_F(TraceEventTestFixture, AsyncBeginEndEvents) { | |
1299 BeginTrace(); | |
1300 | |
1301 unsigned long long id = 0xfeedbeeffeedbeefull; | |
1302 TRACE_EVENT_ASYNC_BEGIN0("cat", "name1", id); | |
1303 TRACE_EVENT_ASYNC_STEP_INTO0("cat", "name1", id, "step1"); | |
1304 TRACE_EVENT_ASYNC_END0("cat", "name1", id); | |
1305 TRACE_EVENT_BEGIN0("cat", "name2"); | |
1306 TRACE_EVENT_ASYNC_BEGIN0("cat", "name3", 0); | |
1307 TRACE_EVENT_ASYNC_STEP_PAST0("cat", "name3", 0, "step2"); | |
1308 | |
1309 EndTraceAndFlush(); | |
1310 | |
1311 EXPECT_TRUE(FindNamePhase("name1", "S")); | |
1312 EXPECT_TRUE(FindNamePhase("name1", "T")); | |
1313 EXPECT_TRUE(FindNamePhase("name1", "F")); | |
1314 | |
1315 std::string id_str; | |
1316 StringAppendF(&id_str, "0x%llx", id); | |
1317 | |
1318 EXPECT_TRUE(FindNamePhaseKeyValue("name1", "S", "id", id_str.c_str())); | |
1319 EXPECT_TRUE(FindNamePhaseKeyValue("name1", "T", "id", id_str.c_str())); | |
1320 EXPECT_TRUE(FindNamePhaseKeyValue("name1", "F", "id", id_str.c_str())); | |
1321 EXPECT_TRUE(FindNamePhaseKeyValue("name3", "S", "id", "0x0")); | |
1322 EXPECT_TRUE(FindNamePhaseKeyValue("name3", "p", "id", "0x0")); | |
1323 | |
1324 // BEGIN events should not have id | |
1325 EXPECT_FALSE(FindNamePhaseKeyValue("name2", "B", "id", "0")); | |
1326 } | |
1327 | |
1328 // Test ASYNC_BEGIN/END events | |
1329 TEST_F(TraceEventTestFixture, AsyncBeginEndPointerMangling) { | |
1330 void* ptr = this; | |
1331 | |
1332 TraceLog::GetInstance()->SetProcessID(100); | |
1333 BeginTrace(); | |
1334 TRACE_EVENT_ASYNC_BEGIN0("cat", "name1", ptr); | |
1335 TRACE_EVENT_ASYNC_BEGIN0("cat", "name2", ptr); | |
1336 EndTraceAndFlush(); | |
1337 | |
1338 TraceLog::GetInstance()->SetProcessID(200); | |
1339 BeginTrace(); | |
1340 TRACE_EVENT_ASYNC_END0("cat", "name1", ptr); | |
1341 EndTraceAndFlush(); | |
1342 | |
1343 DictionaryValue* async_begin = FindNamePhase("name1", "S"); | |
1344 DictionaryValue* async_begin2 = FindNamePhase("name2", "S"); | |
1345 DictionaryValue* async_end = FindNamePhase("name1", "F"); | |
1346 EXPECT_TRUE(async_begin); | |
1347 EXPECT_TRUE(async_begin2); | |
1348 EXPECT_TRUE(async_end); | |
1349 | |
1350 Value* value = NULL; | |
1351 std::string async_begin_id_str; | |
1352 std::string async_begin2_id_str; | |
1353 std::string async_end_id_str; | |
1354 ASSERT_TRUE(async_begin->Get("id", &value)); | |
1355 ASSERT_TRUE(value->GetAsString(&async_begin_id_str)); | |
1356 ASSERT_TRUE(async_begin2->Get("id", &value)); | |
1357 ASSERT_TRUE(value->GetAsString(&async_begin2_id_str)); | |
1358 ASSERT_TRUE(async_end->Get("id", &value)); | |
1359 ASSERT_TRUE(value->GetAsString(&async_end_id_str)); | |
1360 | |
1361 EXPECT_STREQ(async_begin_id_str.c_str(), async_begin2_id_str.c_str()); | |
1362 EXPECT_STRNE(async_begin_id_str.c_str(), async_end_id_str.c_str()); | |
1363 } | |
1364 | |
1365 // Test that static strings are not copied. | |
1366 TEST_F(TraceEventTestFixture, StaticStringVsString) { | |
1367 TraceLog* tracer = TraceLog::GetInstance(); | |
1368 // Make sure old events are flushed: | |
1369 EXPECT_EQ(0u, tracer->GetStatus().event_count); | |
1370 const unsigned char* category_group_enabled = | |
1371 TRACE_EVENT_API_GET_CATEGORY_GROUP_ENABLED("cat"); | |
1372 | |
1373 { | |
1374 BeginTrace(); | |
1375 // Test that string arguments are copied. | |
1376 TraceEventHandle handle1 = | |
1377 trace_event_internal::AddTraceEvent( | |
1378 TRACE_EVENT_PHASE_INSTANT, category_group_enabled, "name1", 0, 0, | |
1379 "arg1", std::string("argval"), "arg2", std::string("argval")); | |
1380 // Test that static TRACE_STR_COPY string arguments are copied. | |
1381 TraceEventHandle handle2 = | |
1382 trace_event_internal::AddTraceEvent( | |
1383 TRACE_EVENT_PHASE_INSTANT, category_group_enabled, "name2", 0, 0, | |
1384 "arg1", TRACE_STR_COPY("argval"), | |
1385 "arg2", TRACE_STR_COPY("argval")); | |
1386 EXPECT_GT(tracer->GetStatus().event_count, 1u); | |
1387 const TraceEvent* event1 = tracer->GetEventByHandle(handle1); | |
1388 const TraceEvent* event2 = tracer->GetEventByHandle(handle2); | |
1389 ASSERT_TRUE(event1); | |
1390 ASSERT_TRUE(event2); | |
1391 EXPECT_STREQ("name1", event1->name()); | |
1392 EXPECT_STREQ("name2", event2->name()); | |
1393 EXPECT_TRUE(event1->parameter_copy_storage() != NULL); | |
1394 EXPECT_TRUE(event2->parameter_copy_storage() != NULL); | |
1395 EXPECT_GT(event1->parameter_copy_storage()->size(), 0u); | |
1396 EXPECT_GT(event2->parameter_copy_storage()->size(), 0u); | |
1397 EndTraceAndFlush(); | |
1398 } | |
1399 | |
1400 { | |
1401 BeginTrace(); | |
1402 // Test that static literal string arguments are not copied. | |
1403 TraceEventHandle handle1 = | |
1404 trace_event_internal::AddTraceEvent( | |
1405 TRACE_EVENT_PHASE_INSTANT, category_group_enabled, "name1", 0, 0, | |
1406 "arg1", "argval", "arg2", "argval"); | |
1407 // Test that static TRACE_STR_COPY NULL string arguments are not copied. | |
1408 const char* str1 = NULL; | |
1409 const char* str2 = NULL; | |
1410 TraceEventHandle handle2 = | |
1411 trace_event_internal::AddTraceEvent( | |
1412 TRACE_EVENT_PHASE_INSTANT, category_group_enabled, "name2", 0, 0, | |
1413 "arg1", TRACE_STR_COPY(str1), | |
1414 "arg2", TRACE_STR_COPY(str2)); | |
1415 EXPECT_GT(tracer->GetStatus().event_count, 1u); | |
1416 const TraceEvent* event1 = tracer->GetEventByHandle(handle1); | |
1417 const TraceEvent* event2 = tracer->GetEventByHandle(handle2); | |
1418 ASSERT_TRUE(event1); | |
1419 ASSERT_TRUE(event2); | |
1420 EXPECT_STREQ("name1", event1->name()); | |
1421 EXPECT_STREQ("name2", event2->name()); | |
1422 EXPECT_TRUE(event1->parameter_copy_storage() == NULL); | |
1423 EXPECT_TRUE(event2->parameter_copy_storage() == NULL); | |
1424 EndTraceAndFlush(); | |
1425 } | |
1426 } | |
1427 | |
1428 // Test that data sent from other threads is gathered | |
1429 TEST_F(TraceEventTestFixture, DataCapturedOnThread) { | |
1430 BeginTrace(); | |
1431 | |
1432 Thread thread("1"); | |
1433 WaitableEvent task_complete_event(false, false); | |
1434 thread.Start(); | |
1435 | |
1436 thread.message_loop()->PostTask( | |
1437 FROM_HERE, base::Bind(&TraceWithAllMacroVariants, &task_complete_event)); | |
1438 task_complete_event.Wait(); | |
1439 thread.Stop(); | |
1440 | |
1441 EndTraceAndFlush(); | |
1442 ValidateAllTraceMacrosCreatedData(trace_parsed_); | |
1443 } | |
1444 | |
1445 // Test that data sent from multiple threads is gathered | |
1446 TEST_F(TraceEventTestFixture, DataCapturedManyThreads) { | |
1447 BeginTrace(); | |
1448 | |
1449 const int num_threads = 4; | |
1450 const int num_events = 4000; | |
1451 Thread* threads[num_threads]; | |
1452 WaitableEvent* task_complete_events[num_threads]; | |
1453 for (int i = 0; i < num_threads; i++) { | |
1454 threads[i] = new Thread(StringPrintf("Thread %d", i)); | |
1455 task_complete_events[i] = new WaitableEvent(false, false); | |
1456 threads[i]->Start(); | |
1457 threads[i]->message_loop()->PostTask( | |
1458 FROM_HERE, base::Bind(&TraceManyInstantEvents, | |
1459 i, num_events, task_complete_events[i])); | |
1460 } | |
1461 | |
1462 for (int i = 0; i < num_threads; i++) { | |
1463 task_complete_events[i]->Wait(); | |
1464 } | |
1465 | |
1466 // Let half of the threads end before flush. | |
1467 for (int i = 0; i < num_threads / 2; i++) { | |
1468 threads[i]->Stop(); | |
1469 delete threads[i]; | |
1470 delete task_complete_events[i]; | |
1471 } | |
1472 | |
1473 EndTraceAndFlushInThreadWithMessageLoop(); | |
1474 ValidateInstantEventPresentOnEveryThread(trace_parsed_, | |
1475 num_threads, num_events); | |
1476 | |
1477 // Let the other half of the threads end after flush. | |
1478 for (int i = num_threads / 2; i < num_threads; i++) { | |
1479 threads[i]->Stop(); | |
1480 delete threads[i]; | |
1481 delete task_complete_events[i]; | |
1482 } | |
1483 } | |
1484 | |
1485 // Test that thread and process names show up in the trace | |
1486 TEST_F(TraceEventTestFixture, ThreadNames) { | |
1487 // Create threads before we enable tracing to make sure | |
1488 // that tracelog still captures them. | |
1489 const int kNumThreads = 4; | |
1490 const int kNumEvents = 10; | |
1491 Thread* threads[kNumThreads]; | |
1492 PlatformThreadId thread_ids[kNumThreads]; | |
1493 for (int i = 0; i < kNumThreads; i++) | |
1494 threads[i] = new Thread(StringPrintf("Thread %d", i)); | |
1495 | |
1496 // Enable tracing. | |
1497 BeginTrace(); | |
1498 | |
1499 // Now run some trace code on these threads. | |
1500 WaitableEvent* task_complete_events[kNumThreads]; | |
1501 for (int i = 0; i < kNumThreads; i++) { | |
1502 task_complete_events[i] = new WaitableEvent(false, false); | |
1503 threads[i]->Start(); | |
1504 thread_ids[i] = threads[i]->thread_id(); | |
1505 threads[i]->message_loop()->PostTask( | |
1506 FROM_HERE, base::Bind(&TraceManyInstantEvents, | |
1507 i, kNumEvents, task_complete_events[i])); | |
1508 } | |
1509 for (int i = 0; i < kNumThreads; i++) { | |
1510 task_complete_events[i]->Wait(); | |
1511 } | |
1512 | |
1513 // Shut things down. | |
1514 for (int i = 0; i < kNumThreads; i++) { | |
1515 threads[i]->Stop(); | |
1516 delete threads[i]; | |
1517 delete task_complete_events[i]; | |
1518 } | |
1519 | |
1520 EndTraceAndFlush(); | |
1521 | |
1522 std::string tmp; | |
1523 int tmp_int; | |
1524 const DictionaryValue* item; | |
1525 | |
1526 // Make sure we get thread name metadata. | |
1527 // Note, the test suite may have created a ton of threads. | |
1528 // So, we'll have thread names for threads we didn't create. | |
1529 std::vector<const DictionaryValue*> items = | |
1530 FindTraceEntries(trace_parsed_, "thread_name"); | |
1531 for (int i = 0; i < static_cast<int>(items.size()); i++) { | |
1532 item = items[i]; | |
1533 ASSERT_TRUE(item); | |
1534 EXPECT_TRUE(item->GetInteger("tid", &tmp_int)); | |
1535 | |
1536 // See if this thread name is one of the threads we just created | |
1537 for (int j = 0; j < kNumThreads; j++) { | |
1538 if(static_cast<int>(thread_ids[j]) != tmp_int) | |
1539 continue; | |
1540 | |
1541 std::string expected_name = StringPrintf("Thread %d", j); | |
1542 EXPECT_TRUE(item->GetString("ph", &tmp) && tmp == "M"); | |
1543 EXPECT_TRUE(item->GetInteger("pid", &tmp_int) && | |
1544 tmp_int == static_cast<int>(base::GetCurrentProcId())); | |
1545 // If the thread name changes or the tid gets reused, the name will be | |
1546 // a comma-separated list of thread names, so look for a substring. | |
1547 EXPECT_TRUE(item->GetString("args.name", &tmp) && | |
1548 tmp.find(expected_name) != std::string::npos); | |
1549 } | |
1550 } | |
1551 } | |
1552 | |
1553 TEST_F(TraceEventTestFixture, ThreadNameChanges) { | |
1554 BeginTrace(); | |
1555 | |
1556 PlatformThread::SetName(""); | |
1557 TRACE_EVENT_INSTANT0("drink", "water", TRACE_EVENT_SCOPE_THREAD); | |
1558 | |
1559 PlatformThread::SetName("cafe"); | |
1560 TRACE_EVENT_INSTANT0("drink", "coffee", TRACE_EVENT_SCOPE_THREAD); | |
1561 | |
1562 PlatformThread::SetName("shop"); | |
1563 // No event here, so won't appear in combined name. | |
1564 | |
1565 PlatformThread::SetName("pub"); | |
1566 TRACE_EVENT_INSTANT0("drink", "beer", TRACE_EVENT_SCOPE_THREAD); | |
1567 TRACE_EVENT_INSTANT0("drink", "wine", TRACE_EVENT_SCOPE_THREAD); | |
1568 | |
1569 PlatformThread::SetName(" bar"); | |
1570 TRACE_EVENT_INSTANT0("drink", "whisky", TRACE_EVENT_SCOPE_THREAD); | |
1571 | |
1572 EndTraceAndFlush(); | |
1573 | |
1574 std::vector<const DictionaryValue*> items = | |
1575 FindTraceEntries(trace_parsed_, "thread_name"); | |
1576 EXPECT_EQ(1u, items.size()); | |
1577 ASSERT_GT(items.size(), 0u); | |
1578 const DictionaryValue* item = items[0]; | |
1579 ASSERT_TRUE(item); | |
1580 int tid; | |
1581 EXPECT_TRUE(item->GetInteger("tid", &tid)); | |
1582 EXPECT_EQ(PlatformThread::CurrentId(), static_cast<PlatformThreadId>(tid)); | |
1583 | |
1584 std::string expected_name = "cafe,pub, bar"; | |
1585 std::string tmp; | |
1586 EXPECT_TRUE(item->GetString("args.name", &tmp)); | |
1587 EXPECT_EQ(expected_name, tmp); | |
1588 } | |
1589 | |
1590 // Test that the disabled trace categories are included/excluded from the | |
1591 // trace output correctly. | |
1592 TEST_F(TraceEventTestFixture, DisabledCategories) { | |
1593 BeginTrace(); | |
1594 TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("cc"), "first", | |
1595 TRACE_EVENT_SCOPE_THREAD); | |
1596 TRACE_EVENT_INSTANT0("included", "first", TRACE_EVENT_SCOPE_THREAD); | |
1597 EndTraceAndFlush(); | |
1598 { | |
1599 const DictionaryValue* item = NULL; | |
1600 ListValue& trace_parsed = trace_parsed_; | |
1601 EXPECT_NOT_FIND_("disabled-by-default-cc"); | |
1602 EXPECT_FIND_("included"); | |
1603 } | |
1604 Clear(); | |
1605 | |
1606 BeginSpecificTrace("disabled-by-default-cc"); | |
1607 TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("cc"), "second", | |
1608 TRACE_EVENT_SCOPE_THREAD); | |
1609 TRACE_EVENT_INSTANT0("other_included", "second", TRACE_EVENT_SCOPE_THREAD); | |
1610 EndTraceAndFlush(); | |
1611 | |
1612 { | |
1613 const DictionaryValue* item = NULL; | |
1614 ListValue& trace_parsed = trace_parsed_; | |
1615 EXPECT_FIND_("disabled-by-default-cc"); | |
1616 EXPECT_FIND_("other_included"); | |
1617 } | |
1618 | |
1619 Clear(); | |
1620 | |
1621 BeginSpecificTrace("other_included"); | |
1622 TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("cc") ",other_included", | |
1623 "first", TRACE_EVENT_SCOPE_THREAD); | |
1624 TRACE_EVENT_INSTANT0("other_included," TRACE_DISABLED_BY_DEFAULT("cc"), | |
1625 "second", TRACE_EVENT_SCOPE_THREAD); | |
1626 EndTraceAndFlush(); | |
1627 | |
1628 { | |
1629 const DictionaryValue* item = NULL; | |
1630 ListValue& trace_parsed = trace_parsed_; | |
1631 EXPECT_FIND_("disabled-by-default-cc,other_included"); | |
1632 EXPECT_FIND_("other_included,disabled-by-default-cc"); | |
1633 } | |
1634 } | |
1635 | |
1636 TEST_F(TraceEventTestFixture, NormallyNoDeepCopy) { | |
1637 // Test that the TRACE_EVENT macros do not deep-copy their string. If they | |
1638 // do so it may indicate a performance regression, but more-over it would | |
1639 // make the DEEP_COPY overloads redundant. | |
1640 std::string name_string("event name"); | |
1641 | |
1642 BeginTrace(); | |
1643 TRACE_EVENT_INSTANT0("category", name_string.c_str(), | |
1644 TRACE_EVENT_SCOPE_THREAD); | |
1645 | |
1646 // Modify the string in place (a wholesale reassignment may leave the old | |
1647 // string intact on the heap). | |
1648 name_string[0] = '@'; | |
1649 | |
1650 EndTraceAndFlush(); | |
1651 | |
1652 EXPECT_FALSE(FindTraceEntry(trace_parsed_, "event name")); | |
1653 EXPECT_TRUE(FindTraceEntry(trace_parsed_, name_string.c_str())); | |
1654 } | |
1655 | |
1656 TEST_F(TraceEventTestFixture, DeepCopy) { | |
1657 static const char kOriginalName1[] = "name1"; | |
1658 static const char kOriginalName2[] = "name2"; | |
1659 static const char kOriginalName3[] = "name3"; | |
1660 std::string name1(kOriginalName1); | |
1661 std::string name2(kOriginalName2); | |
1662 std::string name3(kOriginalName3); | |
1663 std::string arg1("arg1"); | |
1664 std::string arg2("arg2"); | |
1665 std::string val1("val1"); | |
1666 std::string val2("val2"); | |
1667 | |
1668 BeginTrace(); | |
1669 TRACE_EVENT_COPY_INSTANT0("category", name1.c_str(), | |
1670 TRACE_EVENT_SCOPE_THREAD); | |
1671 TRACE_EVENT_COPY_BEGIN1("category", name2.c_str(), | |
1672 arg1.c_str(), 5); | |
1673 TRACE_EVENT_COPY_END2("category", name3.c_str(), | |
1674 arg1.c_str(), val1, | |
1675 arg2.c_str(), val2); | |
1676 | |
1677 // As per NormallyNoDeepCopy, modify the strings in place. | |
1678 name1[0] = name2[0] = name3[0] = arg1[0] = arg2[0] = val1[0] = val2[0] = '@'; | |
1679 | |
1680 EndTraceAndFlush(); | |
1681 | |
1682 EXPECT_FALSE(FindTraceEntry(trace_parsed_, name1.c_str())); | |
1683 EXPECT_FALSE(FindTraceEntry(trace_parsed_, name2.c_str())); | |
1684 EXPECT_FALSE(FindTraceEntry(trace_parsed_, name3.c_str())); | |
1685 | |
1686 const DictionaryValue* entry1 = FindTraceEntry(trace_parsed_, kOriginalName1); | |
1687 const DictionaryValue* entry2 = FindTraceEntry(trace_parsed_, kOriginalName2); | |
1688 const DictionaryValue* entry3 = FindTraceEntry(trace_parsed_, kOriginalName3); | |
1689 ASSERT_TRUE(entry1); | |
1690 ASSERT_TRUE(entry2); | |
1691 ASSERT_TRUE(entry3); | |
1692 | |
1693 int i; | |
1694 EXPECT_FALSE(entry2->GetInteger("args.@rg1", &i)); | |
1695 EXPECT_TRUE(entry2->GetInteger("args.arg1", &i)); | |
1696 EXPECT_EQ(5, i); | |
1697 | |
1698 std::string s; | |
1699 EXPECT_TRUE(entry3->GetString("args.arg1", &s)); | |
1700 EXPECT_EQ("val1", s); | |
1701 EXPECT_TRUE(entry3->GetString("args.arg2", &s)); | |
1702 EXPECT_EQ("val2", s); | |
1703 } | |
1704 | |
1705 // Test that TraceResultBuffer outputs the correct result whether it is added | |
1706 // in chunks or added all at once. | |
1707 TEST_F(TraceEventTestFixture, TraceResultBuffer) { | |
1708 Clear(); | |
1709 | |
1710 trace_buffer_.Start(); | |
1711 trace_buffer_.AddFragment("bla1"); | |
1712 trace_buffer_.AddFragment("bla2"); | |
1713 trace_buffer_.AddFragment("bla3,bla4"); | |
1714 trace_buffer_.Finish(); | |
1715 EXPECT_STREQ(json_output_.json_output.c_str(), "[bla1,bla2,bla3,bla4]"); | |
1716 | |
1717 Clear(); | |
1718 | |
1719 trace_buffer_.Start(); | |
1720 trace_buffer_.AddFragment("bla1,bla2,bla3,bla4"); | |
1721 trace_buffer_.Finish(); | |
1722 EXPECT_STREQ(json_output_.json_output.c_str(), "[bla1,bla2,bla3,bla4]"); | |
1723 } | |
1724 | |
1725 // Test that trace_event parameters are not evaluated if the tracing | |
1726 // system is disabled. | |
1727 TEST_F(TraceEventTestFixture, TracingIsLazy) { | |
1728 BeginTrace(); | |
1729 | |
1730 int a = 0; | |
1731 TRACE_EVENT_INSTANT1("category", "test", TRACE_EVENT_SCOPE_THREAD, "a", a++); | |
1732 EXPECT_EQ(1, a); | |
1733 | |
1734 TraceLog::GetInstance()->SetDisabled(); | |
1735 | |
1736 TRACE_EVENT_INSTANT1("category", "test", TRACE_EVENT_SCOPE_THREAD, "a", a++); | |
1737 EXPECT_EQ(1, a); | |
1738 | |
1739 EndTraceAndFlush(); | |
1740 } | |
1741 | |
1742 TEST_F(TraceEventTestFixture, TraceEnableDisable) { | |
1743 TraceLog* trace_log = TraceLog::GetInstance(); | |
1744 CategoryFilter cf_inc_all("*"); | |
1745 trace_log->SetEnabled(cf_inc_all, | |
1746 TraceLog::RECORDING_MODE, | |
1747 TraceOptions()); | |
1748 EXPECT_TRUE(trace_log->IsEnabled()); | |
1749 trace_log->SetDisabled(); | |
1750 EXPECT_FALSE(trace_log->IsEnabled()); | |
1751 | |
1752 trace_log->SetEnabled(cf_inc_all, | |
1753 TraceLog::RECORDING_MODE, | |
1754 TraceOptions()); | |
1755 EXPECT_TRUE(trace_log->IsEnabled()); | |
1756 const std::vector<std::string> empty; | |
1757 trace_log->SetEnabled(CategoryFilter(), | |
1758 TraceLog::RECORDING_MODE, | |
1759 TraceOptions()); | |
1760 EXPECT_TRUE(trace_log->IsEnabled()); | |
1761 trace_log->SetDisabled(); | |
1762 EXPECT_FALSE(trace_log->IsEnabled()); | |
1763 trace_log->SetDisabled(); | |
1764 EXPECT_FALSE(trace_log->IsEnabled()); | |
1765 } | |
1766 | |
1767 TEST_F(TraceEventTestFixture, TraceCategoriesAfterNestedEnable) { | |
1768 TraceLog* trace_log = TraceLog::GetInstance(); | |
1769 trace_log->SetEnabled(CategoryFilter("foo,bar"), | |
1770 TraceLog::RECORDING_MODE, | |
1771 TraceOptions()); | |
1772 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("foo")); | |
1773 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("bar")); | |
1774 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1775 trace_log->SetEnabled(CategoryFilter("foo2"), | |
1776 TraceLog::RECORDING_MODE, | |
1777 TraceOptions()); | |
1778 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("foo2")); | |
1779 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1780 // The "" becomes the default catergory set when applied. | |
1781 trace_log->SetEnabled(CategoryFilter(), | |
1782 TraceLog::RECORDING_MODE, | |
1783 TraceOptions()); | |
1784 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("foo")); | |
1785 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1786 EXPECT_STREQ("-*Debug,-*Test", | |
1787 trace_log->GetCurrentCategoryFilter().ToString().c_str()); | |
1788 trace_log->SetDisabled(); | |
1789 trace_log->SetDisabled(); | |
1790 trace_log->SetDisabled(); | |
1791 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("foo")); | |
1792 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1793 | |
1794 trace_log->SetEnabled(CategoryFilter("-foo,-bar"), | |
1795 TraceLog::RECORDING_MODE, | |
1796 TraceOptions()); | |
1797 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("foo")); | |
1798 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1799 trace_log->SetEnabled(CategoryFilter("moo"), | |
1800 TraceLog::RECORDING_MODE, | |
1801 TraceOptions()); | |
1802 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("baz")); | |
1803 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("moo")); | |
1804 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("foo")); | |
1805 EXPECT_STREQ("-foo,-bar", | |
1806 trace_log->GetCurrentCategoryFilter().ToString().c_str()); | |
1807 trace_log->SetDisabled(); | |
1808 trace_log->SetDisabled(); | |
1809 | |
1810 // Make sure disabled categories aren't cleared if we set in the second. | |
1811 trace_log->SetEnabled(CategoryFilter("disabled-by-default-cc,foo"), | |
1812 TraceLog::RECORDING_MODE, | |
1813 TraceOptions()); | |
1814 EXPECT_FALSE(*trace_log->GetCategoryGroupEnabled("bar")); | |
1815 trace_log->SetEnabled(CategoryFilter("disabled-by-default-gpu"), | |
1816 TraceLog::RECORDING_MODE, | |
1817 TraceOptions()); | |
1818 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("disabled-by-default-cc")); | |
1819 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("disabled-by-default-gpu")); | |
1820 EXPECT_TRUE(*trace_log->GetCategoryGroupEnabled("bar")); | |
1821 EXPECT_STREQ("disabled-by-default-cc,disabled-by-default-gpu", | |
1822 trace_log->GetCurrentCategoryFilter().ToString().c_str()); | |
1823 trace_log->SetDisabled(); | |
1824 trace_log->SetDisabled(); | |
1825 } | |
1826 | |
1827 TEST_F(TraceEventTestFixture, TraceSampling) { | |
1828 TraceOptions trace_options(RECORD_UNTIL_FULL); | |
1829 trace_options.enable_sampling = true; | |
1830 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
1831 TraceLog::RECORDING_MODE, | |
1832 trace_options); | |
1833 | |
1834 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "cc", "Stuff"); | |
1835 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1836 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "cc", "Things"); | |
1837 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1838 | |
1839 EndTraceAndFlush(); | |
1840 | |
1841 // Make sure we hit at least once. | |
1842 EXPECT_TRUE(FindNamePhase("Stuff", "P")); | |
1843 EXPECT_TRUE(FindNamePhase("Things", "P")); | |
1844 } | |
1845 | |
1846 TEST_F(TraceEventTestFixture, TraceSamplingScope) { | |
1847 TraceOptions trace_options(RECORD_UNTIL_FULL); | |
1848 trace_options.enable_sampling = true; | |
1849 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
1850 TraceLog::RECORDING_MODE, | |
1851 trace_options); | |
1852 | |
1853 TRACE_EVENT_SCOPED_SAMPLING_STATE("AAA", "name"); | |
1854 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1855 { | |
1856 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "AAA"); | |
1857 TRACE_EVENT_SCOPED_SAMPLING_STATE("BBB", "name"); | |
1858 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1859 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "BBB"); | |
1860 } | |
1861 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1862 { | |
1863 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "AAA"); | |
1864 TRACE_EVENT_SCOPED_SAMPLING_STATE("CCC", "name"); | |
1865 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1866 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "CCC"); | |
1867 } | |
1868 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1869 { | |
1870 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "AAA"); | |
1871 TRACE_EVENT_SET_SAMPLING_STATE("DDD", "name"); | |
1872 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1873 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "DDD"); | |
1874 } | |
1875 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1876 EXPECT_STREQ(TRACE_EVENT_GET_SAMPLING_STATE(), "DDD"); | |
1877 | |
1878 EndTraceAndFlush(); | |
1879 } | |
1880 | |
1881 TEST_F(TraceEventTestFixture, TraceContinuousSampling) { | |
1882 TraceOptions trace_options(RECORD_UNTIL_FULL); | |
1883 trace_options.enable_sampling = true; | |
1884 | |
1885 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
1886 TraceLog::MONITORING_MODE, | |
1887 trace_options); | |
1888 | |
1889 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "category", "AAA"); | |
1890 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1891 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "category", "BBB"); | |
1892 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1893 | |
1894 FlushMonitoring(); | |
1895 | |
1896 // Make sure we can get the profiled data. | |
1897 EXPECT_TRUE(FindNamePhase("AAA", "P")); | |
1898 EXPECT_TRUE(FindNamePhase("BBB", "P")); | |
1899 | |
1900 Clear(); | |
1901 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1902 | |
1903 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "category", "CCC"); | |
1904 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1905 TRACE_EVENT_SET_SAMPLING_STATE_FOR_BUCKET(1, "category", "DDD"); | |
1906 TraceLog::GetInstance()->WaitSamplingEventForTesting(); | |
1907 | |
1908 FlushMonitoring(); | |
1909 | |
1910 // Make sure the profiled data is accumulated. | |
1911 EXPECT_TRUE(FindNamePhase("AAA", "P")); | |
1912 EXPECT_TRUE(FindNamePhase("BBB", "P")); | |
1913 EXPECT_TRUE(FindNamePhase("CCC", "P")); | |
1914 EXPECT_TRUE(FindNamePhase("DDD", "P")); | |
1915 | |
1916 Clear(); | |
1917 | |
1918 TraceLog::GetInstance()->SetDisabled(); | |
1919 | |
1920 // Make sure disabling the continuous sampling thread clears | |
1921 // the profiled data. | |
1922 EXPECT_FALSE(FindNamePhase("AAA", "P")); | |
1923 EXPECT_FALSE(FindNamePhase("BBB", "P")); | |
1924 EXPECT_FALSE(FindNamePhase("CCC", "P")); | |
1925 EXPECT_FALSE(FindNamePhase("DDD", "P")); | |
1926 | |
1927 Clear(); | |
1928 } | |
1929 | |
1930 class MyData : public ConvertableToTraceFormat { | |
1931 public: | |
1932 MyData() {} | |
1933 | |
1934 void AppendAsTraceFormat(std::string* out) const override { | |
1935 out->append("{\"foo\":1}"); | |
1936 } | |
1937 | |
1938 private: | |
1939 ~MyData() override {} | |
1940 DISALLOW_COPY_AND_ASSIGN(MyData); | |
1941 }; | |
1942 | |
1943 TEST_F(TraceEventTestFixture, ConvertableTypes) { | |
1944 TraceLog::GetInstance()->SetEnabled( | |
1945 CategoryFilter("*"), | |
1946 TraceLog::RECORDING_MODE, | |
1947 TraceOptions()); | |
1948 | |
1949 scoped_refptr<ConvertableToTraceFormat> data(new MyData()); | |
1950 scoped_refptr<ConvertableToTraceFormat> data1(new MyData()); | |
1951 scoped_refptr<ConvertableToTraceFormat> data2(new MyData()); | |
1952 TRACE_EVENT1("foo", "bar", "data", data); | |
1953 TRACE_EVENT2("foo", "baz", | |
1954 "data1", data1, | |
1955 "data2", data2); | |
1956 | |
1957 | |
1958 scoped_refptr<ConvertableToTraceFormat> convertData1(new MyData()); | |
1959 scoped_refptr<ConvertableToTraceFormat> convertData2(new MyData()); | |
1960 TRACE_EVENT2( | |
1961 "foo", | |
1962 "string_first", | |
1963 "str", | |
1964 "string value 1", | |
1965 "convert", | |
1966 convertData1); | |
1967 TRACE_EVENT2( | |
1968 "foo", | |
1969 "string_second", | |
1970 "convert", | |
1971 convertData2, | |
1972 "str", | |
1973 "string value 2"); | |
1974 EndTraceAndFlush(); | |
1975 | |
1976 // One arg version. | |
1977 DictionaryValue* dict = FindNamePhase("bar", "X"); | |
1978 ASSERT_TRUE(dict); | |
1979 | |
1980 const DictionaryValue* args_dict = NULL; | |
1981 dict->GetDictionary("args", &args_dict); | |
1982 ASSERT_TRUE(args_dict); | |
1983 | |
1984 const Value* value = NULL; | |
1985 const DictionaryValue* convertable_dict = NULL; | |
1986 EXPECT_TRUE(args_dict->Get("data", &value)); | |
1987 ASSERT_TRUE(value->GetAsDictionary(&convertable_dict)); | |
1988 | |
1989 int foo_val; | |
1990 EXPECT_TRUE(convertable_dict->GetInteger("foo", &foo_val)); | |
1991 EXPECT_EQ(1, foo_val); | |
1992 | |
1993 // Two arg version. | |
1994 dict = FindNamePhase("baz", "X"); | |
1995 ASSERT_TRUE(dict); | |
1996 | |
1997 args_dict = NULL; | |
1998 dict->GetDictionary("args", &args_dict); | |
1999 ASSERT_TRUE(args_dict); | |
2000 | |
2001 value = NULL; | |
2002 convertable_dict = NULL; | |
2003 EXPECT_TRUE(args_dict->Get("data1", &value)); | |
2004 ASSERT_TRUE(value->GetAsDictionary(&convertable_dict)); | |
2005 | |
2006 value = NULL; | |
2007 convertable_dict = NULL; | |
2008 EXPECT_TRUE(args_dict->Get("data2", &value)); | |
2009 ASSERT_TRUE(value->GetAsDictionary(&convertable_dict)); | |
2010 | |
2011 // Convertable with other types. | |
2012 dict = FindNamePhase("string_first", "X"); | |
2013 ASSERT_TRUE(dict); | |
2014 | |
2015 args_dict = NULL; | |
2016 dict->GetDictionary("args", &args_dict); | |
2017 ASSERT_TRUE(args_dict); | |
2018 | |
2019 std::string str_value; | |
2020 EXPECT_TRUE(args_dict->GetString("str", &str_value)); | |
2021 EXPECT_STREQ("string value 1", str_value.c_str()); | |
2022 | |
2023 value = NULL; | |
2024 convertable_dict = NULL; | |
2025 foo_val = 0; | |
2026 EXPECT_TRUE(args_dict->Get("convert", &value)); | |
2027 ASSERT_TRUE(value->GetAsDictionary(&convertable_dict)); | |
2028 EXPECT_TRUE(convertable_dict->GetInteger("foo", &foo_val)); | |
2029 EXPECT_EQ(1, foo_val); | |
2030 | |
2031 dict = FindNamePhase("string_second", "X"); | |
2032 ASSERT_TRUE(dict); | |
2033 | |
2034 args_dict = NULL; | |
2035 dict->GetDictionary("args", &args_dict); | |
2036 ASSERT_TRUE(args_dict); | |
2037 | |
2038 EXPECT_TRUE(args_dict->GetString("str", &str_value)); | |
2039 EXPECT_STREQ("string value 2", str_value.c_str()); | |
2040 | |
2041 value = NULL; | |
2042 convertable_dict = NULL; | |
2043 foo_val = 0; | |
2044 EXPECT_TRUE(args_dict->Get("convert", &value)); | |
2045 ASSERT_TRUE(value->GetAsDictionary(&convertable_dict)); | |
2046 EXPECT_TRUE(convertable_dict->GetInteger("foo", &foo_val)); | |
2047 EXPECT_EQ(1, foo_val); | |
2048 } | |
2049 | |
2050 TEST_F(TraceEventTestFixture, PrimitiveArgs) { | |
2051 TraceLog::GetInstance()->SetEnabled( | |
2052 CategoryFilter("*"), | |
2053 TraceLog::RECORDING_MODE, | |
2054 TraceOptions()); | |
2055 | |
2056 TRACE_EVENT1("foo", "event1", "int_one", 1); | |
2057 TRACE_EVENT1("foo", "event2", "int_neg_ten", -10); | |
2058 TRACE_EVENT1("foo", "event3", "float_one", 1.0f); | |
2059 TRACE_EVENT1("foo", "event4", "float_half", .5f); | |
2060 TRACE_EVENT1("foo", "event5", "float_neghalf", -.5f); | |
2061 TRACE_EVENT1("foo", "event6", "float_infinity", | |
2062 std::numeric_limits<float>::infinity()); | |
2063 TRACE_EVENT1("foo", "event6b", "float_neg_infinity", | |
2064 -std::numeric_limits<float>::infinity()); | |
2065 TRACE_EVENT1("foo", "event7", "double_nan", | |
2066 std::numeric_limits<double>::quiet_NaN()); | |
2067 void* p = 0; | |
2068 TRACE_EVENT1("foo", "event8", "pointer_null", p); | |
2069 p = reinterpret_cast<void*>(0xbadf00d); | |
2070 TRACE_EVENT1("foo", "event9", "pointer_badf00d", p); | |
2071 TRACE_EVENT1("foo", "event10", "bool_true", true); | |
2072 TRACE_EVENT1("foo", "event11", "bool_false", false); | |
2073 TRACE_EVENT1("foo", "event12", "time_null", | |
2074 base::Time()); | |
2075 TRACE_EVENT1("foo", "event13", "time_one", | |
2076 base::Time::FromInternalValue(1)); | |
2077 TRACE_EVENT1("foo", "event14", "timeticks_null", | |
2078 base::TimeTicks()); | |
2079 TRACE_EVENT1("foo", "event15", "timeticks_one", | |
2080 base::TimeTicks::FromInternalValue(1)); | |
2081 EndTraceAndFlush(); | |
2082 | |
2083 const DictionaryValue* args_dict = NULL; | |
2084 DictionaryValue* dict = NULL; | |
2085 const Value* value = NULL; | |
2086 std::string str_value; | |
2087 int int_value; | |
2088 double double_value; | |
2089 bool bool_value; | |
2090 | |
2091 dict = FindNamePhase("event1", "X"); | |
2092 ASSERT_TRUE(dict); | |
2093 dict->GetDictionary("args", &args_dict); | |
2094 ASSERT_TRUE(args_dict); | |
2095 EXPECT_TRUE(args_dict->GetInteger("int_one", &int_value)); | |
2096 EXPECT_EQ(1, int_value); | |
2097 | |
2098 dict = FindNamePhase("event2", "X"); | |
2099 ASSERT_TRUE(dict); | |
2100 dict->GetDictionary("args", &args_dict); | |
2101 ASSERT_TRUE(args_dict); | |
2102 EXPECT_TRUE(args_dict->GetInteger("int_neg_ten", &int_value)); | |
2103 EXPECT_EQ(-10, int_value); | |
2104 | |
2105 // 1f must be serlized to JSON as "1.0" in order to be a double, not an int. | |
2106 dict = FindNamePhase("event3", "X"); | |
2107 ASSERT_TRUE(dict); | |
2108 dict->GetDictionary("args", &args_dict); | |
2109 ASSERT_TRUE(args_dict); | |
2110 EXPECT_TRUE(args_dict->Get("float_one", &value)); | |
2111 EXPECT_TRUE(value->IsType(Value::TYPE_DOUBLE)); | |
2112 EXPECT_TRUE(value->GetAsDouble(&double_value)); | |
2113 EXPECT_EQ(1, double_value); | |
2114 | |
2115 // .5f must be serlized to JSON as "0.5". | |
2116 dict = FindNamePhase("event4", "X"); | |
2117 ASSERT_TRUE(dict); | |
2118 dict->GetDictionary("args", &args_dict); | |
2119 ASSERT_TRUE(args_dict); | |
2120 EXPECT_TRUE(args_dict->Get("float_half", &value)); | |
2121 EXPECT_TRUE(value->IsType(Value::TYPE_DOUBLE)); | |
2122 EXPECT_TRUE(value->GetAsDouble(&double_value)); | |
2123 EXPECT_EQ(0.5, double_value); | |
2124 | |
2125 // -.5f must be serlized to JSON as "-0.5". | |
2126 dict = FindNamePhase("event5", "X"); | |
2127 ASSERT_TRUE(dict); | |
2128 dict->GetDictionary("args", &args_dict); | |
2129 ASSERT_TRUE(args_dict); | |
2130 EXPECT_TRUE(args_dict->Get("float_neghalf", &value)); | |
2131 EXPECT_TRUE(value->IsType(Value::TYPE_DOUBLE)); | |
2132 EXPECT_TRUE(value->GetAsDouble(&double_value)); | |
2133 EXPECT_EQ(-0.5, double_value); | |
2134 | |
2135 // Infinity is serialized to JSON as a string. | |
2136 dict = FindNamePhase("event6", "X"); | |
2137 ASSERT_TRUE(dict); | |
2138 dict->GetDictionary("args", &args_dict); | |
2139 ASSERT_TRUE(args_dict); | |
2140 EXPECT_TRUE(args_dict->GetString("float_infinity", &str_value)); | |
2141 EXPECT_STREQ("Infinity", str_value.c_str()); | |
2142 dict = FindNamePhase("event6b", "X"); | |
2143 ASSERT_TRUE(dict); | |
2144 dict->GetDictionary("args", &args_dict); | |
2145 ASSERT_TRUE(args_dict); | |
2146 EXPECT_TRUE(args_dict->GetString("float_neg_infinity", &str_value)); | |
2147 EXPECT_STREQ("-Infinity", str_value.c_str()); | |
2148 | |
2149 // NaN is serialized to JSON as a string. | |
2150 dict = FindNamePhase("event7", "X"); | |
2151 ASSERT_TRUE(dict); | |
2152 dict->GetDictionary("args", &args_dict); | |
2153 ASSERT_TRUE(args_dict); | |
2154 EXPECT_TRUE(args_dict->GetString("double_nan", &str_value)); | |
2155 EXPECT_STREQ("NaN", str_value.c_str()); | |
2156 | |
2157 // NULL pointers should be serialized as "0x0". | |
2158 dict = FindNamePhase("event8", "X"); | |
2159 ASSERT_TRUE(dict); | |
2160 dict->GetDictionary("args", &args_dict); | |
2161 ASSERT_TRUE(args_dict); | |
2162 EXPECT_TRUE(args_dict->GetString("pointer_null", &str_value)); | |
2163 EXPECT_STREQ("0x0", str_value.c_str()); | |
2164 | |
2165 // Other pointers should be serlized as a hex string. | |
2166 dict = FindNamePhase("event9", "X"); | |
2167 ASSERT_TRUE(dict); | |
2168 dict->GetDictionary("args", &args_dict); | |
2169 ASSERT_TRUE(args_dict); | |
2170 EXPECT_TRUE(args_dict->GetString("pointer_badf00d", &str_value)); | |
2171 EXPECT_STREQ("0xbadf00d", str_value.c_str()); | |
2172 | |
2173 dict = FindNamePhase("event10", "X"); | |
2174 ASSERT_TRUE(dict); | |
2175 dict->GetDictionary("args", &args_dict); | |
2176 ASSERT_TRUE(args_dict); | |
2177 EXPECT_TRUE(args_dict->GetBoolean("bool_true", &bool_value)); | |
2178 EXPECT_TRUE(bool_value); | |
2179 | |
2180 dict = FindNamePhase("event11", "X"); | |
2181 ASSERT_TRUE(dict); | |
2182 dict->GetDictionary("args", &args_dict); | |
2183 ASSERT_TRUE(args_dict); | |
2184 EXPECT_TRUE(args_dict->GetBoolean("bool_false", &bool_value)); | |
2185 EXPECT_FALSE(bool_value); | |
2186 | |
2187 dict = FindNamePhase("event12", "X"); | |
2188 ASSERT_TRUE(dict); | |
2189 dict->GetDictionary("args", &args_dict); | |
2190 ASSERT_TRUE(args_dict); | |
2191 EXPECT_TRUE(args_dict->GetInteger("time_null", &int_value)); | |
2192 EXPECT_EQ(0, int_value); | |
2193 | |
2194 dict = FindNamePhase("event13", "X"); | |
2195 ASSERT_TRUE(dict); | |
2196 dict->GetDictionary("args", &args_dict); | |
2197 ASSERT_TRUE(args_dict); | |
2198 EXPECT_TRUE(args_dict->GetInteger("time_one", &int_value)); | |
2199 EXPECT_EQ(1, int_value); | |
2200 | |
2201 dict = FindNamePhase("event14", "X"); | |
2202 ASSERT_TRUE(dict); | |
2203 dict->GetDictionary("args", &args_dict); | |
2204 ASSERT_TRUE(args_dict); | |
2205 EXPECT_TRUE(args_dict->GetInteger("timeticks_null", &int_value)); | |
2206 EXPECT_EQ(0, int_value); | |
2207 | |
2208 dict = FindNamePhase("event15", "X"); | |
2209 ASSERT_TRUE(dict); | |
2210 dict->GetDictionary("args", &args_dict); | |
2211 ASSERT_TRUE(args_dict); | |
2212 EXPECT_TRUE(args_dict->GetInteger("timeticks_one", &int_value)); | |
2213 EXPECT_EQ(1, int_value); | |
2214 } | |
2215 | |
2216 class TraceEventCallbackTest : public TraceEventTestFixture { | |
2217 public: | |
2218 void SetUp() override { | |
2219 TraceEventTestFixture::SetUp(); | |
2220 ASSERT_EQ(NULL, s_instance); | |
2221 s_instance = this; | |
2222 } | |
2223 void TearDown() override { | |
2224 TraceLog::GetInstance()->SetDisabled(); | |
2225 ASSERT_TRUE(!!s_instance); | |
2226 s_instance = NULL; | |
2227 TraceEventTestFixture::TearDown(); | |
2228 } | |
2229 | |
2230 protected: | |
2231 // For TraceEventCallbackAndRecordingX tests. | |
2232 void VerifyCallbackAndRecordedEvents(size_t expected_callback_count, | |
2233 size_t expected_recorded_count) { | |
2234 // Callback events. | |
2235 EXPECT_EQ(expected_callback_count, collected_events_names_.size()); | |
2236 for (size_t i = 0; i < collected_events_names_.size(); ++i) { | |
2237 EXPECT_EQ("callback", collected_events_categories_[i]); | |
2238 EXPECT_EQ("yes", collected_events_names_[i]); | |
2239 } | |
2240 | |
2241 // Recorded events. | |
2242 EXPECT_EQ(expected_recorded_count, trace_parsed_.GetSize()); | |
2243 EXPECT_TRUE(FindTraceEntry(trace_parsed_, "recording")); | |
2244 EXPECT_FALSE(FindTraceEntry(trace_parsed_, "callback")); | |
2245 EXPECT_TRUE(FindTraceEntry(trace_parsed_, "yes")); | |
2246 EXPECT_FALSE(FindTraceEntry(trace_parsed_, "no")); | |
2247 } | |
2248 | |
2249 void VerifyCollectedEvent(size_t i, | |
2250 unsigned phase, | |
2251 const std::string& category, | |
2252 const std::string& name) { | |
2253 EXPECT_EQ(phase, collected_events_phases_[i]); | |
2254 EXPECT_EQ(category, collected_events_categories_[i]); | |
2255 EXPECT_EQ(name, collected_events_names_[i]); | |
2256 } | |
2257 | |
2258 std::vector<std::string> collected_events_categories_; | |
2259 std::vector<std::string> collected_events_names_; | |
2260 std::vector<unsigned char> collected_events_phases_; | |
2261 std::vector<TimeTicks> collected_events_timestamps_; | |
2262 | |
2263 static TraceEventCallbackTest* s_instance; | |
2264 static void Callback(TimeTicks timestamp, | |
2265 char phase, | |
2266 const unsigned char* category_group_enabled, | |
2267 const char* name, | |
2268 unsigned long long id, | |
2269 int num_args, | |
2270 const char* const arg_names[], | |
2271 const unsigned char arg_types[], | |
2272 const unsigned long long arg_values[], | |
2273 unsigned char flags) { | |
2274 s_instance->collected_events_phases_.push_back(phase); | |
2275 s_instance->collected_events_categories_.push_back( | |
2276 TraceLog::GetCategoryGroupName(category_group_enabled)); | |
2277 s_instance->collected_events_names_.push_back(name); | |
2278 s_instance->collected_events_timestamps_.push_back(timestamp); | |
2279 } | |
2280 }; | |
2281 | |
2282 TraceEventCallbackTest* TraceEventCallbackTest::s_instance; | |
2283 | |
2284 TEST_F(TraceEventCallbackTest, TraceEventCallback) { | |
2285 TRACE_EVENT_INSTANT0("all", "before enable", TRACE_EVENT_SCOPE_THREAD); | |
2286 TraceLog::GetInstance()->SetEventCallbackEnabled( | |
2287 CategoryFilter("*"), Callback); | |
2288 TRACE_EVENT_INSTANT0("all", "event1", TRACE_EVENT_SCOPE_GLOBAL); | |
2289 TRACE_EVENT_INSTANT0("all", "event2", TRACE_EVENT_SCOPE_GLOBAL); | |
2290 { | |
2291 TRACE_EVENT0("all", "duration"); | |
2292 TRACE_EVENT_INSTANT0("all", "event3", TRACE_EVENT_SCOPE_GLOBAL); | |
2293 } | |
2294 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2295 TRACE_EVENT_INSTANT0("all", "after callback removed", | |
2296 TRACE_EVENT_SCOPE_GLOBAL); | |
2297 ASSERT_EQ(5u, collected_events_names_.size()); | |
2298 EXPECT_EQ("event1", collected_events_names_[0]); | |
2299 EXPECT_EQ(TRACE_EVENT_PHASE_INSTANT, collected_events_phases_[0]); | |
2300 EXPECT_EQ("event2", collected_events_names_[1]); | |
2301 EXPECT_EQ(TRACE_EVENT_PHASE_INSTANT, collected_events_phases_[1]); | |
2302 EXPECT_EQ("duration", collected_events_names_[2]); | |
2303 EXPECT_EQ(TRACE_EVENT_PHASE_BEGIN, collected_events_phases_[2]); | |
2304 EXPECT_EQ("event3", collected_events_names_[3]); | |
2305 EXPECT_EQ(TRACE_EVENT_PHASE_INSTANT, collected_events_phases_[3]); | |
2306 EXPECT_EQ("duration", collected_events_names_[4]); | |
2307 EXPECT_EQ(TRACE_EVENT_PHASE_END, collected_events_phases_[4]); | |
2308 for (size_t i = 1; i < collected_events_timestamps_.size(); i++) { | |
2309 EXPECT_LE(collected_events_timestamps_[i - 1], | |
2310 collected_events_timestamps_[i]); | |
2311 } | |
2312 } | |
2313 | |
2314 TEST_F(TraceEventCallbackTest, TraceEventCallbackWhileFull) { | |
2315 TraceLog::GetInstance()->SetEnabled( | |
2316 CategoryFilter("*"), | |
2317 TraceLog::RECORDING_MODE, | |
2318 TraceOptions()); | |
2319 do { | |
2320 TRACE_EVENT_INSTANT0("all", "badger badger", TRACE_EVENT_SCOPE_GLOBAL); | |
2321 } while (!TraceLog::GetInstance()->BufferIsFull()); | |
2322 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("*"), | |
2323 Callback); | |
2324 TRACE_EVENT_INSTANT0("all", "a snake", TRACE_EVENT_SCOPE_GLOBAL); | |
2325 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2326 ASSERT_EQ(1u, collected_events_names_.size()); | |
2327 EXPECT_EQ("a snake", collected_events_names_[0]); | |
2328 } | |
2329 | |
2330 // 1: Enable callback, enable recording, disable callback, disable recording. | |
2331 TEST_F(TraceEventCallbackTest, TraceEventCallbackAndRecording1) { | |
2332 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2333 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2334 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("callback"), | |
2335 Callback); | |
2336 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2337 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2338 TraceLog::GetInstance()->SetEnabled( | |
2339 CategoryFilter("recording"), | |
2340 TraceLog::RECORDING_MODE, | |
2341 TraceOptions()); | |
2342 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2343 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2344 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2345 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2346 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2347 EndTraceAndFlush(); | |
2348 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2349 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2350 | |
2351 DropTracedMetadataRecords(); | |
2352 VerifyCallbackAndRecordedEvents(2, 2); | |
2353 } | |
2354 | |
2355 // 2: Enable callback, enable recording, disable recording, disable callback. | |
2356 TEST_F(TraceEventCallbackTest, TraceEventCallbackAndRecording2) { | |
2357 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2358 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2359 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("callback"), | |
2360 Callback); | |
2361 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2362 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2363 TraceLog::GetInstance()->SetEnabled( | |
2364 CategoryFilter("recording"), | |
2365 TraceLog::RECORDING_MODE, | |
2366 TraceOptions()); | |
2367 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2368 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2369 EndTraceAndFlush(); | |
2370 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2371 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2372 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2373 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2374 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2375 | |
2376 DropTracedMetadataRecords(); | |
2377 VerifyCallbackAndRecordedEvents(3, 1); | |
2378 } | |
2379 | |
2380 // 3: Enable recording, enable callback, disable callback, disable recording. | |
2381 TEST_F(TraceEventCallbackTest, TraceEventCallbackAndRecording3) { | |
2382 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2383 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2384 TraceLog::GetInstance()->SetEnabled( | |
2385 CategoryFilter("recording"), | |
2386 TraceLog::RECORDING_MODE, | |
2387 TraceOptions()); | |
2388 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2389 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2390 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("callback"), | |
2391 Callback); | |
2392 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2393 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2394 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2395 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2396 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2397 EndTraceAndFlush(); | |
2398 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2399 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2400 | |
2401 DropTracedMetadataRecords(); | |
2402 VerifyCallbackAndRecordedEvents(1, 3); | |
2403 } | |
2404 | |
2405 // 4: Enable recording, enable callback, disable recording, disable callback. | |
2406 TEST_F(TraceEventCallbackTest, TraceEventCallbackAndRecording4) { | |
2407 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2408 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2409 TraceLog::GetInstance()->SetEnabled( | |
2410 CategoryFilter("recording"), | |
2411 TraceLog::RECORDING_MODE, | |
2412 TraceOptions()); | |
2413 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2414 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2415 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("callback"), | |
2416 Callback); | |
2417 TRACE_EVENT_INSTANT0("recording", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2418 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2419 EndTraceAndFlush(); | |
2420 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2421 TRACE_EVENT_INSTANT0("callback", "yes", TRACE_EVENT_SCOPE_GLOBAL); | |
2422 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2423 TRACE_EVENT_INSTANT0("recording", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2424 TRACE_EVENT_INSTANT0("callback", "no", TRACE_EVENT_SCOPE_GLOBAL); | |
2425 | |
2426 DropTracedMetadataRecords(); | |
2427 VerifyCallbackAndRecordedEvents(2, 2); | |
2428 } | |
2429 | |
2430 TEST_F(TraceEventCallbackTest, TraceEventCallbackAndRecordingDuration) { | |
2431 TraceLog::GetInstance()->SetEventCallbackEnabled(CategoryFilter("*"), | |
2432 Callback); | |
2433 { | |
2434 TRACE_EVENT0("callback", "duration1"); | |
2435 TraceLog::GetInstance()->SetEnabled( | |
2436 CategoryFilter("*"), | |
2437 TraceLog::RECORDING_MODE, | |
2438 TraceOptions()); | |
2439 TRACE_EVENT0("callback", "duration2"); | |
2440 EndTraceAndFlush(); | |
2441 TRACE_EVENT0("callback", "duration3"); | |
2442 } | |
2443 TraceLog::GetInstance()->SetEventCallbackDisabled(); | |
2444 | |
2445 ASSERT_EQ(6u, collected_events_names_.size()); | |
2446 VerifyCollectedEvent(0, TRACE_EVENT_PHASE_BEGIN, "callback", "duration1"); | |
2447 VerifyCollectedEvent(1, TRACE_EVENT_PHASE_BEGIN, "callback", "duration2"); | |
2448 VerifyCollectedEvent(2, TRACE_EVENT_PHASE_BEGIN, "callback", "duration3"); | |
2449 VerifyCollectedEvent(3, TRACE_EVENT_PHASE_END, "callback", "duration3"); | |
2450 VerifyCollectedEvent(4, TRACE_EVENT_PHASE_END, "callback", "duration2"); | |
2451 VerifyCollectedEvent(5, TRACE_EVENT_PHASE_END, "callback", "duration1"); | |
2452 } | |
2453 | |
2454 TEST_F(TraceEventTestFixture, TraceBufferVectorReportFull) { | |
2455 TraceLog* trace_log = TraceLog::GetInstance(); | |
2456 trace_log->SetEnabled(CategoryFilter("*"), | |
2457 TraceLog::RECORDING_MODE, | |
2458 TraceOptions()); | |
2459 trace_log->logged_events_.reset( | |
2460 trace_log->CreateTraceBufferVectorOfSize(100)); | |
2461 do { | |
2462 TRACE_EVENT_BEGIN_WITH_ID_TID_AND_TIMESTAMP0( | |
2463 "all", "with_timestamp", 0, 0, | |
2464 TimeTicks::NowFromSystemTraceTime().ToInternalValue()); | |
2465 TRACE_EVENT_END_WITH_ID_TID_AND_TIMESTAMP0( | |
2466 "all", "with_timestamp", 0, 0, | |
2467 TimeTicks::NowFromSystemTraceTime().ToInternalValue()); | |
2468 } while (!trace_log->BufferIsFull()); | |
2469 | |
2470 EndTraceAndFlush(); | |
2471 | |
2472 const DictionaryValue* trace_full_metadata = NULL; | |
2473 | |
2474 trace_full_metadata = FindTraceEntry(trace_parsed_, | |
2475 "overflowed_at_ts"); | |
2476 std::string phase; | |
2477 double buffer_limit_reached_timestamp = 0; | |
2478 | |
2479 EXPECT_TRUE(trace_full_metadata); | |
2480 EXPECT_TRUE(trace_full_metadata->GetString("ph", &phase)); | |
2481 EXPECT_EQ("M", phase); | |
2482 EXPECT_TRUE(trace_full_metadata->GetDouble( | |
2483 "args.overflowed_at_ts", &buffer_limit_reached_timestamp)); | |
2484 EXPECT_DOUBLE_EQ( | |
2485 static_cast<double>( | |
2486 trace_log->buffer_limit_reached_timestamp_.ToInternalValue()), | |
2487 buffer_limit_reached_timestamp); | |
2488 | |
2489 // Test that buffer_limit_reached_timestamp's value is between the timestamp | |
2490 // of the last trace event and current time. | |
2491 DropTracedMetadataRecords(); | |
2492 const DictionaryValue* last_trace_event = NULL; | |
2493 double last_trace_event_timestamp = 0; | |
2494 EXPECT_TRUE(trace_parsed_.GetDictionary(trace_parsed_.GetSize() - 1, | |
2495 &last_trace_event)); | |
2496 EXPECT_TRUE(last_trace_event->GetDouble("ts", &last_trace_event_timestamp)); | |
2497 EXPECT_LE(last_trace_event_timestamp, buffer_limit_reached_timestamp); | |
2498 EXPECT_LE(buffer_limit_reached_timestamp, | |
2499 trace_log->OffsetNow().ToInternalValue()); | |
2500 } | |
2501 | |
2502 TEST_F(TraceEventTestFixture, TraceBufferRingBufferGetReturnChunk) { | |
2503 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
2504 TraceLog::RECORDING_MODE, | |
2505 TraceOptions(RECORD_CONTINUOUSLY)); | |
2506 TraceBuffer* buffer = TraceLog::GetInstance()->trace_buffer(); | |
2507 size_t capacity = buffer->Capacity(); | |
2508 size_t num_chunks = capacity / TraceBufferChunk::kTraceBufferChunkSize; | |
2509 uint32 last_seq = 0; | |
2510 size_t chunk_index; | |
2511 EXPECT_EQ(0u, buffer->Size()); | |
2512 | |
2513 scoped_ptr<TraceBufferChunk*[]> chunks(new TraceBufferChunk*[num_chunks]); | |
2514 for (size_t i = 0; i < num_chunks; ++i) { | |
2515 chunks[i] = buffer->GetChunk(&chunk_index).release(); | |
2516 EXPECT_TRUE(chunks[i]); | |
2517 EXPECT_EQ(i, chunk_index); | |
2518 EXPECT_GT(chunks[i]->seq(), last_seq); | |
2519 EXPECT_EQ((i + 1) * TraceBufferChunk::kTraceBufferChunkSize, | |
2520 buffer->Size()); | |
2521 last_seq = chunks[i]->seq(); | |
2522 } | |
2523 | |
2524 // Ring buffer is never full. | |
2525 EXPECT_FALSE(buffer->IsFull()); | |
2526 | |
2527 // Return all chunks in original order. | |
2528 for (size_t i = 0; i < num_chunks; ++i) | |
2529 buffer->ReturnChunk(i, scoped_ptr<TraceBufferChunk>(chunks[i])); | |
2530 | |
2531 // Should recycle the chunks in the returned order. | |
2532 for (size_t i = 0; i < num_chunks; ++i) { | |
2533 chunks[i] = buffer->GetChunk(&chunk_index).release(); | |
2534 EXPECT_TRUE(chunks[i]); | |
2535 EXPECT_EQ(i, chunk_index); | |
2536 EXPECT_GT(chunks[i]->seq(), last_seq); | |
2537 last_seq = chunks[i]->seq(); | |
2538 } | |
2539 | |
2540 // Return all chunks in reverse order. | |
2541 for (size_t i = 0; i < num_chunks; ++i) { | |
2542 buffer->ReturnChunk( | |
2543 num_chunks - i - 1, | |
2544 scoped_ptr<TraceBufferChunk>(chunks[num_chunks - i - 1])); | |
2545 } | |
2546 | |
2547 // Should recycle the chunks in the returned order. | |
2548 for (size_t i = 0; i < num_chunks; ++i) { | |
2549 chunks[i] = buffer->GetChunk(&chunk_index).release(); | |
2550 EXPECT_TRUE(chunks[i]); | |
2551 EXPECT_EQ(num_chunks - i - 1, chunk_index); | |
2552 EXPECT_GT(chunks[i]->seq(), last_seq); | |
2553 last_seq = chunks[i]->seq(); | |
2554 } | |
2555 | |
2556 for (size_t i = 0; i < num_chunks; ++i) | |
2557 buffer->ReturnChunk(i, scoped_ptr<TraceBufferChunk>(chunks[i])); | |
2558 | |
2559 TraceLog::GetInstance()->SetDisabled(); | |
2560 } | |
2561 | |
2562 TEST_F(TraceEventTestFixture, TraceBufferRingBufferHalfIteration) { | |
2563 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
2564 TraceLog::RECORDING_MODE, | |
2565 TraceOptions(RECORD_CONTINUOUSLY)); | |
2566 TraceBuffer* buffer = TraceLog::GetInstance()->trace_buffer(); | |
2567 size_t capacity = buffer->Capacity(); | |
2568 size_t num_chunks = capacity / TraceBufferChunk::kTraceBufferChunkSize; | |
2569 size_t chunk_index; | |
2570 EXPECT_EQ(0u, buffer->Size()); | |
2571 EXPECT_FALSE(buffer->NextChunk()); | |
2572 | |
2573 size_t half_chunks = num_chunks / 2; | |
2574 scoped_ptr<TraceBufferChunk*[]> chunks(new TraceBufferChunk*[half_chunks]); | |
2575 | |
2576 for (size_t i = 0; i < half_chunks; ++i) { | |
2577 chunks[i] = buffer->GetChunk(&chunk_index).release(); | |
2578 EXPECT_TRUE(chunks[i]); | |
2579 EXPECT_EQ(i, chunk_index); | |
2580 } | |
2581 for (size_t i = 0; i < half_chunks; ++i) | |
2582 buffer->ReturnChunk(i, scoped_ptr<TraceBufferChunk>(chunks[i])); | |
2583 | |
2584 for (size_t i = 0; i < half_chunks; ++i) | |
2585 EXPECT_EQ(chunks[i], buffer->NextChunk()); | |
2586 EXPECT_FALSE(buffer->NextChunk()); | |
2587 TraceLog::GetInstance()->SetDisabled(); | |
2588 } | |
2589 | |
2590 TEST_F(TraceEventTestFixture, TraceBufferRingBufferFullIteration) { | |
2591 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
2592 TraceLog::RECORDING_MODE, | |
2593 TraceOptions(RECORD_CONTINUOUSLY)); | |
2594 TraceBuffer* buffer = TraceLog::GetInstance()->trace_buffer(); | |
2595 size_t capacity = buffer->Capacity(); | |
2596 size_t num_chunks = capacity / TraceBufferChunk::kTraceBufferChunkSize; | |
2597 size_t chunk_index; | |
2598 EXPECT_EQ(0u, buffer->Size()); | |
2599 EXPECT_FALSE(buffer->NextChunk()); | |
2600 | |
2601 scoped_ptr<TraceBufferChunk*[]> chunks(new TraceBufferChunk*[num_chunks]); | |
2602 | |
2603 for (size_t i = 0; i < num_chunks; ++i) { | |
2604 chunks[i] = buffer->GetChunk(&chunk_index).release(); | |
2605 EXPECT_TRUE(chunks[i]); | |
2606 EXPECT_EQ(i, chunk_index); | |
2607 } | |
2608 for (size_t i = 0; i < num_chunks; ++i) | |
2609 buffer->ReturnChunk(i, scoped_ptr<TraceBufferChunk>(chunks[i])); | |
2610 | |
2611 for (size_t i = 0; i < num_chunks; ++i) | |
2612 EXPECT_TRUE(chunks[i] == buffer->NextChunk()); | |
2613 EXPECT_FALSE(buffer->NextChunk()); | |
2614 TraceLog::GetInstance()->SetDisabled(); | |
2615 } | |
2616 | |
2617 TEST_F(TraceEventTestFixture, TraceRecordAsMuchAsPossibleMode) { | |
2618 TraceLog::GetInstance()->SetEnabled(CategoryFilter("*"), | |
2619 TraceLog::RECORDING_MODE, | |
2620 TraceOptions(RECORD_AS_MUCH_AS_POSSIBLE)); | |
2621 TraceBuffer* buffer = TraceLog::GetInstance()->trace_buffer(); | |
2622 EXPECT_EQ(512000000UL, buffer->Capacity()); | |
2623 TraceLog::GetInstance()->SetDisabled(); | |
2624 } | |
2625 | |
2626 // Test the category filter. | |
2627 TEST_F(TraceEventTestFixture, CategoryFilter) { | |
2628 // Using the default filter. | |
2629 CategoryFilter default_cf = CategoryFilter( | |
2630 CategoryFilter::kDefaultCategoryFilterString); | |
2631 std::string category_filter_str = default_cf.ToString(); | |
2632 EXPECT_STREQ("-*Debug,-*Test", category_filter_str.c_str()); | |
2633 EXPECT_TRUE(default_cf.IsCategoryGroupEnabled("not-excluded-category")); | |
2634 EXPECT_FALSE( | |
2635 default_cf.IsCategoryGroupEnabled("disabled-by-default-category")); | |
2636 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("Category1,CategoryDebug")); | |
2637 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("CategoryDebug,Category1")); | |
2638 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("CategoryTest,Category2")); | |
2639 | |
2640 // Make sure that upon an empty string, we fall back to the default filter. | |
2641 default_cf = CategoryFilter(); | |
2642 category_filter_str = default_cf.ToString(); | |
2643 EXPECT_STREQ("-*Debug,-*Test", category_filter_str.c_str()); | |
2644 EXPECT_TRUE(default_cf.IsCategoryGroupEnabled("not-excluded-category")); | |
2645 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("Category1,CategoryDebug")); | |
2646 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("CategoryDebug,Category1")); | |
2647 EXPECT_FALSE(default_cf.IsCategoryGroupEnabled("CategoryTest,Category2")); | |
2648 | |
2649 // Using an arbitrary non-empty filter. | |
2650 CategoryFilter cf("included,-excluded,inc_pattern*,-exc_pattern*"); | |
2651 category_filter_str = cf.ToString(); | |
2652 EXPECT_STREQ("included,inc_pattern*,-excluded,-exc_pattern*", | |
2653 category_filter_str.c_str()); | |
2654 EXPECT_TRUE(cf.IsCategoryGroupEnabled("included")); | |
2655 EXPECT_TRUE(cf.IsCategoryGroupEnabled("inc_pattern_category")); | |
2656 EXPECT_FALSE(cf.IsCategoryGroupEnabled("exc_pattern_category")); | |
2657 EXPECT_FALSE(cf.IsCategoryGroupEnabled("excluded")); | |
2658 EXPECT_FALSE(cf.IsCategoryGroupEnabled("not-excluded-nor-included")); | |
2659 EXPECT_FALSE(cf.IsCategoryGroupEnabled("Category1,CategoryDebug")); | |
2660 EXPECT_FALSE(cf.IsCategoryGroupEnabled("CategoryDebug,Category1")); | |
2661 EXPECT_FALSE(cf.IsCategoryGroupEnabled("CategoryTest,Category2")); | |
2662 | |
2663 cf.Merge(default_cf); | |
2664 category_filter_str = cf.ToString(); | |
2665 EXPECT_STREQ("-excluded,-exc_pattern*,-*Debug,-*Test", | |
2666 category_filter_str.c_str()); | |
2667 cf.Clear(); | |
2668 | |
2669 CategoryFilter reconstructed_cf(category_filter_str); | |
2670 category_filter_str = reconstructed_cf.ToString(); | |
2671 EXPECT_STREQ("-excluded,-exc_pattern*,-*Debug,-*Test", | |
2672 category_filter_str.c_str()); | |
2673 | |
2674 // One included category. | |
2675 CategoryFilter one_inc_cf("only_inc_cat"); | |
2676 category_filter_str = one_inc_cf.ToString(); | |
2677 EXPECT_STREQ("only_inc_cat", category_filter_str.c_str()); | |
2678 | |
2679 // One excluded category. | |
2680 CategoryFilter one_exc_cf("-only_exc_cat"); | |
2681 category_filter_str = one_exc_cf.ToString(); | |
2682 EXPECT_STREQ("-only_exc_cat", category_filter_str.c_str()); | |
2683 | |
2684 // Enabling a disabled- category does not require all categories to be traced | |
2685 // to be included. | |
2686 CategoryFilter disabled_cat("disabled-by-default-cc,-excluded"); | |
2687 EXPECT_STREQ("disabled-by-default-cc,-excluded", | |
2688 disabled_cat.ToString().c_str()); | |
2689 EXPECT_TRUE(disabled_cat.IsCategoryGroupEnabled("disabled-by-default-cc")); | |
2690 EXPECT_TRUE(disabled_cat.IsCategoryGroupEnabled("some_other_group")); | |
2691 EXPECT_FALSE(disabled_cat.IsCategoryGroupEnabled("excluded")); | |
2692 | |
2693 // Enabled a disabled- category and also including makes all categories to | |
2694 // be traced require including. | |
2695 CategoryFilter disabled_inc_cat("disabled-by-default-cc,included"); | |
2696 EXPECT_STREQ("included,disabled-by-default-cc", | |
2697 disabled_inc_cat.ToString().c_str()); | |
2698 EXPECT_TRUE( | |
2699 disabled_inc_cat.IsCategoryGroupEnabled("disabled-by-default-cc")); | |
2700 EXPECT_TRUE(disabled_inc_cat.IsCategoryGroupEnabled("included")); | |
2701 EXPECT_FALSE(disabled_inc_cat.IsCategoryGroupEnabled("other_included")); | |
2702 | |
2703 // Test that IsEmptyOrContainsLeadingOrTrailingWhitespace actually catches | |
2704 // categories that are explicitly forbiden. | |
2705 // This method is called in a DCHECK to assert that we don't have these types | |
2706 // of strings as categories. | |
2707 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2708 " bad_category ")); | |
2709 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2710 " bad_category")); | |
2711 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2712 "bad_category ")); | |
2713 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2714 " bad_category")); | |
2715 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2716 "bad_category ")); | |
2717 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2718 " bad_category ")); | |
2719 EXPECT_TRUE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2720 "")); | |
2721 EXPECT_FALSE(CategoryFilter::IsEmptyOrContainsLeadingOrTrailingWhitespace( | |
2722 "good_category")); | |
2723 } | |
2724 | |
2725 void BlockUntilStopped(WaitableEvent* task_start_event, | |
2726 WaitableEvent* task_stop_event) { | |
2727 task_start_event->Signal(); | |
2728 task_stop_event->Wait(); | |
2729 } | |
2730 | |
2731 TEST_F(TraceEventTestFixture, SetCurrentThreadBlocksMessageLoopBeforeTracing) { | |
2732 BeginTrace(); | |
2733 | |
2734 Thread thread("1"); | |
2735 WaitableEvent task_complete_event(false, false); | |
2736 thread.Start(); | |
2737 thread.message_loop()->PostTask( | |
2738 FROM_HERE, Bind(&TraceLog::SetCurrentThreadBlocksMessageLoop, | |
2739 Unretained(TraceLog::GetInstance()))); | |
2740 | |
2741 thread.message_loop()->PostTask( | |
2742 FROM_HERE, Bind(&TraceWithAllMacroVariants, &task_complete_event)); | |
2743 task_complete_event.Wait(); | |
2744 | |
2745 WaitableEvent task_start_event(false, false); | |
2746 WaitableEvent task_stop_event(false, false); | |
2747 thread.message_loop()->PostTask( | |
2748 FROM_HERE, Bind(&BlockUntilStopped, &task_start_event, &task_stop_event)); | |
2749 task_start_event.Wait(); | |
2750 | |
2751 EndTraceAndFlush(); | |
2752 ValidateAllTraceMacrosCreatedData(trace_parsed_); | |
2753 | |
2754 task_stop_event.Signal(); | |
2755 thread.Stop(); | |
2756 } | |
2757 | |
2758 TEST_F(TraceEventTestFixture, ConvertTraceOptionsToInternalOptions) { | |
2759 TraceLog* trace_log = TraceLog::GetInstance(); | |
2760 TraceOptions options(RECORD_UNTIL_FULL); | |
2761 EXPECT_EQ(TraceLog::kInternalRecordUntilFull, | |
2762 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2763 | |
2764 options.record_mode = RECORD_CONTINUOUSLY; | |
2765 EXPECT_EQ(TraceLog::kInternalRecordContinuously, | |
2766 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2767 | |
2768 options.record_mode = ECHO_TO_CONSOLE; | |
2769 EXPECT_EQ(TraceLog::kInternalEchoToConsole, | |
2770 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2771 | |
2772 options.enable_sampling = true; | |
2773 | |
2774 options.record_mode = RECORD_UNTIL_FULL; | |
2775 EXPECT_EQ( | |
2776 TraceLog::kInternalRecordUntilFull | TraceLog::kInternalEnableSampling, | |
2777 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2778 | |
2779 options.record_mode = RECORD_CONTINUOUSLY; | |
2780 EXPECT_EQ( | |
2781 TraceLog::kInternalRecordContinuously | TraceLog::kInternalEnableSampling, | |
2782 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2783 | |
2784 options.record_mode = ECHO_TO_CONSOLE; | |
2785 EXPECT_EQ( | |
2786 TraceLog::kInternalEchoToConsole | TraceLog::kInternalEnableSampling, | |
2787 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2788 | |
2789 options.enable_systrace = true; | |
2790 EXPECT_EQ( | |
2791 TraceLog::kInternalEchoToConsole | TraceLog::kInternalEnableSampling, | |
2792 trace_log->GetInternalOptionsFromTraceOptions(options)); | |
2793 } | |
2794 | |
2795 void SetBlockingFlagAndBlockUntilStopped(WaitableEvent* task_start_event, | |
2796 WaitableEvent* task_stop_event) { | |
2797 TraceLog::GetInstance()->SetCurrentThreadBlocksMessageLoop(); | |
2798 BlockUntilStopped(task_start_event, task_stop_event); | |
2799 } | |
2800 | |
2801 TEST_F(TraceEventTestFixture, SetCurrentThreadBlocksMessageLoopAfterTracing) { | |
2802 BeginTrace(); | |
2803 | |
2804 Thread thread("1"); | |
2805 WaitableEvent task_complete_event(false, false); | |
2806 thread.Start(); | |
2807 | |
2808 thread.message_loop()->PostTask( | |
2809 FROM_HERE, Bind(&TraceWithAllMacroVariants, &task_complete_event)); | |
2810 task_complete_event.Wait(); | |
2811 | |
2812 WaitableEvent task_start_event(false, false); | |
2813 WaitableEvent task_stop_event(false, false); | |
2814 thread.message_loop()->PostTask( | |
2815 FROM_HERE, Bind(&SetBlockingFlagAndBlockUntilStopped, | |
2816 &task_start_event, &task_stop_event)); | |
2817 task_start_event.Wait(); | |
2818 | |
2819 EndTraceAndFlush(); | |
2820 ValidateAllTraceMacrosCreatedData(trace_parsed_); | |
2821 | |
2822 task_stop_event.Signal(); | |
2823 thread.Stop(); | |
2824 } | |
2825 | |
2826 TEST_F(TraceEventTestFixture, ThreadOnceBlocking) { | |
2827 BeginTrace(); | |
2828 | |
2829 Thread thread("1"); | |
2830 WaitableEvent task_complete_event(false, false); | |
2831 thread.Start(); | |
2832 | |
2833 thread.message_loop()->PostTask( | |
2834 FROM_HERE, Bind(&TraceWithAllMacroVariants, &task_complete_event)); | |
2835 task_complete_event.Wait(); | |
2836 task_complete_event.Reset(); | |
2837 | |
2838 WaitableEvent task_start_event(false, false); | |
2839 WaitableEvent task_stop_event(false, false); | |
2840 thread.message_loop()->PostTask( | |
2841 FROM_HERE, Bind(&BlockUntilStopped, &task_start_event, &task_stop_event)); | |
2842 task_start_event.Wait(); | |
2843 | |
2844 // The thread will timeout in this flush. | |
2845 EndTraceAndFlushInThreadWithMessageLoop(); | |
2846 Clear(); | |
2847 | |
2848 // Let the thread's message loop continue to spin. | |
2849 task_stop_event.Signal(); | |
2850 | |
2851 // The following sequence ensures that the FlushCurrentThread task has been | |
2852 // executed in the thread before continuing. | |
2853 task_start_event.Reset(); | |
2854 task_stop_event.Reset(); | |
2855 thread.message_loop()->PostTask( | |
2856 FROM_HERE, Bind(&BlockUntilStopped, &task_start_event, &task_stop_event)); | |
2857 task_start_event.Wait(); | |
2858 task_stop_event.Signal(); | |
2859 Clear(); | |
2860 | |
2861 // TraceLog should discover the generation mismatch and recover the thread | |
2862 // local buffer for the thread without any error. | |
2863 BeginTrace(); | |
2864 thread.message_loop()->PostTask( | |
2865 FROM_HERE, Bind(&TraceWithAllMacroVariants, &task_complete_event)); | |
2866 task_complete_event.Wait(); | |
2867 task_complete_event.Reset(); | |
2868 EndTraceAndFlushInThreadWithMessageLoop(); | |
2869 ValidateAllTraceMacrosCreatedData(trace_parsed_); | |
2870 } | |
2871 | |
2872 std::string* g_log_buffer = NULL; | |
2873 bool MockLogMessageHandler(int, const char*, int, size_t, | |
2874 const std::string& str) { | |
2875 if (!g_log_buffer) | |
2876 g_log_buffer = new std::string(); | |
2877 g_log_buffer->append(str); | |
2878 return false; | |
2879 } | |
2880 | |
2881 TEST_F(TraceEventTestFixture, EchoToConsole) { | |
2882 logging::LogMessageHandlerFunction old_log_message_handler = | |
2883 logging::GetLogMessageHandler(); | |
2884 logging::SetLogMessageHandler(MockLogMessageHandler); | |
2885 | |
2886 TraceLog::GetInstance()->SetEnabled( | |
2887 CategoryFilter("*"), | |
2888 TraceLog::RECORDING_MODE, | |
2889 TraceOptions(ECHO_TO_CONSOLE)); | |
2890 TRACE_EVENT_BEGIN0("a", "begin_end"); | |
2891 { | |
2892 TRACE_EVENT0("b", "duration"); | |
2893 TRACE_EVENT0("b1", "duration1"); | |
2894 } | |
2895 TRACE_EVENT_INSTANT0("c", "instant", TRACE_EVENT_SCOPE_GLOBAL); | |
2896 TRACE_EVENT_END0("a", "begin_end"); | |
2897 | |
2898 EXPECT_NE(std::string::npos, g_log_buffer->find("begin_end[a]\x1b")); | |
2899 EXPECT_NE(std::string::npos, g_log_buffer->find("| duration[b]\x1b")); | |
2900 EXPECT_NE(std::string::npos, g_log_buffer->find("| | duration1[b1]\x1b")); | |
2901 EXPECT_NE(std::string::npos, g_log_buffer->find("| | duration1[b1] (")); | |
2902 EXPECT_NE(std::string::npos, g_log_buffer->find("| duration[b] (")); | |
2903 EXPECT_NE(std::string::npos, g_log_buffer->find("| instant[c]\x1b")); | |
2904 EXPECT_NE(std::string::npos, g_log_buffer->find("begin_end[a] (")); | |
2905 | |
2906 EndTraceAndFlush(); | |
2907 delete g_log_buffer; | |
2908 logging::SetLogMessageHandler(old_log_message_handler); | |
2909 g_log_buffer = NULL; | |
2910 } | |
2911 | |
2912 bool LogMessageHandlerWithTraceEvent(int, const char*, int, size_t, | |
2913 const std::string&) { | |
2914 TRACE_EVENT0("log", "trace_event"); | |
2915 return false; | |
2916 } | |
2917 | |
2918 TEST_F(TraceEventTestFixture, EchoToConsoleTraceEventRecursion) { | |
2919 logging::LogMessageHandlerFunction old_log_message_handler = | |
2920 logging::GetLogMessageHandler(); | |
2921 logging::SetLogMessageHandler(LogMessageHandlerWithTraceEvent); | |
2922 | |
2923 TraceLog::GetInstance()->SetEnabled( | |
2924 CategoryFilter("*"), | |
2925 TraceLog::RECORDING_MODE, | |
2926 TraceOptions(ECHO_TO_CONSOLE)); | |
2927 { | |
2928 // This should not cause deadlock or infinite recursion. | |
2929 TRACE_EVENT0("b", "duration"); | |
2930 } | |
2931 | |
2932 EndTraceAndFlush(); | |
2933 logging::SetLogMessageHandler(old_log_message_handler); | |
2934 } | |
2935 | |
2936 TEST_F(TraceEventTestFixture, TimeOffset) { | |
2937 BeginTrace(); | |
2938 // Let TraceLog timer start from 0. | |
2939 TimeDelta time_offset = TimeTicks::NowFromSystemTraceTime() - TimeTicks(); | |
2940 TraceLog::GetInstance()->SetTimeOffset(time_offset); | |
2941 | |
2942 { | |
2943 TRACE_EVENT0("all", "duration1"); | |
2944 TRACE_EVENT0("all", "duration2"); | |
2945 } | |
2946 TRACE_EVENT_BEGIN_WITH_ID_TID_AND_TIMESTAMP0( | |
2947 "all", "with_timestamp", 0, 0, | |
2948 TimeTicks::NowFromSystemTraceTime().ToInternalValue()); | |
2949 TRACE_EVENT_END_WITH_ID_TID_AND_TIMESTAMP0( | |
2950 "all", "with_timestamp", 0, 0, | |
2951 TimeTicks::NowFromSystemTraceTime().ToInternalValue()); | |
2952 | |
2953 EndTraceAndFlush(); | |
2954 DropTracedMetadataRecords(); | |
2955 | |
2956 double end_time = static_cast<double>( | |
2957 (TimeTicks::NowFromSystemTraceTime() - time_offset).ToInternalValue()); | |
2958 double last_timestamp = 0; | |
2959 for (size_t i = 0; i < trace_parsed_.GetSize(); ++i) { | |
2960 const DictionaryValue* item; | |
2961 EXPECT_TRUE(trace_parsed_.GetDictionary(i, &item)); | |
2962 double timestamp; | |
2963 EXPECT_TRUE(item->GetDouble("ts", ×tamp)); | |
2964 EXPECT_GE(timestamp, last_timestamp); | |
2965 EXPECT_LE(timestamp, end_time); | |
2966 last_timestamp = timestamp; | |
2967 } | |
2968 } | |
2969 | |
2970 TEST_F(TraceEventTestFixture, ConfigureSyntheticDelays) { | |
2971 BeginSpecificTrace("DELAY(test.Delay;0.05)"); | |
2972 | |
2973 base::TimeTicks start = base::TimeTicks::Now(); | |
2974 { | |
2975 TRACE_EVENT_SYNTHETIC_DELAY("test.Delay"); | |
2976 } | |
2977 base::TimeDelta duration = base::TimeTicks::Now() - start; | |
2978 EXPECT_GE(duration.InMilliseconds(), 50); | |
2979 | |
2980 EndTraceAndFlush(); | |
2981 } | |
2982 | |
2983 TEST_F(TraceEventTestFixture, BadSyntheticDelayConfigurations) { | |
2984 const char* const configs[] = { | |
2985 "", | |
2986 "DELAY(", | |
2987 "DELAY(;", | |
2988 "DELAY(;)", | |
2989 "DELAY(test.Delay)", | |
2990 "DELAY(test.Delay;)" | |
2991 }; | |
2992 for (size_t i = 0; i < arraysize(configs); i++) { | |
2993 BeginSpecificTrace(configs[i]); | |
2994 EndTraceAndFlush(); | |
2995 CategoryFilter filter = TraceLog::GetInstance()->GetCurrentCategoryFilter(); | |
2996 EXPECT_EQ(0u, filter.GetSyntheticDelayValues().size()); | |
2997 } | |
2998 } | |
2999 | |
3000 TEST_F(TraceEventTestFixture, SyntheticDelayConfigurationMerging) { | |
3001 CategoryFilter filter1("DELAY(test.Delay1;16)"); | |
3002 CategoryFilter filter2("DELAY(test.Delay2;32)"); | |
3003 filter1.Merge(filter2); | |
3004 EXPECT_EQ(2u, filter1.GetSyntheticDelayValues().size()); | |
3005 } | |
3006 | |
3007 TEST_F(TraceEventTestFixture, SyntheticDelayConfigurationToString) { | |
3008 const char config[] = "DELAY(test.Delay;16;oneshot)"; | |
3009 CategoryFilter filter(config); | |
3010 EXPECT_EQ(config, filter.ToString()); | |
3011 } | |
3012 | |
3013 TEST(TraceOptionsTest, TraceOptionsFromString) { | |
3014 TraceOptions options; | |
3015 EXPECT_TRUE(options.SetFromString("record-until-full")); | |
3016 EXPECT_EQ(RECORD_UNTIL_FULL, options.record_mode); | |
3017 EXPECT_FALSE(options.enable_sampling); | |
3018 EXPECT_FALSE(options.enable_systrace); | |
3019 | |
3020 EXPECT_TRUE(options.SetFromString("record-continuously")); | |
3021 EXPECT_EQ(RECORD_CONTINUOUSLY, options.record_mode); | |
3022 EXPECT_FALSE(options.enable_sampling); | |
3023 EXPECT_FALSE(options.enable_systrace); | |
3024 | |
3025 EXPECT_TRUE(options.SetFromString("trace-to-console")); | |
3026 EXPECT_EQ(ECHO_TO_CONSOLE, options.record_mode); | |
3027 EXPECT_FALSE(options.enable_sampling); | |
3028 EXPECT_FALSE(options.enable_systrace); | |
3029 | |
3030 EXPECT_TRUE(options.SetFromString("record-as-much-as-possible")); | |
3031 EXPECT_EQ(RECORD_AS_MUCH_AS_POSSIBLE, options.record_mode); | |
3032 EXPECT_FALSE(options.enable_sampling); | |
3033 EXPECT_FALSE(options.enable_systrace); | |
3034 | |
3035 EXPECT_TRUE(options.SetFromString("record-until-full, enable-sampling")); | |
3036 EXPECT_EQ(RECORD_UNTIL_FULL, options.record_mode); | |
3037 EXPECT_TRUE(options.enable_sampling); | |
3038 EXPECT_FALSE(options.enable_systrace); | |
3039 | |
3040 EXPECT_TRUE(options.SetFromString("enable-systrace,record-continuously")); | |
3041 EXPECT_EQ(RECORD_CONTINUOUSLY, options.record_mode); | |
3042 EXPECT_FALSE(options.enable_sampling); | |
3043 EXPECT_TRUE(options.enable_systrace); | |
3044 | |
3045 EXPECT_TRUE(options.SetFromString( | |
3046 "enable-systrace, trace-to-console,enable-sampling")); | |
3047 EXPECT_EQ(ECHO_TO_CONSOLE, options.record_mode); | |
3048 EXPECT_TRUE(options.enable_sampling); | |
3049 EXPECT_TRUE(options.enable_systrace); | |
3050 | |
3051 EXPECT_TRUE(options.SetFromString( | |
3052 "record-continuously,record-until-full,trace-to-console")); | |
3053 EXPECT_EQ(ECHO_TO_CONSOLE, options.record_mode); | |
3054 EXPECT_FALSE(options.enable_systrace); | |
3055 EXPECT_FALSE(options.enable_sampling); | |
3056 | |
3057 EXPECT_TRUE(options.SetFromString("")); | |
3058 EXPECT_EQ(RECORD_UNTIL_FULL, options.record_mode); | |
3059 EXPECT_FALSE(options.enable_systrace); | |
3060 EXPECT_FALSE(options.enable_sampling); | |
3061 | |
3062 EXPECT_FALSE(options.SetFromString("foo-bar-baz")); | |
3063 } | |
3064 | |
3065 TEST(TraceOptionsTest, TraceOptionsToString) { | |
3066 // Test that we can intialize TraceOptions from a string got from | |
3067 // TraceOptions.ToString() method to get a same TraceOptions. | |
3068 TraceRecordMode modes[] = {RECORD_UNTIL_FULL, | |
3069 RECORD_CONTINUOUSLY, | |
3070 ECHO_TO_CONSOLE, | |
3071 RECORD_AS_MUCH_AS_POSSIBLE}; | |
3072 bool enable_sampling_options[] = {true, false}; | |
3073 bool enable_systrace_options[] = {true, false}; | |
3074 | |
3075 for (int i = 0; i < 4; ++i) { | |
3076 for (int j = 0; j < 2; ++j) { | |
3077 for (int k = 0; k < 2; ++k) { | |
3078 TraceOptions original_option = TraceOptions(modes[i]); | |
3079 original_option.enable_sampling = enable_sampling_options[j]; | |
3080 original_option.enable_systrace = enable_systrace_options[k]; | |
3081 TraceOptions new_options; | |
3082 EXPECT_TRUE(new_options.SetFromString(original_option.ToString())); | |
3083 EXPECT_EQ(original_option.record_mode, new_options.record_mode); | |
3084 EXPECT_EQ(original_option.enable_sampling, new_options.enable_sampling); | |
3085 EXPECT_EQ(original_option.enable_systrace, new_options.enable_systrace); | |
3086 } | |
3087 } | |
3088 } | |
3089 } | |
3090 | |
3091 | |
3092 } // namespace debug | |
3093 } // namespace base | |
OLD | NEW |