Merge pull request #1944 from authmillenon/msg_send_receive-test

tests: Add automatic test for msg_send_receive

tests/msg_send_receive/Makefile

@@ -0,0 +1,8 @@
+# name of your application
+APPLICATION = msg_send_receive
+include ../Makefile.tests_common
+
+include $(RIOTBASE)/Makefile.include
+
+test:
+	./tests/01-run.py

tests/msg_send_receive/main.c

@@ -0,0 +1,101 @@
+/*
+ * Copyright (C) 2014 Martin Lenders <mlenders@inf.fu-berlin.de>
+ *
+ * This file is subject to the terms and conditions of the GNU Lesser
+ * General Public License v2.1. See the file LICENSE in the top level
+ * directory for more details.
+ */
+
+/**
+ * @ingroup     tests
+ * @{
+ *
+ * @file
+ * @brief       Test msg_send_receive().
+ *
+ * @author      Martine Lenders <mlenders@inf.fu-berlin.de>
+ * @author      René Kijewski <rene.kijewski@fu-berlin.de>
+ *
+ * @}
+ */
+
+#include <stdio.h>
+
+#include "cpu-conf.h"
+#include "thread.h"
+
+#define THREAD1_STACKSIZE   (KERNEL_CONF_STACKSIZE_PRINTF)
+#define THREAD2_STACKSIZE   (KERNEL_CONF_STACKSIZE_PRINTF)
+
+#ifndef TEST_EXECUTION_NUM
+#define TEST_EXECUTION_NUM  (10)
+#endif
+
+static char thread1_stack[THREAD1_STACKSIZE];
+static char thread2_stack[THREAD2_STACKSIZE];
+
+static kernel_pid_t thread1_pid, thread2_pid;
+
+static void *thread1(void *args)
+{
+    (void)args;
+
+    msg_t msg_req, msg_resp;
+    int counter = 0, success = 1;
+
+    msg_resp.content.ptr = NULL;
+    msg_req.content.ptr = (void *) &counter;
+
+    for (int i = 0; i < TEST_EXECUTION_NUM; i++) {
+        msg_send_receive(&msg_req, &msg_resp, thread2_pid);
+
+        if ((NULL == msg_resp.content.ptr) ||
+            (&counter != ((int *) msg_req.content.ptr)) ||
+            (counter != (*(int *) msg_resp.content.ptr)) ||
+            (counter != (*(int *) msg_req.content.ptr))) {
+            success = 0;
+            break;
+        }
+    }
+
+    if (success) {
+        puts("Test successful.");
+    }
+    else {
+        puts("Test failed.");
+    }
+
+    return NULL;
+}
+
+static void *thread2(void *args)
+{
+    (void)args;
+
+    msg_t msg_req, msg_resp;
+    int counter = 0;
+
+    msg_resp.content.ptr = (void *) &counter;
+
+    for (int i = 0; i < TEST_EXECUTION_NUM; i++) {
+        msg_receive(&msg_req);
+
+        ++*(int *) msg_req.content.ptr;
+        ++*(int *) msg_resp.content.ptr;
+        printf("Incremented counters to %d and %d\n",
+               *(int *) msg_req.content.ptr, *(int *) msg_resp.content.ptr);
+
+        msg_reply(&msg_req, &msg_resp);
+    }
+
+    return NULL;
+}
+
+int main(void)
+{
+    thread2_pid = thread_create(thread2_stack, THREAD2_STACKSIZE, PRIORITY_MAIN - 1,
+                                0, thread2, NULL, "thread2");
+    thread1_pid = thread_create(thread1_stack, THREAD1_STACKSIZE, PRIORITY_MAIN - 2,
+                                0, thread1, NULL, "thread1");
+    return 0;
+}

tests/msg_send_receive/tests/01-run.py

@@ -0,0 +1,33 @@
+#!/usr/bin/env python
+
+# Copyright (C) 2014 Martin Lenders <mlenders@inf.fu-berlin.de>
+#
+# This file is subject to the terms and conditions of the GNU Lesser
+# General Public License v2.1. See the file LICENSE in the top level
+# directory for more details.
+
+import os, signal, sys
+from pexpect import spawn, TIMEOUT, EOF
+
+
+DEFAULT_TIMEOUT = 5
+
+def main():
+    p = None
+
+    try:
+        p = spawn("make term", timeout=DEFAULT_TIMEOUT)
+        p.logfile = sys.stdout
+
+        p.expect("Test successful.")
+    except TIMEOUT as exc:
+        print(exc)
+        return 1
+    finally:
+        if p and not p.terminate():
+            os.killpg(p.pid, signal.SIGKILL)
+
+    return 0
+
+if __name__ == "__main__":
+    sys.exit(main())