From ccce5afa3c2e9c0dd1d39c2735851af1fc00dded Mon Sep 17 00:00:00 2001
From: Ingo Weinhold <ingo_weinhold@gmx.de>
Date: Sun, 20 Apr 2008 17:49:45 +0000
Subject: [PATCH] Added simple test that demonstrates that unblocking threads
 waiting on a semaphore after an interrupted one is broken.

git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@25087 a95241bf-73f2-0310-859d-f6bbb57e9c96
---
 src/tests/system/kernel/Jamfile               |  2 +
 src/tests/system/kernel/sem_acquire_test1.cpp | 65 +++++++++++++++++++
 2 files changed, 67 insertions(+)
 create mode 100644 src/tests/system/kernel/sem_acquire_test1.cpp

diff --git a/src/tests/system/kernel/Jamfile b/src/tests/system/kernel/Jamfile
index 3f6b4342cd..4f66176c7a 100644
--- a/src/tests/system/kernel/Jamfile
+++ b/src/tests/system/kernel/Jamfile
@@ -34,6 +34,8 @@ SimpleTest port_wakeup_test_9 : port_wakeup_test_9.cpp ;
 SimpleTest select_check : select_check.cpp ;
 SimpleTest select_close_test : select_close_test.cpp ;
 
+SimpleTest sem_acquire_test1 : sem_acquire_test1.cpp : be ;
+
 SimpleTest syscall_restart_test : syscall_restart_test.cpp : network ;
 
 SetSupportedPlatformsForTarget syscall_time
diff --git a/src/tests/system/kernel/sem_acquire_test1.cpp b/src/tests/system/kernel/sem_acquire_test1.cpp
new file mode 100644
index 0000000000..8652cc986d
--- /dev/null
+++ b/src/tests/system/kernel/sem_acquire_test1.cpp
@@ -0,0 +1,65 @@
+#include <stdio.h>
+#include <string.h>
+
+#include <OS.h>
+
+
+static sem_id sSemaphore = -1;
+
+
+static status_t
+thread_function1(void* data)
+{
+	const char* threadName = (const char*)data;
+	printf("%s: going to acquire sem...\n", threadName);
+	status_t error = acquire_sem_etc(sSemaphore, 2, 0, 0);
+	printf("%s: acquire_sem_etc() returned: %s\n", threadName, strerror(error));
+	return error;
+}
+
+
+static status_t
+thread_function2(void*)
+{
+	printf("thread2: going to acquire sem...\n");
+	status_t error = acquire_sem_etc(sSemaphore, 1, 0, 0);
+	printf("thread2: acquire_sem_etc() returned: %s\n", strerror(error));
+	return error;
+}
+
+
+
+int
+main()
+{
+	sSemaphore = create_sem(1, "test sem");
+
+	thread_id thread1 = spawn_thread(&thread_function1, "thread1",
+		B_NORMAL_PRIORITY, (void*)"thread1");
+	resume_thread(thread1);
+
+	snooze(100000);
+
+	thread_id thread2 = spawn_thread(&thread_function2, "thread2",
+		B_NORMAL_PRIORITY, NULL);
+	resume_thread(thread2);
+
+	snooze(100000);
+
+	thread_id thread3 = spawn_thread(&thread_function1, "thread3",
+		B_NORMAL_PRIORITY, (void*)"thread3");
+	resume_thread(thread3);
+
+	snooze(100000);
+
+	int32 semCount = 42;
+	get_sem_count(sSemaphore, &semCount);
+	printf("sem count: %ld\n", semCount);
+
+	printf("killing thread1...\n");
+	kill_thread(thread1);
+
+	snooze(2000000);
+
+	return 0;
+}