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

Timestamp:

2012-05-04T10:57:48Z (12 years ago)

Author:

Vojtech Horky <vojtechhorky@…>

Branches:

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

Children:

35a35651

Parents:

90924df (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/include/net/modules.h ) (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
- * Generic module functions.
- *
- * @todo MAKE IT POSSIBLE TO REMOVE THIS FILE VIA EITHER REPLACING PART OF ITS
- * FUNCTIONALITY OR VIA INTEGRATING ITS FUNCTIONALITY MORE TIGHTLY WITH THE REST
- * OF THE SYSTEM.
- */
+#define DURATION_SECS      30
 
-#ifndef LIBC_MODULES_H_
-#define LIBC_MODULES_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;
+                }
+        }
 
-#include <async.h>
-#include <ipc/services.h>
-#include <sys/time.h>
+        // 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.
 
-/** Connect to module function type definition.
- *
- * @return Session to the service.
- *
- */
-typedef async_sess_t *connect_module_t(services_t);
+        TPRINTF("Terminating...\n");
 
-extern void answer_call(ipc_callid_t, int, ipc_call_t *, size_t);
-extern async_sess_t *bind_service(services_t, sysarg_t, sysarg_t, sysarg_t,
-    async_client_conn_t);
-extern async_sess_t *connect_to_service(services_t);
-extern int data_reply(void *, size_t);
-extern void refresh_answer(ipc_call_t *, size_t *);
+leave:
+        console_done(console);
 
-#endif
-
-/** @}
- */
+        return err;
+}