1 files changed, 96 insertions, 0 deletions
diff --git a/erts/emulator/test/driver_SUITE_data/timer_drv.c b/erts/emulator/test/driver_SUITE_data/timer_drv.c
new file mode 100644
index 0000000000..b96a95dd4c
--- /dev/null
+++ b/erts/emulator/test/driver_SUITE_data/timer_drv.c
@@ -0,0 +1,96 @@
+#ifdef VXWORKS
+#include <vxWorks.h>
+#include <taskVarLib.h>
+#include <taskLib.h>
+#include <sysLib.h>
+#include <string.h>
+#include <ioLib.h>
+#endif
+#include <stdio.h>
+#include "erl_driver.h"
+
+#define get_int32(s) ((((unsigned char*) (s))[0] << 24) | \
+                      (((unsigned char*) (s))[1] << 16) | \
+                      (((unsigned char*) (s))[2] << 8)  | \
+                      (((unsigned char*) (s))[3]))
+
+#define START_TIMER 0
+#define CANCEL_TIMER 1
+#define DELAY_START_TIMER 2
+#define TIMER 3
+#define CANCELLED 4
+
+static ErlDrvPort erlang_port;
+static ErlDrvData timer_start(ErlDrvPort, char*);
+static void timer_stop(ErlDrvData), timer_read(ErlDrvData, char*, int), timer(ErlDrvData);
+
+static ErlDrvEntry timer_driver_entry =
+{
+    NULL,
+    timer_start,
+    timer_stop,
+    timer_read,
+    NULL,
+    NULL,
+    "timer_drv",
+    NULL,
+    NULL,
+    NULL,
+    timer,
+    NULL,
+    NULL
+};
+
+DRIVER_INIT(timer_drv)
+{
+    erlang_port = (ErlDrvPort)-1;
+    return &timer_driver_entry;
+}
+
+static ErlDrvData timer_start(ErlDrvPort port, char *buf)
+{
+    if (erlang_port != (ErlDrvPort)-1) {
+	return ERL_DRV_ERROR_GENERAL;
+    }
+    erlang_port = port;
+    return (ErlDrvData)port;
+}
+
+/* set the timer, this is monitored from erlang measuring the time */
+static void timer_read(ErlDrvData port, char *buf, int len)
+{
+    char reply[1];
+
+    if (buf[0] == START_TIMER) { 
+	/* fprintf(stderr, "[timer_drv] Setting timeout: %i\n", get_int32(buf + 1)); */
+	driver_set_timer(port, get_int32(buf + 1));
+    } else if (buf[0] == CANCEL_TIMER) {
+	/*	fprintf(stderr, "[timer_drv] Timer cancelled\n"); */
+	driver_cancel_timer(port);
+	reply[0] = CANCELLED;
+	driver_output(port, reply, 1);
+    } else if (buf[0] == DELAY_START_TIMER) {
+#ifndef __WIN32__
+#ifdef VXWORKS
+	taskDelay(sysClkRateGet());
+#else
+	sleep(1);
+#endif
+#endif
+	driver_set_timer(port, get_int32(buf + 1));
+    }
+}
+
+static void timer_stop(ErlDrvData port)
+{
+    erlang_port = (ErlDrvPort)-1;
+}
+
+static void timer(ErlDrvData port)
+{
+    char reply[1];
+
+    /*   fprintf(stderr, "[timer_drv] timer timed out\n"); */
+    reply[0] = TIMER;
+    driver_output((ErlDrvPort)port, reply, 1);
+}