| … | |
… | |
| 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 | |
