Reimplemented zone memory tracking to avoid race conditions that were causing crashes in the previo…

runtime/vm/thread_test.cc

 // Copyright (c) 2012, 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 "platform/assert.h"
 #include "vm/isolate.h"
 #include "vm/lockers.h"
 #include "vm/unit_test.h"
 #include "vm/profiler.h"
 #include "vm/safepoint.h"
@@ skipping 273 matching lines @@
   Monitor* monitor_;
   intptr_t* done_count_;
   bool* wait_;
 };
 
 
 TEST_CASE(ManySimpleTasksWithZones) {
   const int kTaskCount = 10;
   Monitor monitor;
   Monitor sync;
-  Thread* threads[kTaskCount + 1];
+  Thread* threads[kTaskCount];
   Isolate* isolate = Thread::Current()->isolate();
   intptr_t done_count = 0;
   bool wait = true;
-  threads[kTaskCount] = Thread::Current();
 
   EXPECT(isolate->heap()->GrowthControlState());
   isolate->heap()->DisableGrowthControl();
   for (intptr_t i = 0; i < kTaskCount; i++) {
     Dart::thread_pool()->Run(new SimpleTaskWithZoneAllocation(
         (i + 1), isolate, &threads[i], &sync, &monitor, &done_count, &wait));
   }
   // Wait until all spawned tasks finish their memory operations.
   {
     MonitorLocker ml(&monitor);
     while (done_count < kTaskCount) {
       ml.Wait();
     }
     // Reset the done counter for use later.
     done_count = 0;
   }
 
   // Get the information for the current isolate.
   // We only need to check the current isolate since all tasks are spawned
   // inside this single isolate.
   JSONStream stream;
   isolate->PrintJSON(&stream, false);
   const char* json = stream.ToCString();
 
   Thread* current_thread = Thread::Current();
 
   // Confirm all expected entries are in the JSON output.
-  for (intptr_t i = 0; i < kTaskCount + 1; i++) {
+  for (intptr_t i = 0; i < kTaskCount; i++) {
     Thread* thread = threads[i];
     StackZone stack_zone(current_thread);
     Zone* current_zone = current_thread->zone();
 
     // Check the thread exists and is the correct size.
-    char* thread_info_buf =
-        OS::SCreate(current_zone,
-                    "\"type\":\"_Thread\","
-                    "\"id\":\"threads\\/%" Pd
-                    "\","
-                    "\"kind\":\"%s\","
-                    "\"_memoryHighWatermark\":\"%" Pu "\"",
-                    OSThread::ThreadIdToIntPtr(thread->os_thread()->trace_id()),
-                    Thread::TaskKindToCString(thread->task_kind()),
-                    thread->memory_high_watermark());
-
+    char* thread_info_buf = OS::SCreate(
+        current_zone,
+        "\"type\":\"_Thread\","
+        "\"id\":\"threads\\/%" Pd
+        "\","
+        "\"kind\":\"%s\","
+        "\"_zoneHighWatermark\":\"%" Pu
+        "\","
+        "\"_zoneCapacity\":\"%" Pu "\"",
+        OSThread::ThreadIdToIntPtr(thread->os_thread()->trace_id()),
+        Thread::TaskKindToCString(thread->task_kind()),
+        thread->zone_high_watermark(), thread->current_zone_capacity());
     EXPECT_SUBSTRING(thread_info_buf, json);
   }
 
   // Unblock the tasks so they can finish.
   {
     MonitorLocker sync_ml(&sync);
     wait = false;
     sync_ml.NotifyAll();
   }
   // Now wait for them all to exit before destroying the isolate.
@@ skipping 427 matching lines @@
       TransitionVMToBlocked transition(thread);
       MonitorLocker ml(&done_monitor);
       if (done) {
         break;
       }
     }
   }
 }
 
 }  // namespace dart