From c5b7477a8873e6fd80fab598a8e63a5006e46621 Mon Sep 17 00:00:00 2001
From: Sverker Eriksson <sverker@erlang.org>
Date: Wed, 17 Nov 2010 19:40:42 +0100
Subject: Remove use of unreliable CancelIoEx on Windows.

CancelIoEx has been seen to cause problems with some drivers.
Also improve fallback solution to reuse existing handle-closer-threads.
---
 erts/emulator/test/port_SUITE.erl              | 24 ++++++++++++++++++++++--
 erts/emulator/test/port_SUITE_data/dead_port.c |  6 +++---
 2 files changed, 25 insertions(+), 5 deletions(-)

(limited to 'erts/emulator/test')

diff --git a/erts/emulator/test/port_SUITE.erl b/erts/emulator/test/port_SUITE.erl
index a7476ca9bb..6d89653623 100644
--- a/erts/emulator/test/port_SUITE.erl
+++ b/erts/emulator/test/port_SUITE.erl
@@ -2308,8 +2308,28 @@ close_deaf_port(Config) when is_list(Config) ->
     ?line Dog = test_server:timetrap(test_server:seconds(100)),
     ?line DataDir = ?config(data_dir, Config),
     ?line DeadPort = os:find_executable("dead_port", DataDir),
-
     ?line Port = open_port({spawn,DeadPort++" 60"},[]),
     ?line erlang:port_command(Port,"Hello, can you hear me!?!?"),
     ?line port_close(Port),
-    ok.
+
+    close_deaf_port_1(0, DeadPort).
+
+close_deaf_port_1(1000, _) ->
+    ok;
+close_deaf_port_1(N, Cmd) ->
+    Timeout = integer_to_list(random:uniform(10*1000)),
+    try open_port({spawn,Cmd++" "++Timeout},[]) of
+    	Port ->
+	    ?line erlang:port_command(Port,"Hello, can you hear me!?!?"),
+	    ?line port_close(Port),
+	    close_deaf_port_1(N+1, Cmd)
+    catch
+    	exit:eagain ->
+	    {comment, "Could not spawn more than " ++ integer_to_list(N) ++ " OS processes."}
+    end.
+    
+
+repeat(0, _) -> ok;
+repeat(Cnt, Fun) ->
+    Fun(),
+    repeat(Cnt-1, Fun).
diff --git a/erts/emulator/test/port_SUITE_data/dead_port.c b/erts/emulator/test/port_SUITE_data/dead_port.c
index 6fa77112be..68e96fbf14 100644
--- a/erts/emulator/test/port_SUITE_data/dead_port.c
+++ b/erts/emulator/test/port_SUITE_data/dead_port.c
@@ -72,14 +72,14 @@ char *argv[];
 {
     int x;
     if (argc < 2) {
-	fprintf(stderr,"Usage %s <seconds>\n",argv[0]);
+	fprintf(stderr,"Usage %s <milliseconds>\n",argv[0]);
 	return 1;
     }
     if ((x = atoi(argv[1])) <= 0) {
-	fprintf(stderr,"Usage %s <seconds>\n",argv[0]);
+	fprintf(stderr,"Usage %s <milliseconds>\n",argv[0]);
 	return 1;
     }
-    delay(x*1000);
+    delay(x);
     return 0;
 }
 
-- 
cgit v1.2.3