This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
Use PerlIOBase_open for pop, utf8 and bytes layers
[perl5.git] / perlio.c
CommitLineData
14a5cf38 1/*
5cb43542
RGS
2 * perlio.c
3 * Copyright (c) 1996-2006, Nick Ing-Simmons
1129b882 4 * Copyright (c) 2006, 2007, 2008 Larry Wall and others
5cb43542
RGS
5 *
6 * You may distribute under the terms of either the GNU General Public License
7 * or the Artistic License, as specified in the README file.
760ac839
LW
8 */
9
14a5cf38 10/*
d31a8517
AT
11 * Hour after hour for nearly three weary days he had jogged up and down,
12 * over passes, and through long dales, and across many streams.
4ac71550
TC
13 *
14 * [pp.791-792 of _The Lord of the Rings_, V/iii: "The Muster of Rohan"]
d31a8517
AT
15 */
16
166f8a29
DM
17/* This file contains the functions needed to implement PerlIO, which
18 * is Perl's private replacement for the C stdio library. This is used
19 * by default unless you compile with -Uuseperlio or run with
20 * PERLIO=:stdio (but don't do this unless you know what you're doing)
21 */
22
d31a8517 23/*
71200d45 24 * If we have ActivePerl-like PERL_IMPLICIT_SYS then we need a dTHX to get
14a5cf38 25 * at the dispatch tables, even when we do not need it for other reasons.
71200d45 26 * Invent a dSYS macro to abstract this out
14a5cf38 27 */
7bcba3d4
NIS
28#ifdef PERL_IMPLICIT_SYS
29#define dSYS dTHX
30#else
31#define dSYS dNOOP
32#endif
33
760ac839 34#define VOIDUSED 1
12ae5dfc
JH
35#ifdef PERL_MICRO
36# include "uconfig.h"
37#else
b0f06652
VK
38# ifndef USE_CROSS_COMPILE
39# include "config.h"
40# else
41# include "xconfig.h"
42# endif
12ae5dfc 43#endif
760ac839 44
6f9d8c32 45#define PERLIO_NOT_STDIO 0
760ac839 46#if !defined(PERLIO_IS_STDIO) && !defined(USE_SFIO)
14a5cf38 47/*
71200d45 48 * #define PerlIO FILE
14a5cf38 49 */
760ac839
LW
50#endif
51/*
6f9d8c32 52 * This file provides those parts of PerlIO abstraction
88b61e10 53 * which are not #defined in perlio.h.
6f9d8c32 54 * Which these are depends on various Configure #ifdef's
760ac839
LW
55 */
56
57#include "EXTERN.h"
864dbfa3 58#define PERL_IN_PERLIO_C
760ac839
LW
59#include "perl.h"
60
32af7c23
CL
61#ifdef PERL_IMPLICIT_CONTEXT
62#undef dSYS
63#define dSYS dTHX
64#endif
65
0c4f7ff0
NIS
66#include "XSUB.h"
67
9cffb111
OS
68#ifdef __Lynx__
69/* Missing proto on LynxOS */
70int mkstemp(char*);
71#endif
72
abf9167d
DM
73#define PerlIO_lockcnt(f) (((PerlIOl*)(f))->head->flags)
74
1b7a0411 75/* Call the callback or PerlIOBase, and return failure. */
b32dd47e 76#define Perl_PerlIO_or_Base(f, callback, base, failure, args) \
1b7a0411 77 if (PerlIOValid(f)) { \
46c461b5 78 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;\
1b7a0411
JH
79 if (tab && tab->callback) \
80 return (*tab->callback) args; \
81 else \
82 return PerlIOBase_ ## base args; \
83 } \
84 else \
85 SETERRNO(EBADF, SS_IVCHAN); \
86 return failure
87
88/* Call the callback or fail, and return failure. */
b32dd47e 89#define Perl_PerlIO_or_fail(f, callback, failure, args) \
1b7a0411 90 if (PerlIOValid(f)) { \
46c461b5 91 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;\
1b7a0411
JH
92 if (tab && tab->callback) \
93 return (*tab->callback) args; \
94 SETERRNO(EINVAL, LIB_INVARG); \
95 } \
96 else \
97 SETERRNO(EBADF, SS_IVCHAN); \
98 return failure
99
100/* Call the callback or PerlIOBase, and be void. */
b32dd47e 101#define Perl_PerlIO_or_Base_void(f, callback, base, args) \
1b7a0411 102 if (PerlIOValid(f)) { \
46c461b5 103 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;\
1b7a0411
JH
104 if (tab && tab->callback) \
105 (*tab->callback) args; \
106 else \
107 PerlIOBase_ ## base args; \
1b7a0411
JH
108 } \
109 else \
110 SETERRNO(EBADF, SS_IVCHAN)
111
112/* Call the callback or fail, and be void. */
b32dd47e 113#define Perl_PerlIO_or_fail_void(f, callback, args) \
1b7a0411 114 if (PerlIOValid(f)) { \
46c461b5 115 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;\
1b7a0411
JH
116 if (tab && tab->callback) \
117 (*tab->callback) args; \
37725cdc
NIS
118 else \
119 SETERRNO(EINVAL, LIB_INVARG); \
1b7a0411
JH
120 } \
121 else \
122 SETERRNO(EBADF, SS_IVCHAN)
123
89a3a251
JH
124#if defined(__osf__) && _XOPEN_SOURCE < 500
125extern int fseeko(FILE *, off_t, int);
126extern off_t ftello(FILE *);
127#endif
128
71ab4674 129#ifndef USE_SFIO
a0c21aa1
JH
130
131EXTERN_C int perlsio_binmode(FILE *fp, int iotype, int mode);
132
71ab4674
SP
133int
134perlsio_binmode(FILE *fp, int iotype, int mode)
135{
136 /*
137 * This used to be contents of do_binmode in doio.c
138 */
139#ifdef DOSISH
cd86ed9d 140# if defined(atarist)
58c0efa5 141 PERL_UNUSED_ARG(iotype);
71ab4674
SP
142 if (!fflush(fp)) {
143 if (mode & O_BINARY)
144 ((FILE *) fp)->_flag |= _IOBIN;
145 else
146 ((FILE *) fp)->_flag &= ~_IOBIN;
147 return 1;
148 }
149 return 0;
150# else
151 dTHX;
58c0efa5 152 PERL_UNUSED_ARG(iotype);
71ab4674
SP
153#ifdef NETWARE
154 if (PerlLIO_setmode(fp, mode) != -1) {
155#else
156 if (PerlLIO_setmode(fileno(fp), mode) != -1) {
157#endif
158# if defined(WIN32) && defined(__BORLANDC__)
159 /*
160 * The translation mode of the stream is maintained independent
161of
162 * the translation mode of the fd in the Borland RTL (heavy
163 * digging through their runtime sources reveal). User has to
164set
165 * the mode explicitly for the stream (though they don't
166document
167 * this anywhere). GSAR 97-5-24
168 */
169 fseek(fp, 0L, 0);
170 if (mode & O_BINARY)
171 fp->flags |= _F_BIN;
172 else
173 fp->flags &= ~_F_BIN;
174# endif
175 return 1;
176 }
177 else
178 return 0;
179# endif
180#else
181# if defined(USEMYBINMODE)
182 dTHX;
58c0efa5
RGS
183# if defined(__CYGWIN__)
184 PERL_UNUSED_ARG(iotype);
185# endif
71ab4674
SP
186 if (my_binmode(fp, iotype, mode) != FALSE)
187 return 1;
188 else
189 return 0;
190# else
191 PERL_UNUSED_ARG(fp);
192 PERL_UNUSED_ARG(iotype);
193 PERL_UNUSED_ARG(mode);
194 return 1;
195# endif
196#endif
197}
198#endif /* sfio */
199
06c7082d 200#ifndef O_ACCMODE
22569500 201#define O_ACCMODE 3 /* Assume traditional implementation */
06c7082d
NIS
202#endif
203
204int
205PerlIO_intmode2str(int rawmode, char *mode, int *writing)
206{
de009b76 207 const int result = rawmode & O_ACCMODE;
06c7082d
NIS
208 int ix = 0;
209 int ptype;
210 switch (result) {
211 case O_RDONLY:
212 ptype = IoTYPE_RDONLY;
213 break;
214 case O_WRONLY:
215 ptype = IoTYPE_WRONLY;
216 break;
217 case O_RDWR:
218 default:
219 ptype = IoTYPE_RDWR;
220 break;
221 }
222 if (writing)
223 *writing = (result != O_RDONLY);
224
225 if (result == O_RDONLY) {
226 mode[ix++] = 'r';
227 }
228#ifdef O_APPEND
229 else if (rawmode & O_APPEND) {
230 mode[ix++] = 'a';
231 if (result != O_WRONLY)
232 mode[ix++] = '+';
233 }
234#endif
235 else {
236 if (result == O_WRONLY)
237 mode[ix++] = 'w';
238 else {
239 mode[ix++] = 'r';
240 mode[ix++] = '+';
241 }
242 }
243 if (rawmode & O_BINARY)
244 mode[ix++] = 'b';
245 mode[ix] = '\0';
246 return ptype;
247}
248
eb73beca
NIS
249#ifndef PERLIO_LAYERS
250int
251PerlIO_apply_layers(pTHX_ PerlIO *f, const char *mode, const char *names)
252{
6874a2de
NIS
253 if (!names || !*names
254 || strEQ(names, ":crlf")
255 || strEQ(names, ":raw")
256 || strEQ(names, ":bytes")
257 ) {
14a5cf38
JH
258 return 0;
259 }
260 Perl_croak(aTHX_ "Cannot apply \"%s\" in non-PerlIO perl", names);
261 /*
71200d45 262 * NOTREACHED
14a5cf38
JH
263 */
264 return -1;
eb73beca
NIS
265}
266
13621cfb
NIS
267void
268PerlIO_destruct(pTHX)
269{
270}
271
f5b9d040
NIS
272int
273PerlIO_binmode(pTHX_ PerlIO *fp, int iotype, int mode, const char *names)
274{
92bff44d 275#ifdef USE_SFIO
8772537c
AL
276 PERL_UNUSED_ARG(iotype);
277 PERL_UNUSED_ARG(mode);
278 PERL_UNUSED_ARG(names);
14a5cf38 279 return 1;
92bff44d 280#else
14a5cf38 281 return perlsio_binmode(fp, iotype, mode);
92bff44d 282#endif
f5b9d040 283}
60382766 284
e0fa5af2 285PerlIO *
ecdeb87c 286PerlIO_fdupopen(pTHX_ PerlIO *f, CLONE_PARAMS *param, int flags)
e0fa5af2 287{
a0fd4948 288#if defined(PERL_MICRO) || defined(__SYMBIAN32__)
0553478e
NIS
289 return NULL;
290#else
291#ifdef PERL_IMPLICIT_SYS
22569500 292 return PerlSIO_fdupopen(f);
0553478e 293#else
30753f56
NIS
294#ifdef WIN32
295 return win32_fdupopen(f);
296#else
e0fa5af2 297 if (f) {
504618e9 298 const int fd = PerlLIO_dup(PerlIO_fileno(f));
e0fa5af2 299 if (fd >= 0) {
06c7082d 300 char mode[8];
a5936e02 301#ifdef DJGPP
dcda55fc
AL
302 const int omode = djgpp_get_stream_mode(f);
303#else
304 const int omode = fcntl(fd, F_GETFL);
a5936e02 305#endif
06c7082d 306 PerlIO_intmode2str(omode,mode,NULL);
e0fa5af2 307 /* the r+ is a hack */
06c7082d 308 return PerlIO_fdopen(fd, mode);
e0fa5af2
NIS
309 }
310 return NULL;
311 }
312 else {
93189314 313 SETERRNO(EBADF, SS_IVCHAN);
e0fa5af2 314 }
7114a2d2 315#endif
e0fa5af2 316 return NULL;
0553478e 317#endif
30753f56 318#endif
e0fa5af2
NIS
319}
320
321
14a5cf38 322/*
71200d45 323 * De-mux PerlIO_openn() into fdopen, freopen and fopen type entries
14a5cf38 324 */
ee518936
NIS
325
326PerlIO *
14a5cf38
JH
327PerlIO_openn(pTHX_ const char *layers, const char *mode, int fd,
328 int imode, int perm, PerlIO *old, int narg, SV **args)
329{
7cf31beb
NIS
330 if (narg) {
331 if (narg > 1) {
3b8752bb 332 Perl_croak(aTHX_ "More than one argument to open");
7cf31beb 333 }
14a5cf38
JH
334 if (*args == &PL_sv_undef)
335 return PerlIO_tmpfile();
336 else {
e62f0680 337 const char *name = SvPV_nolen_const(*args);
3b6c1aba 338 if (*mode == IoTYPE_NUMERIC) {
14a5cf38
JH
339 fd = PerlLIO_open3(name, imode, perm);
340 if (fd >= 0)
de009b76 341 return PerlIO_fdopen(fd, mode + 1);
14a5cf38
JH
342 }
343 else if (old) {
344 return PerlIO_reopen(name, mode, old);
345 }
346 else {
347 return PerlIO_open(name, mode);
348 }
349 }
350 }
351 else {
352 return PerlIO_fdopen(fd, (char *) mode);
353 }
354 return NULL;
ee518936
NIS
355}
356
0c4f7ff0
NIS
357XS(XS_PerlIO__Layer__find)
358{
14a5cf38
JH
359 dXSARGS;
360 if (items < 2)
361 Perl_croak(aTHX_ "Usage class->find(name[,load])");
362 else {
dcda55fc 363 const char * const name = SvPV_nolen_const(ST(1));
14a5cf38
JH
364 ST(0) = (strEQ(name, "crlf")
365 || strEQ(name, "raw")) ? &PL_sv_yes : &PL_sv_undef;
366 XSRETURN(1);
367 }
0c4f7ff0
NIS
368}
369
370
371void
372Perl_boot_core_PerlIO(pTHX)
373{
14a5cf38 374 newXS("PerlIO::Layer::find", XS_PerlIO__Layer__find, __FILE__);
0c4f7ff0
NIS
375}
376
ac27b0f5
NIS
377#endif
378
32e30700 379
6f9d8c32 380#ifdef PERLIO_IS_STDIO
760ac839
LW
381
382void
e8632036 383PerlIO_init(pTHX)
760ac839 384{
96a5add6 385 PERL_UNUSED_CONTEXT;
14a5cf38
JH
386 /*
387 * Does nothing (yet) except force this file to be included in perl
71200d45 388 * binary. That allows this file to force inclusion of other functions
14a5cf38 389 * that may be required by loadable extensions e.g. for
71200d45 390 * FileHandle::tmpfile
14a5cf38 391 */
760ac839
LW
392}
393
33dcbb9a 394#undef PerlIO_tmpfile
395PerlIO *
8ac85365 396PerlIO_tmpfile(void)
33dcbb9a 397{
14a5cf38 398 return tmpfile();
33dcbb9a 399}
400
22569500 401#else /* PERLIO_IS_STDIO */
760ac839
LW
402
403#ifdef USE_SFIO
404
405#undef HAS_FSETPOS
406#undef HAS_FGETPOS
407
14a5cf38
JH
408/*
409 * This section is just to make sure these functions get pulled in from
71200d45 410 * libsfio.a
14a5cf38 411 */
760ac839
LW
412
413#undef PerlIO_tmpfile
414PerlIO *
c78749f2 415PerlIO_tmpfile(void)
760ac839 416{
14a5cf38 417 return sftmp(0);
760ac839
LW
418}
419
420void
e8632036 421PerlIO_init(pTHX)
760ac839 422{
96a5add6 423 PERL_UNUSED_CONTEXT;
14a5cf38
JH
424 /*
425 * Force this file to be included in perl binary. Which allows this
426 * file to force inclusion of other functions that may be required by
71200d45 427 * loadable extensions e.g. for FileHandle::tmpfile
14a5cf38 428 */
760ac839 429
14a5cf38 430 /*
71200d45 431 * Hack sfio does its own 'autoflush' on stdout in common cases. Flush
14a5cf38 432 * results in a lot of lseek()s to regular files and lot of small
71200d45 433 * writes to pipes.
14a5cf38
JH
434 */
435 sfset(sfstdout, SF_SHARE, 0);
760ac839
LW
436}
437
b9d6bf13 438/* This is not the reverse of PerlIO_exportFILE(), PerlIO_releaseFILE() is. */
92bff44d 439PerlIO *
4b069b44 440PerlIO_importFILE(FILE *stdio, const char *mode)
92bff44d 441{
de009b76 442 const int fd = fileno(stdio);
4b069b44 443 if (!mode || !*mode) {
81428673 444 mode = "r+";
4b069b44
NIS
445 }
446 return PerlIO_fdopen(fd, mode);
92bff44d
NIS
447}
448
449FILE *
450PerlIO_findFILE(PerlIO *pio)
451{
de009b76
AL
452 const int fd = PerlIO_fileno(pio);
453 FILE * const f = fdopen(fd, "r+");
14a5cf38
JH
454 PerlIO_flush(pio);
455 if (!f && errno == EINVAL)
456 f = fdopen(fd, "w");
457 if (!f && errno == EINVAL)
458 f = fdopen(fd, "r");
459 return f;
92bff44d
NIS
460}
461
462
22569500 463#else /* USE_SFIO */
6f9d8c32 464/*======================================================================================*/
14a5cf38 465/*
71200d45 466 * Implement all the PerlIO interface ourselves.
9e353e3b 467 */
760ac839 468
76ced9ad
NIS
469#include "perliol.h"
470
14a5cf38
JH
471/*
472 * We _MUST_ have <unistd.h> if we are using lseek() and may have large
71200d45 473 * files
14a5cf38 474 */
02f66e2f
NIS
475#ifdef I_UNISTD
476#include <unistd.h>
477#endif
06da4f11
NIS
478#ifdef HAS_MMAP
479#include <sys/mman.h>
480#endif
481
6f9d8c32 482void
14a5cf38
JH
483PerlIO_debug(const char *fmt, ...)
484{
14a5cf38
JH
485 va_list ap;
486 dSYS;
487 va_start(ap, fmt);
582588d2
NC
488 if (!PL_perlio_debug_fd) {
489 if (!PL_tainting && PL_uid == PL_euid && PL_gid == PL_egid) {
490 const char * const s = PerlEnv_getenv("PERLIO_DEBUG");
491 if (s && *s)
492 PL_perlio_debug_fd
493 = PerlLIO_open3(s, O_WRONLY | O_CREAT | O_APPEND, 0666);
494 else
495 PL_perlio_debug_fd = -1;
496 } else {
497 /* tainting or set*id, so ignore the environment, and ensure we
498 skip these tests next time through. */
27da23d5 499 PL_perlio_debug_fd = -1;
582588d2 500 }
14a5cf38 501 }
27da23d5 502 if (PL_perlio_debug_fd > 0) {
14a5cf38 503 dTHX;
70ace5da 504#ifdef USE_ITHREADS
dcda55fc 505 const char * const s = CopFILE(PL_curcop);
70ace5da
NIS
506 /* Use fixed buffer as sv_catpvf etc. needs SVs */
507 char buffer[1024];
1208b3dd
JH
508 const STRLEN len1 = my_snprintf(buffer, sizeof(buffer), "%.40s:%" IVdf " ", s ? s : "(none)", (IV) CopLINE(PL_curcop));
509 const STRLEN len2 = my_vsnprintf(buffer + len1, sizeof(buffer) - len1, fmt, ap);
510 PerlLIO_write(PL_perlio_debug_fd, buffer, len1 + len2);
70ace5da 511#else
dcda55fc
AL
512 const char *s = CopFILE(PL_curcop);
513 STRLEN len;
550e2ce0
NC
514 SV * const sv = Perl_newSVpvf(aTHX_ "%s:%" IVdf " ", s ? s : "(none)",
515 (IV) CopLINE(PL_curcop));
14a5cf38
JH
516 Perl_sv_vcatpvf(aTHX_ sv, fmt, &ap);
517
b83604b4 518 s = SvPV_const(sv, len);
27da23d5 519 PerlLIO_write(PL_perlio_debug_fd, s, len);
14a5cf38 520 SvREFCNT_dec(sv);
70ace5da 521#endif
14a5cf38
JH
522 }
523 va_end(ap);
6f9d8c32
NIS
524}
525
9e353e3b
NIS
526/*--------------------------------------------------------------------------------------*/
527
14a5cf38 528/*
71200d45 529 * Inner level routines
14a5cf38 530 */
9e353e3b 531
16865ff7
DM
532/* check that the head field of each layer points back to the head */
533
534#ifdef DEBUGGING
535# define VERIFY_HEAD(f) PerlIO_verify_head(aTHX_ f)
536static void
537PerlIO_verify_head(pTHX_ PerlIO *f)
538{
539 PerlIOl *head, *p;
540 int seen = 0;
541 if (!PerlIOValid(f))
542 return;
543 p = head = PerlIOBase(f)->head;
544 assert(p);
545 do {
546 assert(p->head == head);
547 if (p == (PerlIOl*)f)
548 seen = 1;
549 p = p->next;
550 } while (p);
551 assert(seen);
552}
553#else
554# define VERIFY_HEAD(f)
555#endif
556
557
14a5cf38 558/*
71200d45 559 * Table of pointers to the PerlIO structs (malloc'ed)
14a5cf38 560 */
05d1247b 561#define PERLIO_TABLE_SIZE 64
6f9d8c32 562
8995e67d
DM
563static void
564PerlIO_init_table(pTHX)
565{
566 if (PL_perlio)
567 return;
568 Newxz(PL_perlio, PERLIO_TABLE_SIZE, PerlIOl);
569}
570
571
572
760ac839 573PerlIO *
5f1a76d0 574PerlIO_allocate(pTHX)
6f9d8c32 575{
97aff369 576 dVAR;
14a5cf38 577 /*
71200d45 578 * Find a free slot in the table, allocating new table as necessary
14a5cf38 579 */
303f2dc3
DM
580 PerlIOl **last;
581 PerlIOl *f;
a1ea730d 582 last = &PL_perlio;
14a5cf38
JH
583 while ((f = *last)) {
584 int i;
303f2dc3 585 last = (PerlIOl **) (f);
14a5cf38 586 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3 587 if (!((++f)->next)) {
abf9167d 588 f->flags = 0; /* lockcnt */
303f2dc3 589 f->tab = NULL;
16865ff7 590 f->head = f;
303f2dc3 591 return (PerlIO *)f;
14a5cf38
JH
592 }
593 }
594 }
303f2dc3 595 Newxz(f,PERLIO_TABLE_SIZE,PerlIOl);
14a5cf38
JH
596 if (!f) {
597 return NULL;
598 }
303f2dc3 599 *last = (PerlIOl*) f++;
abf9167d 600 f->flags = 0; /* lockcnt */
303f2dc3 601 f->tab = NULL;
16865ff7 602 f->head = f;
303f2dc3 603 return (PerlIO*) f;
05d1247b
NIS
604}
605
a1ea730d
NIS
606#undef PerlIO_fdupopen
607PerlIO *
ecdeb87c 608PerlIO_fdupopen(pTHX_ PerlIO *f, CLONE_PARAMS *param, int flags)
a1ea730d 609{
04892f78 610 if (PerlIOValid(f)) {
de009b76 611 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
fe5a182c 612 PerlIO_debug("fdupopen f=%p param=%p\n",(void*)f,(void*)param);
210e727c
JH
613 if (tab && tab->Dup)
614 return (*tab->Dup)(aTHX_ PerlIO_allocate(aTHX), f, param, flags);
37725cdc
NIS
615 else {
616 return PerlIOBase_dup(aTHX_ PerlIO_allocate(aTHX), f, param, flags);
617 }
a1ea730d 618 }
210e727c
JH
619 else
620 SETERRNO(EBADF, SS_IVCHAN);
621
622 return NULL;
a1ea730d
NIS
623}
624
625void
303f2dc3 626PerlIO_cleantable(pTHX_ PerlIOl **tablep)
05d1247b 627{
303f2dc3 628 PerlIOl * const table = *tablep;
14a5cf38
JH
629 if (table) {
630 int i;
303f2dc3 631 PerlIO_cleantable(aTHX_(PerlIOl **) & (table[0]));
14a5cf38 632 for (i = PERLIO_TABLE_SIZE - 1; i > 0; i--) {
303f2dc3
DM
633 PerlIOl * const f = table + i;
634 if (f->next) {
635 PerlIO_close(&(f->next));
14a5cf38
JH
636 }
637 }
3a1ee7e8 638 Safefree(table);
14a5cf38 639 *tablep = NULL;
05d1247b 640 }
05d1247b
NIS
641}
642
fcf2db38
NIS
643
644PerlIO_list_t *
3a1ee7e8 645PerlIO_list_alloc(pTHX)
fcf2db38 646{
14a5cf38 647 PerlIO_list_t *list;
96a5add6 648 PERL_UNUSED_CONTEXT;
a02a5408 649 Newxz(list, 1, PerlIO_list_t);
14a5cf38
JH
650 list->refcnt = 1;
651 return list;
fcf2db38
NIS
652}
653
654void
3a1ee7e8 655PerlIO_list_free(pTHX_ PerlIO_list_t *list)
fcf2db38 656{
14a5cf38
JH
657 if (list) {
658 if (--list->refcnt == 0) {
659 if (list->array) {
14a5cf38 660 IV i;
ef8d46e8
VP
661 for (i = 0; i < list->cur; i++)
662 SvREFCNT_dec(list->array[i].arg);
14a5cf38
JH
663 Safefree(list->array);
664 }
665 Safefree(list);
666 }
667 }
fcf2db38
NIS
668}
669
670void
3a1ee7e8 671PerlIO_list_push(pTHX_ PerlIO_list_t *list, PerlIO_funcs *funcs, SV *arg)
14a5cf38 672{
97aff369 673 dVAR;
334e202e 674 PerlIO_pair_t *p;
b37c2d43
AL
675 PERL_UNUSED_CONTEXT;
676
14a5cf38
JH
677 if (list->cur >= list->len) {
678 list->len += 8;
679 if (list->array)
680 Renew(list->array, list->len, PerlIO_pair_t);
681 else
a02a5408 682 Newx(list->array, list->len, PerlIO_pair_t);
14a5cf38
JH
683 }
684 p = &(list->array[list->cur++]);
685 p->funcs = funcs;
686 if ((p->arg = arg)) {
f84c484e 687 SvREFCNT_inc_simple_void_NN(arg);
14a5cf38 688 }
fcf2db38
NIS
689}
690
3a1ee7e8
NIS
691PerlIO_list_t *
692PerlIO_clone_list(pTHX_ PerlIO_list_t *proto, CLONE_PARAMS *param)
693{
b37c2d43 694 PerlIO_list_t *list = NULL;
694c95cf
JH
695 if (proto) {
696 int i;
697 list = PerlIO_list_alloc(aTHX);
698 for (i=0; i < proto->cur; i++) {
a951d81d
BL
699 SV *arg = proto->array[i].arg;
700#ifdef sv_dup
701 if (arg && param)
702 arg = sv_dup(arg, param);
703#else
704 PERL_UNUSED_ARG(param);
705#endif
694c95cf
JH
706 PerlIO_list_push(aTHX_ list, proto->array[i].funcs, arg);
707 }
3a1ee7e8
NIS
708 }
709 return list;
710}
4a4a6116 711
05d1247b 712void
3a1ee7e8 713PerlIO_clone(pTHX_ PerlInterpreter *proto, CLONE_PARAMS *param)
9a6404c5 714{
3aaf42a7 715#ifdef USE_ITHREADS
303f2dc3
DM
716 PerlIOl **table = &proto->Iperlio;
717 PerlIOl *f;
3a1ee7e8
NIS
718 PL_perlio = NULL;
719 PL_known_layers = PerlIO_clone_list(aTHX_ proto->Iknown_layers, param);
720 PL_def_layerlist = PerlIO_clone_list(aTHX_ proto->Idef_layerlist, param);
8995e67d 721 PerlIO_init_table(aTHX);
a25429c6 722 PerlIO_debug("Clone %p from %p\n",(void*)aTHX,(void*)proto);
3a1ee7e8
NIS
723 while ((f = *table)) {
724 int i;
303f2dc3 725 table = (PerlIOl **) (f++);
3a1ee7e8 726 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3
DM
727 if (f->next) {
728 (void) fp_dup(&(f->next), 0, param);
3a1ee7e8
NIS
729 }
730 f++;
731 }
732 }
1b6737cc 733#else
a25429c6 734 PERL_UNUSED_CONTEXT;
1b6737cc
AL
735 PERL_UNUSED_ARG(proto);
736 PERL_UNUSED_ARG(param);
3aaf42a7 737#endif
9a6404c5
DM
738}
739
740void
13621cfb
NIS
741PerlIO_destruct(pTHX)
742{
97aff369 743 dVAR;
303f2dc3
DM
744 PerlIOl **table = &PL_perlio;
745 PerlIOl *f;
694c95cf 746#ifdef USE_ITHREADS
a25429c6 747 PerlIO_debug("Destruct %p\n",(void*)aTHX);
694c95cf 748#endif
14a5cf38
JH
749 while ((f = *table)) {
750 int i;
303f2dc3 751 table = (PerlIOl **) (f++);
14a5cf38 752 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3 753 PerlIO *x = &(f->next);
dcda55fc 754 const PerlIOl *l;
14a5cf38 755 while ((l = *x)) {
cc6623a8 756 if (l->tab && l->tab->kind & PERLIO_K_DESTRUCT) {
14a5cf38
JH
757 PerlIO_debug("Destruct popping %s\n", l->tab->name);
758 PerlIO_flush(x);
759 PerlIO_pop(aTHX_ x);
760 }
761 else {
762 x = PerlIONext(x);
763 }
764 }
765 f++;
766 }
767 }
13621cfb
NIS
768}
769
770void
a999f61b 771PerlIO_pop(pTHX_ PerlIO *f)
760ac839 772{
dcda55fc 773 const PerlIOl *l = *f;
16865ff7 774 VERIFY_HEAD(f);
14a5cf38 775 if (l) {
cc6623a8
DM
776 PerlIO_debug("PerlIO_pop f=%p %s\n", (void*)f,
777 l->tab ? l->tab->name : "(Null)");
778 if (l->tab && l->tab->Popped) {
14a5cf38
JH
779 /*
780 * If popped returns non-zero do not free its layer structure
781 * it has either done so itself, or it is shared and still in
71200d45 782 * use
14a5cf38 783 */
f62ce20a 784 if ((*l->tab->Popped) (aTHX_ f) != 0)
14a5cf38
JH
785 return;
786 }
abf9167d
DM
787 if (PerlIO_lockcnt(f)) {
788 /* we're in use; defer freeing the structure */
789 PerlIOBase(f)->flags = PERLIO_F_CLEARED;
790 PerlIOBase(f)->tab = NULL;
791 }
792 else {
793 *f = l->next;
794 Safefree(l);
795 }
796
a8c08ecd 797 }
6f9d8c32
NIS
798}
799
39f7a870
JH
800/* Return as an array the stack of layers on a filehandle. Note that
801 * the stack is returned top-first in the array, and there are three
802 * times as many array elements as there are layers in the stack: the
803 * first element of a layer triplet is the name, the second one is the
804 * arguments, and the third one is the flags. */
805
806AV *
807PerlIO_get_layers(pTHX_ PerlIO *f)
808{
97aff369 809 dVAR;
dcda55fc 810 AV * const av = newAV();
39f7a870 811
dcda55fc
AL
812 if (PerlIOValid(f)) {
813 PerlIOl *l = PerlIOBase(f);
814
815 while (l) {
92e45a3e
NC
816 /* There is some collusion in the implementation of
817 XS_PerlIO_get_layers - it knows that name and flags are
818 generated as fresh SVs here, and takes advantage of that to
819 "copy" them by taking a reference. If it changes here, it needs
820 to change there too. */
dcda55fc
AL
821 SV * const name = l->tab && l->tab->name ?
822 newSVpv(l->tab->name, 0) : &PL_sv_undef;
823 SV * const arg = l->tab && l->tab->Getarg ?
824 (*l->tab->Getarg)(aTHX_ &l, 0, 0) : &PL_sv_undef;
825 av_push(av, name);
826 av_push(av, arg);
827 av_push(av, newSViv((IV)l->flags));
828 l = l->next;
829 }
830 }
39f7a870 831
dcda55fc 832 return av;
39f7a870
JH
833}
834
9e353e3b 835/*--------------------------------------------------------------------------------------*/
14a5cf38 836/*
71200d45 837 * XS Interface for perl code
14a5cf38 838 */
9e353e3b 839
fcf2db38 840PerlIO_funcs *
2edd7e44 841PerlIO_find_layer(pTHX_ const char *name, STRLEN len, int load)
f3862f8b 842{
27da23d5 843 dVAR;
14a5cf38
JH
844 IV i;
845 if ((SSize_t) len <= 0)
846 len = strlen(name);
3a1ee7e8 847 for (i = 0; i < PL_known_layers->cur; i++) {
46c461b5 848 PerlIO_funcs * const f = PL_known_layers->array[i].funcs;
a9f76400 849 if (memEQ(f->name, name, len) && f->name[len] == 0) {
fe5a182c 850 PerlIO_debug("%.*s => %p\n", (int) len, name, (void*)f);
14a5cf38
JH
851 return f;
852 }
853 }
3a1ee7e8
NIS
854 if (load && PL_subname && PL_def_layerlist
855 && PL_def_layerlist->cur >= 2) {
d7a09b41
SR
856 if (PL_in_load_module) {
857 Perl_croak(aTHX_ "Recursive call to Perl_load_module in PerlIO_find_layer");
858 return NULL;
859 } else {
396482e1 860 SV * const pkgsv = newSVpvs("PerlIO");
46c461b5 861 SV * const layer = newSVpvn(name, len);
b96d8cd9 862 CV * const cv = get_cvs("PerlIO::Layer::NoWarnings", 0);
46c461b5 863 ENTER;
4fa7c2bf 864 SAVEBOOL(PL_in_load_module);
c9bca74a 865 if (cv) {
9cfa90c0 866 SAVEGENERICSV(PL_warnhook);
ad64d0ec 867 PL_warnhook = MUTABLE_SV((SvREFCNT_inc_simple_NN(cv)));
c9bca74a 868 }
4fa7c2bf 869 PL_in_load_module = TRUE;
d7a09b41
SR
870 /*
871 * The two SVs are magically freed by load_module
872 */
a0714e2c 873 Perl_load_module(aTHX_ 0, pkgsv, NULL, layer, NULL);
d7a09b41
SR
874 LEAVE;
875 return PerlIO_find_layer(aTHX_ name, len, 0);
876 }
14a5cf38
JH
877 }
878 PerlIO_debug("Cannot find %.*s\n", (int) len, name);
879 return NULL;
f3862f8b
NIS
880}
881
2a1bc955 882#ifdef USE_ATTRIBUTES_FOR_PERLIO
b13b2135
NIS
883
884static int
885perlio_mg_set(pTHX_ SV *sv, MAGIC *mg)
886{
14a5cf38 887 if (SvROK(sv)) {
159b6efe 888 IO * const io = GvIOn(MUTABLE_GV(SvRV(sv)));
dcda55fc
AL
889 PerlIO * const ifp = IoIFP(io);
890 PerlIO * const ofp = IoOFP(io);
be2597df
MHM
891 Perl_warn(aTHX_ "set %" SVf " %p %p %p",
892 SVfARG(sv), (void*)io, (void*)ifp, (void*)ofp);
14a5cf38
JH
893 }
894 return 0;
b13b2135
NIS
895}
896
897static int
898perlio_mg_get(pTHX_ SV *sv, MAGIC *mg)
899{
14a5cf38 900 if (SvROK(sv)) {
159b6efe 901 IO * const io = GvIOn(MUTABLE_GV(SvRV(sv)));
dcda55fc
AL
902 PerlIO * const ifp = IoIFP(io);
903 PerlIO * const ofp = IoOFP(io);
be2597df
MHM
904 Perl_warn(aTHX_ "get %" SVf " %p %p %p",
905 SVfARG(sv), (void*)io, (void*)ifp, (void*)ofp);
14a5cf38
JH
906 }
907 return 0;
b13b2135
NIS
908}
909
910static int
911perlio_mg_clear(pTHX_ SV *sv, MAGIC *mg)
912{
be2597df 913 Perl_warn(aTHX_ "clear %" SVf, SVfARG(sv));
14a5cf38 914 return 0;
b13b2135
NIS
915}
916
917static int
918perlio_mg_free(pTHX_ SV *sv, MAGIC *mg)
919{
be2597df 920 Perl_warn(aTHX_ "free %" SVf, SVfARG(sv));
14a5cf38 921 return 0;
b13b2135
NIS
922}
923
924MGVTBL perlio_vtab = {
14a5cf38
JH
925 perlio_mg_get,
926 perlio_mg_set,
22569500 927 NULL, /* len */
14a5cf38
JH
928 perlio_mg_clear,
929 perlio_mg_free
b13b2135
NIS
930};
931
932XS(XS_io_MODIFY_SCALAR_ATTRIBUTES)
933{
14a5cf38 934 dXSARGS;
dcda55fc
AL
935 SV * const sv = SvRV(ST(1));
936 AV * const av = newAV();
14a5cf38
JH
937 MAGIC *mg;
938 int count = 0;
939 int i;
ad64d0ec 940 sv_magic(sv, MUTABLE_SV(av), PERL_MAGIC_ext, NULL, 0);
14a5cf38
JH
941 SvRMAGICAL_off(sv);
942 mg = mg_find(sv, PERL_MAGIC_ext);
943 mg->mg_virtual = &perlio_vtab;
944 mg_magical(sv);
be2597df 945 Perl_warn(aTHX_ "attrib %" SVf, SVfARG(sv));
14a5cf38
JH
946 for (i = 2; i < items; i++) {
947 STRLEN len;
dcda55fc
AL
948 const char * const name = SvPV_const(ST(i), len);
949 SV * const layer = PerlIO_find_layer(aTHX_ name, len, 1);
14a5cf38 950 if (layer) {
b37c2d43 951 av_push(av, SvREFCNT_inc_simple_NN(layer));
14a5cf38
JH
952 }
953 else {
954 ST(count) = ST(i);
955 count++;
956 }
957 }
958 SvREFCNT_dec(av);
959 XSRETURN(count);
960}
961
22569500 962#endif /* USE_ATTIBUTES_FOR_PERLIO */
2a1bc955 963
e3f3bf95
NIS
964SV *
965PerlIO_tab_sv(pTHX_ PerlIO_funcs *tab)
f3862f8b 966{
da51bb9b 967 HV * const stash = gv_stashpvs("PerlIO::Layer", GV_ADD);
46c461b5 968 SV * const sv = sv_bless(newRV_noinc(newSViv(PTR2IV(tab))), stash);
14a5cf38 969 return sv;
e3f3bf95
NIS
970}
971
5ca1d77f 972XS(XS_PerlIO__Layer__NoWarnings)
c9bca74a 973{
486ec47a 974 /* This is used as a %SIG{__WARN__} handler to suppress warnings
c9bca74a
NIS
975 during loading of layers.
976 */
97aff369 977 dVAR;
c9bca74a 978 dXSARGS;
58c0efa5 979 PERL_UNUSED_ARG(cv);
c9bca74a 980 if (items)
e62f0680 981 PerlIO_debug("warning:%s\n",SvPV_nolen_const(ST(0)));
c9bca74a
NIS
982 XSRETURN(0);
983}
984
5ca1d77f 985XS(XS_PerlIO__Layer__find)
0c4f7ff0 986{
97aff369 987 dVAR;
14a5cf38 988 dXSARGS;
58c0efa5 989 PERL_UNUSED_ARG(cv);
14a5cf38
JH
990 if (items < 2)
991 Perl_croak(aTHX_ "Usage class->find(name[,load])");
992 else {
de009b76 993 STRLEN len;
46c461b5 994 const char * const name = SvPV_const(ST(1), len);
de009b76 995 const bool load = (items > 2) ? SvTRUE(ST(2)) : 0;
46c461b5 996 PerlIO_funcs * const layer = PerlIO_find_layer(aTHX_ name, len, load);
14a5cf38
JH
997 ST(0) =
998 (layer) ? sv_2mortal(PerlIO_tab_sv(aTHX_ layer)) :
999 &PL_sv_undef;
1000 XSRETURN(1);
1001 }
0c4f7ff0
NIS
1002}
1003
e3f3bf95
NIS
1004void
1005PerlIO_define_layer(pTHX_ PerlIO_funcs *tab)
1006{
97aff369 1007 dVAR;
3a1ee7e8
NIS
1008 if (!PL_known_layers)
1009 PL_known_layers = PerlIO_list_alloc(aTHX);
a0714e2c 1010 PerlIO_list_push(aTHX_ PL_known_layers, tab, NULL);
fe5a182c 1011 PerlIO_debug("define %s %p\n", tab->name, (void*)tab);
f3862f8b
NIS
1012}
1013
1141d9f8 1014int
fcf2db38 1015PerlIO_parse_layers(pTHX_ PerlIO_list_t *av, const char *names)
1141d9f8 1016{
97aff369 1017 dVAR;
14a5cf38
JH
1018 if (names) {
1019 const char *s = names;
1020 while (*s) {
1021 while (isSPACE(*s) || *s == ':')
1022 s++;
1023 if (*s) {
1024 STRLEN llen = 0;
1025 const char *e = s;
bd61b366 1026 const char *as = NULL;
14a5cf38
JH
1027 STRLEN alen = 0;
1028 if (!isIDFIRST(*s)) {
1029 /*
1030 * Message is consistent with how attribute lists are
1031 * passed. Even though this means "foo : : bar" is
71200d45 1032 * seen as an invalid separator character.
14a5cf38 1033 */
de009b76 1034 const char q = ((*s == '\'') ? '"' : '\'');
a2a5de95
NC
1035 Perl_ck_warner(aTHX_ packWARN(WARN_LAYER),
1036 "Invalid separator character %c%c%c in PerlIO layer specification %s",
1037 q, *s, q, s);
93189314 1038 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
1039 return -1;
1040 }
1041 do {
1042 e++;
1043 } while (isALNUM(*e));
1044 llen = e - s;
1045 if (*e == '(') {
1046 int nesting = 1;
1047 as = ++e;
1048 while (nesting) {
1049 switch (*e++) {
1050 case ')':
1051 if (--nesting == 0)
1052 alen = (e - 1) - as;
1053 break;
1054 case '(':
1055 ++nesting;
1056 break;
1057 case '\\':
1058 /*
1059 * It's a nul terminated string, not allowed
1060 * to \ the terminating null. Anything other
71200d45 1061 * character is passed over.
14a5cf38
JH
1062 */
1063 if (*e++) {
1064 break;
1065 }
1066 /*
71200d45 1067 * Drop through
14a5cf38
JH
1068 */
1069 case '\0':
1070 e--;
a2a5de95
NC
1071 Perl_ck_warner(aTHX_ packWARN(WARN_LAYER),
1072 "Argument list not closed for PerlIO layer \"%.*s\"",
1073 (int) (e - s), s);
14a5cf38
JH
1074 return -1;
1075 default:
1076 /*
71200d45 1077 * boring.
14a5cf38
JH
1078 */
1079 break;
1080 }
1081 }
1082 }
1083 if (e > s) {
46c461b5 1084 PerlIO_funcs * const layer =
14a5cf38
JH
1085 PerlIO_find_layer(aTHX_ s, llen, 1);
1086 if (layer) {
a951d81d
BL
1087 SV *arg = NULL;
1088 if (as)
1089 arg = newSVpvn(as, alen);
3a1ee7e8 1090 PerlIO_list_push(aTHX_ av, layer,
a951d81d 1091 (arg) ? arg : &PL_sv_undef);
ef8d46e8 1092 SvREFCNT_dec(arg);
14a5cf38
JH
1093 }
1094 else {
a2a5de95
NC
1095 Perl_ck_warner(aTHX_ packWARN(WARN_LAYER), "Unknown PerlIO layer \"%.*s\"",
1096 (int) llen, s);
14a5cf38
JH
1097 return -1;
1098 }
1099 }
1100 s = e;
1101 }
1102 }
1103 }
1104 return 0;
1141d9f8
NIS
1105}
1106
dfebf958 1107void
fcf2db38 1108PerlIO_default_buffer(pTHX_ PerlIO_list_t *av)
dfebf958 1109{
97aff369 1110 dVAR;
27da23d5 1111 PERLIO_FUNCS_DECL(*tab) = &PerlIO_perlio;
35990314 1112#ifdef PERLIO_USING_CRLF
6ce75a77 1113 tab = &PerlIO_crlf;
846be114 1114#else
6ce75a77 1115 if (PerlIO_stdio.Set_ptrcnt)
22569500 1116 tab = &PerlIO_stdio;
846be114 1117#endif
14a5cf38 1118 PerlIO_debug("Pushing %s\n", tab->name);
3a1ee7e8 1119 PerlIO_list_push(aTHX_ av, PerlIO_find_layer(aTHX_ tab->name, 0, 0),
14a5cf38 1120 &PL_sv_undef);
dfebf958
NIS
1121}
1122
e3f3bf95 1123SV *
14a5cf38 1124PerlIO_arg_fetch(PerlIO_list_t *av, IV n)
e3f3bf95 1125{
14a5cf38 1126 return av->array[n].arg;
e3f3bf95
NIS
1127}
1128
f3862f8b 1129PerlIO_funcs *
14a5cf38 1130PerlIO_layer_fetch(pTHX_ PerlIO_list_t *av, IV n, PerlIO_funcs *def)
f3862f8b 1131{
14a5cf38
JH
1132 if (n >= 0 && n < av->cur) {
1133 PerlIO_debug("Layer %" IVdf " is %s\n", n,
1134 av->array[n].funcs->name);
1135 return av->array[n].funcs;
1136 }
1137 if (!def)
1138 Perl_croak(aTHX_ "panic: PerlIO layer array corrupt");
1139 return def;
e3f3bf95
NIS
1140}
1141
4ec2216f
NIS
1142IV
1143PerlIOPop_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
1144{
8772537c
AL
1145 PERL_UNUSED_ARG(mode);
1146 PERL_UNUSED_ARG(arg);
1147 PERL_UNUSED_ARG(tab);
4ec2216f
NIS
1148 if (PerlIOValid(f)) {
1149 PerlIO_flush(f);
1150 PerlIO_pop(aTHX_ f);
1151 return 0;
1152 }
1153 return -1;
1154}
1155
27da23d5 1156PERLIO_FUNCS_DECL(PerlIO_remove) = {
4ec2216f
NIS
1157 sizeof(PerlIO_funcs),
1158 "pop",
1159 0,
1160 PERLIO_K_DUMMY | PERLIO_K_UTF8,
1161 PerlIOPop_pushed,
1162 NULL,
c0888ace 1163 PerlIOBase_open,
4ec2216f
NIS
1164 NULL,
1165 NULL,
1166 NULL,
1167 NULL,
1168 NULL,
1169 NULL,
1170 NULL,
1171 NULL,
de009b76
AL
1172 NULL,
1173 NULL,
4ec2216f
NIS
1174 NULL, /* flush */
1175 NULL, /* fill */
1176 NULL,
1177 NULL,
1178 NULL,
1179 NULL,
1180 NULL, /* get_base */
1181 NULL, /* get_bufsiz */
1182 NULL, /* get_ptr */
1183 NULL, /* get_cnt */
1184 NULL, /* set_ptrcnt */
1185};
1186
fcf2db38 1187PerlIO_list_t *
e3f3bf95
NIS
1188PerlIO_default_layers(pTHX)
1189{
97aff369 1190 dVAR;
3a1ee7e8 1191 if (!PL_def_layerlist) {
bd61b366 1192 const char * const s = (PL_tainting) ? NULL : PerlEnv_getenv("PERLIO");
27da23d5 1193 PERLIO_FUNCS_DECL(*osLayer) = &PerlIO_unix;
3a1ee7e8 1194 PL_def_layerlist = PerlIO_list_alloc(aTHX);
27da23d5 1195 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_unix));
979e2c82 1196#if defined(WIN32)
27da23d5 1197 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_win32));
2f8118af 1198#if 0
14a5cf38 1199 osLayer = &PerlIO_win32;
0c4128ad 1200#endif
2f8118af 1201#endif
27da23d5
JH
1202 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_raw));
1203 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_perlio));
1204 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_stdio));
1205 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_crlf));
06da4f11 1206#ifdef HAS_MMAP
27da23d5 1207 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_mmap));
06da4f11 1208#endif
27da23d5
JH
1209 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_utf8));
1210 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_remove));
1211 PerlIO_define_layer(aTHX_ PERLIO_FUNCS_CAST(&PerlIO_byte));
3a1ee7e8 1212 PerlIO_list_push(aTHX_ PL_def_layerlist,
14a5cf38
JH
1213 PerlIO_find_layer(aTHX_ osLayer->name, 0, 0),
1214 &PL_sv_undef);
1215 if (s) {
3a1ee7e8 1216 PerlIO_parse_layers(aTHX_ PL_def_layerlist, s);
14a5cf38
JH
1217 }
1218 else {
3a1ee7e8 1219 PerlIO_default_buffer(aTHX_ PL_def_layerlist);
14a5cf38 1220 }
1141d9f8 1221 }
3a1ee7e8
NIS
1222 if (PL_def_layerlist->cur < 2) {
1223 PerlIO_default_buffer(aTHX_ PL_def_layerlist);
f3862f8b 1224 }
3a1ee7e8 1225 return PL_def_layerlist;
e3f3bf95
NIS
1226}
1227
0c4f7ff0
NIS
1228void
1229Perl_boot_core_PerlIO(pTHX)
1230{
1231#ifdef USE_ATTRIBUTES_FOR_PERLIO
14a5cf38
JH
1232 newXS("io::MODIFY_SCALAR_ATTRIBUTES", XS_io_MODIFY_SCALAR_ATTRIBUTES,
1233 __FILE__);
0c4f7ff0 1234#endif
14a5cf38 1235 newXS("PerlIO::Layer::find", XS_PerlIO__Layer__find, __FILE__);
c9bca74a 1236 newXS("PerlIO::Layer::NoWarnings", XS_PerlIO__Layer__NoWarnings, __FILE__);
0c4f7ff0 1237}
e3f3bf95
NIS
1238
1239PerlIO_funcs *
1240PerlIO_default_layer(pTHX_ I32 n)
1241{
97aff369 1242 dVAR;
46c461b5 1243 PerlIO_list_t * const av = PerlIO_default_layers(aTHX);
14a5cf38
JH
1244 if (n < 0)
1245 n += av->cur;
27da23d5 1246 return PerlIO_layer_fetch(aTHX_ av, n, PERLIO_FUNCS_CAST(&PerlIO_stdio));
f3862f8b
NIS
1247}
1248
a999f61b
NIS
1249#define PerlIO_default_top() PerlIO_default_layer(aTHX_ -1)
1250#define PerlIO_default_btm() PerlIO_default_layer(aTHX_ 0)
60382766
NIS
1251
1252void
1141d9f8 1253PerlIO_stdstreams(pTHX)
60382766 1254{
97aff369 1255 dVAR;
a1ea730d 1256 if (!PL_perlio) {
8995e67d 1257 PerlIO_init_table(aTHX);
14a5cf38
JH
1258 PerlIO_fdopen(0, "Ir" PERLIO_STDTEXT);
1259 PerlIO_fdopen(1, "Iw" PERLIO_STDTEXT);
1260 PerlIO_fdopen(2, "Iw" PERLIO_STDTEXT);
1261 }
60382766
NIS
1262}
1263
1264PerlIO *
27da23d5 1265PerlIO_push(pTHX_ PerlIO *f, PERLIO_FUNCS_DECL(*tab), const char *mode, SV *arg)
14a5cf38 1266{
16865ff7 1267 VERIFY_HEAD(f);
2dc2558e 1268 if (tab->fsize != sizeof(PerlIO_funcs)) {
0dc17498
TM
1269 Perl_croak( aTHX_
1270 "%s (%d) does not match %s (%d)",
1271 "PerlIO layer function table size", tab->fsize,
1272 "size expected by this perl", sizeof(PerlIO_funcs) );
2dc2558e
NIS
1273 }
1274 if (tab->size) {
b464bac0 1275 PerlIOl *l;
2dc2558e 1276 if (tab->size < sizeof(PerlIOl)) {
0dc17498
TM
1277 Perl_croak( aTHX_
1278 "%s (%d) smaller than %s (%d)",
1279 "PerlIO layer instance size", tab->size,
1280 "size expected by this perl", sizeof(PerlIOl) );
2dc2558e
NIS
1281 }
1282 /* Real layer with a data area */
002e75cf
JH
1283 if (f) {
1284 char *temp;
1285 Newxz(temp, tab->size, char);
1286 l = (PerlIOl*)temp;
1287 if (l) {
1288 l->next = *f;
1289 l->tab = (PerlIO_funcs*) tab;
16865ff7 1290 l->head = ((PerlIOl*)f)->head;
002e75cf
JH
1291 *f = l;
1292 PerlIO_debug("PerlIO_push f=%p %s %s %p\n",
1293 (void*)f, tab->name,
1294 (mode) ? mode : "(Null)", (void*)arg);
1295 if (*l->tab->Pushed &&
1296 (*l->tab->Pushed)
1297 (aTHX_ f, mode, arg, (PerlIO_funcs*) tab) != 0) {
1298 PerlIO_pop(aTHX_ f);
1299 return NULL;
1300 }
2dc2558e 1301 }
002e75cf
JH
1302 else
1303 return NULL;
2dc2558e
NIS
1304 }
1305 }
1306 else if (f) {
1307 /* Pseudo-layer where push does its own stack adjust */
00f51856
NIS
1308 PerlIO_debug("PerlIO_push f=%p %s %s %p\n", (void*)f, tab->name,
1309 (mode) ? mode : "(Null)", (void*)arg);
210e727c 1310 if (tab->Pushed &&
27da23d5 1311 (*tab->Pushed) (aTHX_ f, mode, arg, (PerlIO_funcs*) tab) != 0) {
210e727c 1312 return NULL;
14a5cf38
JH
1313 }
1314 }
1315 return f;
60382766
NIS
1316}
1317
81fe74fb
LT
1318PerlIO *
1319PerlIOBase_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
1320 IV n, const char *mode, int fd, int imode, int perm,
1321 PerlIO *old, int narg, SV **args)
1322{
1323 PerlIO_funcs * const tab = PerlIO_layer_fetch(aTHX_ layers, n - 1, PerlIO_default_layer(aTHX_ 0));
1324 if (tab && tab->Open) {
1325 PerlIO* ret = (*tab->Open)(aTHX_ tab, layers, n - 1, mode, fd, imode, perm, old, narg, args);
1326 if (ret && PerlIO_push(aTHX_ ret, self, mode, PerlIOArg) == -1) {
1327 PerlIO_close(ret);
1328 return NULL;
1329 }
1330 return ret;
1331 }
1332 SETERRNO(EINVAL, LIB_INVARG);
1333 return NULL;
1334}
1335
dfebf958 1336IV
86e05cf2
NIS
1337PerlIOBase_binmode(pTHX_ PerlIO *f)
1338{
1339 if (PerlIOValid(f)) {
1340 /* Is layer suitable for raw stream ? */
cc6623a8 1341 if (PerlIOBase(f)->tab && PerlIOBase(f)->tab->kind & PERLIO_K_RAW) {
86e05cf2
NIS
1342 /* Yes - turn off UTF-8-ness, to undo UTF-8 locale effects */
1343 PerlIOBase(f)->flags &= ~PERLIO_F_UTF8;
1344 }
1345 else {
1346 /* Not suitable - pop it */
1347 PerlIO_pop(aTHX_ f);
1348 }
1349 return 0;
1350 }
1351 return -1;
1352}
1353
1354IV
2dc2558e 1355PerlIORaw_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
dfebf958 1356{
8772537c
AL
1357 PERL_UNUSED_ARG(mode);
1358 PERL_UNUSED_ARG(arg);
1359 PERL_UNUSED_ARG(tab);
86e05cf2 1360
04892f78 1361 if (PerlIOValid(f)) {
86e05cf2 1362 PerlIO *t;
de009b76 1363 const PerlIOl *l;
14a5cf38 1364 PerlIO_flush(f);
86e05cf2
NIS
1365 /*
1366 * Strip all layers that are not suitable for a raw stream
1367 */
1368 t = f;
1369 while (t && (l = *t)) {
cc6623a8 1370 if (l->tab && l->tab->Binmode) {
86e05cf2 1371 /* Has a handler - normal case */
9d97e8b8 1372 if ((*l->tab->Binmode)(aTHX_ t) == 0) {
86e05cf2
NIS
1373 if (*t == l) {
1374 /* Layer still there - move down a layer */
1375 t = PerlIONext(t);
1376 }
1377 }
1378 else {
1379 return -1;
1380 }
14a5cf38
JH
1381 }
1382 else {
86e05cf2
NIS
1383 /* No handler - pop it */
1384 PerlIO_pop(aTHX_ t);
14a5cf38
JH
1385 }
1386 }
86e05cf2 1387 if (PerlIOValid(f)) {
cc6623a8
DM
1388 PerlIO_debug(":raw f=%p :%s\n", (void*)f,
1389 PerlIOBase(f)->tab ? PerlIOBase(f)->tab->name : "(Null)");
86e05cf2
NIS
1390 return 0;
1391 }
14a5cf38
JH
1392 }
1393 return -1;
dfebf958
NIS
1394}
1395
ac27b0f5 1396int
14a5cf38 1397PerlIO_apply_layera(pTHX_ PerlIO *f, const char *mode,
d9dac8cd 1398 PerlIO_list_t *layers, IV n, IV max)
14a5cf38 1399{
14a5cf38
JH
1400 int code = 0;
1401 while (n < max) {
8772537c 1402 PerlIO_funcs * const tab = PerlIO_layer_fetch(aTHX_ layers, n, NULL);
14a5cf38
JH
1403 if (tab) {
1404 if (!PerlIO_push(aTHX_ f, tab, mode, PerlIOArg)) {
1405 code = -1;
1406 break;
1407 }
1408 }
1409 n++;
1410 }
1411 return code;
e3f3bf95
NIS
1412}
1413
1414int
ac27b0f5
NIS
1415PerlIO_apply_layers(pTHX_ PerlIO *f, const char *mode, const char *names)
1416{
14a5cf38 1417 int code = 0;
da0fccaa
DG
1418 ENTER;
1419 save_scalar(PL_errgv);
53f1b6d2 1420 if (f && names) {
8772537c 1421 PerlIO_list_t * const layers = PerlIO_list_alloc(aTHX);
14a5cf38
JH
1422 code = PerlIO_parse_layers(aTHX_ layers, names);
1423 if (code == 0) {
d9dac8cd 1424 code = PerlIO_apply_layera(aTHX_ f, mode, layers, 0, layers->cur);
14a5cf38 1425 }
3a1ee7e8 1426 PerlIO_list_free(aTHX_ layers);
ac27b0f5 1427 }
da0fccaa 1428 LEAVE;
14a5cf38 1429 return code;
ac27b0f5
NIS
1430}
1431
f3862f8b 1432
60382766 1433/*--------------------------------------------------------------------------------------*/
14a5cf38 1434/*
71200d45 1435 * Given the abstraction above the public API functions
14a5cf38 1436 */
60382766
NIS
1437
1438int
f5b9d040 1439PerlIO_binmode(pTHX_ PerlIO *f, int iotype, int mode, const char *names)
76ced9ad 1440{
68b5363f 1441 PerlIO_debug("PerlIO_binmode f=%p %s %c %x %s\n", (void*)f,
cc6623a8
DM
1442 (PerlIOBase(f) && PerlIOBase(f)->tab) ?
1443 PerlIOBase(f)->tab->name : "(Null)",
68b5363f
PD
1444 iotype, mode, (names) ? names : "(Null)");
1445
03c0554d
NIS
1446 if (names) {
1447 /* Do not flush etc. if (e.g.) switching encodings.
1448 if a pushed layer knows it needs to flush lower layers
1449 (for example :unix which is never going to call them)
1450 it can do the flush when it is pushed.
1451 */
1452 return PerlIO_apply_layers(aTHX_ f, NULL, names) == 0 ? TRUE : FALSE;
1453 }
1454 else {
86e05cf2 1455 /* Fake 5.6 legacy of using this call to turn ON O_TEXT */
35990314 1456#ifdef PERLIO_USING_CRLF
03c0554d
NIS
1457 /* Legacy binmode only has meaning if O_TEXT has a value distinct from
1458 O_BINARY so we can look for it in mode.
1459 */
1460 if (!(mode & O_BINARY)) {
1461 /* Text mode */
86e05cf2
NIS
1462 /* FIXME?: Looking down the layer stack seems wrong,
1463 but is a way of reaching past (say) an encoding layer
1464 to flip CRLF-ness of the layer(s) below
1465 */
03c0554d
NIS
1466 while (*f) {
1467 /* Perhaps we should turn on bottom-most aware layer
1468 e.g. Ilya's idea that UNIX TTY could serve
1469 */
cc6623a8
DM
1470 if (PerlIOBase(f)->tab &&
1471 PerlIOBase(f)->tab->kind & PERLIO_K_CANCRLF)
1472 {
03c0554d
NIS
1473 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF)) {
1474 /* Not in text mode - flush any pending stuff and flip it */
1475 PerlIO_flush(f);
1476 PerlIOBase(f)->flags |= PERLIO_F_CRLF;
1477 }
1478 /* Only need to turn it on in one layer so we are done */
1479 return TRUE;
ed53a2bb 1480 }
03c0554d 1481 f = PerlIONext(f);
14a5cf38 1482 }
03c0554d
NIS
1483 /* Not finding a CRLF aware layer presumably means we are binary
1484 which is not what was requested - so we failed
1485 We _could_ push :crlf layer but so could caller
1486 */
1487 return FALSE;
14a5cf38 1488 }
6ce75a77 1489#endif
86e05cf2
NIS
1490 /* Legacy binmode is now _defined_ as being equivalent to pushing :raw
1491 So code that used to be here is now in PerlIORaw_pushed().
03c0554d 1492 */
a0714e2c 1493 return PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_raw), NULL, NULL) ? TRUE : FALSE;
14a5cf38 1494 }
f5b9d040
NIS
1495}
1496
f5b9d040 1497int
e87a358a 1498PerlIO__close(pTHX_ PerlIO *f)
f5b9d040 1499{
37725cdc 1500 if (PerlIOValid(f)) {
46c461b5 1501 PerlIO_funcs * const tab = PerlIOBase(f)->tab;
37725cdc
NIS
1502 if (tab && tab->Close)
1503 return (*tab->Close)(aTHX_ f);
1504 else
1505 return PerlIOBase_close(aTHX_ f);
1506 }
14a5cf38 1507 else {
93189314 1508 SETERRNO(EBADF, SS_IVCHAN);
14a5cf38
JH
1509 return -1;
1510 }
76ced9ad
NIS
1511}
1512
b931b1d9 1513int
e87a358a 1514Perl_PerlIO_close(pTHX_ PerlIO *f)
b931b1d9 1515{
de009b76 1516 const int code = PerlIO__close(aTHX_ f);
37725cdc
NIS
1517 while (PerlIOValid(f)) {
1518 PerlIO_pop(aTHX_ f);
abf9167d
DM
1519 if (PerlIO_lockcnt(f))
1520 /* we're in use; the 'pop' deferred freeing the structure */
1521 f = PerlIONext(f);
f6c77cf1 1522 }
14a5cf38 1523 return code;
b931b1d9
NIS
1524}
1525
b931b1d9 1526int
e87a358a 1527Perl_PerlIO_fileno(pTHX_ PerlIO *f)
b931b1d9 1528{
97aff369 1529 dVAR;
b32dd47e 1530 Perl_PerlIO_or_Base(f, Fileno, fileno, -1, (aTHX_ f));
b931b1d9
NIS
1531}
1532
1141d9f8 1533
fcf2db38 1534static PerlIO_funcs *
2edd7e44
NIS
1535PerlIO_layer_from_ref(pTHX_ SV *sv)
1536{
97aff369 1537 dVAR;
14a5cf38 1538 /*
71200d45 1539 * For any scalar type load the handler which is bundled with perl
14a5cf38 1540 */
526fd1b4 1541 if (SvTYPE(sv) < SVt_PVAV && (!isGV_with_GP(sv) || SvFAKE(sv))) {
75208dda
RGS
1542 PerlIO_funcs *f = PerlIO_find_layer(aTHX_ STR_WITH_LEN("scalar"), 1);
1543 /* This isn't supposed to happen, since PerlIO::scalar is core,
1544 * but could happen anyway in smaller installs or with PAR */
a2a5de95
NC
1545 if (!f)
1546 Perl_ck_warner(aTHX_ packWARN(WARN_LAYER), "Unknown PerlIO layer \"scalar\"");
75208dda
RGS
1547 return f;
1548 }
14a5cf38
JH
1549
1550 /*
71200d45 1551 * For other types allow if layer is known but don't try and load it
14a5cf38
JH
1552 */
1553 switch (SvTYPE(sv)) {
1554 case SVt_PVAV:
6a245ed1 1555 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Array"), 0);
14a5cf38 1556 case SVt_PVHV:
6a245ed1 1557 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Hash"), 0);
14a5cf38 1558 case SVt_PVCV:
6a245ed1 1559 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Code"), 0);
14a5cf38 1560 case SVt_PVGV:
6a245ed1 1561 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Glob"), 0);
42d0e0b7
AL
1562 default:
1563 return NULL;
14a5cf38 1564 }
2edd7e44
NIS
1565}
1566
fcf2db38 1567PerlIO_list_t *
14a5cf38
JH
1568PerlIO_resolve_layers(pTHX_ const char *layers,
1569 const char *mode, int narg, SV **args)
1570{
97aff369 1571 dVAR;
14a5cf38
JH
1572 PerlIO_list_t *def = PerlIO_default_layers(aTHX);
1573 int incdef = 1;
a1ea730d 1574 if (!PL_perlio)
14a5cf38
JH
1575 PerlIO_stdstreams(aTHX);
1576 if (narg) {
dcda55fc 1577 SV * const arg = *args;
14a5cf38 1578 /*
71200d45
NIS
1579 * If it is a reference but not an object see if we have a handler
1580 * for it
14a5cf38
JH
1581 */
1582 if (SvROK(arg) && !sv_isobject(arg)) {
46c461b5 1583 PerlIO_funcs * const handler = PerlIO_layer_from_ref(aTHX_ SvRV(arg));
14a5cf38 1584 if (handler) {
3a1ee7e8
NIS
1585 def = PerlIO_list_alloc(aTHX);
1586 PerlIO_list_push(aTHX_ def, handler, &PL_sv_undef);
14a5cf38
JH
1587 incdef = 0;
1588 }
1589 /*
e934609f 1590 * Don't fail if handler cannot be found :via(...) etc. may do
14a5cf38 1591 * something sensible else we will just stringfy and open
71200d45 1592 * resulting string.
14a5cf38
JH
1593 */
1594 }
1595 }
9fe371da 1596 if (!layers || !*layers)
11bcd5da 1597 layers = Perl_PerlIO_context_layers(aTHX_ mode);
14a5cf38
JH
1598 if (layers && *layers) {
1599 PerlIO_list_t *av;
1600 if (incdef) {
a951d81d 1601 av = PerlIO_clone_list(aTHX_ def, NULL);
14a5cf38
JH
1602 }
1603 else {
1604 av = def;
1605 }
0cff2cf3
NIS
1606 if (PerlIO_parse_layers(aTHX_ av, layers) == 0) {
1607 return av;
1608 }
1609 else {
1610 PerlIO_list_free(aTHX_ av);
b37c2d43 1611 return NULL;
0cff2cf3 1612 }
14a5cf38
JH
1613 }
1614 else {
1615 if (incdef)
1616 def->refcnt++;
1617 return def;
1618 }
ee518936
NIS
1619}
1620
1621PerlIO *
14a5cf38
JH
1622PerlIO_openn(pTHX_ const char *layers, const char *mode, int fd,
1623 int imode, int perm, PerlIO *f, int narg, SV **args)
1624{
97aff369 1625 dVAR;
14a5cf38
JH
1626 if (!f && narg == 1 && *args == &PL_sv_undef) {
1627 if ((f = PerlIO_tmpfile())) {
9fe371da 1628 if (!layers || !*layers)
11bcd5da 1629 layers = Perl_PerlIO_context_layers(aTHX_ mode);
14a5cf38
JH
1630 if (layers && *layers)
1631 PerlIO_apply_layers(aTHX_ f, mode, layers);
1632 }
1633 }
1634 else {
de009b76 1635 PerlIO_list_t *layera;
14a5cf38
JH
1636 IV n;
1637 PerlIO_funcs *tab = NULL;
04892f78 1638 if (PerlIOValid(f)) {
14a5cf38 1639 /*
71200d45
NIS
1640 * This is "reopen" - it is not tested as perl does not use it
1641 * yet
14a5cf38
JH
1642 */
1643 PerlIOl *l = *f;
3a1ee7e8 1644 layera = PerlIO_list_alloc(aTHX);
14a5cf38 1645 while (l) {
a951d81d 1646 SV *arg = NULL;
cc6623a8 1647 if (l->tab && l->tab->Getarg)
a951d81d
BL
1648 arg = (*l->tab->Getarg) (aTHX_ &l, NULL, 0);
1649 PerlIO_list_push(aTHX_ layera, l->tab,
1650 (arg) ? arg : &PL_sv_undef);
ef8d46e8 1651 SvREFCNT_dec(arg);
14a5cf38
JH
1652 l = *PerlIONext(&l);
1653 }
1654 }
1655 else {
1656 layera = PerlIO_resolve_layers(aTHX_ layers, mode, narg, args);
0cff2cf3
NIS
1657 if (!layera) {
1658 return NULL;
1659 }
14a5cf38
JH
1660 }
1661 /*
71200d45 1662 * Start at "top" of layer stack
14a5cf38
JH
1663 */
1664 n = layera->cur - 1;
1665 while (n >= 0) {
46c461b5 1666 PerlIO_funcs * const t = PerlIO_layer_fetch(aTHX_ layera, n, NULL);
14a5cf38
JH
1667 if (t && t->Open) {
1668 tab = t;
1669 break;
1670 }
1671 n--;
1672 }
1673 if (tab) {
1674 /*
71200d45 1675 * Found that layer 'n' can do opens - call it
14a5cf38 1676 */
7cf31beb 1677 if (narg > 1 && !(tab->kind & PERLIO_K_MULTIARG)) {
3b8752bb 1678 Perl_croak(aTHX_ "More than one argument to open(,':%s')",tab->name);
7cf31beb 1679 }
14a5cf38 1680 PerlIO_debug("openn(%s,'%s','%s',%d,%x,%o,%p,%d,%p)\n",
355d3743
PD
1681 tab->name, layers ? layers : "(Null)", mode, fd,
1682 imode, perm, (void*)f, narg, (void*)args);
210e727c
JH
1683 if (tab->Open)
1684 f = (*tab->Open) (aTHX_ tab, layera, n, mode, fd, imode, perm,
1685 f, narg, args);
1686 else {
1687 SETERRNO(EINVAL, LIB_INVARG);
1688 f = NULL;
1689 }
14a5cf38
JH
1690 if (f) {
1691 if (n + 1 < layera->cur) {
1692 /*
1693 * More layers above the one that we used to open -
71200d45 1694 * apply them now
14a5cf38 1695 */
d9dac8cd
NIS
1696 if (PerlIO_apply_layera(aTHX_ f, mode, layera, n + 1, layera->cur) != 0) {
1697 /* If pushing layers fails close the file */
1698 PerlIO_close(f);
14a5cf38
JH
1699 f = NULL;
1700 }
1701 }
1702 }
1703 }
3a1ee7e8 1704 PerlIO_list_free(aTHX_ layera);
14a5cf38
JH
1705 }
1706 return f;
ee518936 1707}
b931b1d9
NIS
1708
1709
9e353e3b 1710SSize_t
e87a358a 1711Perl_PerlIO_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
6f9d8c32 1712{
7918f24d
NC
1713 PERL_ARGS_ASSERT_PERLIO_READ;
1714
b32dd47e 1715 Perl_PerlIO_or_Base(f, Read, read, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1716}
1717
313ca112 1718SSize_t
e87a358a 1719Perl_PerlIO_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 1720{
7918f24d
NC
1721 PERL_ARGS_ASSERT_PERLIO_UNREAD;
1722
b32dd47e 1723 Perl_PerlIO_or_Base(f, Unread, unread, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1724}
1725
9e353e3b 1726SSize_t
e87a358a 1727Perl_PerlIO_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 1728{
7918f24d
NC
1729 PERL_ARGS_ASSERT_PERLIO_WRITE;
1730
b32dd47e 1731 Perl_PerlIO_or_fail(f, Write, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1732}
1733
6f9d8c32 1734int
e87a358a 1735Perl_PerlIO_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
760ac839 1736{
b32dd47e 1737 Perl_PerlIO_or_fail(f, Seek, -1, (aTHX_ f, offset, whence));
760ac839
LW
1738}
1739
9e353e3b 1740Off_t
e87a358a 1741Perl_PerlIO_tell(pTHX_ PerlIO *f)
760ac839 1742{
b32dd47e 1743 Perl_PerlIO_or_fail(f, Tell, -1, (aTHX_ f));
760ac839
LW
1744}
1745
6f9d8c32 1746int
e87a358a 1747Perl_PerlIO_flush(pTHX_ PerlIO *f)
760ac839 1748{
97aff369 1749 dVAR;
14a5cf38
JH
1750 if (f) {
1751 if (*f) {
de009b76 1752 const PerlIO_funcs *tab = PerlIOBase(f)->tab;
1b7a0411
JH
1753
1754 if (tab && tab->Flush)
f62ce20a 1755 return (*tab->Flush) (aTHX_ f);
1b7a0411
JH
1756 else
1757 return 0; /* If no Flush defined, silently succeed. */
14a5cf38
JH
1758 }
1759 else {
fe5a182c 1760 PerlIO_debug("Cannot flush f=%p\n", (void*)f);
93189314 1761 SETERRNO(EBADF, SS_IVCHAN);
14a5cf38
JH
1762 return -1;
1763 }
1764 }
1765 else {
1766 /*
1767 * Is it good API design to do flush-all on NULL, a potentially
486ec47a 1768 * erroneous input? Maybe some magical value (PerlIO*
14a5cf38
JH
1769 * PERLIO_FLUSH_ALL = (PerlIO*)-1;)? Yes, stdio does similar
1770 * things on fflush(NULL), but should we be bound by their design
71200d45 1771 * decisions? --jhi
14a5cf38 1772 */
303f2dc3
DM
1773 PerlIOl **table = &PL_perlio;
1774 PerlIOl *ff;
14a5cf38 1775 int code = 0;
303f2dc3 1776 while ((ff = *table)) {
14a5cf38 1777 int i;
303f2dc3 1778 table = (PerlIOl **) (ff++);
14a5cf38 1779 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3 1780 if (ff->next && PerlIO_flush(&(ff->next)) != 0)
14a5cf38 1781 code = -1;
303f2dc3 1782 ff++;
14a5cf38
JH
1783 }
1784 }
1785 return code;
1786 }
760ac839
LW
1787}
1788
a9c883f6 1789void
f62ce20a 1790PerlIOBase_flush_linebuf(pTHX)
a9c883f6 1791{
97aff369 1792 dVAR;
303f2dc3
DM
1793 PerlIOl **table = &PL_perlio;
1794 PerlIOl *f;
14a5cf38
JH
1795 while ((f = *table)) {
1796 int i;
303f2dc3 1797 table = (PerlIOl **) (f++);
14a5cf38 1798 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3
DM
1799 if (f->next
1800 && (PerlIOBase(&(f->next))->
14a5cf38
JH
1801 flags & (PERLIO_F_LINEBUF | PERLIO_F_CANWRITE))
1802 == (PERLIO_F_LINEBUF | PERLIO_F_CANWRITE))
303f2dc3 1803 PerlIO_flush(&(f->next));
14a5cf38
JH
1804 f++;
1805 }
a9c883f6 1806 }
a9c883f6
NIS
1807}
1808
06da4f11 1809int
e87a358a 1810Perl_PerlIO_fill(pTHX_ PerlIO *f)
06da4f11 1811{
b32dd47e 1812 Perl_PerlIO_or_fail(f, Fill, -1, (aTHX_ f));
06da4f11
NIS
1813}
1814
f3862f8b
NIS
1815int
1816PerlIO_isutf8(PerlIO *f)
1817{
1b7a0411
JH
1818 if (PerlIOValid(f))
1819 return (PerlIOBase(f)->flags & PERLIO_F_UTF8) != 0;
1820 else
1821 SETERRNO(EBADF, SS_IVCHAN);
37725cdc 1822
1b7a0411 1823 return -1;
f3862f8b
NIS
1824}
1825
6f9d8c32 1826int
e87a358a 1827Perl_PerlIO_eof(pTHX_ PerlIO *f)
760ac839 1828{
b32dd47e 1829 Perl_PerlIO_or_Base(f, Eof, eof, -1, (aTHX_ f));
9e353e3b
NIS
1830}
1831
9e353e3b 1832int
e87a358a 1833Perl_PerlIO_error(pTHX_ PerlIO *f)
9e353e3b 1834{
b32dd47e 1835 Perl_PerlIO_or_Base(f, Error, error, -1, (aTHX_ f));
9e353e3b
NIS
1836}
1837
9e353e3b 1838void
e87a358a 1839Perl_PerlIO_clearerr(pTHX_ PerlIO *f)
9e353e3b 1840{
b32dd47e 1841 Perl_PerlIO_or_Base_void(f, Clearerr, clearerr, (aTHX_ f));
9e353e3b
NIS
1842}
1843
9e353e3b 1844void
e87a358a 1845Perl_PerlIO_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 1846{
b32dd47e 1847 Perl_PerlIO_or_Base_void(f, Setlinebuf, setlinebuf, (aTHX_ f));
9e353e3b
NIS
1848}
1849
9e353e3b
NIS
1850int
1851PerlIO_has_base(PerlIO *f)
1852{
1b7a0411 1853 if (PerlIOValid(f)) {
46c461b5 1854 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1855
1856 if (tab)
1857 return (tab->Get_base != NULL);
1b7a0411 1858 }
1b7a0411
JH
1859
1860 return 0;
760ac839
LW
1861}
1862
9e353e3b
NIS
1863int
1864PerlIO_fast_gets(PerlIO *f)
760ac839 1865{
d7dfc388
SK
1866 if (PerlIOValid(f)) {
1867 if (PerlIOBase(f)->flags & PERLIO_F_FASTGETS) {
1868 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411 1869
d7dfc388
SK
1870 if (tab)
1871 return (tab->Set_ptrcnt != NULL);
d7dfc388 1872 }
14a5cf38 1873 }
1b7a0411 1874
14a5cf38 1875 return 0;
9e353e3b
NIS
1876}
1877
9e353e3b
NIS
1878int
1879PerlIO_has_cntptr(PerlIO *f)
1880{
04892f78 1881 if (PerlIOValid(f)) {
46c461b5 1882 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1883
1884 if (tab)
1885 return (tab->Get_ptr != NULL && tab->Get_cnt != NULL);
14a5cf38 1886 }
1b7a0411 1887
14a5cf38 1888 return 0;
9e353e3b
NIS
1889}
1890
9e353e3b
NIS
1891int
1892PerlIO_canset_cnt(PerlIO *f)
1893{
04892f78 1894 if (PerlIOValid(f)) {
46c461b5 1895 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1896
1897 if (tab)
1898 return (tab->Set_ptrcnt != NULL);
14a5cf38 1899 }
1b7a0411 1900
14a5cf38 1901 return 0;
760ac839
LW
1902}
1903
888911fc 1904STDCHAR *
e87a358a 1905Perl_PerlIO_get_base(pTHX_ PerlIO *f)
760ac839 1906{
b32dd47e 1907 Perl_PerlIO_or_fail(f, Get_base, NULL, (aTHX_ f));
9e353e3b
NIS
1908}
1909
9e353e3b 1910int
e87a358a 1911Perl_PerlIO_get_bufsiz(pTHX_ PerlIO *f)
9e353e3b 1912{
b32dd47e 1913 Perl_PerlIO_or_fail(f, Get_bufsiz, -1, (aTHX_ f));
9e353e3b
NIS
1914}
1915
9e353e3b 1916STDCHAR *
e87a358a 1917Perl_PerlIO_get_ptr(pTHX_ PerlIO *f)
9e353e3b 1918{
b32dd47e 1919 Perl_PerlIO_or_fail(f, Get_ptr, NULL, (aTHX_ f));
9e353e3b
NIS
1920}
1921
05d1247b 1922int
e87a358a 1923Perl_PerlIO_get_cnt(pTHX_ PerlIO *f)
9e353e3b 1924{
b32dd47e 1925 Perl_PerlIO_or_fail(f, Get_cnt, -1, (aTHX_ f));
9e353e3b
NIS
1926}
1927
9e353e3b 1928void
e87a358a 1929Perl_PerlIO_set_cnt(pTHX_ PerlIO *f, int cnt)
9e353e3b 1930{
b32dd47e 1931 Perl_PerlIO_or_fail_void(f, Set_ptrcnt, (aTHX_ f, NULL, cnt));
9e353e3b
NIS
1932}
1933
9e353e3b 1934void
e87a358a 1935Perl_PerlIO_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, int cnt)
9e353e3b 1936{
b32dd47e 1937 Perl_PerlIO_or_fail_void(f, Set_ptrcnt, (aTHX_ f, ptr, cnt));
9e353e3b
NIS
1938}
1939
4ec2216f 1940
9e353e3b 1941/*--------------------------------------------------------------------------------------*/
14a5cf38 1942/*
71200d45 1943 * utf8 and raw dummy layers
14a5cf38 1944 */
dfebf958 1945
26fb694e 1946IV
2dc2558e 1947PerlIOUtf8_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
26fb694e 1948{
96a5add6 1949 PERL_UNUSED_CONTEXT;
8772537c
AL
1950 PERL_UNUSED_ARG(mode);
1951 PERL_UNUSED_ARG(arg);
00f51856 1952 if (PerlIOValid(f)) {
cc6623a8 1953 if (tab && tab->kind & PERLIO_K_UTF8)
14a5cf38
JH
1954 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
1955 else
1956 PerlIOBase(f)->flags &= ~PERLIO_F_UTF8;
1957 return 0;
1958 }
1959 return -1;
26fb694e
NIS
1960}
1961
27da23d5 1962PERLIO_FUNCS_DECL(PerlIO_utf8) = {
2dc2558e 1963 sizeof(PerlIO_funcs),
14a5cf38 1964 "utf8",
2dc2558e 1965 0,
6874a2de 1966 PERLIO_K_DUMMY | PERLIO_K_UTF8,
14a5cf38
JH
1967 PerlIOUtf8_pushed,
1968 NULL,
c0888ace 1969 PerlIOBase_open,
14a5cf38
JH
1970 NULL,
1971 NULL,
1972 NULL,
1973 NULL,
1974 NULL,
1975 NULL,
1976 NULL,
1977 NULL,
de009b76
AL
1978 NULL,
1979 NULL,
22569500
NIS
1980 NULL, /* flush */
1981 NULL, /* fill */
14a5cf38
JH
1982 NULL,
1983 NULL,
1984 NULL,
1985 NULL,
22569500
NIS
1986 NULL, /* get_base */
1987 NULL, /* get_bufsiz */
1988 NULL, /* get_ptr */
1989 NULL, /* get_cnt */
1990 NULL, /* set_ptrcnt */
26fb694e
NIS
1991};
1992
27da23d5 1993PERLIO_FUNCS_DECL(PerlIO_byte) = {
2dc2558e 1994 sizeof(PerlIO_funcs),
14a5cf38 1995 "bytes",
2dc2558e 1996 0,
14a5cf38
JH
1997 PERLIO_K_DUMMY,
1998 PerlIOUtf8_pushed,
1999 NULL,
c0888ace 2000 PerlIOBase_open,
14a5cf38
JH
2001 NULL,
2002 NULL,
2003 NULL,
2004 NULL,
2005 NULL,
2006 NULL,
2007 NULL,
2008 NULL,
de009b76
AL
2009 NULL,
2010 NULL,
22569500
NIS
2011 NULL, /* flush */
2012 NULL, /* fill */
14a5cf38
JH
2013 NULL,
2014 NULL,
2015 NULL,
2016 NULL,
22569500
NIS
2017 NULL, /* get_base */
2018 NULL, /* get_bufsiz */
2019 NULL, /* get_ptr */
2020 NULL, /* get_cnt */
2021 NULL, /* set_ptrcnt */
dfebf958
NIS
2022};
2023
2024PerlIO *
14a5cf38
JH
2025PerlIORaw_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
2026 IV n, const char *mode, int fd, int imode, int perm,
2027 PerlIO *old, int narg, SV **args)
dfebf958 2028{
8772537c
AL
2029 PerlIO_funcs * const tab = PerlIO_default_btm();
2030 PERL_UNUSED_ARG(self);
210e727c
JH
2031 if (tab && tab->Open)
2032 return (*tab->Open) (aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
2033 old, narg, args);
2034 SETERRNO(EINVAL, LIB_INVARG);
2035 return NULL;
dfebf958
NIS
2036}
2037
27da23d5 2038PERLIO_FUNCS_DECL(PerlIO_raw) = {
2dc2558e 2039 sizeof(PerlIO_funcs),
14a5cf38 2040 "raw",
2dc2558e 2041 0,
14a5cf38
JH
2042 PERLIO_K_DUMMY,
2043 PerlIORaw_pushed,
2044 PerlIOBase_popped,
2045 PerlIORaw_open,
2046 NULL,
2047 NULL,
2048 NULL,
2049 NULL,
2050 NULL,
2051 NULL,
2052 NULL,
2053 NULL,
de009b76
AL
2054 NULL,
2055 NULL,
22569500
NIS
2056 NULL, /* flush */
2057 NULL, /* fill */
14a5cf38
JH
2058 NULL,
2059 NULL,
2060 NULL,
2061 NULL,
22569500
NIS
2062 NULL, /* get_base */
2063 NULL, /* get_bufsiz */
2064 NULL, /* get_ptr */
2065 NULL, /* get_cnt */
2066 NULL, /* set_ptrcnt */
dfebf958
NIS
2067};
2068/*--------------------------------------------------------------------------------------*/
2069/*--------------------------------------------------------------------------------------*/
14a5cf38 2070/*
71200d45 2071 * "Methods" of the "base class"
14a5cf38 2072 */
9e353e3b
NIS
2073
2074IV
f62ce20a 2075PerlIOBase_fileno(pTHX_ PerlIO *f)
9e353e3b 2076{
04892f78 2077 return PerlIOValid(f) ? PerlIO_fileno(PerlIONext(f)) : -1;
9e353e3b
NIS
2078}
2079
f5b9d040 2080char *
81428673 2081PerlIO_modestr(PerlIO * f, char *buf)
14a5cf38
JH
2082{
2083 char *s = buf;
81428673 2084 if (PerlIOValid(f)) {
de009b76 2085 const IV flags = PerlIOBase(f)->flags;
81428673
NIS
2086 if (flags & PERLIO_F_APPEND) {
2087 *s++ = 'a';
2088 if (flags & PERLIO_F_CANREAD) {
2089 *s++ = '+';
2090 }
14a5cf38 2091 }
81428673
NIS
2092 else if (flags & PERLIO_F_CANREAD) {
2093 *s++ = 'r';
2094 if (flags & PERLIO_F_CANWRITE)
2095 *s++ = '+';
2096 }
2097 else if (flags & PERLIO_F_CANWRITE) {
2098 *s++ = 'w';
2099 if (flags & PERLIO_F_CANREAD) {
2100 *s++ = '+';
2101 }
14a5cf38 2102 }
35990314 2103#ifdef PERLIO_USING_CRLF
81428673
NIS
2104 if (!(flags & PERLIO_F_CRLF))
2105 *s++ = 'b';
5f1a76d0 2106#endif
81428673 2107 }
14a5cf38
JH
2108 *s = '\0';
2109 return buf;
f5b9d040
NIS
2110}
2111
81428673 2112
76ced9ad 2113IV
2dc2558e 2114PerlIOBase_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
9e353e3b 2115{
de009b76 2116 PerlIOl * const l = PerlIOBase(f);
96a5add6 2117 PERL_UNUSED_CONTEXT;
8772537c 2118 PERL_UNUSED_ARG(arg);
de009b76 2119
14a5cf38
JH
2120 l->flags &= ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE |
2121 PERLIO_F_TRUNCATE | PERLIO_F_APPEND);
cc6623a8 2122 if (tab && tab->Set_ptrcnt != NULL)
14a5cf38
JH
2123 l->flags |= PERLIO_F_FASTGETS;
2124 if (mode) {
3b6c1aba 2125 if (*mode == IoTYPE_NUMERIC || *mode == IoTYPE_IMPLICIT)
14a5cf38
JH
2126 mode++;
2127 switch (*mode++) {
2128 case 'r':
2129 l->flags |= PERLIO_F_CANREAD;
2130 break;
2131 case 'a':
2132 l->flags |= PERLIO_F_APPEND | PERLIO_F_CANWRITE;
2133 break;
2134 case 'w':
2135 l->flags |= PERLIO_F_TRUNCATE | PERLIO_F_CANWRITE;
2136 break;
2137 default:
93189314 2138 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2139 return -1;
2140 }
2141 while (*mode) {
2142 switch (*mode++) {
2143 case '+':
2144 l->flags |= PERLIO_F_CANREAD | PERLIO_F_CANWRITE;
2145 break;
2146 case 'b':
2147 l->flags &= ~PERLIO_F_CRLF;
2148 break;
2149 case 't':
2150 l->flags |= PERLIO_F_CRLF;
2151 break;
2152 default:
93189314 2153 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2154 return -1;
2155 }
2156 }
2157 }
2158 else {
2159 if (l->next) {
2160 l->flags |= l->next->flags &
2161 (PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_TRUNCATE |
2162 PERLIO_F_APPEND);
2163 }
2164 }
5e2ab84b 2165#if 0
14a5cf38 2166 PerlIO_debug("PerlIOBase_pushed f=%p %s %s fl=%08" UVxf " (%s)\n",
6c9570dc 2167 (void*)f, PerlIOBase(f)->tab->name, (omode) ? omode : "(Null)",
14a5cf38 2168 l->flags, PerlIO_modestr(f, temp));
5e2ab84b 2169#endif
14a5cf38 2170 return 0;
76ced9ad
NIS
2171}
2172
2173IV
f62ce20a 2174PerlIOBase_popped(pTHX_ PerlIO *f)
76ced9ad 2175{
96a5add6 2176 PERL_UNUSED_CONTEXT;
8772537c 2177 PERL_UNUSED_ARG(f);
14a5cf38 2178 return 0;
760ac839
LW
2179}
2180
9e353e3b 2181SSize_t
f62ce20a 2182PerlIOBase_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 2183{
14a5cf38 2184 /*
71200d45 2185 * Save the position as current head considers it
14a5cf38 2186 */
de009b76 2187 const Off_t old = PerlIO_tell(f);
a0714e2c 2188 PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_pending), "r", NULL);
14a5cf38 2189 PerlIOSelf(f, PerlIOBuf)->posn = old;
de009b76 2190 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
9e353e3b
NIS
2191}
2192
f6c77cf1 2193SSize_t
f62ce20a 2194PerlIOBase_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
f6c77cf1 2195{
14a5cf38
JH
2196 STDCHAR *buf = (STDCHAR *) vbuf;
2197 if (f) {
263df5f1
JH
2198 if (!(PerlIOBase(f)->flags & PERLIO_F_CANREAD)) {
2199 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2200 SETERRNO(EBADF, SS_IVCHAN);
2201 return 0;
2202 }
14a5cf38 2203 while (count > 0) {
93c2c2ec
IZ
2204 get_cnt:
2205 {
14a5cf38
JH
2206 SSize_t avail = PerlIO_get_cnt(f);
2207 SSize_t take = 0;
2208 if (avail > 0)
bb7a0f54 2209 take = ((SSize_t)count < avail) ? (SSize_t)count : avail;
14a5cf38
JH
2210 if (take > 0) {
2211 STDCHAR *ptr = PerlIO_get_ptr(f);
2212 Copy(ptr, buf, take, STDCHAR);
2213 PerlIO_set_ptrcnt(f, ptr + take, (avail -= take));
2214 count -= take;
2215 buf += take;
93c2c2ec
IZ
2216 if (avail == 0) /* set_ptrcnt could have reset avail */
2217 goto get_cnt;
14a5cf38
JH
2218 }
2219 if (count > 0 && avail <= 0) {
2220 if (PerlIO_fill(f) != 0)
2221 break;
2222 }
93c2c2ec 2223 }
14a5cf38
JH
2224 }
2225 return (buf - (STDCHAR *) vbuf);
2226 }
f6c77cf1 2227 return 0;
f6c77cf1
NIS
2228}
2229
9e353e3b 2230IV
f62ce20a 2231PerlIOBase_noop_ok(pTHX_ PerlIO *f)
9e353e3b 2232{
96a5add6 2233 PERL_UNUSED_CONTEXT;
8772537c 2234 PERL_UNUSED_ARG(f);
14a5cf38 2235 return 0;
9e353e3b
NIS
2236}
2237
2238IV
f62ce20a 2239PerlIOBase_noop_fail(pTHX_ PerlIO *f)
06da4f11 2240{
96a5add6 2241 PERL_UNUSED_CONTEXT;
8772537c 2242 PERL_UNUSED_ARG(f);
14a5cf38 2243 return -1;
06da4f11
NIS
2244}
2245
2246IV
f62ce20a 2247PerlIOBase_close(pTHX_ PerlIO *f)
9e353e3b 2248{
37725cdc
NIS
2249 IV code = -1;
2250 if (PerlIOValid(f)) {
2251 PerlIO *n = PerlIONext(f);
2252 code = PerlIO_flush(f);
2253 PerlIOBase(f)->flags &=
2254 ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_OPEN);
2255 while (PerlIOValid(n)) {
de009b76 2256 const PerlIO_funcs * const tab = PerlIOBase(n)->tab;
37725cdc
NIS
2257 if (tab && tab->Close) {
2258 if ((*tab->Close)(aTHX_ n) != 0)
2259 code = -1;
2260 break;
2261 }
2262 else {
2263 PerlIOBase(n)->flags &=
2264 ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_OPEN);
2265 }
2266 n = PerlIONext(n);
2267 }
2268 }
2269 else {
2270 SETERRNO(EBADF, SS_IVCHAN);
2271 }
14a5cf38 2272 return code;
9e353e3b
NIS
2273}
2274
2275IV
f62ce20a 2276PerlIOBase_eof(pTHX_ PerlIO *f)
9e353e3b 2277{
96a5add6 2278 PERL_UNUSED_CONTEXT;
04892f78 2279 if (PerlIOValid(f)) {
14a5cf38
JH
2280 return (PerlIOBase(f)->flags & PERLIO_F_EOF) != 0;
2281 }
2282 return 1;
9e353e3b
NIS
2283}
2284
2285IV
f62ce20a 2286PerlIOBase_error(pTHX_ PerlIO *f)
9e353e3b 2287{
96a5add6 2288 PERL_UNUSED_CONTEXT;
04892f78 2289 if (PerlIOValid(f)) {
14a5cf38
JH
2290 return (PerlIOBase(f)->flags & PERLIO_F_ERROR) != 0;
2291 }
2292 return 1;
9e353e3b
NIS
2293}
2294
2295void
f62ce20a 2296PerlIOBase_clearerr(pTHX_ PerlIO *f)
9e353e3b 2297{
04892f78 2298 if (PerlIOValid(f)) {
dcda55fc 2299 PerlIO * const n = PerlIONext(f);
14a5cf38 2300 PerlIOBase(f)->flags &= ~(PERLIO_F_ERROR | PERLIO_F_EOF);
04892f78 2301 if (PerlIOValid(n))
14a5cf38
JH
2302 PerlIO_clearerr(n);
2303 }
9e353e3b
NIS
2304}
2305
2306void
f62ce20a 2307PerlIOBase_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 2308{
96a5add6 2309 PERL_UNUSED_CONTEXT;
04892f78 2310 if (PerlIOValid(f)) {
14a5cf38
JH
2311 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF;
2312 }
9e353e3b
NIS
2313}
2314
93a8090d
NIS
2315SV *
2316PerlIO_sv_dup(pTHX_ SV *arg, CLONE_PARAMS *param)
2317{
2318 if (!arg)
a0714e2c 2319 return NULL;
93a8090d
NIS
2320#ifdef sv_dup
2321 if (param) {
a951d81d
BL
2322 arg = sv_dup(arg, param);
2323 SvREFCNT_inc_simple_void_NN(arg);
2324 return arg;
93a8090d
NIS
2325 }
2326 else {
2327 return newSVsv(arg);
2328 }
2329#else
1b6737cc 2330 PERL_UNUSED_ARG(param);
93a8090d
NIS
2331 return newSVsv(arg);
2332#endif
2333}
2334
2335PerlIO *
ecdeb87c 2336PerlIOBase_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
93a8090d 2337{
1b6737cc 2338 PerlIO * const nexto = PerlIONext(o);
04892f78 2339 if (PerlIOValid(nexto)) {
de009b76 2340 const PerlIO_funcs * const tab = PerlIOBase(nexto)->tab;
37725cdc
NIS
2341 if (tab && tab->Dup)
2342 f = (*tab->Dup)(aTHX_ f, nexto, param, flags);
2343 else
2344 f = PerlIOBase_dup(aTHX_ f, nexto, param, flags);
93a8090d
NIS
2345 }
2346 if (f) {
dcda55fc 2347 PerlIO_funcs * const self = PerlIOBase(o)->tab;
a951d81d 2348 SV *arg = NULL;
93a8090d 2349 char buf[8];
fe5a182c 2350 PerlIO_debug("PerlIOBase_dup %s f=%p o=%p param=%p\n",
cc6623a8
DM
2351 self ? self->name : "(Null)",
2352 (void*)f, (void*)o, (void*)param);
2353 if (self && self->Getarg)
210e727c 2354 arg = (*self->Getarg)(aTHX_ o, param, flags);
93a8090d 2355 f = PerlIO_push(aTHX_ f, self, PerlIO_modestr(o,buf), arg);
f0720f70
RGS
2356 if (PerlIOBase(o)->flags & PERLIO_F_UTF8)
2357 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
ef8d46e8 2358 SvREFCNT_dec(arg);
93a8090d
NIS
2359 }
2360 return f;
2361}
2362
27da23d5 2363/* PL_perlio_fd_refcnt[] is in intrpvar.h */
93a8090d 2364
8b84d7dd 2365/* Must be called with PL_perlio_mutex locked. */
22c96fc1
NC
2366static void
2367S_more_refcounted_fds(pTHX_ const int new_fd) {
7a89be66 2368 dVAR;
22c96fc1 2369 const int old_max = PL_perlio_fd_refcnt_size;
f4ae5be6 2370 const int new_max = 16 + (new_fd & ~15);
22c96fc1
NC
2371 int *new_array;
2372
2373 PerlIO_debug("More fds - old=%d, need %d, new=%d\n",
2374 old_max, new_fd, new_max);
2375
2376 if (new_fd < old_max) {
2377 return;
2378 }
2379
f4ae5be6
NC
2380 assert (new_max > new_fd);
2381
eae082a0
JH
2382 /* Use plain realloc() since we need this memory to be really
2383 * global and visible to all the interpreters and/or threads. */
2384 new_array = (int*) realloc(PL_perlio_fd_refcnt, new_max * sizeof(int));
22c96fc1
NC
2385
2386 if (!new_array) {
8b84d7dd 2387#ifdef USE_ITHREADS
6cb8cb21 2388 MUTEX_UNLOCK(&PL_perlio_mutex);
22c96fc1
NC
2389#endif
2390 /* Can't use PerlIO to write as it allocates memory */
2391 PerlLIO_write(PerlIO_fileno(Perl_error_log),
2392 PL_no_mem, strlen(PL_no_mem));
2393 my_exit(1);
2394 }
2395
2396 PL_perlio_fd_refcnt_size = new_max;
2397 PL_perlio_fd_refcnt = new_array;
2398
95b63a38
JH
2399 PerlIO_debug("Zeroing %p, %d\n",
2400 (void*)(new_array + old_max),
2401 new_max - old_max);
22c96fc1
NC
2402
2403 Zero(new_array + old_max, new_max - old_max, int);
2404}
2405
2406
93a8090d
NIS
2407void
2408PerlIO_init(pTHX)
2409{
8b84d7dd 2410 /* MUTEX_INIT(&PL_perlio_mutex) is done in PERL_SYS_INIT3(). */
96a5add6 2411 PERL_UNUSED_CONTEXT;
93a8090d
NIS
2412}
2413
168d5872
NIS
2414void
2415PerlIOUnix_refcnt_inc(int fd)
2416{
27da23d5 2417 dTHX;
22c96fc1 2418 if (fd >= 0) {
97aff369 2419 dVAR;
22c96fc1 2420
8b84d7dd 2421#ifdef USE_ITHREADS
6cb8cb21 2422 MUTEX_LOCK(&PL_perlio_mutex);
168d5872 2423#endif
22c96fc1
NC
2424 if (fd >= PL_perlio_fd_refcnt_size)
2425 S_more_refcounted_fds(aTHX_ fd);
2426
27da23d5 2427 PL_perlio_fd_refcnt[fd]++;
8b84d7dd
RGS
2428 if (PL_perlio_fd_refcnt[fd] <= 0) {
2429 Perl_croak(aTHX_ "refcnt_inc: fd %d: %d <= 0\n",
2430 fd, PL_perlio_fd_refcnt[fd]);
2431 }
2432 PerlIO_debug("refcnt_inc: fd %d refcnt=%d\n",
2433 fd, PL_perlio_fd_refcnt[fd]);
22c96fc1 2434
8b84d7dd 2435#ifdef USE_ITHREADS
6cb8cb21 2436 MUTEX_UNLOCK(&PL_perlio_mutex);
168d5872 2437#endif
8b84d7dd
RGS
2438 } else {
2439 Perl_croak(aTHX_ "refcnt_inc: fd %d < 0\n", fd);
168d5872
NIS
2440 }
2441}
2442
168d5872
NIS
2443int
2444PerlIOUnix_refcnt_dec(int fd)
2445{
27da23d5 2446 dTHX;
168d5872 2447 int cnt = 0;
22c96fc1 2448 if (fd >= 0) {
97aff369 2449 dVAR;
8b84d7dd 2450#ifdef USE_ITHREADS
6cb8cb21 2451 MUTEX_LOCK(&PL_perlio_mutex);
168d5872 2452#endif
8b84d7dd
RGS
2453 if (fd >= PL_perlio_fd_refcnt_size) {
2454 Perl_croak(aTHX_ "refcnt_dec: fd %d >= refcnt_size %d\n",
2455 fd, PL_perlio_fd_refcnt_size);
2456 }
2457 if (PL_perlio_fd_refcnt[fd] <= 0) {
2458 Perl_croak(aTHX_ "refcnt_dec: fd %d: %d <= 0\n",
2459 fd, PL_perlio_fd_refcnt[fd]);
2460 }
27da23d5 2461 cnt = --PL_perlio_fd_refcnt[fd];
8b84d7dd
RGS
2462 PerlIO_debug("refcnt_dec: fd %d refcnt=%d\n", fd, cnt);
2463#ifdef USE_ITHREADS
6cb8cb21 2464 MUTEX_UNLOCK(&PL_perlio_mutex);
168d5872 2465#endif
8b84d7dd
RGS
2466 } else {
2467 Perl_croak(aTHX_ "refcnt_dec: fd %d < 0\n", fd);
168d5872
NIS
2468 }
2469 return cnt;
2470}
2471
694c95cf
JH
2472void
2473PerlIO_cleanup(pTHX)
2474{
97aff369 2475 dVAR;
694c95cf
JH
2476 int i;
2477#ifdef USE_ITHREADS
a25429c6 2478 PerlIO_debug("Cleanup layers for %p\n",(void*)aTHX);
9f4bd222
NIS
2479#else
2480 PerlIO_debug("Cleanup layers\n");
694c95cf 2481#endif
e47547a8 2482
694c95cf
JH
2483 /* Raise STDIN..STDERR refcount so we don't close them */
2484 for (i=0; i < 3; i++)
2485 PerlIOUnix_refcnt_inc(i);
2486 PerlIO_cleantable(aTHX_ &PL_perlio);
2487 /* Restore STDIN..STDERR refcount */
2488 for (i=0; i < 3; i++)
2489 PerlIOUnix_refcnt_dec(i);
9f4bd222
NIS
2490
2491 if (PL_known_layers) {
2492 PerlIO_list_free(aTHX_ PL_known_layers);
2493 PL_known_layers = NULL;
2494 }
27da23d5 2495 if (PL_def_layerlist) {
9f4bd222
NIS
2496 PerlIO_list_free(aTHX_ PL_def_layerlist);
2497 PL_def_layerlist = NULL;
2498 }
6cb8cb21
RGS
2499}
2500
0934c9d9 2501void PerlIO_teardown(void) /* Call only from PERL_SYS_TERM(). */
6cb8cb21 2502{
53d44271 2503 dVAR;
4f3da17a
DM
2504#if 0
2505/* XXX we can't rely on an interpreter being present at this late stage,
2506 XXX so we can't use a function like PerlLIO_write that relies on one
2507 being present (at least in win32) :-(.
2508 Disable for now.
2509*/
6cb8cb21
RGS
2510#ifdef DEBUGGING
2511 {
2512 /* By now all filehandles should have been closed, so any
2513 * stray (non-STD-)filehandles indicate *possible* (PerlIO)
2514 * errors. */
77db880c
JH
2515#define PERLIO_TEARDOWN_MESSAGE_BUF_SIZE 64
2516#define PERLIO_TEARDOWN_MESSAGE_FD 2
2517 char buf[PERLIO_TEARDOWN_MESSAGE_BUF_SIZE];
6cb8cb21
RGS
2518 int i;
2519 for (i = 3; i < PL_perlio_fd_refcnt_size; i++) {
77db880c
JH
2520 if (PL_perlio_fd_refcnt[i]) {
2521 const STRLEN len =
2522 my_snprintf(buf, sizeof(buf),
2523 "PerlIO_teardown: fd %d refcnt=%d\n",
2524 i, PL_perlio_fd_refcnt[i]);
2525 PerlLIO_write(PERLIO_TEARDOWN_MESSAGE_FD, buf, len);
2526 }
6cb8cb21
RGS
2527 }
2528 }
2529#endif
4f3da17a 2530#endif
eae082a0
JH
2531 /* Not bothering with PL_perlio_mutex since by now
2532 * all the interpreters are gone. */
1cd82952
RGS
2533 if (PL_perlio_fd_refcnt_size /* Assuming initial size of zero. */
2534 && PL_perlio_fd_refcnt) {
eae082a0 2535 free(PL_perlio_fd_refcnt); /* To match realloc() in S_more_refcounted_fds(). */
432ce874
YO
2536 PL_perlio_fd_refcnt = NULL;
2537 PL_perlio_fd_refcnt_size = 0;
1cd82952 2538 }
694c95cf
JH
2539}
2540
9e353e3b 2541/*--------------------------------------------------------------------------------------*/
14a5cf38 2542/*
71200d45 2543 * Bottom-most level for UNIX-like case
14a5cf38 2544 */
9e353e3b 2545
14a5cf38 2546typedef struct {
22569500
NIS
2547 struct _PerlIO base; /* The generic part */
2548 int fd; /* UNIX like file descriptor */
2549 int oflags; /* open/fcntl flags */
9e353e3b
NIS
2550} PerlIOUnix;
2551
abf9167d
DM
2552static void
2553S_lockcnt_dec(pTHX_ const void* f)
2554{
2555 PerlIO_lockcnt((PerlIO*)f)--;
2556}
2557
2558
2559/* call the signal handler, and if that handler happens to clear
2560 * this handle, free what we can and return true */
2561
2562static bool
2563S_perlio_async_run(pTHX_ PerlIO* f) {
2564 ENTER;
2565 SAVEDESTRUCTOR_X(S_lockcnt_dec, (void*)f);
2566 PerlIO_lockcnt(f)++;
2567 PERL_ASYNC_CHECK();
2568 if ( !(PerlIOBase(f)->flags & PERLIO_F_CLEARED) )
2569 return 0;
2570 /* we've just run some perl-level code that could have done
2571 * anything, including closing the file or clearing this layer.
2572 * If so, free any lower layers that have already been
2573 * cleared, then return an error. */
2574 while (PerlIOValid(f) &&
2575 (PerlIOBase(f)->flags & PERLIO_F_CLEARED))
2576 {
2577 const PerlIOl *l = *f;
2578 *f = l->next;
2579 Safefree(l);
2580 }
2581 return 1;
2582}
2583
6f9d8c32 2584int
9e353e3b 2585PerlIOUnix_oflags(const char *mode)
760ac839 2586{
14a5cf38 2587 int oflags = -1;
3b6c1aba 2588 if (*mode == IoTYPE_IMPLICIT || *mode == IoTYPE_NUMERIC)
14a5cf38
JH
2589 mode++;
2590 switch (*mode) {
2591 case 'r':
2592 oflags = O_RDONLY;
2593 if (*++mode == '+') {
2594 oflags = O_RDWR;
2595 mode++;
2596 }
2597 break;
2598
2599 case 'w':
2600 oflags = O_CREAT | O_TRUNC;
2601 if (*++mode == '+') {
2602 oflags |= O_RDWR;
2603 mode++;
2604 }
2605 else
2606 oflags |= O_WRONLY;
2607 break;
2608
2609 case 'a':
2610 oflags = O_CREAT | O_APPEND;
2611 if (*++mode == '+') {
2612 oflags |= O_RDWR;
2613 mode++;
2614 }
2615 else
2616 oflags |= O_WRONLY;
2617 break;
2618 }
2619 if (*mode == 'b') {
2620 oflags |= O_BINARY;
2621 oflags &= ~O_TEXT;
2622 mode++;
2623 }
2624 else if (*mode == 't') {
2625 oflags |= O_TEXT;
2626 oflags &= ~O_BINARY;
2627 mode++;
2628 }
2629 /*
71200d45 2630 * Always open in binary mode
14a5cf38
JH
2631 */
2632 oflags |= O_BINARY;
2633 if (*mode || oflags == -1) {
93189314 2634 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2635 oflags = -1;
2636 }
2637 return oflags;
9e353e3b
NIS
2638}
2639
2640IV
f62ce20a 2641PerlIOUnix_fileno(pTHX_ PerlIO *f)
9e353e3b 2642{
96a5add6 2643 PERL_UNUSED_CONTEXT;
14a5cf38 2644 return PerlIOSelf(f, PerlIOUnix)->fd;
9e353e3b
NIS
2645}
2646
aa063c35
NIS
2647static void
2648PerlIOUnix_setfd(pTHX_ PerlIO *f, int fd, int imode)
4b803d04 2649{
de009b76 2650 PerlIOUnix * const s = PerlIOSelf(f, PerlIOUnix);
6caa5a9c 2651#if defined(WIN32)
aa063c35
NIS
2652 Stat_t st;
2653 if (PerlLIO_fstat(fd, &st) == 0) {
6caa5a9c 2654 if (!S_ISREG(st.st_mode)) {
aa063c35 2655 PerlIO_debug("%d is not regular file\n",fd);
6caa5a9c
NIS
2656 PerlIOBase(f)->flags |= PERLIO_F_NOTREG;
2657 }
aa063c35
NIS
2658 else {
2659 PerlIO_debug("%d _is_ a regular file\n",fd);
2660 }
6caa5a9c
NIS
2661 }
2662#endif
aa063c35
NIS
2663 s->fd = fd;
2664 s->oflags = imode;
2665 PerlIOUnix_refcnt_inc(fd);
96a5add6 2666 PERL_UNUSED_CONTEXT;
aa063c35
NIS
2667}
2668
2669IV
2670PerlIOUnix_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
2671{
2672 IV code = PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
14a5cf38 2673 if (*PerlIONext(f)) {
4b069b44 2674 /* We never call down so do any pending stuff now */
03c0554d 2675 PerlIO_flush(PerlIONext(f));
14a5cf38 2676 /*
71200d45 2677 * XXX could (or should) we retrieve the oflags from the open file
14a5cf38 2678 * handle rather than believing the "mode" we are passed in? XXX
71200d45 2679 * Should the value on NULL mode be 0 or -1?
14a5cf38 2680 */
acbd16bf 2681 PerlIOUnix_setfd(aTHX_ f, PerlIO_fileno(PerlIONext(f)),
aa063c35 2682 mode ? PerlIOUnix_oflags(mode) : -1);
14a5cf38
JH
2683 }
2684 PerlIOBase(f)->flags |= PERLIO_F_OPEN;
6caa5a9c 2685
14a5cf38 2686 return code;
4b803d04
NIS
2687}
2688
c2fcde81
JH
2689IV
2690PerlIOUnix_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
2691{
de009b76 2692 const int fd = PerlIOSelf(f, PerlIOUnix)->fd;
0723351e 2693 Off_t new_loc;
96a5add6 2694 PERL_UNUSED_CONTEXT;
c2fcde81
JH
2695 if (PerlIOBase(f)->flags & PERLIO_F_NOTREG) {
2696#ifdef ESPIPE
2697 SETERRNO(ESPIPE, LIB_INVARG);
2698#else
2699 SETERRNO(EINVAL, LIB_INVARG);
2700#endif
2701 return -1;
2702 }
0723351e
NC
2703 new_loc = PerlLIO_lseek(fd, offset, whence);
2704 if (new_loc == (Off_t) - 1)
dcda55fc 2705 return -1;
c2fcde81
JH
2706 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
2707 return 0;
2708}
2709
9e353e3b 2710PerlIO *
14a5cf38
JH
2711PerlIOUnix_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
2712 IV n, const char *mode, int fd, int imode,
2713 int perm, PerlIO *f, int narg, SV **args)
2714{
d9dac8cd 2715 if (PerlIOValid(f)) {
cc6623a8 2716 if (PerlIOBase(f)->tab && PerlIOBase(f)->flags & PERLIO_F_OPEN)
f62ce20a 2717 (*PerlIOBase(f)->tab->Close)(aTHX_ f);
14a5cf38
JH
2718 }
2719 if (narg > 0) {
3b6c1aba 2720 if (*mode == IoTYPE_NUMERIC)
14a5cf38
JH
2721 mode++;
2722 else {
2723 imode = PerlIOUnix_oflags(mode);
5e2ce0f3
CB
2724#ifdef VMS
2725 perm = 0777; /* preserve RMS defaults, ACL inheritance, etc. */
2726#else
14a5cf38 2727 perm = 0666;
5e2ce0f3 2728#endif
14a5cf38
JH
2729 }
2730 if (imode != -1) {
e62f0680 2731 const char *path = SvPV_nolen_const(*args);
14a5cf38
JH
2732 fd = PerlLIO_open3(path, imode, perm);
2733 }
2734 }
2735 if (fd >= 0) {
3b6c1aba 2736 if (*mode == IoTYPE_IMPLICIT)
14a5cf38
JH
2737 mode++;
2738 if (!f) {
2739 f = PerlIO_allocate(aTHX);
d9dac8cd
NIS
2740 }
2741 if (!PerlIOValid(f)) {
a33cf58c
NIS
2742 if (!(f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg))) {
2743 return NULL;
2744 }
d9dac8cd 2745 }
aa063c35 2746 PerlIOUnix_setfd(aTHX_ f, fd, imode);
14a5cf38 2747 PerlIOBase(f)->flags |= PERLIO_F_OPEN;
c2fcde81
JH
2748 if (*mode == IoTYPE_APPEND)
2749 PerlIOUnix_seek(aTHX_ f, 0, SEEK_END);
14a5cf38
JH
2750 return f;
2751 }
2752 else {
2753 if (f) {
6f207bd3 2754 NOOP;
14a5cf38 2755 /*
71200d45 2756 * FIXME: pop layers ???
14a5cf38
JH
2757 */
2758 }
2759 return NULL;
2760 }
9e353e3b
NIS
2761}
2762
71200d45 2763PerlIO *
ecdeb87c 2764PerlIOUnix_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 2765{
dcda55fc 2766 const PerlIOUnix * const os = PerlIOSelf(o, PerlIOUnix);
93a8090d 2767 int fd = os->fd;
ecdeb87c
NIS
2768 if (flags & PERLIO_DUP_FD) {
2769 fd = PerlLIO_dup(fd);
2770 }
22c96fc1 2771 if (fd >= 0) {
ecdeb87c 2772 f = PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
2773 if (f) {
2774 /* If all went well overwrite fd in dup'ed lay with the dup()'ed fd */
aa063c35 2775 PerlIOUnix_setfd(aTHX_ f, fd, os->oflags);
71200d45
NIS
2776 return f;
2777 }
71200d45
NIS
2778 }
2779 return NULL;
2780}
2781
2782
9e353e3b 2783SSize_t
f62ce20a 2784PerlIOUnix_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
9e353e3b 2785{
97aff369 2786 dVAR;
abf9167d
DM
2787 int fd;
2788 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
2789 return -1;
2790 fd = PerlIOSelf(f, PerlIOUnix)->fd;
27da23d5
JH
2791#ifdef PERLIO_STD_SPECIAL
2792 if (fd == 0)
2793 return PERLIO_STD_IN(fd, vbuf, count);
2794#endif
81428673 2795 if (!(PerlIOBase(f)->flags & PERLIO_F_CANREAD) ||
1fd8f4ce 2796 PerlIOBase(f)->flags & (PERLIO_F_EOF|PERLIO_F_ERROR)) {
263df5f1 2797 return 0;
1fd8f4ce 2798 }
14a5cf38 2799 while (1) {
b464bac0 2800 const SSize_t len = PerlLIO_read(fd, vbuf, count);
14a5cf38 2801 if (len >= 0 || errno != EINTR) {
ba85f2ea
NIS
2802 if (len < 0) {
2803 if (errno != EAGAIN) {
2804 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2805 }
2806 }
2807 else if (len == 0 && count != 0) {
14a5cf38 2808 PerlIOBase(f)->flags |= PERLIO_F_EOF;
ba85f2ea
NIS
2809 SETERRNO(0,0);
2810 }
14a5cf38
JH
2811 return len;
2812 }
abf9167d
DM
2813 /* EINTR */
2814 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2815 return -1;
14a5cf38 2816 }
b464bac0 2817 /*NOTREACHED*/
9e353e3b
NIS
2818}
2819
2820SSize_t
f62ce20a 2821PerlIOUnix_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 2822{
97aff369 2823 dVAR;
abf9167d
DM
2824 int fd;
2825 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
2826 return -1;
2827 fd = PerlIOSelf(f, PerlIOUnix)->fd;
27da23d5
JH
2828#ifdef PERLIO_STD_SPECIAL
2829 if (fd == 1 || fd == 2)
2830 return PERLIO_STD_OUT(fd, vbuf, count);
2831#endif
14a5cf38 2832 while (1) {
de009b76 2833 const SSize_t len = PerlLIO_write(fd, vbuf, count);
14a5cf38 2834 if (len >= 0 || errno != EINTR) {
ba85f2ea
NIS
2835 if (len < 0) {
2836 if (errno != EAGAIN) {
2837 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2838 }
2839 }
14a5cf38
JH
2840 return len;
2841 }
abf9167d
DM
2842 /* EINTR */
2843 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2844 return -1;
06da4f11 2845 }
1b6737cc 2846 /*NOTREACHED*/
9e353e3b
NIS
2847}
2848
9e353e3b 2849Off_t
f62ce20a 2850PerlIOUnix_tell(pTHX_ PerlIO *f)
9e353e3b 2851{
96a5add6
AL
2852 PERL_UNUSED_CONTEXT;
2853
14a5cf38 2854 return PerlLIO_lseek(PerlIOSelf(f, PerlIOUnix)->fd, 0, SEEK_CUR);
9e353e3b
NIS
2855}
2856
2556f95e
GF
2857
2858IV
2376d97d 2859PerlIOUnix_close(pTHX_ PerlIO *f)
2556f95e 2860{
97aff369 2861 dVAR;
de009b76 2862 const int fd = PerlIOSelf(f, PerlIOUnix)->fd;
14a5cf38 2863 int code = 0;
168d5872
NIS
2864 if (PerlIOBase(f)->flags & PERLIO_F_OPEN) {
2865 if (PerlIOUnix_refcnt_dec(fd) > 0) {
93a8090d
NIS
2866 PerlIOBase(f)->flags &= ~PERLIO_F_OPEN;
2867 return 0;
22569500 2868 }
93a8090d
NIS
2869 }
2870 else {
93189314 2871 SETERRNO(EBADF,SS_IVCHAN);
93a8090d
NIS
2872 return -1;
2873 }
14a5cf38
JH
2874 while (PerlLIO_close(fd) != 0) {
2875 if (errno != EINTR) {
2876 code = -1;
2877 break;
2878 }
abf9167d
DM
2879 /* EINTR */
2880 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2881 return -1;
14a5cf38
JH
2882 }
2883 if (code == 0) {
2884 PerlIOBase(f)->flags &= ~PERLIO_F_OPEN;
2885 }
2886 return code;
9e353e3b
NIS
2887}
2888
27da23d5 2889PERLIO_FUNCS_DECL(PerlIO_unix) = {
2dc2558e 2890 sizeof(PerlIO_funcs),
14a5cf38
JH
2891 "unix",
2892 sizeof(PerlIOUnix),
2893 PERLIO_K_RAW,
2894 PerlIOUnix_pushed,
2376d97d 2895 PerlIOBase_popped,
14a5cf38 2896 PerlIOUnix_open,
86e05cf2 2897 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
2898 NULL,
2899 PerlIOUnix_fileno,
71200d45 2900 PerlIOUnix_dup,
14a5cf38
JH
2901 PerlIOUnix_read,
2902 PerlIOBase_unread,
2903 PerlIOUnix_write,
2904 PerlIOUnix_seek,
2905 PerlIOUnix_tell,
2906 PerlIOUnix_close,
22569500
NIS
2907 PerlIOBase_noop_ok, /* flush */
2908 PerlIOBase_noop_fail, /* fill */
14a5cf38
JH
2909 PerlIOBase_eof,
2910 PerlIOBase_error,
2911 PerlIOBase_clearerr,
2912 PerlIOBase_setlinebuf,
22569500
NIS
2913 NULL, /* get_base */
2914 NULL, /* get_bufsiz */
2915 NULL, /* get_ptr */
2916 NULL, /* get_cnt */
2917 NULL, /* set_ptrcnt */
9e353e3b
NIS
2918};
2919
2920/*--------------------------------------------------------------------------------------*/
14a5cf38 2921/*
71200d45 2922 * stdio as a layer
14a5cf38 2923 */
9e353e3b 2924
313e59c8
NIS
2925#if defined(VMS) && !defined(STDIO_BUFFER_WRITABLE)
2926/* perl5.8 - This ensures the last minute VMS ungetc fix is not
2927 broken by the last second glibc 2.3 fix
2928 */
2929#define STDIO_BUFFER_WRITABLE
2930#endif
2931
2932
14a5cf38
JH
2933typedef struct {
2934 struct _PerlIO base;
22569500 2935 FILE *stdio; /* The stream */
9e353e3b
NIS
2936} PerlIOStdio;
2937
2938IV
f62ce20a 2939PerlIOStdio_fileno(pTHX_ PerlIO *f)
9e353e3b 2940{
96a5add6
AL
2941 PERL_UNUSED_CONTEXT;
2942
c4420975
AL
2943 if (PerlIOValid(f)) {
2944 FILE * const s = PerlIOSelf(f, PerlIOStdio)->stdio;
2945 if (s)
2946 return PerlSIO_fileno(s);
439ba545
NIS
2947 }
2948 errno = EBADF;
2949 return -1;
9e353e3b
NIS
2950}
2951
766a733e 2952char *
14a5cf38
JH
2953PerlIOStdio_mode(const char *mode, char *tmode)
2954{
de009b76 2955 char * const ret = tmode;
a0625d38
SR
2956 if (mode) {
2957 while (*mode) {
2958 *tmode++ = *mode++;
2959 }
14a5cf38 2960 }
95005ad8 2961#if defined(PERLIO_USING_CRLF) || defined(__CYGWIN__)
6ce75a77
JH
2962 *tmode++ = 'b';
2963#endif
14a5cf38
JH
2964 *tmode = '\0';
2965 return ret;
2966}
2967
4b803d04 2968IV
2dc2558e 2969PerlIOStdio_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
4b803d04 2970{
1fd8f4ce
NIS
2971 PerlIO *n;
2972 if (PerlIOValid(f) && PerlIOValid(n = PerlIONext(f))) {
46c461b5 2973 PerlIO_funcs * const toptab = PerlIOBase(n)->tab;
1fd8f4ce
NIS
2974 if (toptab == tab) {
2975 /* Top is already stdio - pop self (duplicate) and use original */
2976 PerlIO_pop(aTHX_ f);
2977 return 0;
2978 } else {
de009b76 2979 const int fd = PerlIO_fileno(n);
1fd8f4ce
NIS
2980 char tmode[8];
2981 FILE *stdio;
81428673 2982 if (fd >= 0 && (stdio = PerlSIO_fdopen(fd,
1fd8f4ce
NIS
2983 mode = PerlIOStdio_mode(mode, tmode)))) {
2984 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
2985 /* We never call down so do any pending stuff now */
2986 PerlIO_flush(PerlIONext(f));
81428673 2987 }
1fd8f4ce
NIS
2988 else {
2989 return -1;
2990 }
2991 }
14a5cf38 2992 }
2dc2558e 2993 return PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
4b803d04
NIS
2994}
2995
22569500 2996
9e353e3b 2997PerlIO *
4b069b44 2998PerlIO_importFILE(FILE *stdio, const char *mode)
9e353e3b 2999{
14a5cf38
JH
3000 dTHX;
3001 PerlIO *f = NULL;
3002 if (stdio) {
22569500 3003 PerlIOStdio *s;
4b069b44
NIS
3004 if (!mode || !*mode) {
3005 /* We need to probe to see how we can open the stream
3006 so start with read/write and then try write and read
3007 we dup() so that we can fclose without loosing the fd.
3008
3009 Note that the errno value set by a failing fdopen
3010 varies between stdio implementations.
3011 */
de009b76 3012 const int fd = PerlLIO_dup(fileno(stdio));
a33cf58c 3013 FILE *f2 = PerlSIO_fdopen(fd, (mode = "r+"));
4b069b44 3014 if (!f2) {
a33cf58c 3015 f2 = PerlSIO_fdopen(fd, (mode = "w"));
4b069b44
NIS
3016 }
3017 if (!f2) {
a33cf58c 3018 f2 = PerlSIO_fdopen(fd, (mode = "r"));
4b069b44
NIS
3019 }
3020 if (!f2) {
3021 /* Don't seem to be able to open */
3022 PerlLIO_close(fd);
3023 return f;
3024 }
3025 fclose(f2);
22569500 3026 }
a0714e2c 3027 if ((f = PerlIO_push(aTHX_(f = PerlIO_allocate(aTHX)), PERLIO_FUNCS_CAST(&PerlIO_stdio), mode, NULL))) {
a33cf58c
NIS
3028 s = PerlIOSelf(f, PerlIOStdio);
3029 s->stdio = stdio;
c586124f 3030 PerlIOUnix_refcnt_inc(fileno(stdio));
a33cf58c 3031 }
14a5cf38
JH
3032 }
3033 return f;
9e353e3b
NIS
3034}
3035
3036PerlIO *
14a5cf38
JH
3037PerlIOStdio_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
3038 IV n, const char *mode, int fd, int imode,
3039 int perm, PerlIO *f, int narg, SV **args)
3040{
3041 char tmode[8];
d9dac8cd 3042 if (PerlIOValid(f)) {
dcda55fc
AL
3043 const char * const path = SvPV_nolen_const(*args);
3044 PerlIOStdio * const s = PerlIOSelf(f, PerlIOStdio);
1751d015
NIS
3045 FILE *stdio;
3046 PerlIOUnix_refcnt_dec(fileno(s->stdio));
3047 stdio = PerlSIO_freopen(path, (mode = PerlIOStdio_mode(mode, tmode)),
14a5cf38
JH
3048 s->stdio);
3049 if (!s->stdio)
3050 return NULL;
3051 s->stdio = stdio;
1751d015 3052 PerlIOUnix_refcnt_inc(fileno(s->stdio));
14a5cf38
JH
3053 return f;
3054 }
3055 else {
3056 if (narg > 0) {
dcda55fc 3057 const char * const path = SvPV_nolen_const(*args);
3b6c1aba 3058 if (*mode == IoTYPE_NUMERIC) {
14a5cf38
JH
3059 mode++;
3060 fd = PerlLIO_open3(path, imode, perm);
3061 }
3062 else {
95005ad8
GH
3063 FILE *stdio;
3064 bool appended = FALSE;
3065#ifdef __CYGWIN__
3066 /* Cygwin wants its 'b' early. */
3067 appended = TRUE;
3068 mode = PerlIOStdio_mode(mode, tmode);
3069#endif
3070 stdio = PerlSIO_fopen(path, mode);
6f0313ac 3071 if (stdio) {
6f0313ac
JH
3072 if (!f) {
3073 f = PerlIO_allocate(aTHX);
3074 }
95005ad8
GH
3075 if (!appended)
3076 mode = PerlIOStdio_mode(mode, tmode);
3077 f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg);
3078 if (f) {
0f0f9e2b
JH
3079 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
3080 PerlIOUnix_refcnt_inc(fileno(stdio));
3081 } else {
3082 PerlSIO_fclose(stdio);
6f0313ac
JH
3083 }
3084 return f;
3085 }
3086 else {
3087 return NULL;
3088 }
14a5cf38
JH
3089 }
3090 }
3091 if (fd >= 0) {
3092 FILE *stdio = NULL;
3093 int init = 0;
3b6c1aba 3094 if (*mode == IoTYPE_IMPLICIT) {
14a5cf38
JH
3095 init = 1;
3096 mode++;
3097 }
3098 if (init) {
3099 switch (fd) {
3100 case 0:
3101 stdio = PerlSIO_stdin;
3102 break;
3103 case 1:
3104 stdio = PerlSIO_stdout;
3105 break;
3106 case 2:
3107 stdio = PerlSIO_stderr;
3108 break;
3109 }
3110 }
3111 else {
3112 stdio = PerlSIO_fdopen(fd, mode =
3113 PerlIOStdio_mode(mode, tmode));
3114 }
3115 if (stdio) {
d9dac8cd
NIS
3116 if (!f) {
3117 f = PerlIO_allocate(aTHX);
3118 }
a33cf58c 3119 if ((f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg))) {
1a159fba
JH
3120 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
3121 PerlIOUnix_refcnt_inc(fileno(stdio));
a33cf58c 3122 }
14a5cf38
JH
3123 return f;
3124 }
3125 }
3126 }
ee518936 3127 return NULL;
9e353e3b
NIS
3128}
3129
1751d015 3130PerlIO *
ecdeb87c 3131PerlIOStdio_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
1751d015
NIS
3132{
3133 /* This assumes no layers underneath - which is what
3134 happens, but is not how I remember it. NI-S 2001/10/16
3135 */
ecdeb87c 3136 if ((f = PerlIOBase_dup(aTHX_ f, o, param, flags))) {
694c95cf 3137 FILE *stdio = PerlIOSelf(o, PerlIOStdio)->stdio;
de009b76 3138 const int fd = fileno(stdio);
9217ff3f 3139 char mode[8];
ecdeb87c 3140 if (flags & PERLIO_DUP_FD) {
de009b76 3141 const int dfd = PerlLIO_dup(fileno(stdio));
9217ff3f
NIS
3142 if (dfd >= 0) {
3143 stdio = PerlSIO_fdopen(dfd, PerlIO_modestr(o,mode));
3144 goto set_this;
ecdeb87c
NIS
3145 }
3146 else {
6f207bd3 3147 NOOP;
ecdeb87c
NIS
3148 /* FIXME: To avoid messy error recovery if dup fails
3149 re-use the existing stdio as though flag was not set
3150 */
3151 }
3152 }
9217ff3f
NIS
3153 stdio = PerlSIO_fdopen(fd, PerlIO_modestr(o,mode));
3154 set_this:
694c95cf 3155 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
40596bc5
SP
3156 if(stdio) {
3157 PerlIOUnix_refcnt_inc(fileno(stdio));
3158 }
1751d015
NIS
3159 }
3160 return f;
3161}
3162
0d7a5398
NIS
3163static int
3164PerlIOStdio_invalidate_fileno(pTHX_ FILE *f)
3165{
96a5add6
AL
3166 PERL_UNUSED_CONTEXT;
3167
0d7a5398 3168 /* XXX this could use PerlIO_canset_fileno() and
37725cdc 3169 * PerlIO_set_fileno() support from Configure
0d7a5398 3170 */
ef8eacb8
AT
3171# if defined(__UCLIBC__)
3172 /* uClibc must come before glibc because it defines __GLIBC__ as well. */
3173 f->__filedes = -1;
3174 return 1;
3175# elif defined(__GLIBC__)
0d7a5398 3176 /* There may be a better way for GLIBC:
37725cdc 3177 - libio.h defines a flag to not close() on cleanup
0d7a5398
NIS
3178 */
3179 f->_fileno = -1;
3180 return 1;
3181# elif defined(__sun__)
f5992bc4 3182 PERL_UNUSED_ARG(f);
cfedb851 3183 return 0;
0d7a5398
NIS
3184# elif defined(__hpux)
3185 f->__fileH = 0xff;
3186 f->__fileL = 0xff;
3187 return 1;
9837d373 3188 /* Next one ->_file seems to be a reasonable fallback, i.e. if
37725cdc 3189 your platform does not have special entry try this one.
9837d373
NIS
3190 [For OSF only have confirmation for Tru64 (alpha)
3191 but assume other OSFs will be similar.]
37725cdc 3192 */
9837d373 3193# elif defined(_AIX) || defined(__osf__) || defined(__irix__)
0d7a5398
NIS
3194 f->_file = -1;
3195 return 1;
3196# elif defined(__FreeBSD__)
3197 /* There may be a better way on FreeBSD:
37725cdc
NIS
3198 - we could insert a dummy func in the _close function entry
3199 f->_close = (int (*)(void *)) dummy_close;
0d7a5398
NIS
3200 */
3201 f->_file = -1;
0c49ea6a
SU
3202 return 1;
3203# elif defined(__OpenBSD__)
3204 /* There may be a better way on OpenBSD:
3205 - we could insert a dummy func in the _close function entry
3206 f->_close = (int (*)(void *)) dummy_close;
3207 */
3208 f->_file = -1;
0d7a5398 3209 return 1;
59ad941d
IZ
3210# elif defined(__EMX__)
3211 /* f->_flags &= ~_IOOPEN; */ /* Will leak stream->_buffer */
3212 f->_handle = -1;
3213 return 1;
0d7a5398
NIS
3214# elif defined(__CYGWIN__)
3215 /* There may be a better way on CYGWIN:
37725cdc
NIS
3216 - we could insert a dummy func in the _close function entry
3217 f->_close = (int (*)(void *)) dummy_close;
0d7a5398
NIS
3218 */
3219 f->_file = -1;
3220 return 1;
3221# elif defined(WIN32)
3222# if defined(__BORLANDC__)
3223 f->fd = PerlLIO_dup(fileno(f));
b475b3e6
JH
3224# elif defined(UNDER_CE)
3225 /* WIN_CE does not have access to FILE internals, it hardly has FILE
3226 structure at all
3227 */
0d7a5398
NIS
3228# else
3229 f->_file = -1;
3230# endif
3231 return 1;
3232# else
3233#if 0
37725cdc 3234 /* Sarathy's code did this - we fall back to a dup/dup2 hack
0d7a5398 3235 (which isn't thread safe) instead
37725cdc 3236 */
0d7a5398
NIS
3237# error "Don't know how to set FILE.fileno on your platform"
3238#endif
8772537c 3239 PERL_UNUSED_ARG(f);
0d7a5398
NIS
3240 return 0;
3241# endif
3242}
3243
1751d015 3244IV
f62ce20a 3245PerlIOStdio_close(pTHX_ PerlIO *f)
1751d015 3246{
c4420975 3247 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
439ba545
NIS
3248 if (!stdio) {
3249 errno = EBADF;
3250 return -1;
3251 }
9217ff3f 3252 else {
de009b76 3253 const int fd = fileno(stdio);
0d7a5398 3254 int invalidate = 0;
bbfd922f 3255 IV result = 0;
1d791a44 3256 int dupfd = -1;
4ee39169 3257 dSAVEDERRNO;
a2e578da
MHM
3258#ifdef USE_ITHREADS
3259 dVAR;
3260#endif
0d7a5398 3261#ifdef SOCKS5_VERSION_NAME
37725cdc
NIS
3262 /* Socks lib overrides close() but stdio isn't linked to
3263 that library (though we are) - so we must call close()
3264 on sockets on stdio's behalf.
3265 */
0d7a5398
NIS
3266 int optval;
3267 Sock_size_t optlen = sizeof(int);
6b4ce6c8 3268 if (getsockopt(fd, SOL_SOCKET, SO_TYPE, (void *) &optval, &optlen) == 0)
37725cdc 3269 invalidate = 1;
0d7a5398 3270#endif
d8723f43
NC
3271 /* Test for -1, as *BSD stdio (at least) on fclose sets the FILE* such
3272 that a subsequent fileno() on it returns -1. Don't want to croak()
3273 from within PerlIOUnix_refcnt_dec() if some buggy caller code is
3274 trying to close an already closed handle which somehow it still has
3275 a reference to. (via.xs, I'm looking at you). */
3276 if (fd != -1 && PerlIOUnix_refcnt_dec(fd) > 0) {
3277 /* File descriptor still in use */
0d7a5398 3278 invalidate = 1;
d8723f43 3279 }
0d7a5398 3280 if (invalidate) {
6b4ce6c8
AL
3281 /* For STD* handles, don't close stdio, since we shared the FILE *, too. */
3282 if (stdio == stdin) /* Some stdios are buggy fflush-ing inputs */
3283 return 0;
3284 if (stdio == stdout || stdio == stderr)
3285 return PerlIO_flush(f);
37725cdc
NIS
3286 /* Tricky - must fclose(stdio) to free memory but not close(fd)
3287 Use Sarathy's trick from maint-5.6 to invalidate the
3288 fileno slot of the FILE *
3289 */
bbfd922f 3290 result = PerlIO_flush(f);
4ee39169 3291 SAVE_ERRNO;
6b4ce6c8 3292 invalidate = PerlIOStdio_invalidate_fileno(aTHX_ stdio);
711e8db2 3293 if (!invalidate) {
9bab90c0
NC
3294#ifdef USE_ITHREADS
3295 MUTEX_LOCK(&PL_perlio_mutex);
5ca745d2
NC
3296 /* Right. We need a mutex here because for a brief while we
3297 will have the situation that fd is actually closed. Hence if
3298 a second thread were to get into this block, its dup() would
3299 likely return our fd as its dupfd. (after all, it is closed)
9bab90c0
NC
3300 Then if we get to the dup2() first, we blat the fd back
3301 (messing up its temporary as a side effect) only for it to
3302 then close its dupfd (== our fd) in its close(dupfd) */
3303
3304 /* There is, of course, a race condition, that any other thread
3305 trying to input/output/whatever on this fd will be stuffed
5ca745d2
NC
3306 for the duration of this little manoeuvrer. Perhaps we
3307 should hold an IO mutex for the duration of every IO
3308 operation if we know that invalidate doesn't work on this
3309 platform, but that would suck, and could kill performance.
9bab90c0
NC
3310
3311 Except that correctness trumps speed.
3312 Advice from klortho #11912. */
3313#endif
6b4ce6c8 3314 dupfd = PerlLIO_dup(fd);
711e8db2 3315#ifdef USE_ITHREADS
9bab90c0
NC
3316 if (dupfd < 0) {
3317 MUTEX_UNLOCK(&PL_perlio_mutex);
711e8db2
NC
3318 /* Oh cXap. This isn't going to go well. Not sure if we can
3319 recover from here, or if closing this particular FILE *
3320 is a good idea now. */
3321 }
3322#endif
3323 }
94ccb807
JH
3324 } else {
3325 SAVE_ERRNO; /* This is here only to silence compiler warnings */
37725cdc 3326 }
0d7a5398 3327 result = PerlSIO_fclose(stdio);
37725cdc
NIS
3328 /* We treat error from stdio as success if we invalidated
3329 errno may NOT be expected EBADF
e8529473
NIS
3330 */
3331 if (invalidate && result != 0) {
4ee39169 3332 RESTORE_ERRNO;
0d7a5398 3333 result = 0;
37725cdc 3334 }
6b4ce6c8
AL
3335#ifdef SOCKS5_VERSION_NAME
3336 /* in SOCKS' case, let close() determine return value */
3337 result = close(fd);
3338#endif
1d791a44 3339 if (dupfd >= 0) {
0d7a5398 3340 PerlLIO_dup2(dupfd,fd);
9bab90c0 3341 PerlLIO_close(dupfd);
711e8db2 3342#ifdef USE_ITHREADS
9bab90c0 3343 MUTEX_UNLOCK(&PL_perlio_mutex);
711e8db2 3344#endif
9217ff3f
NIS
3345 }
3346 return result;
37725cdc 3347 }
1751d015
NIS
3348}
3349
9e353e3b 3350SSize_t
f62ce20a 3351PerlIOStdio_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
9e353e3b 3352{
97aff369 3353 dVAR;
abf9167d 3354 FILE * s;
14a5cf38 3355 SSize_t got = 0;
abf9167d
DM
3356 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3357 return -1;
3358 s = PerlIOSelf(f, PerlIOStdio)->stdio;
4d948241
NIS
3359 for (;;) {
3360 if (count == 1) {
3361 STDCHAR *buf = (STDCHAR *) vbuf;
3362 /*
3363 * Perl is expecting PerlIO_getc() to fill the buffer Linux's
3364 * stdio does not do that for fread()
3365 */
de009b76 3366 const int ch = PerlSIO_fgetc(s);
4d948241
NIS
3367 if (ch != EOF) {
3368 *buf = ch;
3369 got = 1;
3370 }
14a5cf38 3371 }
4d948241
NIS
3372 else
3373 got = PerlSIO_fread(vbuf, 1, count, s);
b1d8b47a
CS
3374 if (got == 0 && PerlSIO_ferror(s))
3375 got = -1;
42a7a32f 3376 if (got >= 0 || errno != EINTR)
4d948241 3377 break;
abf9167d
DM
3378 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3379 return -1;
42a7a32f 3380 SETERRNO(0,0); /* just in case */
14a5cf38 3381 }
14a5cf38 3382 return got;
9e353e3b
NIS
3383}
3384
3385SSize_t
f62ce20a 3386PerlIOStdio_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 3387{
14a5cf38 3388 SSize_t unread = 0;
c4420975 3389 FILE * const s = PerlIOSelf(f, PerlIOStdio)->stdio;
93679785 3390
313e59c8 3391#ifdef STDIO_BUFFER_WRITABLE
9f7cd136 3392 if (PerlIO_fast_gets(f) && PerlIO_has_base(f)) {
93679785
NIS
3393 STDCHAR *buf = ((STDCHAR *) vbuf) + count;
3394 STDCHAR *base = PerlIO_get_base(f);
3395 SSize_t cnt = PerlIO_get_cnt(f);
3396 STDCHAR *ptr = PerlIO_get_ptr(f);
3397 SSize_t avail = ptr - base;
3398 if (avail > 0) {
3399 if (avail > count) {
3400 avail = count;
3401 }
3402 ptr -= avail;
3403 Move(buf-avail,ptr,avail,STDCHAR);
3404 count -= avail;
3405 unread += avail;
3406 PerlIO_set_ptrcnt(f,ptr,cnt+avail);
9f7cd136
NIS
3407 if (PerlSIO_feof(s) && unread >= 0)
3408 PerlSIO_clearerr(s);
3409 }
3410 }
313e59c8
NIS
3411 else
3412#endif
3413 if (PerlIO_has_cntptr(f)) {
9f7cd136
NIS
3414 /* We can get pointer to buffer but not its base
3415 Do ungetc() but check chars are ending up in the
3416 buffer
3417 */
3418 STDCHAR *eptr = (STDCHAR*)PerlSIO_get_ptr(s);
3419 STDCHAR *buf = ((STDCHAR *) vbuf) + count;
3420 while (count > 0) {
de009b76 3421 const int ch = *--buf & 0xFF;
9f7cd136
NIS
3422 if (ungetc(ch,s) != ch) {
3423 /* ungetc did not work */
3424 break;
3425 }
3426 if ((STDCHAR*)PerlSIO_get_ptr(s) != --eptr || ((*eptr & 0xFF) != ch)) {
3427 /* Did not change pointer as expected */
3428 fgetc(s); /* get char back again */
3429 break;
3430 }
3431 /* It worked ! */
3432 count--;
3433 unread++;
93679785
NIS
3434 }
3435 }
3436
3437 if (count > 0) {
3438 unread += PerlIOBase_unread(aTHX_ f, vbuf, count);
14a5cf38
JH
3439 }
3440 return unread;
9e353e3b
NIS
3441}
3442
3443SSize_t
f62ce20a 3444PerlIOStdio_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 3445{
97aff369 3446 dVAR;
4d948241 3447 SSize_t got;
abf9167d
DM
3448 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3449 return -1;
4d948241
NIS
3450 for (;;) {
3451 got = PerlSIO_fwrite(vbuf, 1, count,
3452 PerlIOSelf(f, PerlIOStdio)->stdio);
42a7a32f 3453 if (got >= 0 || errno != EINTR)
4d948241 3454 break;
abf9167d
DM
3455 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3456 return -1;
42a7a32f 3457 SETERRNO(0,0); /* just in case */
4d948241
NIS
3458 }
3459 return got;
9e353e3b
NIS
3460}
3461
94a175e1 3462IV
f62ce20a 3463PerlIOStdio_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
9e353e3b 3464{
c4420975 3465 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3466 PERL_UNUSED_CONTEXT;
3467
94a175e1 3468 return PerlSIO_fseek(stdio, offset, whence);
9e353e3b
NIS
3469}
3470
3471Off_t
f62ce20a 3472PerlIOStdio_tell(pTHX_ PerlIO *f)
9e353e3b 3473{
c4420975 3474 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3475 PERL_UNUSED_CONTEXT;
3476
94a175e1 3477 return PerlSIO_ftell(stdio);
9e353e3b
NIS
3478}
3479
3480IV
f62ce20a 3481PerlIOStdio_flush(pTHX_ PerlIO *f)
9e353e3b 3482{
c4420975 3483 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3484 PERL_UNUSED_CONTEXT;
3485
14a5cf38
JH
3486 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) {
3487 return PerlSIO_fflush(stdio);
3488 }
3489 else {
6f207bd3 3490 NOOP;
88b61e10 3491#if 0
14a5cf38
JH
3492 /*
3493 * FIXME: This discards ungetc() and pre-read stuff which is not
71200d45 3494 * right if this is just a "sync" from a layer above Suspect right
14a5cf38 3495 * design is to do _this_ but not have layer above flush this
71200d45 3496 * layer read-to-read
14a5cf38
JH
3497 */
3498 /*
71200d45 3499 * Not writeable - sync by attempting a seek
14a5cf38 3500 */
4ee39169 3501 dSAVE_ERRNO;
14a5cf38 3502 if (PerlSIO_fseek(stdio, (Off_t) 0, SEEK_CUR) != 0)
4ee39169 3503 RESTORE_ERRNO;
88b61e10 3504#endif
14a5cf38
JH
3505 }
3506 return 0;
9e353e3b
NIS
3507}
3508
3509IV
f62ce20a 3510PerlIOStdio_eof(pTHX_ PerlIO *f)
9e353e3b 3511{
96a5add6
AL
3512 PERL_UNUSED_CONTEXT;
3513
14a5cf38 3514 return PerlSIO_feof(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3515}
3516
3517IV
f62ce20a 3518PerlIOStdio_error(pTHX_ PerlIO *f)
9e353e3b 3519{
96a5add6
AL
3520 PERL_UNUSED_CONTEXT;
3521
263df5f1 3522 return PerlSIO_ferror(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3523}
3524
3525void
f62ce20a 3526PerlIOStdio_clearerr(pTHX_ PerlIO *f)
9e353e3b 3527{
96a5add6
AL
3528 PERL_UNUSED_CONTEXT;
3529
14a5cf38 3530 PerlSIO_clearerr(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3531}
3532
3533void
f62ce20a 3534PerlIOStdio_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 3535{
96a5add6
AL
3536 PERL_UNUSED_CONTEXT;
3537
9e353e3b 3538#ifdef HAS_SETLINEBUF
14a5cf38 3539 PerlSIO_setlinebuf(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b 3540#else
bd61b366 3541 PerlSIO_setvbuf(PerlIOSelf(f, PerlIOStdio)->stdio, NULL, _IOLBF, 0);
9e353e3b
NIS
3542#endif
3543}
3544
3545#ifdef FILE_base
3546STDCHAR *
f62ce20a 3547PerlIOStdio_get_base(pTHX_ PerlIO *f)
9e353e3b 3548{
c4420975 3549 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
cc00df79 3550 return (STDCHAR*)PerlSIO_get_base(stdio);
9e353e3b
NIS
3551}
3552
3553Size_t
f62ce20a 3554PerlIOStdio_get_bufsiz(pTHX_ PerlIO *f)
9e353e3b 3555{
c4420975 3556 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3557 return PerlSIO_get_bufsiz(stdio);
9e353e3b
NIS
3558}
3559#endif
3560
3561#ifdef USE_STDIO_PTR
3562STDCHAR *
f62ce20a 3563PerlIOStdio_get_ptr(pTHX_ PerlIO *f)
9e353e3b 3564{
c4420975 3565 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
cc00df79 3566 return (STDCHAR*)PerlSIO_get_ptr(stdio);
9e353e3b
NIS
3567}
3568
3569SSize_t
f62ce20a 3570PerlIOStdio_get_cnt(pTHX_ PerlIO *f)
9e353e3b 3571{
c4420975 3572 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3573 return PerlSIO_get_cnt(stdio);
9e353e3b
NIS
3574}
3575
3576void
f62ce20a 3577PerlIOStdio_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
9e353e3b 3578{
c4420975 3579 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3580 if (ptr != NULL) {
9e353e3b 3581#ifdef STDIO_PTR_LVALUE
d06fc7d4 3582 PerlSIO_set_ptr(stdio, ptr); /* LHS STDCHAR* cast non-portable */
9e353e3b 3583#ifdef STDIO_PTR_LVAL_SETS_CNT
f8a4dbc5 3584 assert(PerlSIO_get_cnt(stdio) == (cnt));
9e353e3b
NIS
3585#endif
3586#if (!defined(STDIO_PTR_LVAL_NOCHANGE_CNT))
14a5cf38 3587 /*
71200d45 3588 * Setting ptr _does_ change cnt - we are done
14a5cf38
JH
3589 */
3590 return;
9e353e3b 3591#endif
22569500 3592#else /* STDIO_PTR_LVALUE */
14a5cf38 3593 PerlProc_abort();
22569500 3594#endif /* STDIO_PTR_LVALUE */
14a5cf38
JH
3595 }
3596 /*
71200d45 3597 * Now (or only) set cnt
14a5cf38 3598 */
9e353e3b 3599#ifdef STDIO_CNT_LVALUE
14a5cf38 3600 PerlSIO_set_cnt(stdio, cnt);
22569500 3601#else /* STDIO_CNT_LVALUE */
9e353e3b 3602#if (defined(STDIO_PTR_LVALUE) && defined(STDIO_PTR_LVAL_SETS_CNT))
14a5cf38
JH
3603 PerlSIO_set_ptr(stdio,
3604 PerlSIO_get_ptr(stdio) + (PerlSIO_get_cnt(stdio) -
3605 cnt));
22569500 3606#else /* STDIO_PTR_LVAL_SETS_CNT */
14a5cf38 3607 PerlProc_abort();
22569500
NIS
3608#endif /* STDIO_PTR_LVAL_SETS_CNT */
3609#endif /* STDIO_CNT_LVALUE */
9e353e3b
NIS
3610}
3611
93679785 3612
9e353e3b
NIS
3613#endif
3614
93679785
NIS
3615IV
3616PerlIOStdio_fill(pTHX_ PerlIO *f)
3617{
abf9167d 3618 FILE * stdio;
93679785 3619 int c;
96a5add6 3620 PERL_UNUSED_CONTEXT;
abf9167d
DM
3621 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3622 return -1;
3623 stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6 3624
93679785
NIS
3625 /*
3626 * fflush()ing read-only streams can cause trouble on some stdio-s
3627 */
3628 if ((PerlIOBase(f)->flags & PERLIO_F_CANWRITE)) {
3629 if (PerlSIO_fflush(stdio) != 0)
3630 return EOF;
3631 }
f3be3723
BL
3632 for (;;) {
3633 c = PerlSIO_fgetc(stdio);
3634 if (c != EOF)
3635 break;
3636 if (! PerlSIO_ferror(stdio) || errno != EINTR)
3637 return EOF;
abf9167d
DM
3638 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3639 return -1;
f3be3723
BL
3640 SETERRNO(0,0);
3641 }
93679785
NIS
3642
3643#if (defined(STDIO_PTR_LVALUE) && (defined(STDIO_CNT_LVALUE) || defined(STDIO_PTR_LVAL_SETS_CNT)))
313e59c8
NIS
3644
3645#ifdef STDIO_BUFFER_WRITABLE
9f7cd136 3646 if (PerlIO_fast_gets(f) && PerlIO_has_base(f)) {
93679785
NIS
3647 /* Fake ungetc() to the real buffer in case system's ungetc
3648 goes elsewhere
3649 */
3650 STDCHAR *base = (STDCHAR*)PerlSIO_get_base(stdio);
3651 SSize_t cnt = PerlSIO_get_cnt(stdio);
3652 STDCHAR *ptr = (STDCHAR*)PerlSIO_get_ptr(stdio);
3653 if (ptr == base+1) {
3654 *--ptr = (STDCHAR) c;
3655 PerlIOStdio_set_ptrcnt(aTHX_ f,ptr,cnt+1);
3656 if (PerlSIO_feof(stdio))
3657 PerlSIO_clearerr(stdio);
3658 return 0;
3659 }
3660 }
313e59c8
NIS
3661 else
3662#endif
3663 if (PerlIO_has_cntptr(f)) {
9f7cd136
NIS
3664 STDCHAR ch = c;
3665 if (PerlIOStdio_unread(aTHX_ f,&ch,1) == 1) {
3666 return 0;
3667 }
3668 }
93679785
NIS
3669#endif
3670
3671#if defined(VMS)
3672 /* An ungetc()d char is handled separately from the regular
3673 * buffer, so we stuff it in the buffer ourselves.
3674 * Should never get called as should hit code above
3675 */
bad9695d
NIS
3676 *(--((*stdio)->_ptr)) = (unsigned char) c;
3677 (*stdio)->_cnt++;
93679785
NIS
3678#else
3679 /* If buffer snoop scheme above fails fall back to
9f7cd136 3680 using ungetc().
93679785
NIS
3681 */
3682 if (PerlSIO_ungetc(c, stdio) != c)
3683 return EOF;
3684#endif
3685 return 0;
3686}
3687
3688
3689
27da23d5 3690PERLIO_FUNCS_DECL(PerlIO_stdio) = {
2dc2558e 3691 sizeof(PerlIO_funcs),
14a5cf38
JH
3692 "stdio",
3693 sizeof(PerlIOStdio),
86e05cf2 3694 PERLIO_K_BUFFERED|PERLIO_K_RAW,
1fd8f4ce 3695 PerlIOStdio_pushed,
2376d97d 3696 PerlIOBase_popped,
14a5cf38 3697 PerlIOStdio_open,
86e05cf2 3698 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
3699 NULL,
3700 PerlIOStdio_fileno,
71200d45 3701 PerlIOStdio_dup,
14a5cf38
JH
3702 PerlIOStdio_read,
3703 PerlIOStdio_unread,
3704 PerlIOStdio_write,
3705 PerlIOStdio_seek,
3706 PerlIOStdio_tell,
3707 PerlIOStdio_close,
3708 PerlIOStdio_flush,
3709 PerlIOStdio_fill,
3710 PerlIOStdio_eof,
3711 PerlIOStdio_error,
3712 PerlIOStdio_clearerr,
3713 PerlIOStdio_setlinebuf,
9e353e3b 3714#ifdef FILE_base
14a5cf38
JH
3715 PerlIOStdio_get_base,
3716 PerlIOStdio_get_bufsiz,
9e353e3b 3717#else
14a5cf38
JH
3718 NULL,
3719 NULL,
9e353e3b
NIS
3720#endif
3721#ifdef USE_STDIO_PTR
14a5cf38
JH
3722 PerlIOStdio_get_ptr,
3723 PerlIOStdio_get_cnt,
15b61c98 3724# if defined(HAS_FAST_STDIO) && defined(USE_FAST_STDIO)
79ed0f43 3725 PerlIOStdio_set_ptrcnt,
15b61c98
JH
3726# else
3727 NULL,
3728# endif /* HAS_FAST_STDIO && USE_FAST_STDIO */
3729#else
3730 NULL,
14a5cf38
JH
3731 NULL,
3732 NULL,
15b61c98 3733#endif /* USE_STDIO_PTR */
9e353e3b
NIS
3734};
3735
b9d6bf13
JH
3736/* Note that calls to PerlIO_exportFILE() are reversed using
3737 * PerlIO_releaseFILE(), not importFILE. */
9e353e3b 3738FILE *
81428673 3739PerlIO_exportFILE(PerlIO * f, const char *mode)
9e353e3b 3740{
e87a358a 3741 dTHX;
81428673
NIS
3742 FILE *stdio = NULL;
3743 if (PerlIOValid(f)) {
3744 char buf[8];
3745 PerlIO_flush(f);
3746 if (!mode || !*mode) {
3747 mode = PerlIO_modestr(f, buf);
3748 }
3749 stdio = PerlSIO_fdopen(PerlIO_fileno(f), mode);
3750 if (stdio) {
3751 PerlIOl *l = *f;
9f75cc58 3752 PerlIO *f2;
81428673
NIS
3753 /* De-link any lower layers so new :stdio sticks */
3754 *f = NULL;
a0714e2c 3755 if ((f2 = PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_stdio), buf, NULL))) {
9f75cc58 3756 PerlIOStdio *s = PerlIOSelf((f = f2), PerlIOStdio);
81428673 3757 s->stdio = stdio;
6b54a403 3758 PerlIOUnix_refcnt_inc(fileno(stdio));
81428673
NIS
3759 /* Link previous lower layers under new one */
3760 *PerlIONext(f) = l;
3761 }
3762 else {
3763 /* restore layers list */
3764 *f = l;
3765 }
a33cf58c 3766 }
14a5cf38
JH
3767 }
3768 return stdio;
9e353e3b
NIS
3769}
3770
81428673 3771
9e353e3b
NIS
3772FILE *
3773PerlIO_findFILE(PerlIO *f)
3774{
14a5cf38 3775 PerlIOl *l = *f;
bbbc33d0 3776 FILE *stdio;
14a5cf38
JH
3777 while (l) {
3778 if (l->tab == &PerlIO_stdio) {
3779 PerlIOStdio *s = PerlIOSelf(&l, PerlIOStdio);
3780 return s->stdio;
3781 }
3782 l = *PerlIONext(&l);
f7e7eb72 3783 }
4b069b44 3784 /* Uses fallback "mode" via PerlIO_modestr() in PerlIO_exportFILE */
bbbc33d0
NC
3785 /* However, we're not really exporting a FILE * to someone else (who
3786 becomes responsible for closing it, or calling PerlIO_releaseFILE())
486ec47a 3787 So we need to undo its reference count increase on the underlying file
bbbc33d0
NC
3788 descriptor. We have to do this, because if the loop above returns you
3789 the FILE *, then *it* didn't increase any reference count. So there's
3790 only one way to be consistent. */
3791 stdio = PerlIO_exportFILE(f, NULL);
3792 if (stdio) {
3793 const int fd = fileno(stdio);
3794 if (fd >= 0)
3795 PerlIOUnix_refcnt_dec(fd);
3796 }
3797 return stdio;
9e353e3b
NIS
3798}
3799
b9d6bf13 3800/* Use this to reverse PerlIO_exportFILE calls. */
9e353e3b
NIS
3801void
3802PerlIO_releaseFILE(PerlIO *p, FILE *f)
3803{
27da23d5 3804 dVAR;
22569500
NIS
3805 PerlIOl *l;
3806 while ((l = *p)) {
3807 if (l->tab == &PerlIO_stdio) {
3808 PerlIOStdio *s = PerlIOSelf(&l, PerlIOStdio);
3809 if (s->stdio == f) {
3810 dTHX;
6b54a403
NC
3811 const int fd = fileno(f);
3812 if (fd >= 0)
3813 PerlIOUnix_refcnt_dec(fd);
22569500
NIS
3814 PerlIO_pop(aTHX_ p);
3815 return;
3816 }
3817 }
3818 p = PerlIONext(p);
3819 }
3820 return;
9e353e3b
NIS
3821}
3822
3823/*--------------------------------------------------------------------------------------*/
14a5cf38 3824/*
71200d45 3825 * perlio buffer layer
14a5cf38 3826 */
9e353e3b 3827
5e2ab84b 3828IV
2dc2558e 3829PerlIOBuf_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
5e2ab84b 3830{
14a5cf38 3831 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
de009b76 3832 const int fd = PerlIO_fileno(f);
14a5cf38
JH
3833 if (fd >= 0 && PerlLIO_isatty(fd)) {
3834 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF | PERLIO_F_TTY;
3835 }
4b069b44 3836 if (*PerlIONext(f)) {
de009b76 3837 const Off_t posn = PerlIO_tell(PerlIONext(f));
4b069b44
NIS
3838 if (posn != (Off_t) - 1) {
3839 b->posn = posn;
3840 }
14a5cf38 3841 }
2dc2558e 3842 return PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
5e2ab84b
NIS
3843}
3844
9e353e3b 3845PerlIO *
14a5cf38
JH
3846PerlIOBuf_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
3847 IV n, const char *mode, int fd, int imode, int perm,
3848 PerlIO *f, int narg, SV **args)
3849{
04892f78 3850 if (PerlIOValid(f)) {
14a5cf38 3851 PerlIO *next = PerlIONext(f);
67363c0d
JH
3852 PerlIO_funcs *tab =
3853 PerlIO_layer_fetch(aTHX_ layers, n - 1, PerlIOBase(next)->tab);
3854 if (tab && tab->Open)
3855 next =
3856 (*tab->Open)(aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
3857 next, narg, args);
2dc2558e 3858 if (!next || (*PerlIOBase(f)->tab->Pushed) (aTHX_ f, mode, PerlIOArg, self) != 0) {
14a5cf38
JH
3859 return NULL;
3860 }
3861 }
3862 else {
04892f78 3863 PerlIO_funcs *tab = PerlIO_layer_fetch(aTHX_ layers, n - 1, PerlIO_default_btm());
14a5cf38 3864 int init = 0;
3b6c1aba 3865 if (*mode == IoTYPE_IMPLICIT) {
14a5cf38
JH
3866 init = 1;
3867 /*
71200d45 3868 * mode++;
14a5cf38
JH
3869 */
3870 }
67363c0d
JH
3871 if (tab && tab->Open)
3872 f = (*tab->Open)(aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
3873 f, narg, args);
3874 else
3875 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38 3876 if (f) {
22569500 3877 if (PerlIO_push(aTHX_ f, self, mode, PerlIOArg) == 0) {
b26b1ab5
NC
3878 /*
3879 * if push fails during open, open fails. close will pop us.
3880 */
3881 PerlIO_close (f);
3882 return NULL;
3883 } else {
3884 fd = PerlIO_fileno(f);
b26b1ab5
NC
3885 if (init && fd == 2) {
3886 /*
3887 * Initial stderr is unbuffered
3888 */
3889 PerlIOBase(f)->flags |= PERLIO_F_UNBUF;
3890 }
23b84778
IZ
3891#ifdef PERLIO_USING_CRLF
3892# ifdef PERLIO_IS_BINMODE_FD
3893 if (PERLIO_IS_BINMODE_FD(fd))
bd61b366 3894 PerlIO_binmode(aTHX_ f, '<'/*not used*/, O_BINARY, NULL);
23b84778
IZ
3895 else
3896# endif
3897 /*
3898 * do something about failing setmode()? --jhi
3899 */
3900 PerlLIO_setmode(fd, O_BINARY);
3901#endif
8c8488cd
CB
3902#ifdef VMS
3903#include <rms.h>
3904 /* Enable line buffering with record-oriented regular files
3905 * so we don't introduce an extraneous record boundary when
3906 * the buffer fills up.
3907 */
3908 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) {
3909 Stat_t st;
3910 if (PerlLIO_fstat(fd, &st) == 0
3911 && S_ISREG(st.st_mode)
3912 && (st.st_fab_rfm == FAB$C_VAR
3913 || st.st_fab_rfm == FAB$C_VFC)) {
3914 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF;
3915 }
3916 }
3917#endif
14a5cf38
JH
3918 }
3919 }
ee518936 3920 }
14a5cf38 3921 return f;
9e353e3b
NIS
3922}
3923
14a5cf38
JH
3924/*
3925 * This "flush" is akin to sfio's sync in that it handles files in either
93c2c2ec
IZ
3926 * read or write state. For write state, we put the postponed data through
3927 * the next layers. For read state, we seek() the next layers to the
3928 * offset given by current position in the buffer, and discard the buffer
3929 * state (XXXX supposed to be for seek()able buffers only, but now it is done
3930 * in any case?). Then the pass the stick further in chain.
14a5cf38 3931 */
9e353e3b 3932IV
f62ce20a 3933PerlIOBuf_flush(pTHX_ PerlIO *f)
6f9d8c32 3934{
dcda55fc 3935 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 3936 int code = 0;
04892f78 3937 PerlIO *n = PerlIONext(f);
14a5cf38
JH
3938 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF) {
3939 /*
71200d45 3940 * write() the buffer
14a5cf38 3941 */
de009b76
AL
3942 const STDCHAR *buf = b->buf;
3943 const STDCHAR *p = buf;
14a5cf38
JH
3944 while (p < b->ptr) {
3945 SSize_t count = PerlIO_write(n, p, b->ptr - p);
3946 if (count > 0) {
3947 p += count;
3948 }
3949 else if (count < 0 || PerlIO_error(n)) {
3950 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
3951 code = -1;
3952 break;
3953 }
3954 }
3955 b->posn += (p - buf);
3956 }
3957 else if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
3958 STDCHAR *buf = PerlIO_get_base(f);
3959 /*
71200d45 3960 * Note position change
14a5cf38
JH
3961 */
3962 b->posn += (b->ptr - buf);
3963 if (b->ptr < b->end) {
4b069b44
NIS
3964 /* We did not consume all of it - try and seek downstream to
3965 our logical position
14a5cf38 3966 */
4b069b44 3967 if (PerlIOValid(n) && PerlIO_seek(n, b->posn, SEEK_SET) == 0) {
04892f78
NIS
3968 /* Reload n as some layers may pop themselves on seek */
3969 b->posn = PerlIO_tell(n = PerlIONext(f));
14a5cf38 3970 }
ba5c3fe9 3971 else {
4b069b44
NIS
3972 /* Seek failed (e.g. pipe or tty). Do NOT clear buffer or pre-read
3973 data is lost for good - so return saying "ok" having undone
3974 the position adjust
3975 */
3976 b->posn -= (b->ptr - buf);
ba5c3fe9
NIS
3977 return code;
3978 }
14a5cf38
JH
3979 }
3980 }
3981 b->ptr = b->end = b->buf;
3982 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
04892f78 3983 /* We check for Valid because of dubious decision to make PerlIO_flush(NULL) flush all */
04892f78 3984 if (PerlIOValid(n) && PerlIO_flush(n) != 0)
14a5cf38
JH
3985 code = -1;
3986 return code;
6f9d8c32
NIS
3987}
3988
93c2c2ec
IZ
3989/* This discards the content of the buffer after b->ptr, and rereads
3990 * the buffer from the position off in the layer downstream; here off
3991 * is at offset corresponding to b->ptr - b->buf.
3992 */
06da4f11 3993IV
f62ce20a 3994PerlIOBuf_fill(pTHX_ PerlIO *f)
06da4f11 3995{
dcda55fc 3996 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
3997 PerlIO *n = PerlIONext(f);
3998 SSize_t avail;
3999 /*
4b069b44
NIS
4000 * Down-stream flush is defined not to loose read data so is harmless.
4001 * we would not normally be fill'ing if there was data left in anycase.
14a5cf38 4002 */
93c2c2ec 4003 if (PerlIO_flush(f) != 0) /* XXXX Check that its seek() succeeded?! */
14a5cf38
JH
4004 return -1;
4005 if (PerlIOBase(f)->flags & PERLIO_F_TTY)
f62ce20a 4006 PerlIOBase_flush_linebuf(aTHX);
14a5cf38
JH
4007
4008 if (!b->buf)
22569500 4009 PerlIO_get_base(f); /* allocate via vtable */
14a5cf38 4010
0f0eef27 4011 assert(b->buf); /* The b->buf does get allocated via the vtable system. */
ec6fa4f0 4012
14a5cf38 4013 b->ptr = b->end = b->buf;
4b069b44
NIS
4014
4015 if (!PerlIOValid(n)) {
4016 PerlIOBase(f)->flags |= PERLIO_F_EOF;
4017 return -1;
4018 }
4019
14a5cf38
JH
4020 if (PerlIO_fast_gets(n)) {
4021 /*
04892f78 4022 * Layer below is also buffered. We do _NOT_ want to call its
14a5cf38
JH
4023 * ->Read() because that will loop till it gets what we asked for
4024 * which may hang on a pipe etc. Instead take anything it has to
71200d45 4025 * hand, or ask it to fill _once_.
14a5cf38
JH
4026 */
4027 avail = PerlIO_get_cnt(n);
4028 if (avail <= 0) {
4029 avail = PerlIO_fill(n);
4030 if (avail == 0)
4031 avail = PerlIO_get_cnt(n);
4032 else {
4033 if (!PerlIO_error(n) && PerlIO_eof(n))
4034 avail = 0;
4035 }
4036 }
4037 if (avail > 0) {
4038 STDCHAR *ptr = PerlIO_get_ptr(n);
dcda55fc 4039 const SSize_t cnt = avail;
eb160463 4040 if (avail > (SSize_t)b->bufsiz)
14a5cf38
JH
4041 avail = b->bufsiz;
4042 Copy(ptr, b->buf, avail, STDCHAR);
4043 PerlIO_set_ptrcnt(n, ptr + avail, cnt - avail);
4044 }
4045 }
4046 else {
4047 avail = PerlIO_read(n, b->ptr, b->bufsiz);
4048 }
4049 if (avail <= 0) {
4050 if (avail == 0)
4051 PerlIOBase(f)->flags |= PERLIO_F_EOF;
4052 else
4053 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
4054 return -1;
4055 }
4056 b->end = b->buf + avail;
4057 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4058 return 0;
06da4f11
NIS
4059}
4060
6f9d8c32 4061SSize_t
f62ce20a 4062PerlIOBuf_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
6f9d8c32 4063{
04892f78 4064 if (PerlIOValid(f)) {
dcda55fc 4065 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4066 if (!b->ptr)
4067 PerlIO_get_base(f);
f62ce20a 4068 return PerlIOBase_read(aTHX_ f, vbuf, count);
14a5cf38
JH
4069 }
4070 return 0;
6f9d8c32
NIS
4071}
4072
9e353e3b 4073SSize_t
f62ce20a 4074PerlIOBuf_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 4075{
14a5cf38 4076 const STDCHAR *buf = (const STDCHAR *) vbuf + count;
dcda55fc 4077 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4078 SSize_t unread = 0;
4079 SSize_t avail;
4080 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4081 PerlIO_flush(f);
4082 if (!b->buf)
4083 PerlIO_get_base(f);
4084 if (b->buf) {
4085 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
4086 /*
4087 * Buffer is already a read buffer, we can overwrite any chars
71200d45 4088 * which have been read back to buffer start
14a5cf38
JH
4089 */
4090 avail = (b->ptr - b->buf);
4091 }
4092 else {
4093 /*
4094 * Buffer is idle, set it up so whole buffer is available for
71200d45 4095 * unread
14a5cf38
JH
4096 */
4097 avail = b->bufsiz;
4098 b->end = b->buf + avail;
4099 b->ptr = b->end;
4100 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4101 /*
71200d45 4102 * Buffer extends _back_ from where we are now
14a5cf38
JH
4103 */
4104 b->posn -= b->bufsiz;
4105 }
4106 if (avail > (SSize_t) count) {
4107 /*
71200d45 4108 * If we have space for more than count, just move count
14a5cf38
JH
4109 */
4110 avail = count;
4111 }
4112 if (avail > 0) {
4113 b->ptr -= avail;
4114 buf -= avail;
4115 /*
4116 * In simple stdio-like ungetc() case chars will be already
71200d45 4117 * there
14a5cf38
JH
4118 */
4119 if (buf != b->ptr) {
4120 Copy(buf, b->ptr, avail, STDCHAR);
4121 }
4122 count -= avail;
4123 unread += avail;
4124 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4125 }
4126 }
93679785
NIS
4127 if (count > 0) {
4128 unread += PerlIOBase_unread(aTHX_ f, vbuf, count);
4129 }
14a5cf38 4130 return unread;
760ac839
LW
4131}
4132
9e353e3b 4133SSize_t
f62ce20a 4134PerlIOBuf_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 4135{
de009b76 4136 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4137 const STDCHAR *buf = (const STDCHAR *) vbuf;
ee56a6b9 4138 const STDCHAR *flushptr = buf;
14a5cf38
JH
4139 Size_t written = 0;
4140 if (!b->buf)
4141 PerlIO_get_base(f);
4142 if (!(PerlIOBase(f)->flags & PERLIO_F_CANWRITE))
4143 return 0;
0678cb22
NIS
4144 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
4145 if (PerlIO_flush(f) != 0) {
4146 return 0;
4147 }
4148 }
ee56a6b9
CS
4149 if (PerlIOBase(f)->flags & PERLIO_F_LINEBUF) {
4150 flushptr = buf + count;
4151 while (flushptr > buf && *(flushptr - 1) != '\n')
4152 --flushptr;
4153 }
14a5cf38
JH
4154 while (count > 0) {
4155 SSize_t avail = b->bufsiz - (b->ptr - b->buf);
4156 if ((SSize_t) count < avail)
4157 avail = count;
ee56a6b9
CS
4158 if (flushptr > buf && flushptr <= buf + avail)
4159 avail = flushptr - buf;
14a5cf38 4160 PerlIOBase(f)->flags |= PERLIO_F_WRBUF;
ee56a6b9
CS
4161 if (avail) {
4162 Copy(buf, b->ptr, avail, STDCHAR);
4163 count -= avail;
4164 buf += avail;
4165 written += avail;
4166 b->ptr += avail;
4167 if (buf == flushptr)
4168 PerlIO_flush(f);
14a5cf38
JH
4169 }
4170 if (b->ptr >= (b->buf + b->bufsiz))
abf9167d
DM
4171 if (PerlIO_flush(f) == -1)
4172 return -1;
14a5cf38
JH
4173 }
4174 if (PerlIOBase(f)->flags & PERLIO_F_UNBUF)
4175 PerlIO_flush(f);
4176 return written;
9e353e3b
NIS
4177}
4178
94a175e1 4179IV
f62ce20a 4180PerlIOBuf_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
9e353e3b 4181{
14a5cf38
JH
4182 IV code;
4183 if ((code = PerlIO_flush(f)) == 0) {
14a5cf38
JH
4184 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4185 code = PerlIO_seek(PerlIONext(f), offset, whence);
4186 if (code == 0) {
de009b76 4187 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4188 b->posn = PerlIO_tell(PerlIONext(f));
4189 }
9e353e3b 4190 }
14a5cf38 4191 return code;
9e353e3b
NIS
4192}
4193
4194Off_t
f62ce20a 4195PerlIOBuf_tell(pTHX_ PerlIO *f)
9e353e3b 4196{
dcda55fc 4197 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4198 /*
71200d45 4199 * b->posn is file position where b->buf was read, or will be written
14a5cf38
JH
4200 */
4201 Off_t posn = b->posn;
37725cdc 4202 if ((PerlIOBase(f)->flags & PERLIO_F_APPEND) &&
0678cb22
NIS
4203 (PerlIOBase(f)->flags & PERLIO_F_WRBUF)) {
4204#if 1
4205 /* As O_APPEND files are normally shared in some sense it is better
4206 to flush :
4207 */
4208 PerlIO_flush(f);
4209#else
37725cdc 4210 /* when file is NOT shared then this is sufficient */
0678cb22
NIS
4211 PerlIO_seek(PerlIONext(f),0, SEEK_END);
4212#endif
4213 posn = b->posn = PerlIO_tell(PerlIONext(f));
4214 }
14a5cf38
JH
4215 if (b->buf) {
4216 /*
71200d45 4217 * If buffer is valid adjust position by amount in buffer
14a5cf38
JH
4218 */
4219 posn += (b->ptr - b->buf);
4220 }
4221 return posn;
9e353e3b
NIS
4222}
4223
4224IV
44798d05
NIS
4225PerlIOBuf_popped(pTHX_ PerlIO *f)
4226{
de009b76
AL
4227 const IV code = PerlIOBase_popped(aTHX_ f);
4228 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
44798d05
NIS
4229 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
4230 Safefree(b->buf);
4231 }
dcda55fc 4232 b->ptr = b->end = b->buf = NULL;
44798d05
NIS
4233 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4234 return code;
4235}
4236
4237IV
f62ce20a 4238PerlIOBuf_close(pTHX_ PerlIO *f)
9e353e3b 4239{
de009b76
AL
4240 const IV code = PerlIOBase_close(aTHX_ f);
4241 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4242 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
3a1ee7e8 4243 Safefree(b->buf);
14a5cf38 4244 }
dcda55fc 4245 b->ptr = b->end = b->buf = NULL;
14a5cf38
JH
4246 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4247 return code;
760ac839
LW
4248}
4249
9e353e3b 4250STDCHAR *
f62ce20a 4251PerlIOBuf_get_ptr(pTHX_ PerlIO *f)
9e353e3b 4252{
dcda55fc 4253 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4254 if (!b->buf)
4255 PerlIO_get_base(f);
4256 return b->ptr;
9e353e3b
NIS
4257}
4258
05d1247b 4259SSize_t
f62ce20a 4260PerlIOBuf_get_cnt(pTHX_ PerlIO *f)
9e353e3b 4261{
dcda55fc 4262 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4263 if (!b->buf)
4264 PerlIO_get_base(f);
4265 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF)
4266 return (b->end - b->ptr);
4267 return 0;
9e353e3b
NIS
4268}
4269
4270STDCHAR *
f62ce20a 4271PerlIOBuf_get_base(pTHX_ PerlIO *f)
9e353e3b 4272{
dcda55fc 4273 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
96a5add6
AL
4274 PERL_UNUSED_CONTEXT;
4275
14a5cf38
JH
4276 if (!b->buf) {
4277 if (!b->bufsiz)
1810cd7c 4278 b->bufsiz = PERLIOBUF_DEFAULT_BUFSIZ;
e05a0d74 4279 Newxz(b->buf,b->bufsiz, STDCHAR);
14a5cf38
JH
4280 if (!b->buf) {
4281 b->buf = (STDCHAR *) & b->oneword;
4282 b->bufsiz = sizeof(b->oneword);
4283 }
dcda55fc 4284 b->end = b->ptr = b->buf;
06da4f11 4285 }
14a5cf38 4286 return b->buf;
9e353e3b
NIS
4287}
4288
4289Size_t
f62ce20a 4290PerlIOBuf_bufsiz(pTHX_ PerlIO *f)
9e353e3b 4291{
dcda55fc 4292 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4293 if (!b->buf)
4294 PerlIO_get_base(f);
4295 return (b->end - b->buf);
9e353e3b
NIS
4296}
4297
4298void
f62ce20a 4299PerlIOBuf_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
9e353e3b 4300{
dcda55fc 4301 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
babfacb9
JH
4302#ifndef DEBUGGING
4303 PERL_UNUSED_ARG(cnt);
4304#endif
14a5cf38
JH
4305 if (!b->buf)
4306 PerlIO_get_base(f);
4307 b->ptr = ptr;
b727803b
RGS
4308 assert(PerlIO_get_cnt(f) == cnt);
4309 assert(b->ptr >= b->buf);
14a5cf38 4310 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
760ac839
LW
4311}
4312
71200d45 4313PerlIO *
ecdeb87c 4314PerlIOBuf_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 4315{
ecdeb87c 4316 return PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
4317}
4318
4319
4320
27da23d5 4321PERLIO_FUNCS_DECL(PerlIO_perlio) = {
2dc2558e 4322 sizeof(PerlIO_funcs),
14a5cf38
JH
4323 "perlio",
4324 sizeof(PerlIOBuf),
86e05cf2 4325 PERLIO_K_BUFFERED|PERLIO_K_RAW,
14a5cf38 4326 PerlIOBuf_pushed,
44798d05 4327 PerlIOBuf_popped,
14a5cf38 4328 PerlIOBuf_open,
86e05cf2 4329 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
4330 NULL,
4331 PerlIOBase_fileno,
71200d45 4332 PerlIOBuf_dup,
14a5cf38
JH
4333 PerlIOBuf_read,
4334 PerlIOBuf_unread,
4335 PerlIOBuf_write,
4336 PerlIOBuf_seek,
4337 PerlIOBuf_tell,
4338 PerlIOBuf_close,
4339 PerlIOBuf_flush,
4340 PerlIOBuf_fill,
4341 PerlIOBase_eof,
4342 PerlIOBase_error,
4343 PerlIOBase_clearerr,
4344 PerlIOBase_setlinebuf,
4345 PerlIOBuf_get_base,
4346 PerlIOBuf_bufsiz,
4347 PerlIOBuf_get_ptr,
4348 PerlIOBuf_get_cnt,
4349 PerlIOBuf_set_ptrcnt,
9e353e3b
NIS
4350};
4351
66ecd56b 4352/*--------------------------------------------------------------------------------------*/
14a5cf38 4353/*
71200d45 4354 * Temp layer to hold unread chars when cannot do it any other way
14a5cf38 4355 */
5e2ab84b
NIS
4356
4357IV
f62ce20a 4358PerlIOPending_fill(pTHX_ PerlIO *f)
5e2ab84b 4359{
14a5cf38 4360 /*
71200d45 4361 * Should never happen
14a5cf38
JH
4362 */
4363 PerlIO_flush(f);
4364 return 0;
5e2ab84b
NIS
4365}
4366
4367IV
f62ce20a 4368PerlIOPending_close(pTHX_ PerlIO *f)
5e2ab84b 4369{
14a5cf38 4370 /*
71200d45 4371 * A tad tricky - flush pops us, then we close new top
14a5cf38
JH
4372 */
4373 PerlIO_flush(f);
4374 return PerlIO_close(f);
5e2ab84b
NIS
4375}
4376
94a175e1 4377IV
f62ce20a 4378PerlIOPending_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
5e2ab84b 4379{
14a5cf38 4380 /*
71200d45 4381 * A tad tricky - flush pops us, then we seek new top
14a5cf38
JH
4382 */
4383 PerlIO_flush(f);
4384 return PerlIO_seek(f, offset, whence);
5e2ab84b
NIS
4385}
4386
4387
4388IV
f62ce20a 4389PerlIOPending_flush(pTHX_ PerlIO *f)
5e2ab84b 4390{
dcda55fc 4391 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4392 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
3a1ee7e8 4393 Safefree(b->buf);
14a5cf38
JH
4394 b->buf = NULL;
4395 }
4396 PerlIO_pop(aTHX_ f);
4397 return 0;
5e2ab84b
NIS
4398}
4399
4400void
f62ce20a 4401PerlIOPending_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
5e2ab84b 4402{
14a5cf38
JH
4403 if (cnt <= 0) {
4404 PerlIO_flush(f);
4405 }
4406 else {
f62ce20a 4407 PerlIOBuf_set_ptrcnt(aTHX_ f, ptr, cnt);
14a5cf38 4408 }
5e2ab84b
NIS
4409}
4410
4411IV
2dc2558e 4412PerlIOPending_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
5e2ab84b 4413{
de009b76 4414 const IV code = PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
dcda55fc 4415 PerlIOl * const l = PerlIOBase(f);
14a5cf38 4416 /*
71200d45
NIS
4417 * Our PerlIO_fast_gets must match what we are pushed on, or sv_gets()
4418 * etc. get muddled when it changes mid-string when we auto-pop.
14a5cf38
JH
4419 */
4420 l->flags = (l->flags & ~(PERLIO_F_FASTGETS | PERLIO_F_UTF8)) |
4421 (PerlIOBase(PerlIONext(f))->
4422 flags & (PERLIO_F_FASTGETS | PERLIO_F_UTF8));
4423 return code;
5e2ab84b
NIS
4424}
4425
4426SSize_t
f62ce20a 4427PerlIOPending_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
5e2ab84b 4428{
14a5cf38
JH
4429 SSize_t avail = PerlIO_get_cnt(f);
4430 SSize_t got = 0;
eb160463 4431 if ((SSize_t)count < avail)
14a5cf38
JH
4432 avail = count;
4433 if (avail > 0)
f62ce20a 4434 got = PerlIOBuf_read(aTHX_ f, vbuf, avail);
eb160463 4435 if (got >= 0 && got < (SSize_t)count) {
de009b76 4436 const SSize_t more =
14a5cf38
JH
4437 PerlIO_read(f, ((STDCHAR *) vbuf) + got, count - got);
4438 if (more >= 0 || got == 0)
4439 got += more;
4440 }
4441 return got;
5e2ab84b
NIS
4442}
4443
27da23d5 4444PERLIO_FUNCS_DECL(PerlIO_pending) = {
2dc2558e 4445 sizeof(PerlIO_funcs),
14a5cf38
JH
4446 "pending",
4447 sizeof(PerlIOBuf),
86e05cf2 4448 PERLIO_K_BUFFERED|PERLIO_K_RAW, /* not sure about RAW here */
14a5cf38 4449 PerlIOPending_pushed,
44798d05 4450 PerlIOBuf_popped,
14a5cf38 4451 NULL,
86e05cf2 4452 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
4453 NULL,
4454 PerlIOBase_fileno,
71200d45 4455 PerlIOBuf_dup,
14a5cf38
JH
4456 PerlIOPending_read,
4457 PerlIOBuf_unread,
4458 PerlIOBuf_write,
4459 PerlIOPending_seek,
4460 PerlIOBuf_tell,
4461 PerlIOPending_close,
4462 PerlIOPending_flush,
4463 PerlIOPending_fill,
4464 PerlIOBase_eof,
4465 PerlIOBase_error,
4466 PerlIOBase_clearerr,
4467 PerlIOBase_setlinebuf,
4468 PerlIOBuf_get_base,
4469 PerlIOBuf_bufsiz,
4470 PerlIOBuf_get_ptr,
4471 PerlIOBuf_get_cnt,
4472 PerlIOPending_set_ptrcnt,
5e2ab84b
NIS
4473};
4474
4475
4476
4477/*--------------------------------------------------------------------------------------*/
14a5cf38
JH
4478/*
4479 * crlf - translation On read translate CR,LF to "\n" we do this by
4480 * overriding ptr/cnt entries to hand back a line at a time and keeping a
71200d45 4481 * record of which nl we "lied" about. On write translate "\n" to CR,LF
93c2c2ec
IZ
4482 *
4483 * c->nl points on the first byte of CR LF pair when it is temporarily
4484 * replaced by LF, or to the last CR of the buffer. In the former case
4485 * the caller thinks that the buffer ends at c->nl + 1, in the latter
4486 * that it ends at c->nl; these two cases can be distinguished by
4487 * *c->nl. c->nl is set during _getcnt() call, and unset during
4488 * _unread() and _flush() calls.
4489 * It only matters for read operations.
66ecd56b
NIS
4490 */
4491
14a5cf38 4492typedef struct {
22569500
NIS
4493 PerlIOBuf base; /* PerlIOBuf stuff */
4494 STDCHAR *nl; /* Position of crlf we "lied" about in the
14a5cf38 4495 * buffer */
99efab12
NIS
4496} PerlIOCrlf;
4497
ff1e3883
JD
4498/* Inherit the PERLIO_F_UTF8 flag from previous layer.
4499 * Otherwise the :crlf layer would always revert back to
4500 * raw mode.
4501 */
4502static void
4503S_inherit_utf8_flag(PerlIO *f)
4504{
4505 PerlIO *g = PerlIONext(f);
4506 if (PerlIOValid(g)) {
4507 if (PerlIOBase(g)->flags & PERLIO_F_UTF8) {
4508 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
4509 }
4510 }
4511}
4512
f5b9d040 4513IV
2dc2558e 4514PerlIOCrlf_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
f5b9d040 4515{
14a5cf38
JH
4516 IV code;
4517 PerlIOBase(f)->flags |= PERLIO_F_CRLF;
2dc2558e 4518 code = PerlIOBuf_pushed(aTHX_ f, mode, arg, tab);
5e2ab84b 4519#if 0
14a5cf38 4520 PerlIO_debug("PerlIOCrlf_pushed f=%p %s %s fl=%08" UVxf "\n",
6c9570dc 4521 (void*)f, PerlIOBase(f)->tab->name, (mode) ? mode : "(Null)",
14a5cf38 4522 PerlIOBase(f)->flags);
5e2ab84b 4523#endif
8229d19f
JH
4524 {
4525 /* Enable the first CRLF capable layer you can find, but if none
4526 * found, the one we just pushed is fine. This results in at
4527 * any given moment at most one CRLF-capable layer being enabled
4528 * in the whole layer stack. */
4529 PerlIO *g = PerlIONext(f);
ff1e3883 4530 while (PerlIOValid(g)) {
8229d19f
JH
4531 PerlIOl *b = PerlIOBase(g);
4532 if (b && b->tab == &PerlIO_crlf) {
4533 if (!(b->flags & PERLIO_F_CRLF))
4534 b->flags |= PERLIO_F_CRLF;
ff1e3883 4535 S_inherit_utf8_flag(g);
8229d19f
JH
4536 PerlIO_pop(aTHX_ f);
4537 return code;
4538 }
4539 g = PerlIONext(g);
4540 }
4541 }
ff1e3883 4542 S_inherit_utf8_flag(f);
14a5cf38 4543 return code;
f5b9d040
NIS
4544}
4545
4546
99efab12 4547SSize_t
f62ce20a 4548PerlIOCrlf_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
99efab12 4549{
dcda55fc 4550 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
93c2c2ec 4551 if (c->nl) { /* XXXX Shouldn't it be done only if b->ptr > c->nl? */
14a5cf38
JH
4552 *(c->nl) = 0xd;
4553 c->nl = NULL;
4554 }
4555 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF))
f62ce20a 4556 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
14a5cf38
JH
4557 else {
4558 const STDCHAR *buf = (const STDCHAR *) vbuf + count;
4559 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
4560 SSize_t unread = 0;
4561 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4562 PerlIO_flush(f);
4563 if (!b->buf)
4564 PerlIO_get_base(f);
4565 if (b->buf) {
4566 if (!(PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
4567 b->end = b->ptr = b->buf + b->bufsiz;
4568 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4569 b->posn -= b->bufsiz;
4570 }
4571 while (count > 0 && b->ptr > b->buf) {
dcda55fc 4572 const int ch = *--buf;
14a5cf38
JH
4573 if (ch == '\n') {
4574 if (b->ptr - 2 >= b->buf) {
4575 *--(b->ptr) = 0xa;
4576 *--(b->ptr) = 0xd;
4577 unread++;
4578 count--;
4579 }
4580 else {
93c2c2ec
IZ
4581 /* If b->ptr - 1 == b->buf, we are undoing reading 0xa */
4582 *--(b->ptr) = 0xa; /* Works even if 0xa == '\r' */
4583 unread++;
4584 count--;
14a5cf38
JH
4585 }
4586 }
4587 else {
4588 *--(b->ptr) = ch;
4589 unread++;
4590 count--;
4591 }
4592 }
4593 }
4594 return unread;
4595 }
99efab12
NIS
4596}
4597
93c2c2ec 4598/* XXXX This code assumes that buffer size >=2, but does not check it... */
99efab12 4599SSize_t
f62ce20a 4600PerlIOCrlf_get_cnt(pTHX_ PerlIO *f)
99efab12 4601{
dcda55fc 4602 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4603 if (!b->buf)
4604 PerlIO_get_base(f);
4605 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
dcda55fc 4606 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
23b3c6af
NIS
4607 if ((PerlIOBase(f)->flags & PERLIO_F_CRLF) && (!c->nl || *c->nl == 0xd)) {
4608 STDCHAR *nl = (c->nl) ? c->nl : b->ptr;
14a5cf38
JH
4609 scan:
4610 while (nl < b->end && *nl != 0xd)
4611 nl++;
4612 if (nl < b->end && *nl == 0xd) {
4613 test:
4614 if (nl + 1 < b->end) {
4615 if (nl[1] == 0xa) {
4616 *nl = '\n';
4617 c->nl = nl;
4618 }
4619 else {
4620 /*
71200d45 4621 * Not CR,LF but just CR
14a5cf38
JH
4622 */
4623 nl++;
4624 goto scan;
4625 }
4626 }
4627 else {
4628 /*
71200d45 4629 * Blast - found CR as last char in buffer
14a5cf38 4630 */
e87a358a 4631
14a5cf38
JH
4632 if (b->ptr < nl) {
4633 /*
4634 * They may not care, defer work as long as
71200d45 4635 * possible
14a5cf38 4636 */
a0d1d361 4637 c->nl = nl;
14a5cf38
JH
4638 return (nl - b->ptr);
4639 }
4640 else {
4641 int code;
22569500 4642 b->ptr++; /* say we have read it as far as
14a5cf38 4643 * flush() is concerned */
22569500 4644 b->buf++; /* Leave space in front of buffer */
e949e37c
NIS
4645 /* Note as we have moved buf up flush's
4646 posn += ptr-buf
4647 will naturally make posn point at CR
4648 */
22569500
NIS
4649 b->bufsiz--; /* Buffer is thus smaller */
4650 code = PerlIO_fill(f); /* Fetch some more */
4651 b->bufsiz++; /* Restore size for next time */
4652 b->buf--; /* Point at space */
4653 b->ptr = nl = b->buf; /* Which is what we hand
14a5cf38 4654 * off */
22569500 4655 *nl = 0xd; /* Fill in the CR */
14a5cf38 4656 if (code == 0)
22569500 4657 goto test; /* fill() call worked */
14a5cf38 4658 /*
71200d45 4659 * CR at EOF - just fall through
14a5cf38 4660 */
a0d1d361 4661 /* Should we clear EOF though ??? */
14a5cf38
JH
4662 }
4663 }
4664 }
4665 }
4666 return (((c->nl) ? (c->nl + 1) : b->end) - b->ptr);
4667 }
4668 return 0;
99efab12
NIS
4669}
4670
4671void
f62ce20a 4672PerlIOCrlf_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
14a5cf38 4673{
dcda55fc
AL
4674 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
4675 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
14a5cf38
JH
4676 if (!b->buf)
4677 PerlIO_get_base(f);
4678 if (!ptr) {
a0d1d361 4679 if (c->nl) {
14a5cf38 4680 ptr = c->nl + 1;
22569500 4681 if (ptr == b->end && *c->nl == 0xd) {
486ec47a 4682 /* Deferred CR at end of buffer case - we lied about count */
22569500
NIS
4683 ptr--;
4684 }
4685 }
14a5cf38
JH
4686 else {
4687 ptr = b->end;
14a5cf38
JH
4688 }
4689 ptr -= cnt;
4690 }
4691 else {
6f207bd3 4692 NOOP;
3b4bd3fd 4693#if 0
14a5cf38 4694 /*
71200d45 4695 * Test code - delete when it works ...
14a5cf38 4696 */
3b4bd3fd 4697 IV flags = PerlIOBase(f)->flags;
ba7abf9d 4698 STDCHAR *chk = (c->nl) ? (c->nl+1) : b->end;
22569500 4699 if (ptr+cnt == c->nl && c->nl+1 == b->end && *c->nl == 0xd) {
486ec47a 4700 /* Deferred CR at end of buffer case - we lied about count */
a0d1d361 4701 chk--;
22569500 4702 }
14a5cf38
JH
4703 chk -= cnt;
4704
a0d1d361 4705 if (ptr != chk ) {
99ef548b 4706 Perl_croak(aTHX_ "ptr wrong %p != %p fl=%08" UVxf
6c9570dc
MHM
4707 " nl=%p e=%p for %d", (void*)ptr, (void*)chk,
4708 flags, c->nl, b->end, cnt);
14a5cf38 4709 }
99ef548b 4710#endif
14a5cf38
JH
4711 }
4712 if (c->nl) {
4713 if (ptr > c->nl) {
4714 /*
71200d45 4715 * They have taken what we lied about
14a5cf38
JH
4716 */
4717 *(c->nl) = 0xd;
4718 c->nl = NULL;
4719 ptr++;
4720 }
4721 }
4722 b->ptr = ptr;
4723 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
99efab12
NIS
4724}
4725
4726SSize_t
f62ce20a 4727PerlIOCrlf_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
99efab12 4728{
14a5cf38 4729 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF))
f62ce20a 4730 return PerlIOBuf_write(aTHX_ f, vbuf, count);
14a5cf38 4731 else {
dcda55fc 4732 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4733 const STDCHAR *buf = (const STDCHAR *) vbuf;
dcda55fc 4734 const STDCHAR * const ebuf = buf + count;
14a5cf38
JH
4735 if (!b->buf)
4736 PerlIO_get_base(f);
4737 if (!(PerlIOBase(f)->flags & PERLIO_F_CANWRITE))
4738 return 0;
4739 while (buf < ebuf) {
dcda55fc 4740 const STDCHAR * const eptr = b->buf + b->bufsiz;
14a5cf38
JH
4741 PerlIOBase(f)->flags |= PERLIO_F_WRBUF;
4742 while (buf < ebuf && b->ptr < eptr) {
4743 if (*buf == '\n') {
4744 if ((b->ptr + 2) > eptr) {
4745 /*
71200d45 4746 * Not room for both
14a5cf38
JH
4747 */
4748 PerlIO_flush(f);
4749 break;
4750 }
4751 else {
22569500
NIS
4752 *(b->ptr)++ = 0xd; /* CR */
4753 *(b->ptr)++ = 0xa; /* LF */
14a5cf38
JH
4754 buf++;
4755 if (PerlIOBase(f)->flags & PERLIO_F_LINEBUF) {
4756 PerlIO_flush(f);
4757 break;
4758 }
4759 }
4760 }
4761 else {
dcda55fc 4762 *(b->ptr)++ = *buf++;
14a5cf38
JH
4763 }
4764 if (b->ptr >= eptr) {
4765 PerlIO_flush(f);
4766 break;
4767 }
4768 }
4769 }
4770 if (PerlIOBase(f)->flags & PERLIO_F_UNBUF)
4771 PerlIO_flush(f);
4772 return (buf - (STDCHAR *) vbuf);
4773 }
99efab12
NIS
4774}
4775
4776IV
f62ce20a 4777PerlIOCrlf_flush(pTHX_ PerlIO *f)
99efab12 4778{
dcda55fc 4779 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
14a5cf38
JH
4780 if (c->nl) {
4781 *(c->nl) = 0xd;
4782 c->nl = NULL;
4783 }
f62ce20a 4784 return PerlIOBuf_flush(aTHX_ f);
99efab12
NIS
4785}
4786
86e05cf2
NIS
4787IV
4788PerlIOCrlf_binmode(pTHX_ PerlIO *f)
4789{
4790 if ((PerlIOBase(f)->flags & PERLIO_F_CRLF)) {
4791 /* In text mode - flush any pending stuff and flip it */
4792 PerlIOBase(f)->flags &= ~PERLIO_F_CRLF;
4793#ifndef PERLIO_USING_CRLF
4794 /* CRLF is unusual case - if this is just the :crlf layer pop it */
5fae6dc1 4795 PerlIO_pop(aTHX_ f);
86e05cf2
NIS
4796#endif
4797 }
4798 return 0;
4799}
4800
27da23d5 4801PERLIO_FUNCS_DECL(PerlIO_crlf) = {
2dc2558e 4802 sizeof(PerlIO_funcs),
14a5cf38
JH
4803 "crlf",
4804 sizeof(PerlIOCrlf),
86e05cf2 4805 PERLIO_K_BUFFERED | PERLIO_K_CANCRLF | PERLIO_K_RAW,
14a5cf38 4806 PerlIOCrlf_pushed,
44798d05 4807 PerlIOBuf_popped, /* popped */
14a5cf38 4808 PerlIOBuf_open,
86e05cf2 4809 PerlIOCrlf_binmode, /* binmode */
14a5cf38
JH
4810 NULL,
4811 PerlIOBase_fileno,
71200d45 4812 PerlIOBuf_dup,
de009b76 4813 PerlIOBuf_read, /* generic read works with ptr/cnt lies */
22569500
NIS
4814 PerlIOCrlf_unread, /* Put CR,LF in buffer for each '\n' */
4815 PerlIOCrlf_write, /* Put CR,LF in buffer for each '\n' */
14a5cf38
JH
4816 PerlIOBuf_seek,
4817 PerlIOBuf_tell,
4818 PerlIOBuf_close,
4819 PerlIOCrlf_flush,
4820 PerlIOBuf_fill,
4821 PerlIOBase_eof,
4822 PerlIOBase_error,
4823 PerlIOBase_clearerr,
4824 PerlIOBase_setlinebuf,
4825 PerlIOBuf_get_base,
4826 PerlIOBuf_bufsiz,
4827 PerlIOBuf_get_ptr,
4828 PerlIOCrlf_get_cnt,
4829 PerlIOCrlf_set_ptrcnt,
66ecd56b
NIS
4830};
4831
06da4f11
NIS
4832#ifdef HAS_MMAP
4833/*--------------------------------------------------------------------------------------*/
14a5cf38 4834/*
71200d45 4835 * mmap as "buffer" layer
14a5cf38 4836 */
06da4f11 4837
14a5cf38 4838typedef struct {
22569500
NIS
4839 PerlIOBuf base; /* PerlIOBuf stuff */
4840 Mmap_t mptr; /* Mapped address */
4841 Size_t len; /* mapped length */
4842 STDCHAR *bbuf; /* malloced buffer if map fails */
06da4f11
NIS
4843} PerlIOMmap;
4844
4845IV
f62ce20a 4846PerlIOMmap_map(pTHX_ PerlIO *f)
06da4f11 4847{
27da23d5 4848 dVAR;
de009b76
AL
4849 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4850 const IV flags = PerlIOBase(f)->flags;
14a5cf38
JH
4851 IV code = 0;
4852 if (m->len)
4853 abort();
4854 if (flags & PERLIO_F_CANREAD) {
dcda55fc 4855 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
de009b76 4856 const int fd = PerlIO_fileno(f);
10eefe7f
CB
4857 Stat_t st;
4858 code = Fstat(fd, &st);
14a5cf38
JH
4859 if (code == 0 && S_ISREG(st.st_mode)) {
4860 SSize_t len = st.st_size - b->posn;
4861 if (len > 0) {
4862 Off_t posn;
27da23d5
JH
4863 if (PL_mmap_page_size <= 0)
4864 Perl_croak(aTHX_ "panic: bad pagesize %" IVdf,
4865 PL_mmap_page_size);
14a5cf38
JH
4866 if (b->posn < 0) {
4867 /*
4868 * This is a hack - should never happen - open should
71200d45 4869 * have set it !
14a5cf38
JH
4870 */
4871 b->posn = PerlIO_tell(PerlIONext(f));
4872 }
27da23d5 4873 posn = (b->posn / PL_mmap_page_size) * PL_mmap_page_size;
14a5cf38 4874 len = st.st_size - posn;
b91fbb93 4875 m->mptr = (Mmap_t)mmap(NULL, len, PROT_READ, MAP_SHARED, fd, posn);
14a5cf38 4876 if (m->mptr && m->mptr != (Mmap_t) - 1) {
a5262162 4877#if 0 && defined(HAS_MADVISE) && defined(MADV_SEQUENTIAL)
14a5cf38 4878 madvise(m->mptr, len, MADV_SEQUENTIAL);
06da4f11 4879#endif
a5262162 4880#if 0 && defined(HAS_MADVISE) && defined(MADV_WILLNEED)
14a5cf38 4881 madvise(m->mptr, len, MADV_WILLNEED);
a5262162 4882#endif
14a5cf38
JH
4883 PerlIOBase(f)->flags =
4884 (flags & ~PERLIO_F_EOF) | PERLIO_F_RDBUF;
4885 b->end = ((STDCHAR *) m->mptr) + len;
4886 b->buf = ((STDCHAR *) m->mptr) + (b->posn - posn);
4887 b->ptr = b->buf;
4888 m->len = len;
4889 }
4890 else {
4891 b->buf = NULL;
4892 }
4893 }
4894 else {
4895 PerlIOBase(f)->flags =
4896 flags | PERLIO_F_EOF | PERLIO_F_RDBUF;
4897 b->buf = NULL;
4898 b->ptr = b->end = b->ptr;
4899 code = -1;
4900 }
4901 }
4902 }
4903 return code;
06da4f11
NIS
4904}
4905
4906IV
e87a358a 4907PerlIOMmap_unmap(pTHX_ PerlIO *f)
06da4f11 4908{
dcda55fc 4909 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
14a5cf38
JH
4910 IV code = 0;
4911 if (m->len) {
dcda55fc 4912 PerlIOBuf * const b = &m->base;
14a5cf38 4913 if (b->buf) {
1ccb7c8d
JH
4914 /* The munmap address argument is tricky: depending on the
4915 * standard it is either "void *" or "caddr_t" (which is
4916 * usually "char *" (signed or unsigned). If we cast it
4917 * to "void *", those that have it caddr_t and an uptight
4918 * C++ compiler, will freak out. But casting it as char*
4919 * should work. Maybe. (Using Mmap_t figured out by
4920 * Configure doesn't always work, apparently.) */
4921 code = munmap((char*)m->mptr, m->len);
14a5cf38
JH
4922 b->buf = NULL;
4923 m->len = 0;
4924 m->mptr = NULL;
4925 if (PerlIO_seek(PerlIONext(f), b->posn, SEEK_SET) != 0)
4926 code = -1;
4927 }
4928 b->ptr = b->end = b->buf;
4929 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4930 }
4931 return code;
06da4f11
NIS
4932}
4933
4934STDCHAR *
f62ce20a 4935PerlIOMmap_get_base(pTHX_ PerlIO *f)
06da4f11 4936{
dcda55fc
AL
4937 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4938 PerlIOBuf * const b = &m->base;
14a5cf38
JH
4939 if (b->buf && (PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
4940 /*
71200d45 4941 * Already have a readbuffer in progress
14a5cf38
JH
4942 */
4943 return b->buf;
4944 }
4945 if (b->buf) {
4946 /*
71200d45 4947 * We have a write buffer or flushed PerlIOBuf read buffer
14a5cf38 4948 */
22569500
NIS
4949 m->bbuf = b->buf; /* save it in case we need it again */
4950 b->buf = NULL; /* Clear to trigger below */
14a5cf38
JH
4951 }
4952 if (!b->buf) {
22569500 4953 PerlIOMmap_map(aTHX_ f); /* Try and map it */
14a5cf38
JH
4954 if (!b->buf) {
4955 /*
71200d45 4956 * Map did not work - recover PerlIOBuf buffer if we have one
14a5cf38
JH
4957 */
4958 b->buf = m->bbuf;
4959 }
4960 }
4961 b->ptr = b->end = b->buf;
4962 if (b->buf)
4963 return b->buf;
f62ce20a 4964 return PerlIOBuf_get_base(aTHX_ f);
06da4f11
NIS
4965}
4966
4967SSize_t
f62ce20a 4968PerlIOMmap_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
06da4f11 4969{
dcda55fc
AL
4970 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4971 PerlIOBuf * const b = &m->base;
14a5cf38
JH
4972 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4973 PerlIO_flush(f);
4974 if (b->ptr && (b->ptr - count) >= b->buf
4975 && memEQ(b->ptr - count, vbuf, count)) {
4976 b->ptr -= count;
4977 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4978 return count;
4979 }
4980 if (m->len) {
4981 /*
71200d45 4982 * Loose the unwritable mapped buffer
14a5cf38
JH
4983 */
4984 PerlIO_flush(f);
4985 /*
71200d45 4986 * If flush took the "buffer" see if we have one from before
14a5cf38
JH
4987 */
4988 if (!b->buf && m->bbuf)
4989 b->buf = m->bbuf;
4990 if (!b->buf) {
f62ce20a 4991 PerlIOBuf_get_base(aTHX_ f);
14a5cf38
JH
4992 m->bbuf = b->buf;
4993 }
4994 }
f62ce20a 4995 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
06da4f11
NIS
4996}
4997
4998SSize_t
f62ce20a 4999PerlIOMmap_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
06da4f11 5000{
de009b76
AL
5001 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
5002 PerlIOBuf * const b = &m->base;
5003
14a5cf38
JH
5004 if (!b->buf || !(PerlIOBase(f)->flags & PERLIO_F_WRBUF)) {
5005 /*
71200d45 5006 * No, or wrong sort of, buffer
14a5cf38
JH
5007 */
5008 if (m->len) {
e87a358a 5009 if (PerlIOMmap_unmap(aTHX_ f) != 0)
14a5cf38
JH
5010 return 0;
5011 }
5012 /*
71200d45 5013 * If unmap took the "buffer" see if we have one from before
14a5cf38
JH
5014 */
5015 if (!b->buf && m->bbuf)
5016 b->buf = m->bbuf;
5017 if (!b->buf) {
f62ce20a 5018 PerlIOBuf_get_base(aTHX_ f);
14a5cf38
JH
5019 m->bbuf = b->buf;
5020 }
06da4f11 5021 }
f62ce20a 5022 return PerlIOBuf_write(aTHX_ f, vbuf, count);
06da4f11
NIS
5023}
5024
5025IV
f62ce20a 5026PerlIOMmap_flush(pTHX_ PerlIO *f)
06da4f11 5027{
dcda55fc
AL
5028 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
5029 PerlIOBuf * const b = &m->base;
f62ce20a 5030 IV code = PerlIOBuf_flush(aTHX_ f);
14a5cf38 5031 /*
71200d45 5032 * Now we are "synced" at PerlIOBuf level
14a5cf38
JH
5033 */
5034 if (b->buf) {
5035 if (m->len) {
5036 /*
71200d45 5037 * Unmap the buffer
14a5cf38 5038 */
e87a358a 5039 if (PerlIOMmap_unmap(aTHX_ f) != 0)
14a5cf38
JH
5040 code = -1;
5041 }
5042 else {
5043 /*
5044 * We seem to have a PerlIOBuf buffer which was not mapped
71200d45 5045 * remember it in case we need one later
14a5cf38
JH
5046 */
5047 m->bbuf = b->buf;
5048 }
5049 }
5050 return code;
06da4f11
NIS
5051}
5052
5053IV
f62ce20a 5054PerlIOMmap_fill(pTHX_ PerlIO *f)
06da4f11 5055{
dcda55fc 5056 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
5057 IV code = PerlIO_flush(f);
5058 if (code == 0 && !b->buf) {
f62ce20a 5059 code = PerlIOMmap_map(aTHX_ f);
14a5cf38
JH
5060 }
5061 if (code == 0 && !(PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
f62ce20a 5062 code = PerlIOBuf_fill(aTHX_ f);
14a5cf38
JH
5063 }
5064 return code;
06da4f11
NIS
5065}
5066
5067IV
f62ce20a 5068PerlIOMmap_close(pTHX_ PerlIO *f)
06da4f11 5069{
dcda55fc
AL
5070 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
5071 PerlIOBuf * const b = &m->base;
14a5cf38
JH
5072 IV code = PerlIO_flush(f);
5073 if (m->bbuf) {
5074 b->buf = m->bbuf;
5075 m->bbuf = NULL;
5076 b->ptr = b->end = b->buf;
5077 }
f62ce20a 5078 if (PerlIOBuf_close(aTHX_ f) != 0)
14a5cf38
JH
5079 code = -1;
5080 return code;
06da4f11
NIS
5081}
5082
71200d45 5083PerlIO *
ecdeb87c 5084PerlIOMmap_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 5085{
ecdeb87c 5086 return PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
5087}
5088
06da4f11 5089
27da23d5 5090PERLIO_FUNCS_DECL(PerlIO_mmap) = {
2dc2558e 5091 sizeof(PerlIO_funcs),
14a5cf38
JH
5092 "mmap",
5093 sizeof(PerlIOMmap),
86e05cf2 5094 PERLIO_K_BUFFERED|PERLIO_K_RAW,
14a5cf38 5095 PerlIOBuf_pushed,
44798d05 5096 PerlIOBuf_popped,
14a5cf38 5097 PerlIOBuf_open,
86e05cf2 5098 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
5099 NULL,
5100 PerlIOBase_fileno,
71200d45 5101 PerlIOMmap_dup,
14a5cf38
JH
5102 PerlIOBuf_read,
5103 PerlIOMmap_unread,
5104 PerlIOMmap_write,
5105 PerlIOBuf_seek,
5106 PerlIOBuf_tell,
5107 PerlIOBuf_close,
5108 PerlIOMmap_flush,
5109 PerlIOMmap_fill,
5110 PerlIOBase_eof,
5111 PerlIOBase_error,
5112 PerlIOBase_clearerr,
5113 PerlIOBase_setlinebuf,
5114 PerlIOMmap_get_base,
5115 PerlIOBuf_bufsiz,
5116 PerlIOBuf_get_ptr,
5117 PerlIOBuf_get_cnt,
5118 PerlIOBuf_set_ptrcnt,
06da4f11
NIS
5119};
5120
22569500 5121#endif /* HAS_MMAP */
06da4f11 5122
9e353e3b 5123PerlIO *
e87a358a 5124Perl_PerlIO_stdin(pTHX)
9e353e3b 5125{
97aff369 5126 dVAR;
a1ea730d 5127 if (!PL_perlio) {
14a5cf38
JH
5128 PerlIO_stdstreams(aTHX);
5129 }
303f2dc3 5130 return (PerlIO*)&PL_perlio[1];
9e353e3b
NIS
5131}
5132
9e353e3b 5133PerlIO *
e87a358a 5134Perl_PerlIO_stdout(pTHX)
9e353e3b 5135{
97aff369 5136 dVAR;
a1ea730d 5137 if (!PL_perlio) {
14a5cf38
JH
5138 PerlIO_stdstreams(aTHX);
5139 }
303f2dc3 5140 return (PerlIO*)&PL_perlio[2];
9e353e3b
NIS
5141}
5142
9e353e3b 5143PerlIO *
e87a358a 5144Perl_PerlIO_stderr(pTHX)
9e353e3b 5145{
97aff369 5146 dVAR;
a1ea730d 5147 if (!PL_perlio) {
14a5cf38
JH
5148 PerlIO_stdstreams(aTHX);
5149 }
303f2dc3 5150 return (PerlIO*)&PL_perlio[3];
9e353e3b
NIS
5151}
5152
5153/*--------------------------------------------------------------------------------------*/
5154
9e353e3b
NIS
5155char *
5156PerlIO_getname(PerlIO *f, char *buf)
5157{
14a5cf38 5158 dTHX;
a15cef0c 5159#ifdef VMS
73d840c0 5160 char *name = NULL;
7659f319 5161 bool exported = FALSE;
14a5cf38 5162 FILE *stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
7659f319
CB
5163 if (!stdio) {
5164 stdio = PerlIO_exportFILE(f,0);
5165 exported = TRUE;
5166 }
5167 if (stdio) {
14a5cf38 5168 name = fgetname(stdio, buf);
7659f319
CB
5169 if (exported) PerlIO_releaseFILE(f,stdio);
5170 }
73d840c0 5171 return name;
a15cef0c 5172#else
8772537c
AL
5173 PERL_UNUSED_ARG(f);
5174 PERL_UNUSED_ARG(buf);
14a5cf38 5175 Perl_croak(aTHX_ "Don't know how to get file name");
bd61b366 5176 return NULL;
a15cef0c 5177#endif
9e353e3b
NIS
5178}
5179
5180
5181/*--------------------------------------------------------------------------------------*/
14a5cf38
JH
5182/*
5183 * Functions which can be called on any kind of PerlIO implemented in
71200d45 5184 * terms of above
14a5cf38 5185 */
9e353e3b 5186
e87a358a
NIS
5187#undef PerlIO_fdopen
5188PerlIO *
5189PerlIO_fdopen(int fd, const char *mode)
5190{
5191 dTHX;
bd61b366 5192 return PerlIO_openn(aTHX_ NULL, mode, fd, 0, 0, NULL, 0, NULL);
e87a358a
NIS
5193}
5194
5195#undef PerlIO_open
5196PerlIO *
5197PerlIO_open(const char *path, const char *mode)
5198{
5199 dTHX;
42d9b98d 5200 SV *name = sv_2mortal(newSVpv(path, 0));
bd61b366 5201 return PerlIO_openn(aTHX_ NULL, mode, -1, 0, 0, NULL, 1, &name);
e87a358a
NIS
5202}
5203
5204#undef Perlio_reopen
5205PerlIO *
5206PerlIO_reopen(const char *path, const char *mode, PerlIO *f)
5207{
5208 dTHX;
42d9b98d 5209 SV *name = sv_2mortal(newSVpv(path,0));
bd61b366 5210 return PerlIO_openn(aTHX_ NULL, mode, -1, 0, 0, f, 1, &name);
e87a358a
NIS
5211}
5212
9e353e3b 5213#undef PerlIO_getc
6f9d8c32 5214int
9e353e3b 5215PerlIO_getc(PerlIO *f)
760ac839 5216{
e87a358a 5217 dTHX;
14a5cf38 5218 STDCHAR buf[1];
de009b76 5219 if ( 1 == PerlIO_read(f, buf, 1) ) {
14a5cf38
JH
5220 return (unsigned char) buf[0];
5221 }
5222 return EOF;
313ca112
NIS
5223}
5224
5225#undef PerlIO_ungetc
5226int
5227PerlIO_ungetc(PerlIO *f, int ch)
5228{
e87a358a 5229 dTHX;
14a5cf38
JH
5230 if (ch != EOF) {
5231 STDCHAR buf = ch;
5232 if (PerlIO_unread(f, &buf, 1) == 1)
5233 return ch;
5234 }
5235 return EOF;
760ac839
LW
5236}
5237
9e353e3b
NIS
5238#undef PerlIO_putc
5239int
5240PerlIO_putc(PerlIO *f, int ch)
760ac839 5241{
e87a358a 5242 dTHX;
14a5cf38
JH
5243 STDCHAR buf = ch;
5244 return PerlIO_write(f, &buf, 1);
760ac839
LW
5245}
5246
9e353e3b 5247#undef PerlIO_puts
760ac839 5248int
9e353e3b 5249PerlIO_puts(PerlIO *f, const char *s)
760ac839 5250{
e87a358a 5251 dTHX;
dcda55fc 5252 return PerlIO_write(f, s, strlen(s));
760ac839
LW
5253}
5254
5255#undef PerlIO_rewind
5256void
c78749f2 5257PerlIO_rewind(PerlIO *f)
760ac839 5258{
e87a358a 5259 dTHX;
14a5cf38
JH
5260 PerlIO_seek(f, (Off_t) 0, SEEK_SET);
5261 PerlIO_clearerr(f);
6f9d8c32
NIS
5262}
5263
5264#undef PerlIO_vprintf
5265int
5266PerlIO_vprintf(PerlIO *f, const char *fmt, va_list ap)
5267{
14a5cf38 5268 dTHX;
53ce71d3 5269 SV * sv;
b83604b4 5270 const char *s;
14a5cf38
JH
5271 STRLEN len;
5272 SSize_t wrote;
2cc61e15 5273#ifdef NEED_VA_COPY
14a5cf38
JH
5274 va_list apc;
5275 Perl_va_copy(ap, apc);
53ce71d3 5276 sv = vnewSVpvf(fmt, &apc);
2cc61e15 5277#else
53ce71d3 5278 sv = vnewSVpvf(fmt, &ap);
2cc61e15 5279#endif
b83604b4 5280 s = SvPV_const(sv, len);
14a5cf38
JH
5281 wrote = PerlIO_write(f, s, len);
5282 SvREFCNT_dec(sv);
5283 return wrote;
760ac839
LW
5284}
5285
5286#undef PerlIO_printf
6f9d8c32 5287int
14a5cf38 5288PerlIO_printf(PerlIO *f, const char *fmt, ...)
760ac839 5289{
14a5cf38
JH
5290 va_list ap;
5291 int result;
5292 va_start(ap, fmt);
5293 result = PerlIO_vprintf(f, fmt, ap);
5294 va_end(ap);
5295 return result;
760ac839
LW
5296}
5297
5298#undef PerlIO_stdoutf
6f9d8c32 5299int
14a5cf38 5300PerlIO_stdoutf(const char *fmt, ...)
760ac839 5301{
e87a358a 5302 dTHX;
14a5cf38
JH
5303 va_list ap;
5304 int result;
5305 va_start(ap, fmt);
5306 result = PerlIO_vprintf(PerlIO_stdout(), fmt, ap);
5307 va_end(ap);
5308 return result;
760ac839
LW
5309}
5310
5311#undef PerlIO_tmpfile
5312PerlIO *
c78749f2 5313PerlIO_tmpfile(void)
760ac839 5314{
2941a2e1
JH
5315 dTHX;
5316 PerlIO *f = NULL;
2941a2e1 5317#ifdef WIN32
de009b76 5318 const int fd = win32_tmpfd();
2941a2e1
JH
5319 if (fd >= 0)
5320 f = PerlIO_fdopen(fd, "w+b");
5321#else /* WIN32 */
460c8493 5322# if defined(HAS_MKSTEMP) && ! defined(VMS) && ! defined(OS2)
0b99e986
RGS
5323 int fd = -1;
5324 char tempname[] = "/tmp/PerlIO_XXXXXX";
5325 const char * const tmpdir = PL_tainting ? NULL : PerlEnv_getenv("TMPDIR");
525f6fe9 5326 SV * sv = NULL;
2941a2e1
JH
5327 /*
5328 * I have no idea how portable mkstemp() is ... NI-S
5329 */
7299ca58 5330 if (tmpdir && *tmpdir) {
0b99e986 5331 /* if TMPDIR is set and not empty, we try that first */
7299ca58 5332 sv = newSVpv(tmpdir, 0);
0b99e986
RGS
5333 sv_catpv(sv, tempname + 4);
5334 fd = mkstemp(SvPVX(sv));
5335 }
5336 if (fd < 0) {
7299ca58 5337 sv = NULL;
0b99e986
RGS
5338 /* else we try /tmp */
5339 fd = mkstemp(tempname);
5340 }
2941a2e1
JH
5341 if (fd >= 0) {
5342 f = PerlIO_fdopen(fd, "w+");
5343 if (f)
5344 PerlIOBase(f)->flags |= PERLIO_F_TEMP;
0b99e986 5345 PerlLIO_unlink(sv ? SvPVX_const(sv) : tempname);
2941a2e1 5346 }
ef8d46e8 5347 SvREFCNT_dec(sv);
2941a2e1 5348# else /* !HAS_MKSTEMP, fallback to stdio tmpfile(). */
c4420975 5349 FILE * const stdio = PerlSIO_tmpfile();
2941a2e1 5350
085e731f
CB
5351 if (stdio)
5352 f = PerlIO_fdopen(fileno(stdio), "w+");
5353
2941a2e1
JH
5354# endif /* else HAS_MKSTEMP */
5355#endif /* else WIN32 */
5356 return f;
760ac839
LW
5357}
5358
6f9d8c32
NIS
5359#undef HAS_FSETPOS
5360#undef HAS_FGETPOS
5361
22569500
NIS
5362#endif /* USE_SFIO */
5363#endif /* PERLIO_IS_STDIO */
760ac839 5364
9e353e3b 5365/*======================================================================================*/
14a5cf38 5366/*
71200d45
NIS
5367 * Now some functions in terms of above which may be needed even if we are
5368 * not in true PerlIO mode
9e353e3b 5369 */
188f0c84
YO
5370const char *
5371Perl_PerlIO_context_layers(pTHX_ const char *mode)
5372{
5373 dVAR;
8b850bd5
NC
5374 const char *direction = NULL;
5375 SV *layers;
188f0c84
YO
5376 /*
5377 * Need to supply default layer info from open.pm
5378 */
8b850bd5
NC
5379
5380 if (!PL_curcop)
5381 return NULL;
5382
5383 if (mode && mode[0] != 'r') {
5384 if (PL_curcop->cop_hints & HINT_LEXICAL_IO_OUT)
5385 direction = "open>";
5386 } else {
5387 if (PL_curcop->cop_hints & HINT_LEXICAL_IO_IN)
5388 direction = "open<";
188f0c84 5389 }
8b850bd5
NC
5390 if (!direction)
5391 return NULL;
5392
20439bc7 5393 layers = cop_hints_fetch_pvn(PL_curcop, direction, 5, 0, 0);
8b850bd5
NC
5394
5395 assert(layers);
5396 return SvOK(layers) ? SvPV_nolen_const(layers) : NULL;
188f0c84
YO
5397}
5398
9e353e3b 5399
760ac839
LW
5400#ifndef HAS_FSETPOS
5401#undef PerlIO_setpos
5402int
766a733e 5403PerlIO_setpos(PerlIO *f, SV *pos)
760ac839 5404{
14a5cf38
JH
5405 dTHX;
5406 if (SvOK(pos)) {
5407 STRLEN len;
c4420975 5408 const Off_t * const posn = (Off_t *) SvPV(pos, len);
14a5cf38
JH
5409 if (f && len == sizeof(Off_t))
5410 return PerlIO_seek(f, *posn, SEEK_SET);
5411 }
93189314 5412 SETERRNO(EINVAL, SS_IVCHAN);
14a5cf38 5413 return -1;
760ac839 5414}
c411622e 5415#else
c411622e 5416#undef PerlIO_setpos
5417int
766a733e 5418PerlIO_setpos(PerlIO *f, SV *pos)
c411622e 5419{
14a5cf38
JH
5420 dTHX;
5421 if (SvOK(pos)) {
5422 STRLEN len;
c4420975 5423 Fpos_t * const fpos = (Fpos_t *) SvPV(pos, len);
14a5cf38 5424 if (f && len == sizeof(Fpos_t)) {
2d4389e4 5425#if defined(USE_64_BIT_STDIO) && defined(USE_FSETPOS64)
14a5cf38 5426 return fsetpos64(f, fpos);
d9b3e12d 5427#else
14a5cf38 5428 return fsetpos(f, fpos);
d9b3e12d 5429#endif
14a5cf38 5430 }
766a733e 5431 }
93189314 5432 SETERRNO(EINVAL, SS_IVCHAN);
14a5cf38 5433 return -1;
c411622e 5434}
5435#endif
760ac839
LW
5436
5437#ifndef HAS_FGETPOS
5438#undef PerlIO_getpos
5439int
766a733e 5440PerlIO_getpos(PerlIO *f, SV *pos)
760ac839 5441{
14a5cf38
JH
5442 dTHX;
5443 Off_t posn = PerlIO_tell(f);
5444 sv_setpvn(pos, (char *) &posn, sizeof(posn));
5445 return (posn == (Off_t) - 1) ? -1 : 0;
760ac839 5446}
c411622e 5447#else
c411622e 5448#undef PerlIO_getpos
5449int
766a733e 5450PerlIO_getpos(PerlIO *f, SV *pos)
c411622e 5451{
14a5cf38
JH
5452 dTHX;
5453 Fpos_t fpos;
5454 int code;
2d4389e4 5455#if defined(USE_64_BIT_STDIO) && defined(USE_FSETPOS64)
14a5cf38 5456 code = fgetpos64(f, &fpos);
d9b3e12d 5457#else
14a5cf38 5458 code = fgetpos(f, &fpos);
d9b3e12d 5459#endif
14a5cf38
JH
5460 sv_setpvn(pos, (char *) &fpos, sizeof(fpos));
5461 return code;
c411622e 5462}
5463#endif
760ac839
LW
5464
5465#if (defined(PERLIO_IS_STDIO) || !defined(USE_SFIO)) && !defined(HAS_VPRINTF)
5466
5467int
c78749f2 5468vprintf(char *pat, char *args)
662a7e3f
CS
5469{
5470 _doprnt(pat, args, stdout);
22569500 5471 return 0; /* wrong, but perl doesn't use the return
14a5cf38 5472 * value */
662a7e3f
CS
5473}
5474
5475int
c78749f2 5476vfprintf(FILE *fd, char *pat, char *args)
760ac839
LW
5477{
5478 _doprnt(pat, args, fd);
22569500 5479 return 0; /* wrong, but perl doesn't use the return
14a5cf38 5480 * value */
760ac839
LW
5481}
5482
5483#endif
5484
5485#ifndef PerlIO_vsprintf
6f9d8c32 5486int
8ac85365 5487PerlIO_vsprintf(char *s, int n, const char *fmt, va_list ap)
760ac839 5488{
8ff9a42b 5489 dTHX;
d9fad198 5490 const int val = my_vsnprintf(s, n > 0 ? n : 0, fmt, ap);
14333449
AL
5491 PERL_UNUSED_CONTEXT;
5492
1208b3dd
JH
5493#ifndef PERL_MY_VSNPRINTF_GUARDED
5494 if (val < 0 || (n > 0 ? val >= n : 0)) {
37405f90 5495 Perl_croak(aTHX_ "panic: my_vsnprintf overflow in PerlIO_vsprintf\n");
760ac839 5496 }
1208b3dd 5497#endif
14a5cf38 5498 return val;
760ac839
LW
5499}
5500#endif
5501
5502#ifndef PerlIO_sprintf
6f9d8c32 5503int
14a5cf38 5504PerlIO_sprintf(char *s, int n, const char *fmt, ...)
760ac839 5505{
14a5cf38
JH
5506 va_list ap;
5507 int result;
5508 va_start(ap, fmt);
5509 result = PerlIO_vsprintf(s, n, fmt, ap);
5510 va_end(ap);
5511 return result;
760ac839
LW
5512}
5513#endif
9cfa90c0
NC
5514
5515/*
5516 * Local variables:
5517 * c-indentation-style: bsd
5518 * c-basic-offset: 4
5519 * indent-tabs-mode: t
5520 * End:
5521 *
37442d52
RGS
5522 * ex: set ts=8 sts=4 sw=4 noet:
5523 */