X-Git-Url: http://git.vpit.fr/?a=blobdiff_plain;f=t%2F41-clone.t;h=1efd250bd13f6c8a0b59c6401256f70804bda238;hb=be3665d8224dfbb9cff5f53796500821d9c8185a;hp=b6bd2a8f70af3c2169d8ce66d976cd7069126f25;hpb=8edd65482a48cda016b4677014dcb80b2b923cb1;p=perl%2Fmodules%2FVariable-Magic.git diff --git a/t/41-clone.t b/t/41-clone.t index b6bd2a8..1efd250 100644 --- a/t/41-clone.t +++ b/t/41-clone.t @@ -1,39 +1,19 @@ -#!perl -T +#!perl use strict; use warnings; -sub skipall { - my ($msg) = @_; - require Test::More; - Test::More::plan(skip_all => $msg); -} - -use Config qw/%Config/; - -BEGIN { - my $t_v = '1.67'; - my $ts_v = '1.14'; - skipall 'This perl wasn\'t built to support threads' - unless $Config{useithreads}; - skipall "threads $t_v required to test thread safety" - unless eval "use threads $t_v; 1"; - skipall "threads::shared $ts_v required to test thread safety" - unless eval "use threads::shared $ts_v; 1"; -} - -use Test::More; # after threads +use Variable::Magic qw< + wizard cast dispell getdata + VMG_OP_INFO_NAME VMG_OP_INFO_OBJECT +>; -use Variable::Magic qw/wizard cast dispell getdata VMG_THREADSAFE VMG_OP_INFO_NAME VMG_OP_INFO_OBJECT/; +use lib 't/lib'; +use VPIT::TestHelpers ( + threads => [ 'Variable::Magic' => 'Variable::Magic::VMG_THREADSAFE()' ], +); -BEGIN { - skipall 'This Variable::Magic isn\'t thread safe' unless VMG_THREADSAFE; - plan tests => 2 * 3 + 2 * (2 * 10 + 2) + 2 * (2 * 7 + 2); - my $v = $threads::VERSION; - diag "Using threads $v" if defined $v; - $v = $threads::shared::VERSION; - diag "Using threads::shared $v" if defined $v; -} +use Test::Leaner 'no_plan'; my $destroyed : shared = 0; my $c : shared = 0; @@ -41,55 +21,88 @@ my $c : shared = 0; sub spawn_wiz { my ($op_info) = @_; + my $desc = "wizard with op_info $op_info in main thread"; + + local $@; my $wiz = eval { - wizard data => sub { $_[1] + threads->tid() }, - get => sub { lock $c; ++$c; 0 }, - set => sub { - my $op = $_[-1]; - my $tid = threads->tid(); - if ($op_info == VMG_OP_INFO_OBJECT) { - is_deeply { class => ref($op), name => $op->name }, - { class => 'B::BINOP', name => 'sassign' }, - "op object in thread $tid is correct"; - } else { - is $op, 'sassign', "op name in thread $tid is correct"; - } - 0 - }, - free => sub { lock $destroyed; ++$destroyed; 0 }, - op_info => $op_info + wizard( + data => sub { $_[1] + threads->tid() }, + get => sub { lock $c; ++$c; 0 }, + set => sub { + my $op = $_[-1]; + my $tid = threads->tid(); + + if ($op_info == VMG_OP_INFO_OBJECT) { + is_deeply { class => ref($op), name => $op->name }, + { class => 'B::BINOP', name => 'sassign' }, + "op object in thread $tid is correct"; + } else { + is $op, 'sassign', "op name in thread $tid is correct"; + } + + return 0 + }, + free => sub { lock $destroyed; ++$destroyed; 0 }, + op_info => $op_info, + ); }; - is($@, '', "wizard with op_info $op_info in main thread doesn't croak"); - isnt($wiz, undef, "wizard with op_info $op_info in main thread is defined"); - is($c, 0, "wizard with op_info $op_info in main thread doesn't trigger magic"); + is $@, '', "$desc doesn't croak"; + isnt $wiz, undef, "$desc is defined"; + is $c, 0, "$desc doesn't trigger magic"; return $wiz; } sub try { my ($dispell, $wiz) = @_; - my $tid = threads->tid(); - my $a = 3; - my $res = eval { cast $a, $wiz, sub { 5 }->() }; - is($@, '', "cast in thread $tid doesn't croak"); - my $b; - eval { $b = $a }; - is($@, '', "get in thread $tid doesn't croak"); - is($b, 3, "get in thread $tid returns the right thing"); - my $d = eval { getdata $a, $wiz }; - is($@, '', "getdata in thread $tid doesn't croak"); - is($d, 5 + $tid, "getdata in thread $tid returns the right thing"); - eval { $a = 9 }; - is($@, '', "set in thread $tid (check opname) doesn't croak"); - if ($dispell) { - $res = eval { dispell $a, $wiz }; - is($@, '', "dispell in thread $tid doesn't croak"); - undef $b; + my $tid = threads->tid; + + my $a = 3; + + { + local $@; + my $res = eval { cast $a, $wiz, sub { 5 }->() }; + is $@, '', "cast in thread $tid doesn't croak"; + } + + { + local $@; + my $b; eval { $b = $a }; - is($@, '', "get in thread $tid after dispell doesn't croak"); - is($b, 9, "get in thread $tid after dispell returns the right thing"); + is $@, '', "get in thread $tid doesn't croak"; + is $b, 3, "get in thread $tid returns the right thing"; + } + + { + local $@; + my $d = eval { getdata $a, $wiz }; + is $@, '', "getdata in thread $tid doesn't croak"; + is $d, 5 + $tid, "getdata in thread $tid returns the right thing"; + } + + { + local $@; + eval { $a = 9 }; + is $@, '', "set in thread $tid (check opname) doesn't croak"; } - return; # Ugly if not here + + if ($dispell) { + { + local $@; + my $res = eval { dispell $a, $wiz }; + is $@, '', "dispell in thread $tid doesn't croak"; + } + + { + local $@; + my $b; + eval { $b = $a }; + is $@, '', "get in thread $tid after dispell doesn't croak"; + is $b, 9, "get in thread $tid after dispell returns the right thing"; + } + } + + return; } my $wiz_name = spawn_wiz VMG_OP_INFO_NAME; @@ -106,8 +119,8 @@ for my $dispell (1, 0) { $destroyed = 0; } - my @t = map { threads->create(\&try, $dispell, $wiz) } 1 .. 2; - $_->join for @t; + my @threads = map spawn(\&try, $dispell, $wiz), 1 .. 2; + $_->join for @threads; { lock $c; @@ -119,3 +132,45 @@ for my $dispell (1, 0) { } } } + +{ + my @threads; + my $flag : shared = 0; + my $destroyed; + + { + my $wiz = wizard( + set => sub { + my $tid = threads->tid; + pass "set callback called in thread $tid" + }, + free => sub { ++$destroyed }, + ); + + my $var = 123; + cast $var, $wiz; + + @threads = map spawn( + sub { + my $tid = threads->tid; + my $exp = 456 + $tid; + { + lock $flag; + threads::shared::cond_wait($flag) until $flag; + } + $var = $exp; + is $var, $exp, "\$var could be assigned to in thread $tid"; + } + ), 1 .. 5; + } + + is $destroyed, 1, 'wizard is destroyed'; + + { + lock $flag; + $flag = 1; + threads::shared::cond_broadcast($flag); + } + + $_->join for @threads; +}