Changeset c6588ce in mainline for uspace/app/tester/ipc/starve.c

Timestamp:

2012-05-05T08:12:17Z (12 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

ee04c28

Parents:

2cc7f16 (diff), d21e935c (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge mainline changes.

File:

• uspace/app/tester/ipc/starve.c (moved) (moved from uspace/lib/c/generic/net/icmp_common.c ) (2 diffs)

uspace/app/tester/ipc/starve.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2009 Lukas Mejdrech
+ * Copyright (c) 2012 Vojtech Horky
  * All rights reserved.
  *
@@ -27 +27 @@
  */
 
-/** @addtogroup libc
- *  @{
- */
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/time.h>
+#include <io/console.h>
+#include <async.h>
+#include "../tester.h"
 
-/** @file
- * ICMP common interface implementation.
- * @see icmp_common.h
- */
+#define DURATION_SECS      30
 
-#include <net/modules.h>
-#include <net/icmp_common.h>
-#include <ipc/services.h>
-#include <ipc/icmp.h>
-#include <sys/time.h>
-#include <async.h>
+const char *test_starve_ipc(void)
+{
+        const char *err = NULL;
+        console_ctrl_t *console = console_init(stdin, stdout);
+        if (console == NULL) {
+                return "Failed to init connection with console.";
+        }
+        
+        struct timeval start;
+        if (gettimeofday(&start, NULL) != 0) {
+                err = "Failed getting the time";
+                goto leave;
+        }
+        
+        TPRINTF("Intensive computation shall be imagined (for %ds)...\n", DURATION_SECS);
+        TPRINTF("Press a key to terminate prematurely...\n");
+        while (true) {
+                struct timeval now;
+                if (gettimeofday(&now, NULL) != 0) {
+                        err = "Failed getting the time";
+                        goto leave;
+                }
+                
+                if (tv_sub(&now, &start) >= DURATION_SECS * 1000000L)
+                        break;
+                
+                kbd_event_t ev;
+                suseconds_t timeout = 0;
+                bool has_event = console_get_kbd_event_timeout(console, &ev, &timeout);
+                if (has_event && (ev.type == KEY_PRESS)) {
+                        TPRINTF("Key %d pressed, terminating.\n", ev.key);
+                        break;
+                }
+        }
 
-/** Connect to the ICMP module.
- *
- * @return ICMP module session.
- *
- */
-async_sess_t *icmp_connect_module(void)
-{
-        return connect_to_service(SERVICE_ICMP);
+        // FIXME - unless a key was pressed, the answer leaked as no one
+        // will wait for it.
+        // We cannot use async_forget() directly, though. Something like
+        // console_forget_pending_kbd_event() shall come here.
+
+        TPRINTF("Terminating...\n");
+
+leave:
+        console_done(console);
+
+        return err;
 }
-
-/** @}
- */