Endless thread safe timeline recorder

runtime/vm/thread.cc

 // Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #include "vm/thread.h"
 
 #include "vm/growable_array.h"
 #include "vm/isolate.h"
 #include "vm/lockers.h"
 #include "vm/object.h"
@@ skipping 90 matching lines @@
 #undef INIT_VALUE
 }
 
 
 void Thread::Schedule(Isolate* isolate) {
   State st;
   if (isolate->thread_registry()->RestoreStateTo(this, &st)) {
     ASSERT(isolate->thread_registry()->Contains(this));
     state_ = st;
   }
+  PostSchedule();
+}
+
+
+void Thread::PostSchedule() {
+  if ((current_block() == NULL) || current_block()->IsFull()) {
+    // Thread doesn't have a timeline block or it is full, request a new one.

[koda, 2015/08/07 01:09:54]

Why not let these cases be handled naturally when we actually try to add another
entry?

[Cutch, 2015/08/07 16:47:42]

Done.

+    set_current_block(isolate_->GetNewTimelineBlock());
+  }
 }
 
 
 void Thread::Unschedule() {
   ThreadRegistry* reg = isolate_->thread_registry();
   ASSERT(reg->Contains(this));
   reg->SaveStateFrom(this, state_);
   ClearState();
 }
 
@@ skipping 137 matching lines @@
 #define COMPUTE_OFFSET(type_name, member_name, expr, default_init_value)       \
   ASSERT((expr)->IsVMHeapObject());                                            \
   if (object.raw() == expr) return Thread::member_name##offset();
 CACHED_VM_OBJECTS_LIST(COMPUTE_OFFSET)
 #undef COMPUTE_OFFSET
   UNREACHABLE();
   return -1;
 }
 
 }  // namespace dart