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

Timestamp:

2012-04-20T07:32:57Z (12 years ago)

Author:

Vojtech Horky <vojtechhorky@…>

Branches:

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

Children:

097f421

Parents:

90f067d9 (diff), 606c369 (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/net/tl/tl_remote.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 libnet
- * @{
- */
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/time.h>
+#include <io/console.h>
+#include <async.h>
+#include "../tester.h"
 
-#include <tl_remote.h>
-#include <generic.h>
-#include <packet_client.h>
-#include <ipc/services.h>
-#include <ipc/tl.h>
-#include <net/device.h>
-#include <net/packet.h>
-#include <async.h>
+#define DURATION_SECS      30
 
-/** Notify the remote transport layer modules about the received packet/s.
- *
- * @param[in] sess      Transport layer module session.
- * @param[in] device_id Device identifier.
- * @param[in] packet    Received packet or the received packet queue.
- *                      The packet queue is used to carry a fragmented
- *                      datagram. The first packet contains the headers,
- *                      the others contain only data.
- * @param[in] target    Target transport layer module service to be
- *                      delivered to.
- * @param[in] error     Packet error reporting service. Prefixes the
- *                      received packet.
- *
- * @return EOK on success.
- *
- */
-int tl_received_msg(async_sess_t *sess, nic_device_id_t device_id, packet_t *packet,
-    services_t target, services_t error)
+const char *test_starve_ipc(void)
 {
-        return generic_received_msg_remote(sess, NET_TL_RECEIVED, device_id,
-            packet_get_id(packet), target, error);
+        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;
+                }
+        }
+
+        // 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;
 }
-
-/** @}
- */