1 #define PERL_NO_GET_CONTEXT
11 struct _PerlIO base; /* Base "class" info */
41 static const MGVTBL PerlIOVia_tag = { 0, 0, 0, 0, 0, 0, 0, 0 };
43 #define MYMethod(x) #x,&s->x
46 PerlIOVia_fetchmethod(pTHX_ PerlIOVia * s, const char *method, CV ** save)
48 GV *gv = gv_fetchmeth(s->stash, method, strlen(method), 0);
50 Perl_warn(aTHX_ "Lookup %s::%s => %p", HvNAME_get(s->stash), method, gv);
53 return *save = GvCV(gv);
56 return *save = (CV *) - 1;
61 * Try and call method, possibly via cached lookup.
62 * If method does not exist return Nullsv (caller may fallback to another approach
63 * If method does exist call it with flags passing variable number of args
64 * Last arg is a "filehandle" to layer below (if present)
65 * Returns scalar returned by method (if any) otherwise sv_undef
69 PerlIOVia_method(pTHX_ PerlIO * f, const char *method, CV ** save, int flags,
72 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
75 (*save) ? *save : PerlIOVia_fetchmethod(aTHX_ s, method, save);
76 if (cv != (CV *) - 1) {
83 PUSHSTACKi(PERLSI_MAGIC);
87 while ((arg = va_arg(ap, SV *))) {
94 char *package = HvNAME_get(s->stash);
97 return Nullsv; /* can this ever happen? */
98 gv = newGVgen(package);
100 s->fh = newRV((SV *) gv);
103 /* shamelessly stolen from IO::File's new_tmpfile() */
104 (void) hv_delete(GvSTASH(gv), GvNAME(gv), GvNAMELEN(gv), G_DISCARD);
107 IoIFP(s->io) = PerlIONext(f);
108 IoOFP(s->io) = PerlIONext(f);
112 PerlIO_debug("No next\n");
113 /* FIXME: How should this work for OPEN etc? */
116 count = call_sv((SV *) cv, flags);
123 result = &PL_sv_undef;
132 PerlIOVia_pushed(pTHX_ PerlIO * f, const char *mode, SV * arg,
135 IV code = PerlIOBase_pushed(aTHX_ f, mode, Nullsv, tab);
137 if (SvTYPE(arg) >= SVt_PVMG
138 && mg_findext(arg, PERL_MAGIC_ext, &PerlIOVia_tag)) {
143 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
145 if (ckWARN(WARN_LAYER))
146 Perl_warner(aTHX_ packWARN(WARN_LAYER),
147 "No package specified");
153 const char *pkg = SvPV(arg, pkglen);
155 newSVpvn(Perl_form(aTHX_ "PerlIO::via::%s", pkg),
157 s->stash = gv_stashpvn(SvPVX_const(s->obj), pkglen + 13, 0);
159 SvREFCNT_dec(s->obj);
160 s->obj = SvREFCNT_inc(arg);
161 s->stash = gv_stashpvn(pkg, pkglen, 0);
168 /* binmode() passes NULL - so find out what mode is */
169 mode = PerlIO_modestr(f,lmode);
171 modesv = newSVpvn_flags(mode, strlen(mode), SVs_TEMP);
172 result = PerlIOVia_method(aTHX_ f, MYMethod(PUSHED), G_SCALAR,
175 if (sv_isobject(result)) {
176 SvREFCNT_dec(s->obj);
177 s->obj = SvREFCNT_inc(result);
179 else if (SvIV(result) != 0)
185 modesv = (*PerlIONext(f) && (PerlIOBase(PerlIONext(f))->flags & PERLIO_F_UTF8))
186 ? &PL_sv_yes : &PL_sv_no;
187 result = PerlIOVia_method(aTHX_ f, MYMethod(UTF8), G_SCALAR, modesv, Nullsv);
188 if (result && SvTRUE(result)) {
189 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
192 PerlIOBase(f)->flags &= ~PERLIO_F_UTF8;
194 if (PerlIOVia_fetchmethod(aTHX_ s, MYMethod(FILL)) ==
196 PerlIOBase(f)->flags &= ~PERLIO_F_FASTGETS;
198 PerlIOBase(f)->flags |= PERLIO_F_FASTGETS;
201 if (ckWARN(WARN_LAYER))
202 Perl_warner(aTHX_ packWARN(WARN_LAYER),
203 "Cannot find package '%.*s'", (int) pkglen,
221 PerlIOVia_open(pTHX_ PerlIO_funcs * self, PerlIO_list_t * layers,
222 IV n, const char *mode, int fd, int imode, int perm,
223 PerlIO * f, int narg, SV ** args)
226 f = PerlIO_push(aTHX_ PerlIO_allocate(aTHX), self, mode,
231 if (!PerlIO_push(aTHX_ f, self, mode, PerlIOArg))
235 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
238 SV *fdsv = sv_2mortal(newSViv(fd));
240 PerlIOVia_method(aTHX_ f, MYMethod(FDOPEN), G_SCALAR, fdsv,
245 SV *imodesv = sv_2mortal(newSViv(imode));
246 SV *permsv = sv_2mortal(newSViv(perm));
248 PerlIOVia_method(aTHX_ f, MYMethod(SYSOPEN), G_SCALAR,
249 *args, imodesv, permsv, Nullsv);
253 PerlIOVia_method(aTHX_ f, MYMethod(OPEN), G_SCALAR,
258 if (sv_isobject(result))
259 s->obj = SvREFCNT_inc(result);
260 else if (!SvTRUE(result)) {
265 /* Required open method not present */
266 PerlIO_funcs *tab = NULL;
270 PerlIO_layer_fetch(aTHX_ layers, m, NULL);
278 if ((*tab->Open) (aTHX_ tab, layers, m, mode, fd, imode,
279 perm, PerlIONext(f), narg, args)) {
280 PerlIO_debug("Opened with %s => %p->%p\n", tab->name,
281 PerlIONext(f), *PerlIONext(f));
284 * More layers above the one that we used to open -
287 if (PerlIO_apply_layera
288 (aTHX_ PerlIONext(f), mode, layers, m + 1,
290 /* If pushing layers fails close the file */
295 /* FIXME - Call an OPENED method here ? */
299 PerlIO_debug("Open fail %s => %p->%p\n", tab->name,
300 PerlIONext(f), *PerlIONext(f));
301 /* Sub-layer open failed */
305 PerlIO_debug("Nothing to open with");
306 /* Nothing to do the open */
316 PerlIOVia_popped(pTHX_ PerlIO * f)
318 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
319 PerlIOVia_method(aTHX_ f, MYMethod(POPPED), G_VOID, Nullsv);
321 SvREFCNT_dec(s->var);
335 SvREFCNT_dec(s->obj);
342 PerlIOVia_close(pTHX_ PerlIO * f)
344 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
345 IV code = PerlIOBase_close(aTHX_ f);
347 PerlIOVia_method(aTHX_ f, MYMethod(CLOSE), G_SCALAR, Nullsv);
348 if (result && SvIV(result) != 0)
350 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
355 PerlIOVia_fileno(pTHX_ PerlIO * f)
357 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
359 PerlIOVia_method(aTHX_ f, MYMethod(FILENO), G_SCALAR, Nullsv);
360 return (result) ? SvIV(result) : PerlIO_fileno(PerlIONext(f));
364 PerlIOVia_binmode(pTHX_ PerlIO * f)
366 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
368 PerlIOVia_method(aTHX_ f, MYMethod(BINMODE), G_SCALAR, Nullsv);
369 if (!result || !SvOK(result)) {
377 PerlIOVia_seek(pTHX_ PerlIO * f, Off_t offset, int whence)
379 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
380 SV *offsv = sv_2mortal(sizeof(Off_t) > sizeof(IV)
381 ? newSVnv((NV)offset) : newSViv((IV)offset));
382 SV *whsv = sv_2mortal(newSViv(whence));
384 PerlIOVia_method(aTHX_ f, MYMethod(SEEK), G_SCALAR, offsv, whsv,
386 #if Off_t_size == 8 && defined(CONDOP_SIZE) && CONDOP_SIZE < Off_t_size
388 return (Off_t) SvIV(result);
392 return (result) ? SvIV(result) : -1;
397 PerlIOVia_tell(pTHX_ PerlIO * f)
399 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
401 PerlIOVia_method(aTHX_ f, MYMethod(TELL), G_SCALAR, Nullsv);
403 ? (SvNOK(result) ? (Off_t)SvNV(result) : (Off_t)SvIV(result))
408 PerlIOVia_unread(pTHX_ PerlIO * f, const void *vbuf, Size_t count)
410 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
411 SV *buf = newSVpvn_flags((char *) vbuf, count, SVs_TEMP);
413 PerlIOVia_method(aTHX_ f, MYMethod(UNREAD), G_SCALAR, buf, Nullsv);
415 return (SSize_t) SvIV(result);
417 return PerlIOBase_unread(aTHX_ f, vbuf, count);
422 PerlIOVia_read(pTHX_ PerlIO * f, void *vbuf, Size_t count)
425 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
426 if (PerlIOBase(f)->flags & PERLIO_F_FASTGETS) {
427 rd = PerlIOBase_read(aTHX_ f, vbuf, count);
430 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
431 SV *buf = sv_2mortal(newSV(count));
432 SV *n = sv_2mortal(newSViv(count));
434 PerlIOVia_method(aTHX_ f, MYMethod(READ), G_SCALAR, buf, n,
437 rd = (SSize_t) SvIV(result);
438 Move(SvPVX(buf), vbuf, rd, char);
447 PerlIOVia_write(pTHX_ PerlIO * f, const void *vbuf, Size_t count)
449 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) {
450 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
451 SV *buf = newSVpvn((char *) vbuf, count);
453 PerlIOVia_method(aTHX_ f, MYMethod(WRITE), G_SCALAR, buf,
457 return (SSize_t) SvIV(result);
464 PerlIOVia_fill(pTHX_ PerlIO * f)
466 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
467 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
469 PerlIOVia_method(aTHX_ f, MYMethod(FILL), G_SCALAR, Nullsv);
471 SvREFCNT_dec(s->var);
474 if (result && SvOK(result)) {
476 const char *p = SvPV(result, len);
477 s->var = newSVpvn(p, len);
478 s->cnt = SvCUR(s->var);
482 PerlIOBase(f)->flags |= PERLIO_F_EOF;
488 PerlIOVia_flush(pTHX_ PerlIO * f)
490 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
492 PerlIOVia_method(aTHX_ f, MYMethod(FLUSH), G_SCALAR, Nullsv);
493 if (s->var && s->cnt > 0) {
494 SvREFCNT_dec(s->var);
497 return (result) ? SvIV(result) : 0;
501 PerlIOVia_get_base(pTHX_ PerlIO * f)
503 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
504 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
506 return (STDCHAR *) SvPVX(s->var);
509 return (STDCHAR *) NULL;
513 PerlIOVia_get_ptr(pTHX_ PerlIO * f)
515 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
516 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
518 STDCHAR *p = (STDCHAR *) (SvEND(s->var) - s->cnt);
522 return (STDCHAR *) NULL;
526 PerlIOVia_get_cnt(pTHX_ PerlIO * f)
528 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
529 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
538 PerlIOVia_bufsiz(pTHX_ PerlIO * f)
540 if (PerlIOBase(f)->flags & PERLIO_F_CANREAD) {
541 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
543 return SvCUR(s->var);
549 PerlIOVia_set_ptrcnt(pTHX_ PerlIO * f, STDCHAR * ptr, SSize_t cnt)
551 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
552 PERL_UNUSED_ARG(ptr);
557 PerlIOVia_setlinebuf(pTHX_ PerlIO * f)
559 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
560 PerlIOVia_method(aTHX_ f, MYMethod(SETLINEBUF), G_VOID, Nullsv);
561 PerlIOBase_setlinebuf(aTHX_ f);
565 PerlIOVia_clearerr(pTHX_ PerlIO * f)
567 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
568 PerlIOVia_method(aTHX_ f, MYMethod(CLEARERR), G_VOID, Nullsv);
569 PerlIOBase_clearerr(aTHX_ f);
573 PerlIOVia_error(pTHX_ PerlIO * f)
575 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
577 PerlIOVia_method(aTHX_ f, "ERROR", &s->mERROR, G_SCALAR, Nullsv);
578 return (result) ? SvIV(result) : PerlIOBase_error(aTHX_ f);
582 PerlIOVia_eof(pTHX_ PerlIO * f)
584 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
586 PerlIOVia_method(aTHX_ f, "EOF", &s->mEOF, G_SCALAR, Nullsv);
587 return (result) ? SvIV(result) : PerlIOBase_eof(aTHX_ f);
591 PerlIOVia_getarg(pTHX_ PerlIO * f, CLONE_PARAMS * param, int flags)
593 PerlIOVia *s = PerlIOSelf(f, PerlIOVia);
595 PERL_UNUSED_ARG(flags);
597 /* During cloning, return an undef token object so that _pushed() knows
598 * that it should not call methods and wait for _dup() to actually dup the
602 sv_magicext(sv, NULL, PERL_MAGIC_ext, &PerlIOVia_tag, 0, 0);
606 arg = PerlIOVia_method(aTHX_ f, MYMethod(GETARG), G_SCALAR, Nullsv);
608 /* arg is a temp, and PerlIOBase_dup() will explicitly free it */
612 arg = newSVpvn(HvNAME(s->stash), HvNAMELEN(s->stash));
619 PerlIOVia_dup(pTHX_ PerlIO * f, PerlIO * o, CLONE_PARAMS * param,
622 if ((f = PerlIOBase_dup(aTHX_ f, o, param, flags))) {
625 /* For a non-interpreter dup stash and obj have been set up
628 But if this is a clone for a new interpreter we need to
629 translate the objects to their dups.
632 PerlIOVia *fs = PerlIOSelf(f, PerlIOVia);
633 PerlIOVia *os = PerlIOSelf(o, PerlIOVia);
635 fs->obj = sv_dup_inc(os->obj, param);
636 fs->stash = (HV*)sv_dup((SV*)os->stash, param);
637 fs->var = sv_dup_inc(os->var, param);
640 /* fh, io, cached CVs left as NULL, PerlIOVia_method()
641 will reinitialize them if needed */
644 /* for a non-threaded dup fs->obj and stash should be set by _pushed() */
652 static PERLIO_FUNCS_DECL(PerlIO_object) = {
653 sizeof(PerlIO_funcs),
656 PERLIO_K_BUFFERED|PERLIO_K_DESTRUCT,
659 PerlIOVia_open, /* NULL, */
660 PerlIOVia_binmode, /* NULL, */
675 PerlIOVia_setlinebuf,
680 PerlIOVia_set_ptrcnt,
684 #endif /* Layers available */
686 MODULE = PerlIO::via PACKAGE = PerlIO::via
692 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_object));