blob: 8eac55bc5a391700ea26f583b9b9602f4644d736 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
use strict;
use warnings;
BEGIN {
require($ENV{PERL_CORE} ? '../../t/test.pl' : './t/test.pl');
use Config;
if (! $Config{'useithreads'}) {
skip_all(q/Perl not compiled with 'useithreads'/);
}
}
use ExtUtils::testlib;
use threads;
BEGIN {
if (! eval 'use threads::shared; 1') {
skip_all('threads::shared not available');
}
local $SIG{'HUP'} = sub {};
my $thr = threads->create(sub {});
eval { $thr->kill('HUP') };
$thr->join();
if ($@ && $@ =~ /safe signals/) {
skip_all('Not using safe signals');
}
plan(3);
};
fresh_perl_is(<<'EOI', 'ok', { }, 'No signal handler in thread');
use threads;
use Thread::Semaphore;
my $sema = Thread::Semaphore->new(0);
my $test = sub {
my $sema = shift;
$sema->up();
while(1) { sleep(1); }
};
my $thr = threads->create($test, $sema);
$sema->down();
$thr->detach();
eval {
$thr->kill('STOP');
};
print(($@ =~ /no signal handler set/) ? 'ok' : 'not ok');
EOI
fresh_perl_is(<<'EOI', 'ok', { }, 'Handler to signal mismatch');
use threads;
use Thread::Semaphore;
my $sema = Thread::Semaphore->new(0);
my $test = sub {
my $sema = shift;
$SIG{'TERM'} = sub { threads->exit() };
$sema->up();
while(1) { sleep(1); }
};
my $thr = threads->create($test, $sema);
$sema->down();
$thr->detach();
eval {
$thr->kill('STOP');
};
print(($@ =~ /no signal handler set/) ? 'ok' : 'not ok');
EOI
fresh_perl_is(<<'EOI', 'ok', { }, 'Handler and signal match');
use threads;
use Thread::Semaphore;
my $sema = Thread::Semaphore->new(0);
my $test = sub {
my $sema = shift;
$SIG{'STOP'} = sub { threads->exit() };
$sema->up();
while(1) { sleep(1); }
};
my $thr = threads->create($test, $sema);
$sema->down();
$thr->detach();
eval {
$thr->kill('STOP');
};
print((! $@) ? 'ok' : 'not ok');
EOI
exit(0);
# EOF
|
