summaryrefslogtreecommitdiff
path: root/3rdparty/plibsys/tests/pshm_test.cpp
diff options
context:
space:
mode:
authorsanine <sanine.not@pm.me>2022-08-27 23:52:56 -0500
committersanine <sanine.not@pm.me>2022-08-27 23:52:56 -0500
commita4dd0ad63c00f4dee3b86dfd3075d1d61b2b3180 (patch)
tree13bd5bfa15e6fea2a12f176bae79adf9c6fd0933 /3rdparty/plibsys/tests/pshm_test.cpp
parentbde3e4f1bb7b8f8abca0884a7d994ee1c17a66b1 (diff)
add plibsys
Diffstat (limited to '3rdparty/plibsys/tests/pshm_test.cpp')
-rw-r--r--3rdparty/plibsys/tests/pshm_test.cpp313
1 files changed, 313 insertions, 0 deletions
diff --git a/3rdparty/plibsys/tests/pshm_test.cpp b/3rdparty/plibsys/tests/pshm_test.cpp
new file mode 100644
index 0000000..bc89692
--- /dev/null
+++ b/3rdparty/plibsys/tests/pshm_test.cpp
@@ -0,0 +1,313 @@
+/*
+ * The MIT License
+ *
+ * Copyright (C) 2013-2019 Alexander Saprykin <saprykin.spb@gmail.com>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining
+ * a copy of this software and associated documentation files (the
+ * 'Software'), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, sublicense, and/or sell copies of the Software, and to
+ * permit persons to whom the Software is furnished to do so, subject to
+ * the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be
+ * included in all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED 'AS IS', WITHOUT WARRANTY OF ANY KIND,
+ * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+ * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
+ * CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
+ * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+ * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+
+#include "plibsys.h"
+#include "ptestmacros.h"
+
+#include <stdlib.h>
+#include <time.h>
+
+P_TEST_MODULE_INIT ();
+
+static void * shm_test_thread (void *arg)
+{
+ pint rand_num;
+ psize shm_size;
+ ppointer addr;
+ PShm *shm;
+
+ if (arg == NULL)
+ p_uthread_exit (1);
+
+ shm = (PShm *) arg;
+ rand_num = rand () % 127;
+ shm_size = p_shm_get_size (shm);
+ addr = p_shm_get_address (shm);
+
+ if (shm_size == 0 || addr == NULL)
+ p_uthread_exit (1);
+
+ if (!p_shm_lock (shm, NULL))
+ p_uthread_exit (1);
+
+ for (puint i = 0; i < shm_size; ++i)
+ *(((pchar *) addr) + i) = (pchar) rand_num;
+
+ if (!p_shm_unlock (shm, NULL))
+ p_uthread_exit (1);
+
+ p_uthread_exit (0);
+
+ return NULL;
+}
+
+extern "C" ppointer pmem_alloc (psize nbytes)
+{
+ P_UNUSED (nbytes);
+ return (ppointer) NULL;
+}
+
+extern "C" ppointer pmem_realloc (ppointer block, psize nbytes)
+{
+ P_UNUSED (block);
+ P_UNUSED (nbytes);
+ return (ppointer) NULL;
+}
+
+extern "C" void pmem_free (ppointer block)
+{
+ P_UNUSED (block);
+}
+
+P_TEST_CASE_BEGIN (pshm_nomem_test)
+{
+ p_libsys_init ();
+
+ PMemVTable vtable;
+
+ vtable.free = pmem_free;
+ vtable.malloc = pmem_alloc;
+ vtable.realloc = pmem_realloc;
+
+ P_TEST_CHECK (p_mem_set_vtable (&vtable) == TRUE);
+
+ P_TEST_CHECK (p_shm_new ("p_shm_test_memory_block", 1024, P_SHM_ACCESS_READWRITE, NULL) == NULL);
+
+ p_mem_restore_vtable ();
+
+ p_libsys_shutdown ();
+}
+P_TEST_CASE_END ()
+
+P_TEST_CASE_BEGIN (pshm_invalid_test)
+{
+ p_libsys_init ();
+
+ P_TEST_CHECK (p_shm_new (NULL, 0, P_SHM_ACCESS_READWRITE, NULL) == NULL);
+ P_TEST_CHECK (p_shm_lock (NULL, NULL) == FALSE);
+ P_TEST_CHECK (p_shm_unlock (NULL, NULL) == FALSE);
+ P_TEST_CHECK (p_shm_get_address (NULL) == NULL);
+ P_TEST_CHECK (p_shm_get_size (NULL) == 0);
+ p_shm_take_ownership (NULL);
+
+ PShm *shm = p_shm_new ("p_shm_invalid_test", 0, P_SHM_ACCESS_READWRITE, NULL);
+ p_shm_take_ownership (shm);
+ p_shm_free (shm);
+
+ shm = p_shm_new ("p_shm_invalid_test", 10, (PShmAccessPerms) -1, NULL);
+ p_shm_take_ownership (shm);
+ p_shm_free (shm);
+
+ p_libsys_shutdown ();
+}
+P_TEST_CASE_END ()
+
+P_TEST_CASE_BEGIN (pshm_general_test)
+{
+ PShm *shm = NULL;
+#ifndef P_OS_HPUX
+ PShm *shm2 = NULL;
+#endif
+ ppointer addr, addr2;
+ pint i;
+
+ p_libsys_init ();
+
+ shm = p_shm_new ("p_shm_test_memory_block", 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+ p_shm_take_ownership (shm);
+ p_shm_free (shm);
+
+ shm = p_shm_new ("p_shm_test_memory_block", 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+ P_TEST_REQUIRE (p_shm_get_size (shm) == 1024);
+
+ addr = p_shm_get_address (shm);
+ P_TEST_REQUIRE (addr != NULL);
+
+#ifndef P_OS_HPUX
+ shm2 = p_shm_new ("p_shm_test_memory_block", 1024, P_SHM_ACCESS_READONLY, NULL);
+
+ if (shm2 == NULL) {
+ /* OK, some systems may want exactly the same permissions */
+ shm2 = p_shm_new ("p_shm_test_memory_block", 1024, P_SHM_ACCESS_READWRITE, NULL);
+ }
+
+ P_TEST_REQUIRE (shm2 != NULL);
+ P_TEST_REQUIRE (p_shm_get_size (shm2) == 1024);
+
+ addr2 = p_shm_get_address (shm2);
+ P_TEST_REQUIRE (addr2 != NULL);
+#endif
+
+ for (i = 0; i < 512; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ *(((pchar *) addr) + i) = 'a';
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+
+#ifndef P_OS_HPUX
+ for (i = 0; i < 512; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm2, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) == 'a');
+ P_TEST_CHECK (p_shm_unlock (shm2, NULL));
+ }
+#else
+ for (i = 0; i < 512; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) == 'a');
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+#endif
+
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ *(((pchar *) addr) + i) = 'b';
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+
+#ifndef P_OS_HPUX
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm2, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) != 'c');
+ P_TEST_CHECK (p_shm_unlock (shm2, NULL));
+ }
+
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm2, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) == 'b');
+ P_TEST_CHECK (p_shm_unlock (shm2, NULL));
+ }
+#else
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) != 'c');
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) == 'b');
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+#endif
+
+ p_shm_free (shm);
+
+ shm = p_shm_new ("p_shm_test_memory_block_2", 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+ P_TEST_REQUIRE (p_shm_get_size (shm) == 1024);
+
+ addr = p_shm_get_address (shm);
+ P_TEST_REQUIRE (addr != NULL);
+
+ for (i = 0; i < 1024; ++i) {
+ P_TEST_CHECK (p_shm_lock (shm, NULL));
+ P_TEST_CHECK (*(((pchar *) addr) + i) != 'b');
+ P_TEST_CHECK (p_shm_unlock (shm, NULL));
+ }
+
+ p_shm_free (shm);
+
+#ifndef P_OS_HPUX
+ p_shm_free (shm2);
+#endif
+
+ p_libsys_shutdown ();
+}
+P_TEST_CASE_END ()
+
+P_TEST_CASE_BEGIN (pshm_thread_test)
+{
+ PShm *shm;
+ PUThread *thr1, *thr2, *thr3;
+ ppointer addr;
+ pint i, val;
+ pboolean test_ok;
+
+ p_libsys_init ();
+
+ srand ((puint) time (NULL));
+
+ shm = p_shm_new ("p_shm_test_memory_block", 1024 * 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+ p_shm_take_ownership (shm);
+ p_shm_free (shm);
+
+ shm = p_shm_new ("p_shm_test_memory_block", 1024 * 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+
+ if (p_shm_get_size (shm) != 1024 * 1024) {
+ p_shm_free (shm);
+ shm = p_shm_new ("p_shm_test_memory_block", 1024 * 1024, P_SHM_ACCESS_READWRITE, NULL);
+ P_TEST_REQUIRE (shm != NULL);
+ }
+
+ P_TEST_REQUIRE (p_shm_get_size (shm) == 1024 * 1024);
+
+ addr = p_shm_get_address (shm);
+ P_TEST_REQUIRE (addr != NULL);
+
+ thr1 = p_uthread_create ((PUThreadFunc) shm_test_thread, (ppointer) shm, TRUE, NULL);
+ P_TEST_REQUIRE (thr1 != NULL);
+
+ thr2 = p_uthread_create ((PUThreadFunc) shm_test_thread, (ppointer) shm, TRUE, NULL);
+ P_TEST_REQUIRE (thr2 != NULL);
+
+ thr3 = p_uthread_create ((PUThreadFunc) shm_test_thread, (ppointer) shm, TRUE, NULL);
+ P_TEST_REQUIRE (thr3 != NULL);
+
+ P_TEST_CHECK (p_uthread_join (thr1) == 0);
+ P_TEST_CHECK (p_uthread_join (thr2) == 0);
+ P_TEST_CHECK (p_uthread_join (thr3) == 0);
+
+ test_ok = TRUE;
+ val = *((pchar *) addr);
+
+ for (i = 1; i < 1024 * 1024; ++i)
+ if (*(((pchar *) addr) + i) != val) {
+ test_ok = FALSE;
+ break;
+ }
+
+ P_TEST_REQUIRE (test_ok == TRUE);
+
+ p_uthread_unref (thr1);
+ p_uthread_unref (thr2);
+ p_uthread_unref (thr3);
+ p_shm_free (shm);
+
+ p_libsys_shutdown ();
+}
+P_TEST_CASE_END ()
+
+P_TEST_SUITE_BEGIN()
+{
+ P_TEST_SUITE_RUN_CASE (pshm_nomem_test);
+ P_TEST_SUITE_RUN_CASE (pshm_invalid_test);
+ P_TEST_SUITE_RUN_CASE (pshm_general_test);
+ P_TEST_SUITE_RUN_CASE (pshm_thread_test);
+}
+P_TEST_SUITE_END()