| … | |
… | |
| 1662 | static IV |
1662 | static IV |
| 1663 | PerlIOCede_pushed (pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab) |
1663 | PerlIOCede_pushed (pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab) |
| 1664 | { |
1664 | { |
| 1665 | PerlIOCede *self = PerlIOSelf (f, PerlIOCede); |
1665 | PerlIOCede *self = PerlIOSelf (f, PerlIOCede); |
| 1666 | |
1666 | |
| 1667 | self->every = SvNV (arg); |
1667 | self->every = SvCUR (arg) ? SvNV (arg) : 0.01; |
| 1668 | self->next = nvtime () + self->every; |
1668 | self->next = nvtime () + self->every; |
| 1669 | |
1669 | |
| 1670 | return PerlIOBuf_pushed (aTHX_ f, mode, Nullsv, tab); |
1670 | return PerlIOBuf_pushed (aTHX_ f, mode, Nullsv, tab); |
| 1671 | } |
1671 | } |
| 1672 | |
1672 | |
| … | |
… | |
| 1688 | { |
1688 | { |
| 1689 | api_cede (); |
1689 | api_cede (); |
| 1690 | self->next = now + self->every; |
1690 | self->next = now + self->every; |
| 1691 | } |
1691 | } |
| 1692 | |
1692 | |
| 1693 | return PerlIOBuf_flush (f); |
1693 | return PerlIOBuf_flush (aTHX_ f); |
| 1694 | } |
1694 | } |
| 1695 | |
1695 | |
| 1696 | static PerlIO_funcs PerlIO_cede = |
1696 | static PerlIO_funcs PerlIO_cede = |
| 1697 | { |
1697 | { |
| 1698 | sizeof(PerlIO_funcs), |
1698 | sizeof(PerlIO_funcs), |
