… | |
… | |
100 | |
100 | |
101 | sub readable { &Coro::Handle::FH::readable } |
101 | sub readable { &Coro::Handle::FH::readable } |
102 | sub writable { &Coro::Handle::FH::writable } |
102 | sub writable { &Coro::Handle::FH::writable } |
103 | |
103 | |
104 | BEGIN { |
104 | BEGIN { |
105 | our $VERSION = '1.1'; |
105 | our $VERSION = '1.2'; |
106 | |
106 | |
107 | require XSLoader; |
107 | require XSLoader; |
108 | XSLoader::load Coro::Mysql::, $VERSION; |
108 | XSLoader::load Coro::Mysql::, $VERSION; |
109 | } |
109 | } |
110 | |
110 | |
… | |
… | |
140 | if (AnyEvent::detect ne "AnyEvent::Impl::EV" || !_use_ev) { |
140 | if (AnyEvent::detect ne "AnyEvent::Impl::EV" || !_use_ev) { |
141 | require Coro::Handle; |
141 | require Coro::Handle; |
142 | $fh = Coro::Handle::unblock ($fh); |
142 | $fh = Coro::Handle::unblock ($fh); |
143 | } |
143 | } |
144 | |
144 | |
145 | _patch $sock, $DBH->{sockfd}, $fh, tied ${$fh}; |
145 | _patch $sock, $DBH->{sockfd}, $DBH->{mysql_clientversion}, $fh, tied ${$fh}; |
146 | } |
146 | } |
147 | |
147 | |
148 | $DBH |
148 | $DBH |
149 | } |
149 | } |
150 | |
150 | |