Website Summary Files Commits Branches @commit @diff @stats
path: root / gctest / minitrace / minitrace_test_mt.cpp
diff options
context:
space:
mode:
Commitfefc19f44df05b8dce8eff0fcff50ad3761bb78e (patch)
Author
 Dimitar Trendafilov <trendafilov.dn@gmail.com>
2020-12-23 14:55:13 +0200
Committer
 Dimitar Trendafilov <trendafilov.dn@gmail.com>
2020-12-23 14:55:13 +0200
Filesa67c5916f28efc4267fb22ae141a23e2bbeb66dd /gctest/minitrace/minitrace_test_mt.cpp
IPL-fefc19f44df05b8dce8eff0fcff50ad3761bb78e.tar
IPL-fefc19f44df05b8dce8eff0fcff50ad3761bb78e.tar.gz
IPL-fefc19f44df05b8dce8eff0fcff50ad3761bb78e.zip
Parent32f732d5e91da6c911e2f983e317dc4da8b1c1e3 (diff)
Parentdbe9285608507c592fede216f2c147c5a3d40cea (diff)
Merge commit 'dbe9285608507c592fede216f2c147c5a3d40cea' as 'gctest/minitrace'
1 files changed, 60 insertions, 0 deletions
-rw-r--r--gctest/minitrace/minitrace_test_mt.cpp60
diff --git a/gctest/minitrace/minitrace_test_mt.cpp b/gctest/minitrace/minitrace_test_mt.cpp
new file mode 100644
index 0000000..899a193
--- /dev/null
+++ b/gctest/minitrace/minitrace_test_mt.cpp
@@ -0,0 +1,60 @@
+// Test minitrace with multiple threads.
+
+#include <inttypes.h>
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+
+#include "minitrace.h"
+
+// Does some meaningless work.
+int work(int cycles) {
+ int a = cycles;
+ for (int i = 0; i < cycles; i++) {
+ a ^= 373;
+ a = (a << 13) | (a >> (32 - 13));
+ }
+ return a;
+}
+
+void *worker_thread(void *param) {
+ int id = (int)(intptr_t)param;
+ char temp[256]; sprintf(temp, "Worker Thread %i", id);
+ MTR_META_THREAD_NAME(temp);
+ int x = 0;
+ for (int i = 0; i < 32; i++) {
+ MTR_BEGIN_I(__FILE__, "Worker", "ID", id);
+ x += work((rand() & 0x7fff) * 1000);
+ MTR_END(__FILE__, "Worker");
+ }
+ return (void *)(intptr_t)x;
+}
+
+void phase2() {
+ for (int i = 0; i < 10000; i++) {
+ MTR_BEGIN_FUNC();
+ MTR_END_FUNC();
+ }
+}
+
+int main() {
+ int i;
+ mtr_init("mt_trace.json");
+ MTR_META_PROCESS_NAME("Multithreaded Test");
+ MTR_META_THREAD_NAME("Main Thread");
+ MTR_BEGIN_FUNC();
+ #define NUMT 8
+ pthread_t threads[NUMT];
+ for (i = 0; i < NUMT; i++) {
+ pthread_create(&threads[i], 0, &worker_thread, (void *)(intptr_t)i);
+ }
+ for (i = 0; i < NUMT; i++) {
+ pthread_join(threads[i], 0);
+ }
+ phase2();
+
+ MTR_END_FUNC();
+ mtr_shutdown();
+ return 0;
+}