Contents

#include "extconf.h"

// This file is only compiled on systems where pthread_getcpuclockid() is available;
// Otherwise we compile clock_id_noop.c
#ifdef HAVE_PTHREAD_GETCPUCLOCKID

#include <pthread.h>
#include <time.h>
#include <errno.h>

#include <ruby.h>
#include "private_vm_api_access.h"
#include "clock_id.h"

// Validate that our home-cooked pthread_id_for() matches pthread_self() for the current thread
void self_test_clock_id(void) {
  rb_nativethread_id_t expected_pthread_id = pthread_self();
  rb_nativethread_id_t actual_pthread_id = pthread_id_for(rb_thread_current());

  if (expected_pthread_id != actual_pthread_id) rb_raise(rb_eRuntimeError, "pthread_id_for() self-test failed");
}

VALUE clock_id_for(VALUE self, VALUE thread) {
  rb_nativethread_id_t thread_id = pthread_id_for(thread);

  clockid_t clock_id;
  int error = pthread_getcpuclockid(thread_id, &clock_id);

  if (error == 0) {
    return CLOCKID2NUM(clock_id);
  } else {
    switch(error) {
      // The more specific error messages are based on the pthread_getcpuclockid(3) man page
      case ENOENT:
        rb_exc_raise(rb_syserr_new(error, "Failed to get clock_id for given thread: Per-thread CPU time clocks are not supported by the system."));
      case ESRCH:
        rb_exc_raise(rb_syserr_new(error, "Failed to get clock_id for given thread: No thread could be found."));
      default:
        rb_exc_raise(rb_syserr_new(error, "Failed to get clock_id for given thread"));
    }
  }
}

#endif

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ddtrace-1.2.0	ext/ddtrace_profiling_native_extension/clock_id_from_pthread.c