mirror of
https://github.com/RPCS3/rpcs3.git
synced 2024-11-22 10:42:36 +01:00
util/thread_ctrl: Method for measuring cycles a thread has run for
Also add a getter for the native thread handle.
This commit is contained in:
parent
5defa9c7b0
commit
8981227644
@ -31,6 +31,7 @@
|
|||||||
#include <pthread.h>
|
#include <pthread.h>
|
||||||
#include <sys/time.h>
|
#include <sys/time.h>
|
||||||
#include <sys/resource.h>
|
#include <sys/resource.h>
|
||||||
|
#include <time.h>
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#include "sync.h"
|
#include "sync.h"
|
||||||
@ -1851,6 +1852,36 @@ void thread_ctrl::notify()
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
u64 thread_ctrl::get_cycles()
|
||||||
|
{
|
||||||
|
u64 cycles;
|
||||||
|
|
||||||
|
#ifdef _WIN32
|
||||||
|
if (QueryThreadCycleTime((HANDLE)m_thread.load(), &cycles))
|
||||||
|
{
|
||||||
|
#else
|
||||||
|
struct timespec thread_time;
|
||||||
|
if (!clock_gettime(CLOCK_THREAD_CPUTIME_ID, &thread_time))
|
||||||
|
{
|
||||||
|
cycles = static_cast<u64>(thread_time.tv_sec) * 1'000'000'000 + thread_time.tv_nsec;
|
||||||
|
#endif
|
||||||
|
// Report 0 the first time this function is called
|
||||||
|
if (m_cycles == 0)
|
||||||
|
{
|
||||||
|
m_cycles = cycles;
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
const auto diff_cycles = cycles - m_cycles;
|
||||||
|
m_cycles = cycles;
|
||||||
|
return diff_cycles;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
return m_cycles;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void thread_ctrl::test()
|
void thread_ctrl::test()
|
||||||
{
|
{
|
||||||
const auto _this = g_tls_this_thread;
|
const auto _this = g_tls_this_thread;
|
||||||
|
@ -138,6 +138,9 @@ class thread_ctrl final
|
|||||||
// Fixed name
|
// Fixed name
|
||||||
std::string m_name;
|
std::string m_name;
|
||||||
|
|
||||||
|
// CPU cycles thread has run for
|
||||||
|
u64 m_cycles{0};
|
||||||
|
|
||||||
// Start thread
|
// Start thread
|
||||||
static void start(const std::shared_ptr<thread_ctrl>&, task_stack);
|
static void start(const std::shared_ptr<thread_ctrl>&, task_stack);
|
||||||
|
|
||||||
@ -172,6 +175,15 @@ public:
|
|||||||
return m_name;
|
return m_name;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Get CPU cycles since last time this function was called. First call returns 0.
|
||||||
|
u64 get_cycles();
|
||||||
|
|
||||||
|
// Get platform-specific thread handle
|
||||||
|
std::uintptr_t get_native_handle() const
|
||||||
|
{
|
||||||
|
return m_thread.load();
|
||||||
|
}
|
||||||
|
|
||||||
// Get exception
|
// Get exception
|
||||||
std::exception_ptr get_exception() const;
|
std::exception_ptr get_exception() const;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user