Skip to content

Commit

Permalink
Add omrthread_get_self_thread_time()
Browse files Browse the repository at this point in the history
This function returns the user and system cpu time of the calling
thread. This new function is needed because the only way that we're
aware of to get the user CPU time of a thread is to use
getrusage(RUSAGE_THREAD, ...) which can only be called on the current
thread.

Related: eclipse-openj9/openj9#20186

Signed-off-by: Gengchen Tuo <[email protected]>
  • Loading branch information
thallium committed Oct 11, 2024
1 parent d68a419 commit 930d9a6
Show file tree
Hide file tree
Showing 2 changed files with 51 additions and 0 deletions.
14 changes: 14 additions & 0 deletions include_core/thread_api.h
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,11 @@ typedef struct omrthread_monitor_walk_state_t {
BOOLEAN lockTaken;
} omrthread_monitor_walk_state_t;

typedef struct omrthread_thread_time_t {
int64_t userTime;
int64_t sysTime;
} omrthread_thread_time_t;

/* ---------------- omrthreadinspect.c ---------------- */

/**
Expand Down Expand Up @@ -1424,6 +1429,15 @@ omrthread_monitor_pin(omrthread_monitor_t monitor, omrthread_t self);
void
omrthread_monitor_unpin(omrthread_monitor_t monitor, omrthread_t self);

/**
* Gets the system and user CPU time of the current thread.
*
* @param[out] threadTime the pointer to the thread time structure
* @return 0 on success or -1 on failure
*/
intptr_t
omrthread_get_self_thread_time(omrthread_thread_time_t *threadTime);

/* forward struct definition */
struct J9ThreadLibrary;

Expand Down
37 changes: 37 additions & 0 deletions thread/common/thrprof.c
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,11 @@
* APIs for querying per-thread statistics: CPU usage, stack usage.
*/

#if defined (LINUX)
#define _GNU_SOURCE
#include <sys/resource.h>
#endif /* defined (LINUX) */

#include <string.h> /* for memset() */
#include "omrcfg.h"

Expand Down Expand Up @@ -1025,3 +1030,35 @@ omrthread_get_jvm_cpu_usage_info_error_recovery(void)
GLOBAL_UNLOCK_SIMPLE(lib);
}
}

intptr_t
omrthread_get_self_thread_time(omrthread_thread_time_t *threadTime)
{
#if defined(LINUX)
struct rusage rUsage = {0};
int rc = getrusage(RUSAGE_THREAD, &rUsage);

if (-1 == rc) {
return -1;
}

threadTime->userTime = (SEC_TO_NANO_CONVERSION_CONSTANT * (int64_t)rUsage.ru_utime.tv_sec)
+ (MICRO_TO_NANO_CONVERSION_CONSTANT * (int64_t)rUsage.ru_utime.tv_usec);
threadTime->sysTime = (SEC_TO_NANO_CONVERSION_CONSTANT * (int64_t)rUsage.ru_stime.tv_sec)
+ (MICRO_TO_NANO_CONVERSION_CONSTANT * (int64_t)rUsage.ru_stime.tv_usec);
#else /* defined(LINUX) */
omrthread_t self = omrthread_self();

int64_t userTime = omrthread_get_user_time(self);
int64_t cpuTime = omrthread_get_cpu_time(self);

if ((-1 == cpuTime) || (-1 == userTime)) {
return -1;
}

threadTime->sysTime = cpuTime - userTime;
threadTime->userTime = userTime;
#endif /* defined(LINUX) */

return 0;
}

0 comments on commit 930d9a6

Please sign in to comment.