… | |
… | |
447 | PUSHs (sv_2mortal (newSViv (req->result))); |
447 | PUSHs (sv_2mortal (newSViv (req->result))); |
448 | PUTBACK; |
448 | PUTBACK; |
449 | call_pv ("IO::AIO::_fd2fh", G_SCALAR | G_EVAL); |
449 | call_pv ("IO::AIO::_fd2fh", G_SCALAR | G_EVAL); |
450 | SPAGAIN; |
450 | SPAGAIN; |
451 | |
451 | |
452 | fh = SvREFCNT_inc (POPs); |
452 | fh = POPs; |
453 | |
|
|
454 | PUSHMARK (SP); |
453 | PUSHMARK (SP); |
455 | XPUSHs (sv_2mortal (fh)); |
454 | XPUSHs (fh); |
456 | } |
455 | } |
457 | break; |
456 | break; |
458 | |
457 | |
459 | case REQ_GROUP: |
458 | case REQ_GROUP: |
460 | req->int1 = 2; /* mark group as finished */ |
459 | req->int1 = 2; /* mark group as finished */ |
… | |
… | |
1651 | |
1650 | |
1652 | int |
1651 | int |
1653 | poll() |
1652 | poll() |
1654 | PROTOTYPE: |
1653 | PROTOTYPE: |
1655 | CODE: |
1654 | CODE: |
1656 | if (nreqs) |
|
|
1657 | { |
|
|
1658 | poll_wait (); |
1655 | poll_wait (); |
1659 | RETVAL = poll_cb (); |
1656 | RETVAL = poll_cb (); |
1660 | } |
|
|
1661 | else |
|
|
1662 | RETVAL = 0; |
|
|
1663 | OUTPUT: |
1657 | OUTPUT: |
1664 | RETVAL |
1658 | RETVAL |
1665 | |
1659 | |
1666 | int |
1660 | int |
1667 | poll_fileno() |
1661 | poll_fileno() |
… | |
… | |
1681 | |
1675 | |
1682 | void |
1676 | void |
1683 | poll_wait() |
1677 | poll_wait() |
1684 | PROTOTYPE: |
1678 | PROTOTYPE: |
1685 | CODE: |
1679 | CODE: |
1686 | if (nreqs) |
|
|
1687 | poll_wait (); |
1680 | poll_wait (); |
1688 | |
1681 | |
1689 | int |
1682 | int |
1690 | nreqs() |
1683 | nreqs() |
1691 | PROTOTYPE: |
1684 | PROTOTYPE: |
1692 | CODE: |
1685 | CODE: |