| … | … | ||
|---|---|---|---|
| 348 | close $fh; | 348 | close $fh; |
| 349 | CFPlus::fh_nonblocking $FH, 1; | 349 | CFPlus::fh_nonblocking $FH, 1; |
| 350 | 350 | ||
| 351 | $CB{die} = sub { die shift }; | 351 | $CB{die} = sub { die shift }; |
| 352 | 352 | ||
| 353 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', cb => \&fh_read); | 353 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', nice => 1, cb => \&fh_read); |
| 354 | 354 | ||
| 355 | sync_tick; | 355 | sync_tick; |
| 356 | } | 356 | } |
| 357 | 357 | ||
| 358 | sub stop { | 358 | sub stop { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |