summaryrefslogtreecommitdiff
path: root/schulung_tools/ipc_shm/recv.c
diff options
context:
space:
mode:
authorJohn Ogness <john.ogness@linutronix.de>2017-12-19 10:59:40 +0100
committerJohn Ogness <john.ogness@linutronix.de>2017-12-19 10:59:40 +0100
commit270520b4a2eac8725c8575c3180964289722e191 (patch)
treed9512cd96d0c52e14293c3f8bc19fd168ee14025 /schulung_tools/ipc_shm/recv.c
parent27209bb802048f4803d9cd9a5c2f99d613986446 (diff)
schulung_tools: add various demos and tools
Different tools have been used by various trainers as demos. Put all these into master so they are available to all trainers. ipc_pipe: ipc demo using pipes ipc_shm: ipc demo using shared memory libduma: source and instructions for compiling libduma matrix: demo of good and bad cache access mtrace: patch and infos for using mtrace with ASLR rtex: demo of handling page faults Signed-off-by: John Ogness <john.ogness@linutronix.de>
Diffstat (limited to 'schulung_tools/ipc_shm/recv.c')
-rw-r--r--schulung_tools/ipc_shm/recv.c49
1 files changed, 49 insertions, 0 deletions
diff --git a/schulung_tools/ipc_shm/recv.c b/schulung_tools/ipc_shm/recv.c
new file mode 100644
index 0000000..8a08338
--- /dev/null
+++ b/schulung_tools/ipc_shm/recv.c
@@ -0,0 +1,49 @@
+#include <stdio.h>
+#include <pthread.h>
+#include <unistd.h>
+#include <errno.h>
+#include <sys/types.h>
+#include "shm.h"
+
+int main(void)
+{
+ struct share_data *data;
+ int rv;
+
+ if (create_share() != 0)
+ return 1;
+
+ data = get_share();
+ if (!data)
+ return 1;
+
+ init_share(data);
+
+ if (pthread_mutex_lock(&data->m) != 0)
+ return 1;
+
+ printf("recv (%d): waiting for signal\n", getpid());
+
+ do {
+ rv = pthread_cond_wait(&data->c, &data->m);
+ if (rv != 0) {
+ if (rv == EOWNERDEAD) {
+ printf("recv(%d): recover mutex\n", getpid());
+ data->msg[0] = 0;
+ pthread_mutex_consistent(&data->m);
+ } else {
+ /* maybe rv == ENOTRECOVERABLE */
+ return 1;
+ }
+ }
+ } while (rv != 0);
+
+ /* set "received" uprobe here */
+
+ printf("recv (%d): received signal: %s\n", getpid(), data->msg);
+ pthread_mutex_unlock(&data->m);
+
+ remove_share();
+
+ return 0;
+}