WebSVN – HelenOS-historic – Diff – /uspace/trunk/init/init.c

 /*
  * Copyright (C) 2005 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:
+ *
  * - Redistributions of source code must retain the above copyright
  *   notice, this list of conditions and the following disclaimer.
  * - Redistributions in binary form must reproduce the above copyright
  *   notice, this list of conditions and the following disclaimer in the
  *   documentation and/or other materials provided with the distribution.
  * - The name of the author may not be used to endorse or promote products
  *   derived from this software without specific prior written permission.
+ *
  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  * 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.
  */
 #include "version.h"
 #include <ipc.h>
 #include <stdio.h>
 #include <unistd.h>
 #include <stdlib.h>
 #include <ns.h>
 #include <thread.h>
+int a;
 extern void utest(void *arg);
 void utest(void *arg)
+{
     printf("Uspace thread started.\n");
     for (;;)
+        ;
+}
 static void test_printf(void)
+{
     printf("Simple text.\n");
     printf("Now insert '%s' string.\n","this");
     printf("Signed formats on uns. numbers: '%d', '%+d', '% d', '%u' (,+, ,u)\n", 321, 321, 321, 321);
     printf("Signed formats on sig. numbers: '%d', '%+d', '% d', '%u' (,+, ,u)\n", -321, -321, -321, -321);
     printf("Signed with different sized: '%hhd', '%hd', '%d', '%ld', %lld;\n", -3, -32, -321, -32101l, -3210123ll);
     printf("And now... '%hhd' byte! '%hd' word! '%d' int! \n", 11, 11111, 1111111111);
     printf("Different bases: %#hx, %#hu, %#ho and %#hb\n", 123, 123, 123, 123);
     printf("Different bases signed: %#hx, %#hu, %#ho and %#hb\n", -123, -123, -123, -123);
     printf("'%llX' llX! Another '%llx' llx! \n", 0x1234567887654321ll, 0x1234567887654321ll);
     printf("'%llX' with 64bit value and '%x' with 32 bit value. \n", 0x1234567887654321ll, 0x12345678 );
     printf("'%llx' 64bit, '%x' 32bit, '%hhx' 8bit, '%hx' 16bit, '%llX' 64bit and '%s' string.\n", 0x1234567887654321ll, 0x12345678, 0x12, 0x1234, 0x1234567887654321ull, "Lovely string" );
     printf("Thats all, folks!\n");
+}
 extern char _heap;
 static void test_mremap(void)
+{
     printf("Writing to good memory\n");
     mremap(&_heap, 120000, 0);
     printf("%P\n", ((char *)&_heap));
     printf("%P\n", ((char *)&_heap) + 80000);
     *(((char *)&_heap) + 80000) = 10;
     printf("Making small\n");
     mremap(&_heap, 16000, 0);
     printf("Failing..\n");
     *((&_heap) + 80000) = 10;
     printf("memory done\n");
+}
 /*
 static void test_sbrk(void)
+{
     printf("Writing to good memory\n");
     printf("Got: %P\n", sbrk(120000));
     printf("%P\n", ((char *)&_heap));
     printf("%P\n", ((char *)&_heap) + 80000);
     *(((char *)&_heap) + 80000) = 10;
     printf("Making small, got: %P\n",sbrk(-120000));
     printf("Testing access to heap\n");
     _heap = 10;
     printf("Failing..\n");
     *((&_heap) + 80000) = 10;
     printf("memory done\n");
+}
 */
 /*
 static void test_malloc(void)
+{
     char *data;
     data = malloc(10);
     printf("Heap: %P, data: %P\n", &_heap, data);
     data[0] = 'a';
     free(data);
+}
 */
 static void test_ping(void)
+{
     ipcarg_t result;
     int retval;
     retval = ipc_call_sync(PHONE_NS, NS_PING, 0xbeef,&result);
     printf("Retval: %d - received: %P\n", retval, result);
+}
 static void got_answer(void *private, int retval, ipc_data_t *data)
+{
     printf("Retval: %d...%s...%zX, %zX\n", retval, private,
            IPC_GET_ARG1(*data), IPC_GET_ARG2(*data));
+}
 static void test_async_ipc(void)
+{
     ipc_call_t data;
     int i;
     printf("Sending ping\n");
     ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
              "Pong1", got_answer);
     ipc_call_async_2(PHONE_NS, NS_PING, 2, 0xbeefbee4,
              "Pong2", got_answer);
     ipc_call_async_2(PHONE_NS, NS_PING, 3, 0xbeefbee4,
              "Pong3", got_answer);
     ipc_call_async_2(PHONE_NS, NS_PING, 4, 0xbeefbee4,
              "Pong4", got_answer);
     ipc_call_async_2(PHONE_NS, NS_PING, 5, 0xbeefbee4,
              "Pong5", got_answer);
     ipc_call_async_2(PHONE_NS, NS_PING, 6, 0xbeefbee4,
              "Pong6", got_answer);
     printf("Waiting forever...\n");
     for (i=0; i<100;i++)
         printf(".");
     printf("\n");
     ipc_wait_for_call(&data, NULL);
     printf("Received call???\n");
+}
 static void got_answer_2(void *private, int retval, ipc_data_t *data)
+{
     printf("Pong\n");
+}
 static void test_advanced_ipc(void)
+{
     int res;
     unsigned long long taskid;
     ipc_callid_t callid;
     ipc_call_t data;
     int i;
     printf("Asking 0 to connect to me...\n");
     res = ipc_connect_to_me(0, 1, 2, &taskid);
     printf("Result: %d - taskid: %llu\n", res, taskid);
     for (i=0; i < 100; i++) {
         printf("----------------\n");
         ipc_call_async(PHONE_NS, NS_PING_SVC, 0, "prov",
                    got_answer_2);
         callid = ipc_wait_for_call(&data, NULL);
         printf("Received ping\n");
         ipc_answer(callid, 0, 0, 0);
+    }
-    callid = ipc_wait_for_call(&data, NULL);
+//  callid = ipc_wait_for_call(&data, NULL);
+}
 static void test_connection_ipc(void)
+{
     int res;
     ipcarg_t result;
     printf("Starting connect...\n");
     res = ipc_connect_me_to(PHONE_NS, 10, 20);
     printf("Connected: %d\n", res);
     printf("pinging.\n");
     res = ipc_call_sync(res, NS_PING, 0xbeef,&result);
-    printf("Retval: %d - received: %zd\n", res, result);
+    printf("Retval: %d - received: %X\n", res, result);
+}
+static void test_hangup(void)
+{
+    int phoneid;
+    ipc_call_t data;
+    ipc_callid_t callid;
+    int i;
+    printf("Starting connect...\n");
+    phoneid = ipc_connect_me_to(PHONE_NS, 10, 20);
+    printf("Phoneid: %d, pinging\n", phoneid);
+    ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
+             "Pong1", got_answer);
+    printf("Hangin up\n");
+    ipc_hangup(phoneid);
+    printf("Connecting\n");
+    phoneid = ipc_connect_me_to(PHONE_NS, 10, 20);
+    printf("Newphid: %d\n", phoneid);
+    for (i=0; i < 1000; i++) {
+        if ((callid=ipc_wait_for_call(&data, IPC_WAIT_NONBLOCKING)))
+            printf("callid: %d\n");
+    }
+    printf("New new phoneid: %d\n", ipc_connect_me_to(PHONE_NS, 10, 20));
+}
+static void test_slam(void)
+{
+    int i;
+    ipc_call_t data;
+    ipc_callid_t callid;
+    printf("ping");
+    ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
+             "Pong1", got_answer);
+    printf("slam");
+    ipc_call_async_2(PHONE_NS, NS_HANGUP, 1, 0xbeefbee2,
+             "Hang", got_answer);
+    printf("ping2\n");
+    ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
+             "Ping2", got_answer);
+    for (i=0; i < 1000; i++) {
+        if ((callid=ipc_wait_for_call(&data, IPC_WAIT_NONBLOCKING)))
+            printf("callid: %d\n");
+    }
+    ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
+             "Pong1", got_answer);
+    printf("Closing file\n");
+    ipc_hangup(PHONE_NS);
+    ipc_call_async_2(PHONE_NS, NS_PING, 1, 0xbeefbee2,
+             "Pong1", got_answer);
+    ipc_wait_for_call(&data, 0);
+}
 int main(int argc, char *argv[])
+{
     int tid;
     version_print();
 /*  test_printf(); */
 //  test_ping();
 //  test_async_ipc();
 //  test_advanced_ipc();
-    test_connection_ipc();
+//  test_connection_ipc();
+//  test_hangup();
+    test_slam();
-    if ((tid = thread_create(utest, NULL, "utest") != -1)) {
+//  if ((tid = thread_create(utest, NULL, "utest") != -1)) {
-        printf("Created thread tid=%d\n", tid);
+//      printf("Created thread tid=%d\n", tid);
-    }
+//  }
     return 0;
+}

Subversion Repositories HelenOS-historic

(root)/uspace/trunk/init/init.c – Rev 1081 → 1089