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