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
|
#!perl -w
$|=1;
# --- Test DBI support for threads created after the DBI was loaded
BEGIN { eval "use threads;" } # Must be first
my $use_threads_err = $@;
use strict;
use Config qw(%Config);
use Test::More;
BEGIN {
if (!$Config{useithreads} || $] < 5.008001) {
plan skip_all => "this $^O perl $] not supported for DBI iThreads";
}
die $use_threads_err if $use_threads_err; # need threads
}
my $threads = 4;
plan tests => 4 + 4 * $threads;
{
package threads_sub;
use base qw(threads);
}
use_ok('DBI');
$DBI::PurePerl = $DBI::PurePerl; # just to silence used only once warning
$DBI::neat_maxlen = 12345;
cmp_ok($DBI::neat_maxlen, '==', 12345, '... assignment of neat_maxlen was successful');
my @connect_args = ("dbi:ExampleP:", '', '');
my $dbh_parent = DBI->connect_cached(@connect_args);
isa_ok( $dbh_parent, 'DBI::db' );
# this our function for the threads to run
sub testing {
cmp_ok($DBI::neat_maxlen, '==', 12345, '... DBI::neat_maxlen still holding its value');
my $dbh = DBI->connect_cached(@connect_args);
isa_ok( $dbh, 'DBI::db' );
isnt($dbh, $dbh_parent, '... new $dbh is not the same instance as $dbh_parent');
SKIP: {
# skip seems broken with threads (5.8.3)
# skip "Kids attribute not supported under DBI::PurePerl", 1 if $DBI::PurePerl;
cmp_ok($dbh->{Driver}->{Kids}, '==', 1, '... the Driver has one Kid')
unless $DBI::PurePerl && ok(1);
}
# RT #77137: a thread created from a thread was crashing the
# interpreter
threads->new(sub {})->join();
}
# load up the threads
my @thr;
push @thr, threads_sub->create( \&testing )
or die "thread->create failed ($!)"
foreach (1..$threads);
# join all the threads
foreach my $thread (@thr) {
$thread->join;
# provide a little insurance against thread scheduling issues (hopefully)
# http://www.nntp.perl.org/group/perl.cpan.testers/2009/06/msg4369660.html
eval { select undef, undef, undef, 0.2 };
}
pass('... all tests have passed');
1;
|
