diff options
author | Jarkko Hietaniemi <jhi@iki.fi> | 2002-01-18 15:07:49 +0000 |
---|---|---|
committer | Jarkko Hietaniemi <jhi@iki.fi> | 2002-01-18 15:07:49 +0000 |
commit | ae054b0e4ed0f5e3de61defdd2afafe7cc278dc0 (patch) | |
tree | 18e5108a7131a5a4dd1aeb22133c7d3708697a5d /ext/Socket/Socket.t | |
parent | 41504350f37c10b0232d0cbe73e80e8b4c8f317c (diff) | |
download | perl-ae054b0e4ed0f5e3de61defdd2afafe7cc278dc0.tar.gz |
Try to make the connect/read/write timeouting.
p4raw-id: //depot/perl@14330
Diffstat (limited to 'ext/Socket/Socket.t')
-rwxr-xr-x | ext/Socket/Socket.t | 48 |
1 files changed, 39 insertions, 9 deletions
diff --git a/ext/Socket/Socket.t b/ext/Socket/Socket.t index ebf5a5f072..ed87e67184 100755 --- a/ext/Socket/Socket.t +++ b/ext/Socket/Socket.t @@ -9,69 +9,99 @@ BEGIN { print "1..0\n"; exit 0; } + $has_alarm = $Config{d_alarm}; } use Socket; print "1..16\n"; +$alarmed = 0; +sub arm { $alarmed = 0; alarm(shift) if $has_alarm } +sub alarmed { $alarmed = 1 } +$SIG{ALRM} = 'alarmed' if $has_alarm; + if (socket(T,PF_INET,SOCK_STREAM,6)) { print "ok 1\n"; - + + arm(5); if (connect(T,pack_sockaddr_in(7,inet_aton("localhost")))){ + arm(0); + print "ok 2\n"; print "# Connected to " . inet_ntoa((unpack_sockaddr_in(getpeername(T)))[1])."\n"; + arm(5); syswrite(T,"hello",5); + arm(0); + + arm(5); $read = sysread(T,$buff,10); # Connection may be granted, then closed! + arm(0); + while ($read > 0 && length($buff) < 5) { # adjust for fact that TCP doesn't guarantee size of reads/writes + arm(5); $read = sysread(T,$buff,10,length($buff)); + arm(0); } print(($read == 0 || $buff eq "hello") ? "ok 3\n" : "not ok 3\n"); } else { print "# You're allowed to fail tests 2 and 3 if\n"; print "# the echo service has been disabled.\n"; - print "# $!\n"; - print "ok 2\n"; - print "ok 3\n"; + print "# 'Interrupted system call' indicates a hanging echo service.\n"; + print "# Error: $!\n"; + print "ok 2 - skipped\n"; + print "ok 3 - skipped\n"; } } else { - print "# $!\n"; + print "# Error: $!\n"; print "not ok 1\n"; } if( socket(S,PF_INET,SOCK_STREAM,6) ){ print "ok 4\n"; + arm(5); if (connect(S,pack_sockaddr_in(7,INADDR_LOOPBACK))){ + arm(0); + print "ok 5\n"; print "# Connected to " . inet_ntoa((unpack_sockaddr_in(getpeername(S)))[1])."\n"; + arm(5); syswrite(S,"olleh",5); + arm(0); + + arm(5); $read = sysread(S,$buff,10); # Connection may be granted, then closed! + arm(0); + while ($read > 0 && length($buff) < 5) { # adjust for fact that TCP doesn't guarantee size of reads/writes + arm(5); $read = sysread(S,$buff,10,length($buff)); + arm(0); } print(($read == 0 || $buff eq "olleh") ? "ok 6\n" : "not ok 6\n"); } else { print "# You're allowed to fail tests 5 and 6 if\n"; print "# the echo service has been disabled.\n"; - print "# $!\n"; - print "ok 5\n"; - print "ok 6\n"; + print "# 'Interrupted system call' indicates a hanging echo service.\n"; + print "# Error: $!\n"; + print "ok 5 - skipped\n"; + print "ok 6 - skipped\n"; } } else { - print "# $!\n"; + print "# Error: $!\n"; print "not ok 4\n"; } |