[Fuchsia] Enable CPU profiling for the standalone VM

runtime/vm/os_thread_fuchsia.cc

 // Copyright (c) 2016, 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/globals.h"  // NOLINT
 #if defined(HOST_OS_FUCHSIA)
 
+#include "vm/os.h"
 #include "vm/os_thread.h"
 #include "vm/os_thread_fuchsia.h"
 
 #include <errno.h>  // NOLINT
+#include <magenta/status.h>
 #include <magenta/syscalls.h>
 #include <magenta/syscalls/object.h>
 #include <magenta/threads.h>
 #include <magenta/types.h>
 
 #include "platform/assert.h"
 
 namespace dart {
 
 #define VALIDATE_PTHREAD_RESULT(result)                                        \
@@ skipping 134 matching lines @@
   return kStackSize;
 }
 
 
 ThreadId OSThread::GetCurrentThreadId() {
   mx_info_handle_basic_t info;
   mx_handle_t thread_handle = thrd_get_mx_handle(thrd_current());
   mx_status_t status =
       mx_object_get_info(thread_handle, MX_INFO_HANDLE_BASIC, &info,
                          sizeof(info), nullptr, nullptr);
-  return status == NO_ERROR ? info.koid : MX_KOID_INVALID;
+  if (status != NO_ERROR) {
+    FATAL1("Failed to get thread koid: %s\n", mx_status_get_string(status));
+  }
+  return info.koid;
 }
 
 
 #ifndef PRODUCT
 ThreadId OSThread::GetCurrentThreadTraceId() {
   return pthread_self();
 }
 #endif  // PRODUCT
 
 
@@ skipping 214 matching lines @@
 #if defined(DEBUG)
   // When running with assertions enabled we track the owner.
   ASSERT(IsOwnedByCurrentThread());
   ThreadId saved_owner = owner_;
   owner_ = OSThread::kInvalidThreadId;
 #endif  // defined(DEBUG)
 
   Monitor::WaitResult retval = kNotified;
   if (micros == kNoTimeout) {
     // Wait forever.
-    int result = pthread_cond_wait(data_.cond(), data_.mutex());
+    int result;
+    do {
+      result = pthread_cond_wait(data_.cond(), data_.mutex());
+      // TODO(MG-795): Disallow ETIMEDOUT when pthread_cond_wait() can no longer
+      // return it.
+    } while (result == ETIMEDOUT);
     VALIDATE_PTHREAD_RESULT(result);
   } else {
     struct timespec ts;
     ComputeTimeSpecMicros(&ts, micros);
     int result = pthread_cond_timedwait(data_.cond(), data_.mutex(), &ts);
     ASSERT((result == 0) || (result == ETIMEDOUT));
     if (result == ETIMEDOUT) {
       retval = kTimedOut;
     }
   }
@@ skipping 19 matching lines @@
 void Monitor::NotifyAll() {
   // When running with assertions enabled we track the owner.
   ASSERT(IsOwnedByCurrentThread());
   int result = pthread_cond_broadcast(data_.cond());
   VALIDATE_PTHREAD_RESULT(result);
 }
 
 }  // namespace dart
 
 #endif  // defined(HOST_OS_FUCHSIA)