| … | |
… | |
| 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.2'; |
110 | our $VERSION = 1.26; |
| 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 | _patch $sock, $DBH->{sockfd}, $DBH->{mysql_clientversion}, $fh, tied ${$fh}; |
150 | _patch $sock, $DBH->{sockfd}, $DBH->{mysql_clientversion}, $fh, tied *$$fh; |
| 151 | } |
151 | } |
| 152 | |
152 | |
| 153 | $DBH |
153 | $DBH |
| 154 | } |
154 | } |
| 155 | |
155 | |
