… | |
… | |
68 | use AnyEvent (); |
68 | use AnyEvent (); |
69 | use AnyEvent::Util (); |
69 | use AnyEvent::Util (); |
70 | |
70 | |
71 | use Errno (); |
71 | use Errno (); |
72 | |
72 | |
73 | our $VERSION = '3.0'; |
73 | our $VERSION = '3.02'; |
74 | |
74 | |
75 | =head2 METHODS |
75 | =head2 METHODS |
76 | |
76 | |
77 | =over 4 |
77 | =over 4 |
78 | |
78 | |
… | |
… | |
186 | # available, even before the forked process exsist. |
186 | # available, even before the forked process exsist. |
187 | # this is mostly done so this module is compatible |
187 | # this is mostly done so this module is compatible |
188 | # to versions of itself older than 3.0. |
188 | # to versions of itself older than 3.0. |
189 | my ($client, $server) = AnyEvent::Util::portable_socketpair |
189 | my ($client, $server) = AnyEvent::Util::portable_socketpair |
190 | or croak "unable to create AnyEvent::DBI communications pipe: $!"; |
190 | or croak "unable to create AnyEvent::DBI communications pipe: $!"; |
|
|
191 | |
|
|
192 | AnyEvent::fh_unblock $client; |
191 | |
193 | |
192 | my $fork = delete $arg{fork_template}; |
194 | my $fork = delete $arg{fork_template}; |
193 | |
195 | |
194 | my %dbi_args = %arg; |
196 | my %dbi_args = %arg; |
195 | delete @dbi_args{qw(on_connect on_error timeout fork_template exec_server)}; |
197 | delete @dbi_args{qw(on_connect on_error timeout fork_template exec_server)}; |