… | |
… | |
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 */ |
… | |
… | |
1644 | PROTOTYPE: |
1643 | PROTOTYPE: |
1645 | CODE: |
1644 | CODE: |
1646 | while (nreqs) |
1645 | while (nreqs) |
1647 | { |
1646 | { |
1648 | poll_wait (); |
1647 | poll_wait (); |
1649 | poll_cb (0); |
1648 | poll_cb (); |
1650 | } |
1649 | } |
1651 | |
1650 | |
1652 | void |
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 | poll_cb (0); |
1656 | RETVAL = poll_cb (); |
1660 | } |
1657 | OUTPUT: |
|
|
1658 | RETVAL |
1661 | |
1659 | |
1662 | int |
1660 | int |
1663 | poll_fileno() |
1661 | poll_fileno() |
1664 | PROTOTYPE: |
1662 | PROTOTYPE: |
1665 | CODE: |
1663 | CODE: |
… | |
… | |
1677 | |
1675 | |
1678 | void |
1676 | void |
1679 | poll_wait() |
1677 | poll_wait() |
1680 | PROTOTYPE: |
1678 | PROTOTYPE: |
1681 | CODE: |
1679 | CODE: |
1682 | if (nreqs) |
|
|
1683 | poll_wait (); |
1680 | poll_wait (); |
1684 | |
1681 | |
1685 | int |
1682 | int |
1686 | nreqs() |
1683 | nreqs() |
1687 | PROTOTYPE: |
1684 | PROTOTYPE: |
1688 | CODE: |
1685 | CODE: |