ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/AIO.xs
(Generate patch)

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.108 by root, Thu Oct 4 12:50:35 2007 UTC vs.
Revision 1.109 by root, Sat Oct 6 14:05:19 2007 UTC

… …
527 527
528 if (do_open (gv, sym, symlen, 0, 0, 0, 0)) 528 if (do_open (gv, sym, symlen, 0, 0, 0, 0))
529 fh = (SV *)gv; 529 fh = (SV *)gv;
530 } 530 }
531 531
532 XPUSHs (fh); 532 PUSHs (fh);
533 } 533 }
534 break; 534 break;
535 535
536 case REQ_GROUP: 536 case REQ_GROUP:
537 req->int1 = 2; /* mark group as finished */ 537 req->int1 = 2; /* mark group as finished */
… …
581 } 581 }
582 582
583 errno = req->errorno; 583 errno = req->errorno;
584 584
585 PUTBACK; 585 PUTBACK;
586 call_sv (req->callback, G_VOID | G_EVAL); 586 call_sv (req->callback, G_VOID | G_EVAL | G_DISCARD);
587 SPAGAIN; 587 SPAGAIN;
588 588
589 FREETMPS; 589 FREETMPS;
590 LEAVE; 590 LEAVE;
591
592 PUTBACK;
591 } 593 }
592 594
593 if (req->grp) 595 if (req->grp)
594 { 596 {
595 aio_req grp = req->grp; 597 aio_req grp = req->grp;
… …
1255 case REQ_FCHMOD: req->result = fchmod (req->int1, req->mode); break; 1257 case REQ_FCHMOD: req->result = fchmod (req->int1, req->mode); break;
1256 case REQ_TRUNCATE: req->result = truncate (req->ptr1, req->offs); break; 1258 case REQ_TRUNCATE: req->result = truncate (req->ptr1, req->offs); break;
1257 case REQ_FTRUNCATE: req->result = ftruncate (req->int1, req->offs); break; 1259 case REQ_FTRUNCATE: req->result = ftruncate (req->int1, req->offs); break;
1258 1260
1259 case REQ_OPEN: req->result = open (req->ptr1, req->int1, req->mode); break; 1261 case REQ_OPEN: req->result = open (req->ptr1, req->int1, req->mode); break;
1260 case REQ_CLOSE: req->result = PerlIO_close ((PerlIO *)req->ptr1); break; 1262 case REQ_CLOSE: req->result = close (req->int1); break;
1261 case REQ_UNLINK: req->result = unlink (req->ptr1); break; 1263 case REQ_UNLINK: req->result = unlink (req->ptr1); break;
1262 case REQ_RMDIR: req->result = rmdir (req->ptr1); break; 1264 case REQ_RMDIR: req->result = rmdir (req->ptr1); break;
1263 case REQ_MKDIR: req->result = mkdir (req->ptr1, req->mode); break; 1265 case REQ_MKDIR: req->result = mkdir (req->ptr1, req->mode); break;
1264 case REQ_RENAME: req->result = rename (req->ptr2, req->ptr1); break; 1266 case REQ_RENAME: req->result = rename (req->ptr2, req->ptr1); break;
1265 case REQ_LINK: req->result = link (req->ptr2, req->ptr1); break; 1267 case REQ_LINK: req->result = link (req->ptr2, req->ptr1); break;
… …
1532 req->int1 = PerlIO_fileno (IoIFP (sv_2io (fh))); 1534 req->int1 = PerlIO_fileno (IoIFP (sv_2io (fh)));
1533 1535
1534 REQ_SEND (req); 1536 REQ_SEND (req);
1535} 1537}
1536 1538
1539int
1540_dup (int fd)
1541 PROTOTYPE: $
1542 CODE:
1543 RETVAL = dup (fd);
1544 OUTPUT:
1545 RETVAL
1546
1537void 1547void
1538aio_close (SV *fh, SV *callback=&PL_sv_undef) 1548_aio_close (int fd, SV *callback=&PL_sv_undef)
1539 PROTOTYPE: $;$ 1549 PROTOTYPE: $;$
1540 PPCODE: 1550 PPCODE:
1541{ 1551{
1542 PerlIO *io = IoIFP (sv_2io (fh));
1543 int fd = PerlIO_fileno (io);
1544
1545 if (fd < 0)
1546 croak ("aio_close called with fd-less filehandle");
1547
1548 PerlIO_binmode (aTHX_ io, 0, 0, 0);
1549
1550 {
1551 dREQ; 1552 dREQ;
1552 1553
1553 req->type = REQ_CLOSE; 1554 req->type = REQ_CLOSE;
1554 req->sv1 = newSVsv (fh); 1555 req->int1 = fd;
1555 req->ptr1 = (void *)io;
1556 1556
1557 REQ_SEND (req); 1557 REQ_SEND (req);
1558 }
1559} 1558}
1560 1559
1561void 1560void
1562aio_read (SV *fh, SV *offset, SV *length, SV8 *data, IV dataoffset, SV *callback=&PL_sv_undef) 1561aio_read (SV *fh, SV *offset, SV *length, SV8 *data, IV dataoffset, SV *callback=&PL_sv_undef)
1563 ALIAS: 1562 ALIAS:

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines