1 // Copyright (c) 2006-2008 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 #ifndef BASE_TRACKED_OBJECTS_H_ 6 #define BASE_TRACKED_OBJECTS_H_ 7 8 #include <map> 9 #include <string> 10 #include <vector> 11 12 #include "base/lock.h" 13 #include "base/task.h" 14 #include "base/thread_local_storage.h" 15 #include "base/tracked.h" 16 17 // TrackedObjects provides a database of stats about objects (generally Tasks) 18 // that are tracked. Tracking means their birth, death, duration, birth thread, 19 // death thread, and birth place are recorded. This data is carefully spread 20 // across a series of objects so that the counts and times can be rapidly 21 // updated without (usually) having to lock the data, and hence there is usually 22 // very little contention caused by the tracking. The data can be viewed via 23 // the about:objects URL, with a variety of sorting and filtering choices. 24 // 25 // Theese classes serve as the basis of a profiler of sorts for the Tasks 26 // system. As a result, design decisions were made to maximize speed, by 27 // minimizing recurring allocation/deallocation, lock contention and data 28 // copying. In the "stable" state, which is reached relatively quickly, there 29 // is no separate marginal allocation cost associated with construction or 30 // destruction of tracked objects, no locks are generally employed, and probably 31 // the largest computational cost is associated with obtaining start and stop 32 // times for instances as they are created and destroyed. The introduction of 33 // worker threads had a slight impact on this approach, and required use of some 34 // locks when accessing data from the worker threads. 35 // 36 // The following describes the lifecycle of tracking an instance. 37 // 38 // First off, when the instance is created, the FROM_HERE macro is expanded 39 // to specify the birth place (file, line, function) where the instance was 40 // created. That data is used to create a transient Location instance 41 // encapsulating the above triple of information. The strings (like __FILE__) 42 // are passed around by reference, with the assumption that they are static, and 43 // will never go away. This ensures that the strings can be dealt with as atoms 44 // with great efficiency (i.e., copying of strings is never needed, and 45 // comparisons for equality can be based on pointer comparisons). 46 // 47 // Next, a Births instance is created for use ONLY on the thread where this 48 // instance was created. That Births instance records (in a base class 49 // BirthOnThread) references to the static data provided in a Location instance, 50 // as well as a pointer specifying the thread on which the birth takes place. 51 // Hence there is at most one Births instance for each Location on each thread. 52 // The derived Births class contains slots for recording statistics about all 53 // instances born at the same location. Statistics currently include only the 54 // count of instances constructed. 55 // Since the base class BirthOnThread contains only constant data, it can be 56 // freely accessed by any thread at any time (i.e., only the statistic needs to 57 // be handled carefully, and it is ONLY read or written by the birth thread). 58 // 59 // Having now either constructed or found the Births instance described above, a 60 // pointer to the Births instance is then embedded in a base class of the 61 // instance we're tracking (usually a Task). This fact alone is very useful in 62 // debugging, when there is a question of where an instance came from. In 63 // addition, the birth time is also embedded in the base class Tracked (see 64 // tracked.h), and used to later evaluate the lifetime duration. 65 // As a result of the above embedding, we can (for any tracked instance) find 66 // out its location of birth, and thread of birth, without using any locks, as 67 // all that data is constant across the life of the process. 68 // 69 // The amount of memory used in the above data structures depends on how many 70 // threads there are, and how many Locations of construction there are. 71 // Fortunately, we don't use memory that is the product of those two counts, but 72 // rather we only need one Births instance for each thread that constructs an 73 // instance at a Location. In many cases, instances (such as Tasks) are only 74 // created on one thread, so the memory utilization is actually fairly 75 // restrained. 76 // 77 // Lastly, when an instance is deleted, the final tallies of statistics are 78 // carefully accumulated. That tallying wrties into slots (members) in a 79 // collection of DeathData instances. For each birth place Location that is 80 // destroyed on a thread, there is a DeathData instance to record the additional 81 // death count, as well as accumulate the lifetime duration of the instance as 82 // it is destroyed (dies). By maintaining a single place to aggregate this 83 // addition *only* for the given thread, we avoid the need to lock such 84 // DeathData instances. 85 // 86 // With the above lifecycle description complete, the major remaining detail is 87 // explaining how each thread maintains a list of DeathData instances, and of 88 // Births instances, and is able to avoid additional (redundant/unnecessary) 89 // allocations. 90 // 91 // Each thread maintains a list of data items specific to that thread in a 92 // ThreadData instance (for that specific thread only). The two critical items 93 // are lists of DeathData and Births instances. These lists are maintained in 94 // STL maps, which are indexed by Location. As noted earlier, we can compare 95 // locations very efficiently as we consider the underlying data (file, 96 // function, line) to be atoms, and hence pointer comparison is used rather than 97 // (slow) string comparisons. 98 // 99 // To provide a mechanism for iterating over all "known threads," which means 100 // threads that have recorded a birth or a death, we create a singly linked list 101 // of ThreadData instances. Each such instance maintains a pointer to the next 102 // one. A static member of ThreadData provides a pointer to the first_ item on 103 // this global list, and access to that first_ item requires the use of a lock_. 104 // When new ThreadData instances is added to the global list, it is pre-pended, 105 // which ensures that any prior acquisition of the list is valid (i.e., the 106 // holder can iterate over it without fear of it changing, or the necessity of 107 // using an additional lock. Iterations are actually pretty rare (used 108 // primarilly for cleanup, or snapshotting data for display), so this lock has 109 // very little global performance impact. 110 // 111 // The above description tries to define the high performance (run time) 112 // portions of these classes. After gathering statistics, calls instigated 113 // by visiting about:objects will assemble and aggregate data for display. The 114 // following data structures are used for producing such displays. They are 115 // not performance critical, and their only major constraint is that they should 116 // be able to run concurrently with ongoing augmentation of the birth and death 117 // data. 118 // 119 // For a given birth location, information about births are spread across data 120 // structures that are asynchronously changing on various threads. For display 121 // purposes, we need to construct Snapshot instances for each combination of 122 // birth thread, death thread, and location, along with the count of such 123 // lifetimes. We gather such data into a Snapshot instances, so that such 124 // instances can be sorted and aggregated (and remain frozen during our 125 // processing). Snapshot instances use pointers to constant portions of the 126 // birth and death datastructures, but have local (frozen) copies of the actual 127 // statistics (birth count, durations, etc. etc.). 128 // 129 // A DataCollector is a container object that holds a set of Snapshots. A 130 // DataCollector can be passed from thread to thread, and each thread 131 // contributes to it by adding or updating Snapshot instances. DataCollector 132 // instances are thread safe containers which are passed to various threads to 133 // accumulate all Snapshot instances. 134 // 135 // After an array of Snapshots instances are colleted into a DataCollector, they 136 // need to be sorted, and possibly aggregated (example: how many threads are in 137 // a specific consecutive set of Snapshots? What was the total birth count for 138 // that set? etc.). Aggregation instances collect running sums of any set of 139 // snapshot instances, and are used to print sub-totals in an about:objects 140 // page. 141 // 142 // TODO(jar): I need to store DataCollections, and provide facilities for taking 143 // the difference between two gathered DataCollections. For now, I'm just 144 // adding a hack that Reset()'s to zero all counts and stats. This is also 145 // done in a slighly thread-unsafe fashion, as the reseting is done 146 // asynchronously relative to ongoing updates, and worse yet, some data fields 147 // are 64bit quantities, and are not atomicly accessed (reset or incremented 148 // etc.). For basic profiling, this will work "most of the time," and should be 149 // sufficient... but storing away DataCollections is the "right way" to do this. 150 // 151 class MessageLoop; 152 153 154 namespace tracked_objects { 155 156 //------------------------------------------------------------------------------ 157 // For a specific thread, and a specific birth place, the collection of all 158 // death info (with tallies for each death thread, to prevent access conflicts). 159 class ThreadData; 160 class BirthOnThread { 161 public: 162 explicit BirthOnThread(const Location& location); 163 164 const Location location() const { return location_; } 165 const ThreadData* birth_thread() const { return birth_thread_; } 166 167 private: 168 // File/lineno of birth. This defines the essence of the type, as the context 169 // of the birth (construction) often tell what the item is for. This field 170 // is const, and hence safe to access from any thread. 171 const Location location_; 172 173 // The thread that records births into this object. Only this thread is 174 // allowed to access birth_count_ (which changes over time). 175 const ThreadData* birth_thread_; // The thread this birth took place on. 176 177 DISALLOW_COPY_AND_ASSIGN(BirthOnThread); 178 }; 179 180 //------------------------------------------------------------------------------ 181 // A class for accumulating counts of births (without bothering with a map<>). 182 183 class Births: public BirthOnThread { 184 public: 185 explicit Births(const Location& location); 186 187 int birth_count() const { return birth_count_; } 188 189 // When we have a birth we update the count for this BirhPLace. 190 void RecordBirth() { ++birth_count_; } 191 192 // When a birthplace is changed (updated), we need to decrement the counter 193 // for the old instance. 194 void ForgetBirth() { --birth_count_; } // We corrected a birth place. 195 196 // Hack to quickly reset all counts to zero. 197 void Clear() { birth_count_ = 0; } 198 199 private: 200 // The number of births on this thread for our location_. 201 int birth_count_; 202 203 DISALLOW_COPY_AND_ASSIGN(Births); 204 }; 205 206 //------------------------------------------------------------------------------ 207 // Basic info summarizing multiple destructions of an object with a single 208 // birthplace (fixed Location). Used both on specific threads, and also used 209 // in snapshots when integrating assembled data. 210 211 class DeathData { 212 public: 213 // Default initializer. 214 DeathData() : count_(0), square_duration_(0) {} 215 216 // When deaths have not yet taken place, and we gather data from all the 217 // threads, we create DeathData stats that tally the number of births without 218 // a corrosponding death. 219 explicit DeathData(int count) : count_(count), square_duration_(0) {} 220 221 void RecordDeath(const base::TimeDelta& duration); 222 223 // Metrics accessors. 224 int count() const { return count_; } 225 base::TimeDelta life_duration() const { return life_duration_; } 226 int64 square_duration() const { return square_duration_; } 227 int AverageMsDuration() const; 228 double StandardDeviation() const; 229 230 // Accumulate metrics from other into this. 231 void AddDeathData(const DeathData& other); 232 233 // Simple print of internal state. 234 void Write(std::string* output) const; 235 236 // Reset all tallies to zero. 237 void Clear(); 238 239 private: 240 int count_; // Number of destructions. 241 base::TimeDelta life_duration_; // Sum of all lifetime durations. 242 int64 square_duration_; // Sum of squares in milliseconds. 243 }; 244 245 //------------------------------------------------------------------------------ 246 // A temporary collection of data that can be sorted and summarized. It is 247 // gathered (carefully) from many threads. Instances are held in arrays and 248 // processed, filtered, and rendered. 249 // The source of this data was collected on many threads, and is asynchronously 250 // changing. The data in this instance is not asynchronously changing. 251 252 class Snapshot { 253 public: 254 // When snapshotting a full life cycle set (birth-to-death), use this: 255 Snapshot(const BirthOnThread& birth_on_thread, const ThreadData& death_thread, 256 const DeathData& death_data); 257 258 // When snapshotting a birth, with no death yet, use this: 259 Snapshot(const BirthOnThread& birth_on_thread, int count); 260 261 262 const ThreadData* birth_thread() const { return birth_->birth_thread(); } 263 const Location location() const { return birth_->location(); } 264 const BirthOnThread& birth() const { return *birth_; } 265 const ThreadData* death_thread() const {return death_thread_; } 266 const DeathData& death_data() const { return death_data_; } 267 const std::string DeathThreadName() const; 268 269 int count() const { return death_data_.count(); } 270 base::TimeDelta life_duration() const { return death_data_.life_duration(); } 271 int64 square_duration() const { return death_data_.square_duration(); } 272 int AverageMsDuration() const { return death_data_.AverageMsDuration(); } 273 274 void Write(std::string* output) const; 275 276 void Add(const Snapshot& other); 277 278 private: 279 const BirthOnThread* birth_; // Includes Location and birth_thread. 280 const ThreadData* death_thread_; 281 DeathData death_data_; 282 }; 283 //------------------------------------------------------------------------------ 284 // DataCollector is a container class for Snapshot and BirthOnThread count 285 // items. It protects the gathering under locks, so that it could be called via 286 // Posttask on any threads, or passed to all the target threads in parallel. 287 288 class DataCollector { 289 public: 290 typedef std::vector<Snapshot> Collection; 291 292 // Construct with a list of how many threads should contribute. This helps us 293 // determine (in the async case) when we are done with all contributions. 294 DataCollector(); 295 296 // Add all stats from the indicated thread into our arrays. This function is 297 // mutex protected, and *could* be called from any threads (although current 298 // implementation serialized calls to Append). 299 void Append(const ThreadData& thread_data); 300 301 // After the accumulation phase, the following accessor is used to process the 302 // data. 303 Collection* collection(); 304 305 // After collection of death data is complete, we can add entries for all the 306 // remaining living objects. 307 void AddListOfLivingObjects(); 308 309 private: 310 // This instance may be provided to several threads to contribute data. The 311 // following counter tracks how many more threads will contribute. When it is 312 // zero, then all asynchronous contributions are complete, and locked access 313 // is no longer needed. 314 int count_of_contributing_threads_; 315 316 // The array that we collect data into. 317 Collection collection_; 318 319 // The total number of births recorded at each location for which we have not 320 // seen a death count. 321 typedef std::map<const BirthOnThread*, int> BirthCount; 322 BirthCount global_birth_count_; 323 324 Lock accumulation_lock_; // Protects access during accumulation phase. 325 326 DISALLOW_COPY_AND_ASSIGN(DataCollector); 327 }; 328 329 //------------------------------------------------------------------------------ 330 // Aggregation contains summaries (totals and subtotals) of groups of Snapshot 331 // instances to provide printing of these collections on a single line. 332 333 class Aggregation: public DeathData { 334 public: 335 Aggregation() : birth_count_(0) {} 336 337 void AddDeathSnapshot(const Snapshot& snapshot); 338 void AddBirths(const Births& births); 339 void AddBirth(const BirthOnThread& birth); 340 void AddBirthPlace(const Location& location); 341 void Write(std::string* output) const; 342 void Clear(); 343 344 private: 345 int birth_count_; 346 std::map<std::string, int> birth_files_; 347 std::map<Location, int> locations_; 348 std::map<const ThreadData*, int> birth_threads_; 349 DeathData death_data_; 350 std::map<const ThreadData*, int> death_threads_; 351 352 DISALLOW_COPY_AND_ASSIGN(Aggregation); 353 }; 354 355 //------------------------------------------------------------------------------ 356 // Comparator is a class that supports the comparison of Snapshot instances. 357 // An instance is actually a list of chained Comparitors, that can provide for 358 // arbitrary ordering. The path portion of an about:objects URL is translated 359 // into such a chain, which is then used to order Snapshot instances in a 360 // vector. It orders them into groups (for aggregation), and can also order 361 // instances within the groups (for detailed rendering of the instances in an 362 // aggregation). 363 364 class Comparator { 365 public: 366 // Selector enum is the token identifier for each parsed keyword, most of 367 // which specify a sort order. 368 // Since it is not meaningful to sort more than once on a specific key, we 369 // use bitfields to accumulate what we have sorted on so far. 370 enum Selector { 371 // Sort orders. 372 NIL = 0, 373 BIRTH_THREAD = 1, 374 DEATH_THREAD = 2, 375 BIRTH_FILE = 4, 376 BIRTH_FUNCTION = 8, 377 BIRTH_LINE = 16, 378 COUNT = 32, 379 AVERAGE_DURATION = 64, 380 TOTAL_DURATION = 128, 381 382 // Imediate action keywords. 383 RESET_ALL_DATA = -1, 384 }; 385 386 explicit Comparator(); 387 388 // Reset the comparator to a NIL selector. Clear() and recursively delete any 389 // tiebreaker_ entries. NOTE: We can't use a standard destructor, because 390 // the sort algorithm makes copies of this object, and then deletes them, 391 // which would cause problems (either we'd make expensive deep copies, or we'd 392 // do more thna one delete on a tiebreaker_. 393 void Clear(); 394 395 // The less() operator for sorting the array via std::sort(). 396 bool operator()(const Snapshot& left, const Snapshot& right) const; 397 398 void Sort(DataCollector::Collection* collection) const; 399 400 // Check to see if the items are sort equivalents (should be aggregated). 401 bool Equivalent(const Snapshot& left, const Snapshot& right) const; 402 403 // Check to see if all required fields are present in the given sample. 404 bool Acceptable(const Snapshot& sample) const; 405 406 // A comparator can be refined by specifying what to do if the selected basis 407 // for comparison is insufficient to establish an ordering. This call adds 408 // the indicated attribute as the new "least significant" basis of comparison. 409 void SetTiebreaker(Selector selector, const std::string& required); 410 411 // Indicate if this instance is set up to sort by the given Selector, thereby 412 // putting that information in the SortGrouping, so it is not needed in each 413 // printed line. 414 bool IsGroupedBy(Selector selector) const; 415 416 // Using the tiebreakers as set above, we mostly get an ordering, which 417 // equivalent groups. If those groups are displayed (rather than just being 418 // aggregated, then the following is used to order them (within the group). 419 void SetSubgroupTiebreaker(Selector selector); 420 421 // Translate a keyword and restriction in URL path to a selector for sorting. 422 void ParseKeyphrase(const std::string& key_phrase); 423 424 // Parse a query in an about:objects URL to decide on sort ordering. 425 bool ParseQuery(const std::string& query); 426 427 // Output a header line that can be used to indicated what items will be 428 // collected in the group. It lists all (potentially) tested attributes and 429 // their values (in the sample item). 430 bool WriteSortGrouping(const Snapshot& sample, std::string* output) const; 431 432 // Output a sample, with SortGroup details not displayed. 433 void WriteSnapshot(const Snapshot& sample, std::string* output) const; 434 435 private: 436 // The selector directs this instance to compare based on the specified 437 // members of the tested elements. 438 enum Selector selector_; 439 440 // For filtering into acceptable and unacceptable snapshot instance, the 441 // following is required to be a substring of the selector_ field. 442 std::string required_; 443 444 // If this instance can't decide on an ordering, we can consult a tie-breaker 445 // which may have a different basis of comparison. 446 Comparator* tiebreaker_; 447 448 // We or together all the selectors we sort on (not counting sub-group 449 // selectors), so that we can tell if we've decided to group on any given 450 // criteria. 451 int combined_selectors_; 452 453 // Some tiebreakrs are for subgroup ordering, and not for basic ordering (in 454 // preparation for aggregation). The subgroup tiebreakers are not consulted 455 // when deciding if two items are in equivalent groups. This flag tells us 456 // to ignore the tiebreaker when doing Equivalent() testing. 457 bool use_tiebreaker_for_sort_only_; 458 }; 459 460 461 //------------------------------------------------------------------------------ 462 // For each thread, we have a ThreadData that stores all tracking info generated 463 // on this thread. This prevents the need for locking as data accumulates. 464 465 class ThreadData { 466 public: 467 typedef std::map<Location, Births*> BirthMap; 468 typedef std::map<const Births*, DeathData> DeathMap; 469 470 ThreadData(); 471 472 // Using Thread Local Store, find the current instance for collecting data. 473 // If an instance does not exist, construct one (and remember it for use on 474 // this thread. 475 // If shutdown has already started, and we don't yet have an instance, then 476 // return null. 477 static ThreadData* current(); 478 479 // For a given about:objects URL, develop resulting HTML, and append to 480 // output. 481 static void WriteHTML(const std::string& query, std::string* output); 482 483 // For a given accumulated array of results, use the comparator to sort and 484 // subtotal, writing the results to the output. 485 static void WriteHTMLTotalAndSubtotals( 486 const DataCollector::Collection& match_array, 487 const Comparator& comparator, std::string* output); 488 489 // In this thread's data, record a new birth. 490 Births* TallyABirth(const Location& location); 491 492 // Find a place to record a death on this thread. 493 void TallyADeath(const Births& lifetimes, const base::TimeDelta& duration); 494 495 // (Thread safe) Get start of list of instances. 496 static ThreadData* first(); 497 // Iterate through the null terminated list of instances. 498 ThreadData* next() const { return next_; } 499 500 MessageLoop* message_loop() const { return message_loop_; } 501 const std::string ThreadName() const; 502 503 // Using our lock, make a copy of the specified maps. These calls may arrive 504 // from non-local threads, and are used to quickly scan data from all threads 505 // in order to build an HTML page for about:objects. 506 void SnapshotBirthMap(BirthMap *output) const; 507 void SnapshotDeathMap(DeathMap *output) const; 508 509 // Hack: asynchronously clear all birth counts and death tallies data values 510 // in all ThreadData instances. The numerical (zeroing) part is done without 511 // use of a locks or atomics exchanges, and may (for int64 values) produce 512 // bogus counts VERY rarely. 513 static void ResetAllThreadData(); 514 515 // Using our lock to protect the iteration, Clear all birth and death data. 516 void Reset(); 517 518 // Using the "known list of threads" gathered during births and deaths, the 519 // following attempts to run the given function once all all such threads. 520 // Note that the function can only be run on threads which have a message 521 // loop! 522 static void RunOnAllThreads(void (*Func)()); 523 524 // Set internal status_ to either become ACTIVE, or later, to be SHUTDOWN, 525 // based on argument being true or false respectively. 526 // IF tracking is not compiled in, this function will return false. 527 static bool StartTracking(bool status); 528 static bool IsActive(); 529 530 #ifdef OS_WIN 531 // WARNING: ONLY call this function when all MessageLoops are still intact for 532 // all registered threads. IF you call it later, you will crash. 533 // Note: You don't need to call it at all, and you can wait till you are 534 // single threaded (again) to do the cleanup via 535 // ShutdownSingleThreadedCleanup(). 536 // Start the teardown (shutdown) process in a multi-thread mode by disabling 537 // further additions to thread database on all threads. First it makes a 538 // local (locked) change to prevent any more threads from registering. Then 539 // it Posts a Task to all registered threads to be sure they are aware that no 540 // more accumulation can take place. 541 static void ShutdownMultiThreadTracking(); 542 #endif 543 544 // WARNING: ONLY call this function when you are running single threaded 545 // (again) and all message loops and threads have terminated. Until that 546 // point some threads may still attempt to write into our data structures. 547 // Delete recursively all data structures, starting with the list of 548 // ThreadData instances. 549 static void ShutdownSingleThreadedCleanup(); 550 551 private: 552 // Current allowable states of the tracking system. The states always 553 // proceed towards SHUTDOWN, and never go backwards. 554 enum Status { 555 UNINITIALIZED, 556 ACTIVE, 557 SHUTDOWN, 558 }; 559 560 // A class used to count down which is accessed by several threads. This is 561 // used to make sure RunOnAllThreads() actually runs a task on the expected 562 // count of threads. 563 class ThreadSafeDownCounter { 564 public: 565 // Constructor sets the count, once and for all. 566 explicit ThreadSafeDownCounter(size_t count); 567 568 // Decrement the count, and return true if we hit zero. Also delete this 569 // instance automatically when we hit zero. 570 bool LastCaller(); 571 572 private: 573 size_t remaining_count_; 574 Lock lock_; // protect access to remaining_count_. 575 }; 576 577 #ifdef OS_WIN 578 // A Task class that runs a static method supplied, and checks to see if this 579 // is the last tasks instance (on last thread) that will run the method. 580 // IF this is the last run, then the supplied event is signalled. 581 class RunTheStatic : public Task { 582 public: 583 typedef void (*FunctionPointer)(); 584 RunTheStatic(FunctionPointer function, 585 HANDLE completion_handle, 586 ThreadSafeDownCounter* counter); 587 // Run the supplied static method, and optionally set the event. 588 void Run(); 589 590 private: 591 FunctionPointer function_; 592 HANDLE completion_handle_; 593 // Make sure enough tasks are called before completion is signaled. 594 ThreadSafeDownCounter* counter_; 595 596 DISALLOW_COPY_AND_ASSIGN(RunTheStatic); 597 }; 598 #endif 599 600 // Each registered thread is called to set status_ to SHUTDOWN. 601 // This is done redundantly on every registered thread because it is not 602 // protected by a mutex. Running on all threads guarantees we get the 603 // notification into the memory cache of all possible threads. 604 static void ShutdownDisablingFurtherTracking(); 605 606 // We use thread local store to identify which ThreadData to interact with. 607 static TLSSlot tls_index_; 608 609 // Link to the most recently created instance (starts a null terminated list). 610 static ThreadData* first_; 611 // Protection for access to first_. 612 static Lock list_lock_; 613 614 // We set status_ to SHUTDOWN when we shut down the tracking service. This 615 // setting is redundantly established by all participating threads so that we 616 // are *guaranteed* (without locking) that all threads can "see" the status 617 // and avoid additional calls into the service. 618 static Status status_; 619 620 // Link to next instance (null terminated list). Used to globally track all 621 // registered instances (corresponds to all registered threads where we keep 622 // data). 623 ThreadData* next_; 624 625 // The message loop where tasks needing to access this instance's private data 626 // should be directed. Since some threads have no message loop, some 627 // instances have data that can't be (safely) modified externally. 628 MessageLoop* message_loop_; 629 630 // A map used on each thread to keep track of Births on this thread. 631 // This map should only be accessed on the thread it was constructed on. 632 // When a snapshot is needed, this structure can be locked in place for the 633 // duration of the snapshotting activity. 634 BirthMap birth_map_; 635 636 // Similar to birth_map_, this records informations about death of tracked 637 // instances (i.e., when a tracked instance was destroyed on this thread). 638 // It is locked before changing, and hence other threads may access it by 639 // locking before reading it. 640 DeathMap death_map_; 641 642 // Lock to protect *some* access to BirthMap and DeathMap. The maps are 643 // regularly read and written on this thread, but may only be read from other 644 // threads. To support this, we acquire this lock if we are writing from this 645 // thread, or reading from another thread. For reading from this thread we 646 // don't need a lock, as there is no potential for a conflict since the 647 // writing is only done from this thread. 648 mutable Lock lock_; 649 650 DISALLOW_COPY_AND_ASSIGN(ThreadData); 651 }; 652 653 654 //------------------------------------------------------------------------------ 655 // Provide simple way to to start global tracking, and to tear down tracking 656 // when done. Note that construction and destruction of this object must be 657 // done when running in threaded mode (before spawning a lot of threads 658 // for construction, and after shutting down all the threads for destruction). 659 660 // To prevent grabbing thread local store resources time and again if someone 661 // chooses to try to re-run the browser many times, we maintain global state and 662 // only allow the tracking system to be started up at most once, and shutdown 663 // at most once. See bug 31344 for an example. 664 665 class AutoTracking { 666 public: 667 AutoTracking() { 668 if (state_ != kNeverBeenRun) 669 return; 670 ThreadData::StartTracking(true); 671 state_ = kRunning; 672 } 673 674 ~AutoTracking() { 675 #ifndef NDEBUG 676 if (state_ != kRunning) 677 return; 678 // Don't call these in a Release build: they just waste time. 679 // The following should ONLY be called when in single threaded mode. It is 680 // unsafe to do this cleanup if other threads are still active. 681 // It is also very unnecessary, so I'm only doing this in debug to satisfy 682 // purify (if we need to!). 683 ThreadData::ShutdownSingleThreadedCleanup(); 684 state_ = kTornDownAndStopped; 685 #endif 686 } 687 688 private: 689 enum State { 690 kNeverBeenRun, 691 kRunning, 692 kTornDownAndStopped, 693 }; 694 static State state_; 695 696 DISALLOW_COPY_AND_ASSIGN(AutoTracking); 697 }; 698 699 700 } // namespace tracked_objects 701 702 #endif // BASE_TRACKED_OBJECTS_H_ 703