WebSVN – HelenOS – Diff – /trunk/uspace/tester/tester.c

 /*
  * Copyright (c) 2006 Ondrej Palkovsky
+ * Copyright (c) 2007 Martin Decky
  * All rights reserved.
+ *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
-/** @addtogroup ippc IPC Tester
+/** @addtogroup tester User space Tester
- * @brief   IPC tester and task faulter.
+ * @brief   User space testing infrastructure.
  * @{
  */
 /**
  * @file
  */
+#include <unistd.h>
 #include <stdio.h>
-#include <async.h>
-#include <ipc/ipc.h>
-#include <ipc/services.h>
-#include <errno.h>
+#include "tester.h"
+int myservice = 0;
+int phones[MAX_PHONES];
+int connections[MAX_CONNECTIONS];
+ipc_callid_t callids[MAX_CONNECTIONS];
+test_t tests[] = {
+#include "thread/thread1.def"
-#define TEST_START       10000
+#include "print/print1.def"
-#define MAXLIST          4
+#include "ipc/register.def"
+#include "ipc/connect.def"
+    {NULL, NULL, NULL}
+};
-#define MSG_HANG_ME_UP   2000
-static int connections[50];
+static bool run_test(test_t *test)
-static ipc_callid_t callids[50];
-static int phones[20];
-static int myservice = 0;
-static void client_connection(ipc_callid_t iid, ipc_call_t *icall)
+{
-    ipc_callid_t callid;
-    ipc_call_t call;
-    ipcarg_t phonehash = icall->in_phone_hash;
-    int retval;
-    int i;
-    printf("Connected phone: %P, accepting\n", icall->in_phone_hash);
+    printf("%s\t\t%s\n", test->name, test->desc);
-    ipc_answer_fast(iid, 0, 0, 0);
-    for (i=0;i < 1024;i++)
-        if (!connections[i]) {
-            connections[i] = phonehash;
-            break;
-        }
-    while (1) {
+    /* Execute the test */
-        callid = async_get_call(&call);
+    char * ret = test->entry(false);
-        switch (IPC_GET_METHOD(call)) {
-        case IPC_M_PHONE_HUNGUP:
-            printf("Phone (%P) hung up.\n", phonehash);
-            retval = 0;
-            break;
-        default:
-            printf("Received message from %P: %X\n", phonehash,callid);
-            for (i = 0; i < 1024; i++)
-                if (!callids[i]) {
+    if (ret == NULL) {
-                    callids[i] = callid;
+        printf("Test passed\n\n");
-                    break;
-                }
-            continue;
+        return true;
-        }
-        ipc_answer_fast(callid, retval, 0, 0);
+    }
-}
-static void printhelp(void)
-{
-    printf("? - help\n");
+    printf("%s\n\n", ret);
-    printf("c - connect to other service\n");
-    printf("h - hangup connection\n");
-    printf("a - send async message to other service\n");
-    printf("s - send sync message to other service\n");
-    printf("d - answer message that we have received\n");
-    printf("j - jump to endless loop\n");
-    printf("p - page fault\n");
+    return false;
-    printf("u - unaligned read\n");
+}
-static void callback(void *private, int retval, ipc_call_t *data)
+static void run_safe_tests(void)
+{
-    printf("Received response to msg %d - retval: %d.\n", private,
-           retval);
+}
-static void do_answer_msg(void)
+static void list_tests(void)
+{
-    int i,cnt, errn = 0;
-    char c;
-    cnt = 0;
+    test_t *test;
-    for (i = 0;i < 50; i++) {
-        if (callids[i]) {
-            printf("%d: %P\n", cnt, callids[i]);
-            cnt++;
-        }
-        if (cnt >= 10)
-            break;
-    }
-    if (!cnt)
-        return;
-    printf("Choose message:\n");
-    do {
-        c = getchar();
-    } while (c < '0' || (c-'0') >= cnt);
-    cnt = c - '0' + 1;
+    char c = 'a';
-    for (i = 0; cnt; i++)
+    for (test = tests; test->name != NULL; test++, c++)
-        if (callids[i])
-            cnt--;
-    i -= 1;
-    printf("Normal (n) or hangup (h) or error(e) message?\n");
+        printf("%c\t%s\t\t%s%s\n", c, test->name, test->desc, (test->safe ? "" : " (unsafe)"));
-    do {
-        c = getchar();
-    } while (c != 'n' && c != 'h' && c != 'e');
-    if (c == 'n')
-        errn = 0;
-    else if (c == 'h')
-        errn = EHANGUP;
-    else if (c == 'e')
-        errn = ENOENT;
-    printf("Answering %P\n", callids[i]);
-    ipc_answer_fast(callids[i], errn, 0, 0);
-    callids[i] = 0;
-}
-static void do_send_msg(int async)
-{
-    int phoneid;
-    int res;
-    static int msgid = 1;
-    char c;
-    printf("Select phoneid to send msg: 2-9\n");
-    do {
-        c = getchar();
-    } while (c < '2' || c > '9');
-    phoneid = c - '0';
-    if (async) {
-        ipc_call_async(phoneid, 2000, 0, (void *)msgid, callback, 1);
-        printf("Async sent - msg %d\n", msgid);
-        msgid++;
-    } else {
-        printf("Sending msg...");
-        res = ipc_call_sync_2(phoneid, 2000, 0, 0, NULL, NULL);
-        printf("done: %d\n", res);
-    }
-}
-static void do_hangup(void)
-{
-    char c;
-    int res;
-    int phoneid;
-    printf("Select phoneid to hangup: 2-9\n");
-    do {
-        c = getchar();
-    } while (c < '2' || c > '9');
-    phoneid = c - '0';
-    printf("Hanging up...");
-    res = ipc_hangup(phoneid);
-    printf("done: %d\n", phoneid);
-}
-static void do_connect(void)
-{
-    char c;
-    int svc;
-    int phid;
-    printf("Choose one service: 0:10000....9:10009\n");
-    do {
-        c = getchar();
-    } while (c < '0' || c > '9');
-    svc = TEST_START + c - '0';
-    if (svc == myservice) {
-        printf("Currently cannot connect to myself, update test\n");
-        return;
-    }
-    printf("Connecting to %d..", svc);
+    printf("*\t\t\tRun all safe tests\n");
-    phid = ipc_connect_me_to(PHONE_NS, svc, 0);
-    if (phid > 0) {
-        printf("phoneid: %d\n", phid);
-        phones[phid] = 1;
-    } else
-        printf("error: %d\n", phid);
+}
 int main(void)
+{
-    ipcarg_t phonead;
-    int i;
-    char c;
-    int res;
-    volatile long long var;
-    volatile int var1;
-    printf("********************************\n");
-    printf("***********IPC Tester***********\n");
-    printf("********************************\n");
-    async_set_client_connection(client_connection);
-    for (i = TEST_START; i < TEST_START + 10; i++) {
-        res = ipc_connect_to_me(PHONE_NS, i, 0, &phonead);
-        if (!res)
-            break;
-        printf("Failed registering as %d..:%d\n", i, res);
-    }
-    printf("Registered as service: %d\n", i);
-    myservice = i;
-    printhelp();
     while (1) {
-        c = getchar();
+        char c;
-        switch (c) {
+        test_t *test;
-        case '?':
-            printhelp();
+        list_tests();
-            break;
-        case 'h':
-            do_hangup();
+        printf("> ");
-            break;
-        case 'c':
+        c = getchar();
-            do_connect();
+        printf("%c\n", c);
-            break;
-        case 'a':
+        if ((c >= 'a') && (c <= 'z')) {
-            do_send_msg(1);
+            for (test = tests; test->name != NULL; test++, c--)
-            break;
-        case 's':
+                if (c == 'a')
-            do_send_msg(0);
-            break;
+                    break;
-        case 'd':
-            do_answer_msg();
-            break;
-        case 'j':
+            if (c > 'a')
-            printf("Entering infinite loop\n");
+                printf("Unknown test\n\n");
-            while (1)
-                ;
+            else
-            break;
+                run_test(test);
-        case 'p':
-            printf("Doing page fault\n");
-            *((char *)0) = 1;
+        } else if (c == '*')
-            printf("done\n");
+            run_safe_tests();
-            break;
+        else
-        case 'u':
-            var1=*( (int *) ( ( (char *)(&var) ) + 1 ) );
+            printf("Invalid test\n\n");
-            break;
-        }
+    }
+}
 /** @}
  */

Subversion Repositories HelenOS

(root)/trunk/uspace/tester/tester.c – Rev 2186 → 2188