… | |
… | |
105 | |
105 | |
106 | sub readable { &Coro::Handle::FH::readable } |
106 | sub readable { &Coro::Handle::FH::readable } |
107 | sub writable { &Coro::Handle::FH::writable } |
107 | sub writable { &Coro::Handle::FH::writable } |
108 | |
108 | |
109 | BEGIN { |
109 | BEGIN { |
110 | our $VERSION = '1.23'; |
110 | our $VERSION = '1.24'; |
111 | |
111 | |
112 | require XSLoader; |
112 | require XSLoader; |
113 | XSLoader::load Coro::Mysql::, $VERSION; |
113 | XSLoader::load Coro::Mysql::, $VERSION; |
114 | } |
114 | } |
115 | |
115 | |
… | |
… | |
145 | if (AnyEvent::detect ne "AnyEvent::Impl::EV" || !_use_ev) { |
145 | if (AnyEvent::detect ne "AnyEvent::Impl::EV" || !_use_ev) { |
146 | require Coro::Handle; |
146 | require Coro::Handle; |
147 | $fh = Coro::Handle::unblock ($fh); |
147 | $fh = Coro::Handle::unblock ($fh); |
148 | } |
148 | } |
149 | |
149 | |
|
|
150 | warn "$sock,$DBH->{sockfd},$DBH->{mysql_clientversion},$fh\n";#d# |
150 | _patch $sock, $DBH->{sockfd}, $DBH->{mysql_clientversion}, $fh, tied *$$fh; |
151 | _patch $sock, $DBH->{sockfd}, $DBH->{mysql_clientversion}, $fh, tied *$$fh; |
151 | } |
152 | } |
152 | |
153 | |
153 | $DBH |
154 | $DBH |
154 | } |
155 | } |