… | |
… | |
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)}; |