This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
regexec.c: Fix /a complements
[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,
1163 NULL,
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
dfebf958 1318IV
86e05cf2
NIS
1319PerlIOBase_binmode(pTHX_ PerlIO *f)
1320{
1321 if (PerlIOValid(f)) {
1322 /* Is layer suitable for raw stream ? */
cc6623a8 1323 if (PerlIOBase(f)->tab && PerlIOBase(f)->tab->kind & PERLIO_K_RAW) {
86e05cf2
NIS
1324 /* Yes - turn off UTF-8-ness, to undo UTF-8 locale effects */
1325 PerlIOBase(f)->flags &= ~PERLIO_F_UTF8;
1326 }
1327 else {
1328 /* Not suitable - pop it */
1329 PerlIO_pop(aTHX_ f);
1330 }
1331 return 0;
1332 }
1333 return -1;
1334}
1335
1336IV
2dc2558e 1337PerlIORaw_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
dfebf958 1338{
8772537c
AL
1339 PERL_UNUSED_ARG(mode);
1340 PERL_UNUSED_ARG(arg);
1341 PERL_UNUSED_ARG(tab);
86e05cf2 1342
04892f78 1343 if (PerlIOValid(f)) {
86e05cf2 1344 PerlIO *t;
de009b76 1345 const PerlIOl *l;
14a5cf38 1346 PerlIO_flush(f);
86e05cf2
NIS
1347 /*
1348 * Strip all layers that are not suitable for a raw stream
1349 */
1350 t = f;
1351 while (t && (l = *t)) {
cc6623a8 1352 if (l->tab && l->tab->Binmode) {
86e05cf2 1353 /* Has a handler - normal case */
9d97e8b8 1354 if ((*l->tab->Binmode)(aTHX_ t) == 0) {
86e05cf2
NIS
1355 if (*t == l) {
1356 /* Layer still there - move down a layer */
1357 t = PerlIONext(t);
1358 }
1359 }
1360 else {
1361 return -1;
1362 }
14a5cf38
JH
1363 }
1364 else {
86e05cf2
NIS
1365 /* No handler - pop it */
1366 PerlIO_pop(aTHX_ t);
14a5cf38
JH
1367 }
1368 }
86e05cf2 1369 if (PerlIOValid(f)) {
cc6623a8
DM
1370 PerlIO_debug(":raw f=%p :%s\n", (void*)f,
1371 PerlIOBase(f)->tab ? PerlIOBase(f)->tab->name : "(Null)");
86e05cf2
NIS
1372 return 0;
1373 }
14a5cf38
JH
1374 }
1375 return -1;
dfebf958
NIS
1376}
1377
ac27b0f5 1378int
14a5cf38 1379PerlIO_apply_layera(pTHX_ PerlIO *f, const char *mode,
d9dac8cd 1380 PerlIO_list_t *layers, IV n, IV max)
14a5cf38 1381{
14a5cf38
JH
1382 int code = 0;
1383 while (n < max) {
8772537c 1384 PerlIO_funcs * const tab = PerlIO_layer_fetch(aTHX_ layers, n, NULL);
14a5cf38
JH
1385 if (tab) {
1386 if (!PerlIO_push(aTHX_ f, tab, mode, PerlIOArg)) {
1387 code = -1;
1388 break;
1389 }
1390 }
1391 n++;
1392 }
1393 return code;
e3f3bf95
NIS
1394}
1395
1396int
ac27b0f5
NIS
1397PerlIO_apply_layers(pTHX_ PerlIO *f, const char *mode, const char *names)
1398{
14a5cf38 1399 int code = 0;
da0fccaa
DG
1400 ENTER;
1401 save_scalar(PL_errgv);
53f1b6d2 1402 if (f && names) {
8772537c 1403 PerlIO_list_t * const layers = PerlIO_list_alloc(aTHX);
14a5cf38
JH
1404 code = PerlIO_parse_layers(aTHX_ layers, names);
1405 if (code == 0) {
d9dac8cd 1406 code = PerlIO_apply_layera(aTHX_ f, mode, layers, 0, layers->cur);
14a5cf38 1407 }
3a1ee7e8 1408 PerlIO_list_free(aTHX_ layers);
ac27b0f5 1409 }
da0fccaa 1410 LEAVE;
14a5cf38 1411 return code;
ac27b0f5
NIS
1412}
1413
f3862f8b 1414
60382766 1415/*--------------------------------------------------------------------------------------*/
14a5cf38 1416/*
71200d45 1417 * Given the abstraction above the public API functions
14a5cf38 1418 */
60382766
NIS
1419
1420int
f5b9d040 1421PerlIO_binmode(pTHX_ PerlIO *f, int iotype, int mode, const char *names)
76ced9ad 1422{
68b5363f 1423 PerlIO_debug("PerlIO_binmode f=%p %s %c %x %s\n", (void*)f,
cc6623a8
DM
1424 (PerlIOBase(f) && PerlIOBase(f)->tab) ?
1425 PerlIOBase(f)->tab->name : "(Null)",
68b5363f
PD
1426 iotype, mode, (names) ? names : "(Null)");
1427
03c0554d
NIS
1428 if (names) {
1429 /* Do not flush etc. if (e.g.) switching encodings.
1430 if a pushed layer knows it needs to flush lower layers
1431 (for example :unix which is never going to call them)
1432 it can do the flush when it is pushed.
1433 */
1434 return PerlIO_apply_layers(aTHX_ f, NULL, names) == 0 ? TRUE : FALSE;
1435 }
1436 else {
86e05cf2 1437 /* Fake 5.6 legacy of using this call to turn ON O_TEXT */
35990314 1438#ifdef PERLIO_USING_CRLF
03c0554d
NIS
1439 /* Legacy binmode only has meaning if O_TEXT has a value distinct from
1440 O_BINARY so we can look for it in mode.
1441 */
1442 if (!(mode & O_BINARY)) {
1443 /* Text mode */
86e05cf2
NIS
1444 /* FIXME?: Looking down the layer stack seems wrong,
1445 but is a way of reaching past (say) an encoding layer
1446 to flip CRLF-ness of the layer(s) below
1447 */
03c0554d
NIS
1448 while (*f) {
1449 /* Perhaps we should turn on bottom-most aware layer
1450 e.g. Ilya's idea that UNIX TTY could serve
1451 */
cc6623a8
DM
1452 if (PerlIOBase(f)->tab &&
1453 PerlIOBase(f)->tab->kind & PERLIO_K_CANCRLF)
1454 {
03c0554d
NIS
1455 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF)) {
1456 /* Not in text mode - flush any pending stuff and flip it */
1457 PerlIO_flush(f);
1458 PerlIOBase(f)->flags |= PERLIO_F_CRLF;
1459 }
1460 /* Only need to turn it on in one layer so we are done */
1461 return TRUE;
ed53a2bb 1462 }
03c0554d 1463 f = PerlIONext(f);
14a5cf38 1464 }
03c0554d
NIS
1465 /* Not finding a CRLF aware layer presumably means we are binary
1466 which is not what was requested - so we failed
1467 We _could_ push :crlf layer but so could caller
1468 */
1469 return FALSE;
14a5cf38 1470 }
6ce75a77 1471#endif
86e05cf2
NIS
1472 /* Legacy binmode is now _defined_ as being equivalent to pushing :raw
1473 So code that used to be here is now in PerlIORaw_pushed().
03c0554d 1474 */
a0714e2c 1475 return PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_raw), NULL, NULL) ? TRUE : FALSE;
14a5cf38 1476 }
f5b9d040
NIS
1477}
1478
f5b9d040 1479int
e87a358a 1480PerlIO__close(pTHX_ PerlIO *f)
f5b9d040 1481{
37725cdc 1482 if (PerlIOValid(f)) {
46c461b5 1483 PerlIO_funcs * const tab = PerlIOBase(f)->tab;
37725cdc
NIS
1484 if (tab && tab->Close)
1485 return (*tab->Close)(aTHX_ f);
1486 else
1487 return PerlIOBase_close(aTHX_ f);
1488 }
14a5cf38 1489 else {
93189314 1490 SETERRNO(EBADF, SS_IVCHAN);
14a5cf38
JH
1491 return -1;
1492 }
76ced9ad
NIS
1493}
1494
b931b1d9 1495int
e87a358a 1496Perl_PerlIO_close(pTHX_ PerlIO *f)
b931b1d9 1497{
de009b76 1498 const int code = PerlIO__close(aTHX_ f);
37725cdc
NIS
1499 while (PerlIOValid(f)) {
1500 PerlIO_pop(aTHX_ f);
abf9167d
DM
1501 if (PerlIO_lockcnt(f))
1502 /* we're in use; the 'pop' deferred freeing the structure */
1503 f = PerlIONext(f);
f6c77cf1 1504 }
14a5cf38 1505 return code;
b931b1d9
NIS
1506}
1507
b931b1d9 1508int
e87a358a 1509Perl_PerlIO_fileno(pTHX_ PerlIO *f)
b931b1d9 1510{
97aff369 1511 dVAR;
b32dd47e 1512 Perl_PerlIO_or_Base(f, Fileno, fileno, -1, (aTHX_ f));
b931b1d9
NIS
1513}
1514
1141d9f8 1515
fcf2db38 1516static PerlIO_funcs *
2edd7e44
NIS
1517PerlIO_layer_from_ref(pTHX_ SV *sv)
1518{
97aff369 1519 dVAR;
14a5cf38 1520 /*
71200d45 1521 * For any scalar type load the handler which is bundled with perl
14a5cf38 1522 */
526fd1b4 1523 if (SvTYPE(sv) < SVt_PVAV && (!isGV_with_GP(sv) || SvFAKE(sv))) {
75208dda
RGS
1524 PerlIO_funcs *f = PerlIO_find_layer(aTHX_ STR_WITH_LEN("scalar"), 1);
1525 /* This isn't supposed to happen, since PerlIO::scalar is core,
1526 * but could happen anyway in smaller installs or with PAR */
a2a5de95
NC
1527 if (!f)
1528 Perl_ck_warner(aTHX_ packWARN(WARN_LAYER), "Unknown PerlIO layer \"scalar\"");
75208dda
RGS
1529 return f;
1530 }
14a5cf38
JH
1531
1532 /*
71200d45 1533 * For other types allow if layer is known but don't try and load it
14a5cf38
JH
1534 */
1535 switch (SvTYPE(sv)) {
1536 case SVt_PVAV:
6a245ed1 1537 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Array"), 0);
14a5cf38 1538 case SVt_PVHV:
6a245ed1 1539 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Hash"), 0);
14a5cf38 1540 case SVt_PVCV:
6a245ed1 1541 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Code"), 0);
14a5cf38 1542 case SVt_PVGV:
6a245ed1 1543 return PerlIO_find_layer(aTHX_ STR_WITH_LEN("Glob"), 0);
42d0e0b7
AL
1544 default:
1545 return NULL;
14a5cf38 1546 }
2edd7e44
NIS
1547}
1548
fcf2db38 1549PerlIO_list_t *
14a5cf38
JH
1550PerlIO_resolve_layers(pTHX_ const char *layers,
1551 const char *mode, int narg, SV **args)
1552{
97aff369 1553 dVAR;
14a5cf38
JH
1554 PerlIO_list_t *def = PerlIO_default_layers(aTHX);
1555 int incdef = 1;
a1ea730d 1556 if (!PL_perlio)
14a5cf38
JH
1557 PerlIO_stdstreams(aTHX);
1558 if (narg) {
dcda55fc 1559 SV * const arg = *args;
14a5cf38 1560 /*
71200d45
NIS
1561 * If it is a reference but not an object see if we have a handler
1562 * for it
14a5cf38
JH
1563 */
1564 if (SvROK(arg) && !sv_isobject(arg)) {
46c461b5 1565 PerlIO_funcs * const handler = PerlIO_layer_from_ref(aTHX_ SvRV(arg));
14a5cf38 1566 if (handler) {
3a1ee7e8
NIS
1567 def = PerlIO_list_alloc(aTHX);
1568 PerlIO_list_push(aTHX_ def, handler, &PL_sv_undef);
14a5cf38
JH
1569 incdef = 0;
1570 }
1571 /*
e934609f 1572 * Don't fail if handler cannot be found :via(...) etc. may do
14a5cf38 1573 * something sensible else we will just stringfy and open
71200d45 1574 * resulting string.
14a5cf38
JH
1575 */
1576 }
1577 }
9fe371da 1578 if (!layers || !*layers)
11bcd5da 1579 layers = Perl_PerlIO_context_layers(aTHX_ mode);
14a5cf38
JH
1580 if (layers && *layers) {
1581 PerlIO_list_t *av;
1582 if (incdef) {
a951d81d 1583 av = PerlIO_clone_list(aTHX_ def, NULL);
14a5cf38
JH
1584 }
1585 else {
1586 av = def;
1587 }
0cff2cf3
NIS
1588 if (PerlIO_parse_layers(aTHX_ av, layers) == 0) {
1589 return av;
1590 }
1591 else {
1592 PerlIO_list_free(aTHX_ av);
b37c2d43 1593 return NULL;
0cff2cf3 1594 }
14a5cf38
JH
1595 }
1596 else {
1597 if (incdef)
1598 def->refcnt++;
1599 return def;
1600 }
ee518936
NIS
1601}
1602
1603PerlIO *
14a5cf38
JH
1604PerlIO_openn(pTHX_ const char *layers, const char *mode, int fd,
1605 int imode, int perm, PerlIO *f, int narg, SV **args)
1606{
97aff369 1607 dVAR;
14a5cf38
JH
1608 if (!f && narg == 1 && *args == &PL_sv_undef) {
1609 if ((f = PerlIO_tmpfile())) {
9fe371da 1610 if (!layers || !*layers)
11bcd5da 1611 layers = Perl_PerlIO_context_layers(aTHX_ mode);
14a5cf38
JH
1612 if (layers && *layers)
1613 PerlIO_apply_layers(aTHX_ f, mode, layers);
1614 }
1615 }
1616 else {
de009b76 1617 PerlIO_list_t *layera;
14a5cf38
JH
1618 IV n;
1619 PerlIO_funcs *tab = NULL;
04892f78 1620 if (PerlIOValid(f)) {
14a5cf38 1621 /*
71200d45
NIS
1622 * This is "reopen" - it is not tested as perl does not use it
1623 * yet
14a5cf38
JH
1624 */
1625 PerlIOl *l = *f;
3a1ee7e8 1626 layera = PerlIO_list_alloc(aTHX);
14a5cf38 1627 while (l) {
a951d81d 1628 SV *arg = NULL;
cc6623a8 1629 if (l->tab && l->tab->Getarg)
a951d81d
BL
1630 arg = (*l->tab->Getarg) (aTHX_ &l, NULL, 0);
1631 PerlIO_list_push(aTHX_ layera, l->tab,
1632 (arg) ? arg : &PL_sv_undef);
ef8d46e8 1633 SvREFCNT_dec(arg);
14a5cf38
JH
1634 l = *PerlIONext(&l);
1635 }
1636 }
1637 else {
1638 layera = PerlIO_resolve_layers(aTHX_ layers, mode, narg, args);
0cff2cf3
NIS
1639 if (!layera) {
1640 return NULL;
1641 }
14a5cf38
JH
1642 }
1643 /*
71200d45 1644 * Start at "top" of layer stack
14a5cf38
JH
1645 */
1646 n = layera->cur - 1;
1647 while (n >= 0) {
46c461b5 1648 PerlIO_funcs * const t = PerlIO_layer_fetch(aTHX_ layera, n, NULL);
14a5cf38
JH
1649 if (t && t->Open) {
1650 tab = t;
1651 break;
1652 }
1653 n--;
1654 }
1655 if (tab) {
1656 /*
71200d45 1657 * Found that layer 'n' can do opens - call it
14a5cf38 1658 */
7cf31beb 1659 if (narg > 1 && !(tab->kind & PERLIO_K_MULTIARG)) {
3b8752bb 1660 Perl_croak(aTHX_ "More than one argument to open(,':%s')",tab->name);
7cf31beb 1661 }
14a5cf38 1662 PerlIO_debug("openn(%s,'%s','%s',%d,%x,%o,%p,%d,%p)\n",
355d3743
PD
1663 tab->name, layers ? layers : "(Null)", mode, fd,
1664 imode, perm, (void*)f, narg, (void*)args);
210e727c
JH
1665 if (tab->Open)
1666 f = (*tab->Open) (aTHX_ tab, layera, n, mode, fd, imode, perm,
1667 f, narg, args);
1668 else {
1669 SETERRNO(EINVAL, LIB_INVARG);
1670 f = NULL;
1671 }
14a5cf38
JH
1672 if (f) {
1673 if (n + 1 < layera->cur) {
1674 /*
1675 * More layers above the one that we used to open -
71200d45 1676 * apply them now
14a5cf38 1677 */
d9dac8cd
NIS
1678 if (PerlIO_apply_layera(aTHX_ f, mode, layera, n + 1, layera->cur) != 0) {
1679 /* If pushing layers fails close the file */
1680 PerlIO_close(f);
14a5cf38
JH
1681 f = NULL;
1682 }
1683 }
1684 }
1685 }
3a1ee7e8 1686 PerlIO_list_free(aTHX_ layera);
14a5cf38
JH
1687 }
1688 return f;
ee518936 1689}
b931b1d9
NIS
1690
1691
9e353e3b 1692SSize_t
e87a358a 1693Perl_PerlIO_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
6f9d8c32 1694{
7918f24d
NC
1695 PERL_ARGS_ASSERT_PERLIO_READ;
1696
b32dd47e 1697 Perl_PerlIO_or_Base(f, Read, read, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1698}
1699
313ca112 1700SSize_t
e87a358a 1701Perl_PerlIO_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 1702{
7918f24d
NC
1703 PERL_ARGS_ASSERT_PERLIO_UNREAD;
1704
b32dd47e 1705 Perl_PerlIO_or_Base(f, Unread, unread, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1706}
1707
9e353e3b 1708SSize_t
e87a358a 1709Perl_PerlIO_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 1710{
7918f24d
NC
1711 PERL_ARGS_ASSERT_PERLIO_WRITE;
1712
b32dd47e 1713 Perl_PerlIO_or_fail(f, Write, -1, (aTHX_ f, vbuf, count));
760ac839
LW
1714}
1715
6f9d8c32 1716int
e87a358a 1717Perl_PerlIO_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
760ac839 1718{
b32dd47e 1719 Perl_PerlIO_or_fail(f, Seek, -1, (aTHX_ f, offset, whence));
760ac839
LW
1720}
1721
9e353e3b 1722Off_t
e87a358a 1723Perl_PerlIO_tell(pTHX_ PerlIO *f)
760ac839 1724{
b32dd47e 1725 Perl_PerlIO_or_fail(f, Tell, -1, (aTHX_ f));
760ac839
LW
1726}
1727
6f9d8c32 1728int
e87a358a 1729Perl_PerlIO_flush(pTHX_ PerlIO *f)
760ac839 1730{
97aff369 1731 dVAR;
14a5cf38
JH
1732 if (f) {
1733 if (*f) {
de009b76 1734 const PerlIO_funcs *tab = PerlIOBase(f)->tab;
1b7a0411
JH
1735
1736 if (tab && tab->Flush)
f62ce20a 1737 return (*tab->Flush) (aTHX_ f);
1b7a0411
JH
1738 else
1739 return 0; /* If no Flush defined, silently succeed. */
14a5cf38
JH
1740 }
1741 else {
fe5a182c 1742 PerlIO_debug("Cannot flush f=%p\n", (void*)f);
93189314 1743 SETERRNO(EBADF, SS_IVCHAN);
14a5cf38
JH
1744 return -1;
1745 }
1746 }
1747 else {
1748 /*
1749 * Is it good API design to do flush-all on NULL, a potentially
486ec47a 1750 * erroneous input? Maybe some magical value (PerlIO*
14a5cf38
JH
1751 * PERLIO_FLUSH_ALL = (PerlIO*)-1;)? Yes, stdio does similar
1752 * things on fflush(NULL), but should we be bound by their design
71200d45 1753 * decisions? --jhi
14a5cf38 1754 */
303f2dc3
DM
1755 PerlIOl **table = &PL_perlio;
1756 PerlIOl *ff;
14a5cf38 1757 int code = 0;
303f2dc3 1758 while ((ff = *table)) {
14a5cf38 1759 int i;
303f2dc3 1760 table = (PerlIOl **) (ff++);
14a5cf38 1761 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3 1762 if (ff->next && PerlIO_flush(&(ff->next)) != 0)
14a5cf38 1763 code = -1;
303f2dc3 1764 ff++;
14a5cf38
JH
1765 }
1766 }
1767 return code;
1768 }
760ac839
LW
1769}
1770
a9c883f6 1771void
f62ce20a 1772PerlIOBase_flush_linebuf(pTHX)
a9c883f6 1773{
97aff369 1774 dVAR;
303f2dc3
DM
1775 PerlIOl **table = &PL_perlio;
1776 PerlIOl *f;
14a5cf38
JH
1777 while ((f = *table)) {
1778 int i;
303f2dc3 1779 table = (PerlIOl **) (f++);
14a5cf38 1780 for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
303f2dc3
DM
1781 if (f->next
1782 && (PerlIOBase(&(f->next))->
14a5cf38
JH
1783 flags & (PERLIO_F_LINEBUF | PERLIO_F_CANWRITE))
1784 == (PERLIO_F_LINEBUF | PERLIO_F_CANWRITE))
303f2dc3 1785 PerlIO_flush(&(f->next));
14a5cf38
JH
1786 f++;
1787 }
a9c883f6 1788 }
a9c883f6
NIS
1789}
1790
06da4f11 1791int
e87a358a 1792Perl_PerlIO_fill(pTHX_ PerlIO *f)
06da4f11 1793{
b32dd47e 1794 Perl_PerlIO_or_fail(f, Fill, -1, (aTHX_ f));
06da4f11
NIS
1795}
1796
f3862f8b
NIS
1797int
1798PerlIO_isutf8(PerlIO *f)
1799{
1b7a0411
JH
1800 if (PerlIOValid(f))
1801 return (PerlIOBase(f)->flags & PERLIO_F_UTF8) != 0;
1802 else
1803 SETERRNO(EBADF, SS_IVCHAN);
37725cdc 1804
1b7a0411 1805 return -1;
f3862f8b
NIS
1806}
1807
6f9d8c32 1808int
e87a358a 1809Perl_PerlIO_eof(pTHX_ PerlIO *f)
760ac839 1810{
b32dd47e 1811 Perl_PerlIO_or_Base(f, Eof, eof, -1, (aTHX_ f));
9e353e3b
NIS
1812}
1813
9e353e3b 1814int
e87a358a 1815Perl_PerlIO_error(pTHX_ PerlIO *f)
9e353e3b 1816{
b32dd47e 1817 Perl_PerlIO_or_Base(f, Error, error, -1, (aTHX_ f));
9e353e3b
NIS
1818}
1819
9e353e3b 1820void
e87a358a 1821Perl_PerlIO_clearerr(pTHX_ PerlIO *f)
9e353e3b 1822{
b32dd47e 1823 Perl_PerlIO_or_Base_void(f, Clearerr, clearerr, (aTHX_ f));
9e353e3b
NIS
1824}
1825
9e353e3b 1826void
e87a358a 1827Perl_PerlIO_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 1828{
b32dd47e 1829 Perl_PerlIO_or_Base_void(f, Setlinebuf, setlinebuf, (aTHX_ f));
9e353e3b
NIS
1830}
1831
9e353e3b
NIS
1832int
1833PerlIO_has_base(PerlIO *f)
1834{
1b7a0411 1835 if (PerlIOValid(f)) {
46c461b5 1836 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1837
1838 if (tab)
1839 return (tab->Get_base != NULL);
1b7a0411 1840 }
1b7a0411
JH
1841
1842 return 0;
760ac839
LW
1843}
1844
9e353e3b
NIS
1845int
1846PerlIO_fast_gets(PerlIO *f)
760ac839 1847{
d7dfc388
SK
1848 if (PerlIOValid(f)) {
1849 if (PerlIOBase(f)->flags & PERLIO_F_FASTGETS) {
1850 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411 1851
d7dfc388
SK
1852 if (tab)
1853 return (tab->Set_ptrcnt != NULL);
d7dfc388 1854 }
14a5cf38 1855 }
1b7a0411 1856
14a5cf38 1857 return 0;
9e353e3b
NIS
1858}
1859
9e353e3b
NIS
1860int
1861PerlIO_has_cntptr(PerlIO *f)
1862{
04892f78 1863 if (PerlIOValid(f)) {
46c461b5 1864 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1865
1866 if (tab)
1867 return (tab->Get_ptr != NULL && tab->Get_cnt != NULL);
14a5cf38 1868 }
1b7a0411 1869
14a5cf38 1870 return 0;
9e353e3b
NIS
1871}
1872
9e353e3b
NIS
1873int
1874PerlIO_canset_cnt(PerlIO *f)
1875{
04892f78 1876 if (PerlIOValid(f)) {
46c461b5 1877 const PerlIO_funcs * const tab = PerlIOBase(f)->tab;
1b7a0411
JH
1878
1879 if (tab)
1880 return (tab->Set_ptrcnt != NULL);
14a5cf38 1881 }
1b7a0411 1882
14a5cf38 1883 return 0;
760ac839
LW
1884}
1885
888911fc 1886STDCHAR *
e87a358a 1887Perl_PerlIO_get_base(pTHX_ PerlIO *f)
760ac839 1888{
b32dd47e 1889 Perl_PerlIO_or_fail(f, Get_base, NULL, (aTHX_ f));
9e353e3b
NIS
1890}
1891
9e353e3b 1892int
e87a358a 1893Perl_PerlIO_get_bufsiz(pTHX_ PerlIO *f)
9e353e3b 1894{
b32dd47e 1895 Perl_PerlIO_or_fail(f, Get_bufsiz, -1, (aTHX_ f));
9e353e3b
NIS
1896}
1897
9e353e3b 1898STDCHAR *
e87a358a 1899Perl_PerlIO_get_ptr(pTHX_ PerlIO *f)
9e353e3b 1900{
b32dd47e 1901 Perl_PerlIO_or_fail(f, Get_ptr, NULL, (aTHX_ f));
9e353e3b
NIS
1902}
1903
05d1247b 1904int
e87a358a 1905Perl_PerlIO_get_cnt(pTHX_ PerlIO *f)
9e353e3b 1906{
b32dd47e 1907 Perl_PerlIO_or_fail(f, Get_cnt, -1, (aTHX_ f));
9e353e3b
NIS
1908}
1909
9e353e3b 1910void
e87a358a 1911Perl_PerlIO_set_cnt(pTHX_ PerlIO *f, int cnt)
9e353e3b 1912{
b32dd47e 1913 Perl_PerlIO_or_fail_void(f, Set_ptrcnt, (aTHX_ f, NULL, cnt));
9e353e3b
NIS
1914}
1915
9e353e3b 1916void
e87a358a 1917Perl_PerlIO_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, int cnt)
9e353e3b 1918{
b32dd47e 1919 Perl_PerlIO_or_fail_void(f, Set_ptrcnt, (aTHX_ f, ptr, cnt));
9e353e3b
NIS
1920}
1921
4ec2216f 1922
9e353e3b 1923/*--------------------------------------------------------------------------------------*/
14a5cf38 1924/*
71200d45 1925 * utf8 and raw dummy layers
14a5cf38 1926 */
dfebf958 1927
26fb694e 1928IV
2dc2558e 1929PerlIOUtf8_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
26fb694e 1930{
96a5add6 1931 PERL_UNUSED_CONTEXT;
8772537c
AL
1932 PERL_UNUSED_ARG(mode);
1933 PERL_UNUSED_ARG(arg);
00f51856 1934 if (PerlIOValid(f)) {
cc6623a8 1935 if (tab && tab->kind & PERLIO_K_UTF8)
14a5cf38
JH
1936 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
1937 else
1938 PerlIOBase(f)->flags &= ~PERLIO_F_UTF8;
1939 return 0;
1940 }
1941 return -1;
26fb694e
NIS
1942}
1943
27da23d5 1944PERLIO_FUNCS_DECL(PerlIO_utf8) = {
2dc2558e 1945 sizeof(PerlIO_funcs),
14a5cf38 1946 "utf8",
2dc2558e 1947 0,
6874a2de 1948 PERLIO_K_DUMMY | PERLIO_K_UTF8,
14a5cf38
JH
1949 PerlIOUtf8_pushed,
1950 NULL,
1951 NULL,
1952 NULL,
1953 NULL,
1954 NULL,
1955 NULL,
1956 NULL,
1957 NULL,
1958 NULL,
1959 NULL,
de009b76
AL
1960 NULL,
1961 NULL,
22569500
NIS
1962 NULL, /* flush */
1963 NULL, /* fill */
14a5cf38
JH
1964 NULL,
1965 NULL,
1966 NULL,
1967 NULL,
22569500
NIS
1968 NULL, /* get_base */
1969 NULL, /* get_bufsiz */
1970 NULL, /* get_ptr */
1971 NULL, /* get_cnt */
1972 NULL, /* set_ptrcnt */
26fb694e
NIS
1973};
1974
27da23d5 1975PERLIO_FUNCS_DECL(PerlIO_byte) = {
2dc2558e 1976 sizeof(PerlIO_funcs),
14a5cf38 1977 "bytes",
2dc2558e 1978 0,
14a5cf38
JH
1979 PERLIO_K_DUMMY,
1980 PerlIOUtf8_pushed,
1981 NULL,
1982 NULL,
1983 NULL,
1984 NULL,
1985 NULL,
1986 NULL,
1987 NULL,
1988 NULL,
1989 NULL,
1990 NULL,
de009b76
AL
1991 NULL,
1992 NULL,
22569500
NIS
1993 NULL, /* flush */
1994 NULL, /* fill */
14a5cf38
JH
1995 NULL,
1996 NULL,
1997 NULL,
1998 NULL,
22569500
NIS
1999 NULL, /* get_base */
2000 NULL, /* get_bufsiz */
2001 NULL, /* get_ptr */
2002 NULL, /* get_cnt */
2003 NULL, /* set_ptrcnt */
dfebf958
NIS
2004};
2005
2006PerlIO *
14a5cf38
JH
2007PerlIORaw_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
2008 IV n, const char *mode, int fd, int imode, int perm,
2009 PerlIO *old, int narg, SV **args)
dfebf958 2010{
8772537c
AL
2011 PerlIO_funcs * const tab = PerlIO_default_btm();
2012 PERL_UNUSED_ARG(self);
210e727c
JH
2013 if (tab && tab->Open)
2014 return (*tab->Open) (aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
2015 old, narg, args);
2016 SETERRNO(EINVAL, LIB_INVARG);
2017 return NULL;
dfebf958
NIS
2018}
2019
27da23d5 2020PERLIO_FUNCS_DECL(PerlIO_raw) = {
2dc2558e 2021 sizeof(PerlIO_funcs),
14a5cf38 2022 "raw",
2dc2558e 2023 0,
14a5cf38
JH
2024 PERLIO_K_DUMMY,
2025 PerlIORaw_pushed,
2026 PerlIOBase_popped,
2027 PerlIORaw_open,
2028 NULL,
2029 NULL,
2030 NULL,
2031 NULL,
2032 NULL,
2033 NULL,
2034 NULL,
2035 NULL,
de009b76
AL
2036 NULL,
2037 NULL,
22569500
NIS
2038 NULL, /* flush */
2039 NULL, /* fill */
14a5cf38
JH
2040 NULL,
2041 NULL,
2042 NULL,
2043 NULL,
22569500
NIS
2044 NULL, /* get_base */
2045 NULL, /* get_bufsiz */
2046 NULL, /* get_ptr */
2047 NULL, /* get_cnt */
2048 NULL, /* set_ptrcnt */
dfebf958
NIS
2049};
2050/*--------------------------------------------------------------------------------------*/
2051/*--------------------------------------------------------------------------------------*/
14a5cf38 2052/*
71200d45 2053 * "Methods" of the "base class"
14a5cf38 2054 */
9e353e3b
NIS
2055
2056IV
f62ce20a 2057PerlIOBase_fileno(pTHX_ PerlIO *f)
9e353e3b 2058{
04892f78 2059 return PerlIOValid(f) ? PerlIO_fileno(PerlIONext(f)) : -1;
9e353e3b
NIS
2060}
2061
f5b9d040 2062char *
81428673 2063PerlIO_modestr(PerlIO * f, char *buf)
14a5cf38
JH
2064{
2065 char *s = buf;
81428673 2066 if (PerlIOValid(f)) {
de009b76 2067 const IV flags = PerlIOBase(f)->flags;
81428673
NIS
2068 if (flags & PERLIO_F_APPEND) {
2069 *s++ = 'a';
2070 if (flags & PERLIO_F_CANREAD) {
2071 *s++ = '+';
2072 }
14a5cf38 2073 }
81428673
NIS
2074 else if (flags & PERLIO_F_CANREAD) {
2075 *s++ = 'r';
2076 if (flags & PERLIO_F_CANWRITE)
2077 *s++ = '+';
2078 }
2079 else if (flags & PERLIO_F_CANWRITE) {
2080 *s++ = 'w';
2081 if (flags & PERLIO_F_CANREAD) {
2082 *s++ = '+';
2083 }
14a5cf38 2084 }
35990314 2085#ifdef PERLIO_USING_CRLF
81428673
NIS
2086 if (!(flags & PERLIO_F_CRLF))
2087 *s++ = 'b';
5f1a76d0 2088#endif
81428673 2089 }
14a5cf38
JH
2090 *s = '\0';
2091 return buf;
f5b9d040
NIS
2092}
2093
81428673 2094
76ced9ad 2095IV
2dc2558e 2096PerlIOBase_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
9e353e3b 2097{
de009b76 2098 PerlIOl * const l = PerlIOBase(f);
96a5add6 2099 PERL_UNUSED_CONTEXT;
8772537c 2100 PERL_UNUSED_ARG(arg);
de009b76 2101
14a5cf38
JH
2102 l->flags &= ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE |
2103 PERLIO_F_TRUNCATE | PERLIO_F_APPEND);
cc6623a8 2104 if (tab && tab->Set_ptrcnt != NULL)
14a5cf38
JH
2105 l->flags |= PERLIO_F_FASTGETS;
2106 if (mode) {
3b6c1aba 2107 if (*mode == IoTYPE_NUMERIC || *mode == IoTYPE_IMPLICIT)
14a5cf38
JH
2108 mode++;
2109 switch (*mode++) {
2110 case 'r':
2111 l->flags |= PERLIO_F_CANREAD;
2112 break;
2113 case 'a':
2114 l->flags |= PERLIO_F_APPEND | PERLIO_F_CANWRITE;
2115 break;
2116 case 'w':
2117 l->flags |= PERLIO_F_TRUNCATE | PERLIO_F_CANWRITE;
2118 break;
2119 default:
93189314 2120 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2121 return -1;
2122 }
2123 while (*mode) {
2124 switch (*mode++) {
2125 case '+':
2126 l->flags |= PERLIO_F_CANREAD | PERLIO_F_CANWRITE;
2127 break;
2128 case 'b':
2129 l->flags &= ~PERLIO_F_CRLF;
2130 break;
2131 case 't':
2132 l->flags |= PERLIO_F_CRLF;
2133 break;
2134 default:
93189314 2135 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2136 return -1;
2137 }
2138 }
2139 }
2140 else {
2141 if (l->next) {
2142 l->flags |= l->next->flags &
2143 (PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_TRUNCATE |
2144 PERLIO_F_APPEND);
2145 }
2146 }
5e2ab84b 2147#if 0
14a5cf38 2148 PerlIO_debug("PerlIOBase_pushed f=%p %s %s fl=%08" UVxf " (%s)\n",
6c9570dc 2149 (void*)f, PerlIOBase(f)->tab->name, (omode) ? omode : "(Null)",
14a5cf38 2150 l->flags, PerlIO_modestr(f, temp));
5e2ab84b 2151#endif
14a5cf38 2152 return 0;
76ced9ad
NIS
2153}
2154
2155IV
f62ce20a 2156PerlIOBase_popped(pTHX_ PerlIO *f)
76ced9ad 2157{
96a5add6 2158 PERL_UNUSED_CONTEXT;
8772537c 2159 PERL_UNUSED_ARG(f);
14a5cf38 2160 return 0;
760ac839
LW
2161}
2162
9e353e3b 2163SSize_t
f62ce20a 2164PerlIOBase_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 2165{
14a5cf38 2166 /*
71200d45 2167 * Save the position as current head considers it
14a5cf38 2168 */
de009b76 2169 const Off_t old = PerlIO_tell(f);
a0714e2c 2170 PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_pending), "r", NULL);
14a5cf38 2171 PerlIOSelf(f, PerlIOBuf)->posn = old;
de009b76 2172 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
9e353e3b
NIS
2173}
2174
f6c77cf1 2175SSize_t
f62ce20a 2176PerlIOBase_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
f6c77cf1 2177{
14a5cf38
JH
2178 STDCHAR *buf = (STDCHAR *) vbuf;
2179 if (f) {
263df5f1
JH
2180 if (!(PerlIOBase(f)->flags & PERLIO_F_CANREAD)) {
2181 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2182 SETERRNO(EBADF, SS_IVCHAN);
2183 return 0;
2184 }
14a5cf38 2185 while (count > 0) {
93c2c2ec
IZ
2186 get_cnt:
2187 {
14a5cf38
JH
2188 SSize_t avail = PerlIO_get_cnt(f);
2189 SSize_t take = 0;
2190 if (avail > 0)
bb7a0f54 2191 take = ((SSize_t)count < avail) ? (SSize_t)count : avail;
14a5cf38
JH
2192 if (take > 0) {
2193 STDCHAR *ptr = PerlIO_get_ptr(f);
2194 Copy(ptr, buf, take, STDCHAR);
2195 PerlIO_set_ptrcnt(f, ptr + take, (avail -= take));
2196 count -= take;
2197 buf += take;
93c2c2ec
IZ
2198 if (avail == 0) /* set_ptrcnt could have reset avail */
2199 goto get_cnt;
14a5cf38
JH
2200 }
2201 if (count > 0 && avail <= 0) {
2202 if (PerlIO_fill(f) != 0)
2203 break;
2204 }
93c2c2ec 2205 }
14a5cf38
JH
2206 }
2207 return (buf - (STDCHAR *) vbuf);
2208 }
f6c77cf1 2209 return 0;
f6c77cf1
NIS
2210}
2211
9e353e3b 2212IV
f62ce20a 2213PerlIOBase_noop_ok(pTHX_ PerlIO *f)
9e353e3b 2214{
96a5add6 2215 PERL_UNUSED_CONTEXT;
8772537c 2216 PERL_UNUSED_ARG(f);
14a5cf38 2217 return 0;
9e353e3b
NIS
2218}
2219
2220IV
f62ce20a 2221PerlIOBase_noop_fail(pTHX_ PerlIO *f)
06da4f11 2222{
96a5add6 2223 PERL_UNUSED_CONTEXT;
8772537c 2224 PERL_UNUSED_ARG(f);
14a5cf38 2225 return -1;
06da4f11
NIS
2226}
2227
2228IV
f62ce20a 2229PerlIOBase_close(pTHX_ PerlIO *f)
9e353e3b 2230{
37725cdc
NIS
2231 IV code = -1;
2232 if (PerlIOValid(f)) {
2233 PerlIO *n = PerlIONext(f);
2234 code = PerlIO_flush(f);
2235 PerlIOBase(f)->flags &=
2236 ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_OPEN);
2237 while (PerlIOValid(n)) {
de009b76 2238 const PerlIO_funcs * const tab = PerlIOBase(n)->tab;
37725cdc
NIS
2239 if (tab && tab->Close) {
2240 if ((*tab->Close)(aTHX_ n) != 0)
2241 code = -1;
2242 break;
2243 }
2244 else {
2245 PerlIOBase(n)->flags &=
2246 ~(PERLIO_F_CANREAD | PERLIO_F_CANWRITE | PERLIO_F_OPEN);
2247 }
2248 n = PerlIONext(n);
2249 }
2250 }
2251 else {
2252 SETERRNO(EBADF, SS_IVCHAN);
2253 }
14a5cf38 2254 return code;
9e353e3b
NIS
2255}
2256
2257IV
f62ce20a 2258PerlIOBase_eof(pTHX_ PerlIO *f)
9e353e3b 2259{
96a5add6 2260 PERL_UNUSED_CONTEXT;
04892f78 2261 if (PerlIOValid(f)) {
14a5cf38
JH
2262 return (PerlIOBase(f)->flags & PERLIO_F_EOF) != 0;
2263 }
2264 return 1;
9e353e3b
NIS
2265}
2266
2267IV
f62ce20a 2268PerlIOBase_error(pTHX_ PerlIO *f)
9e353e3b 2269{
96a5add6 2270 PERL_UNUSED_CONTEXT;
04892f78 2271 if (PerlIOValid(f)) {
14a5cf38
JH
2272 return (PerlIOBase(f)->flags & PERLIO_F_ERROR) != 0;
2273 }
2274 return 1;
9e353e3b
NIS
2275}
2276
2277void
f62ce20a 2278PerlIOBase_clearerr(pTHX_ PerlIO *f)
9e353e3b 2279{
04892f78 2280 if (PerlIOValid(f)) {
dcda55fc 2281 PerlIO * const n = PerlIONext(f);
14a5cf38 2282 PerlIOBase(f)->flags &= ~(PERLIO_F_ERROR | PERLIO_F_EOF);
04892f78 2283 if (PerlIOValid(n))
14a5cf38
JH
2284 PerlIO_clearerr(n);
2285 }
9e353e3b
NIS
2286}
2287
2288void
f62ce20a 2289PerlIOBase_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 2290{
96a5add6 2291 PERL_UNUSED_CONTEXT;
04892f78 2292 if (PerlIOValid(f)) {
14a5cf38
JH
2293 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF;
2294 }
9e353e3b
NIS
2295}
2296
93a8090d
NIS
2297SV *
2298PerlIO_sv_dup(pTHX_ SV *arg, CLONE_PARAMS *param)
2299{
2300 if (!arg)
a0714e2c 2301 return NULL;
93a8090d
NIS
2302#ifdef sv_dup
2303 if (param) {
a951d81d
BL
2304 arg = sv_dup(arg, param);
2305 SvREFCNT_inc_simple_void_NN(arg);
2306 return arg;
93a8090d
NIS
2307 }
2308 else {
2309 return newSVsv(arg);
2310 }
2311#else
1b6737cc 2312 PERL_UNUSED_ARG(param);
93a8090d
NIS
2313 return newSVsv(arg);
2314#endif
2315}
2316
2317PerlIO *
ecdeb87c 2318PerlIOBase_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
93a8090d 2319{
1b6737cc 2320 PerlIO * const nexto = PerlIONext(o);
04892f78 2321 if (PerlIOValid(nexto)) {
de009b76 2322 const PerlIO_funcs * const tab = PerlIOBase(nexto)->tab;
37725cdc
NIS
2323 if (tab && tab->Dup)
2324 f = (*tab->Dup)(aTHX_ f, nexto, param, flags);
2325 else
2326 f = PerlIOBase_dup(aTHX_ f, nexto, param, flags);
93a8090d
NIS
2327 }
2328 if (f) {
dcda55fc 2329 PerlIO_funcs * const self = PerlIOBase(o)->tab;
a951d81d 2330 SV *arg = NULL;
93a8090d 2331 char buf[8];
fe5a182c 2332 PerlIO_debug("PerlIOBase_dup %s f=%p o=%p param=%p\n",
cc6623a8
DM
2333 self ? self->name : "(Null)",
2334 (void*)f, (void*)o, (void*)param);
2335 if (self && self->Getarg)
210e727c 2336 arg = (*self->Getarg)(aTHX_ o, param, flags);
93a8090d 2337 f = PerlIO_push(aTHX_ f, self, PerlIO_modestr(o,buf), arg);
f0720f70
RGS
2338 if (PerlIOBase(o)->flags & PERLIO_F_UTF8)
2339 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
ef8d46e8 2340 SvREFCNT_dec(arg);
93a8090d
NIS
2341 }
2342 return f;
2343}
2344
27da23d5 2345/* PL_perlio_fd_refcnt[] is in intrpvar.h */
93a8090d 2346
8b84d7dd 2347/* Must be called with PL_perlio_mutex locked. */
22c96fc1
NC
2348static void
2349S_more_refcounted_fds(pTHX_ const int new_fd) {
7a89be66 2350 dVAR;
22c96fc1 2351 const int old_max = PL_perlio_fd_refcnt_size;
f4ae5be6 2352 const int new_max = 16 + (new_fd & ~15);
22c96fc1
NC
2353 int *new_array;
2354
2355 PerlIO_debug("More fds - old=%d, need %d, new=%d\n",
2356 old_max, new_fd, new_max);
2357
2358 if (new_fd < old_max) {
2359 return;
2360 }
2361
f4ae5be6
NC
2362 assert (new_max > new_fd);
2363
eae082a0
JH
2364 /* Use plain realloc() since we need this memory to be really
2365 * global and visible to all the interpreters and/or threads. */
2366 new_array = (int*) realloc(PL_perlio_fd_refcnt, new_max * sizeof(int));
22c96fc1
NC
2367
2368 if (!new_array) {
8b84d7dd 2369#ifdef USE_ITHREADS
6cb8cb21 2370 MUTEX_UNLOCK(&PL_perlio_mutex);
22c96fc1
NC
2371#endif
2372 /* Can't use PerlIO to write as it allocates memory */
2373 PerlLIO_write(PerlIO_fileno(Perl_error_log),
2374 PL_no_mem, strlen(PL_no_mem));
2375 my_exit(1);
2376 }
2377
2378 PL_perlio_fd_refcnt_size = new_max;
2379 PL_perlio_fd_refcnt = new_array;
2380
95b63a38
JH
2381 PerlIO_debug("Zeroing %p, %d\n",
2382 (void*)(new_array + old_max),
2383 new_max - old_max);
22c96fc1
NC
2384
2385 Zero(new_array + old_max, new_max - old_max, int);
2386}
2387
2388
93a8090d
NIS
2389void
2390PerlIO_init(pTHX)
2391{
8b84d7dd 2392 /* MUTEX_INIT(&PL_perlio_mutex) is done in PERL_SYS_INIT3(). */
96a5add6 2393 PERL_UNUSED_CONTEXT;
93a8090d
NIS
2394}
2395
168d5872
NIS
2396void
2397PerlIOUnix_refcnt_inc(int fd)
2398{
27da23d5 2399 dTHX;
22c96fc1 2400 if (fd >= 0) {
97aff369 2401 dVAR;
22c96fc1 2402
8b84d7dd 2403#ifdef USE_ITHREADS
6cb8cb21 2404 MUTEX_LOCK(&PL_perlio_mutex);
168d5872 2405#endif
22c96fc1
NC
2406 if (fd >= PL_perlio_fd_refcnt_size)
2407 S_more_refcounted_fds(aTHX_ fd);
2408
27da23d5 2409 PL_perlio_fd_refcnt[fd]++;
8b84d7dd
RGS
2410 if (PL_perlio_fd_refcnt[fd] <= 0) {
2411 Perl_croak(aTHX_ "refcnt_inc: fd %d: %d <= 0\n",
2412 fd, PL_perlio_fd_refcnt[fd]);
2413 }
2414 PerlIO_debug("refcnt_inc: fd %d refcnt=%d\n",
2415 fd, PL_perlio_fd_refcnt[fd]);
22c96fc1 2416
8b84d7dd 2417#ifdef USE_ITHREADS
6cb8cb21 2418 MUTEX_UNLOCK(&PL_perlio_mutex);
168d5872 2419#endif
8b84d7dd
RGS
2420 } else {
2421 Perl_croak(aTHX_ "refcnt_inc: fd %d < 0\n", fd);
168d5872
NIS
2422 }
2423}
2424
168d5872
NIS
2425int
2426PerlIOUnix_refcnt_dec(int fd)
2427{
27da23d5 2428 dTHX;
168d5872 2429 int cnt = 0;
22c96fc1 2430 if (fd >= 0) {
97aff369 2431 dVAR;
8b84d7dd 2432#ifdef USE_ITHREADS
6cb8cb21 2433 MUTEX_LOCK(&PL_perlio_mutex);
168d5872 2434#endif
8b84d7dd
RGS
2435 if (fd >= PL_perlio_fd_refcnt_size) {
2436 Perl_croak(aTHX_ "refcnt_dec: fd %d >= refcnt_size %d\n",
2437 fd, PL_perlio_fd_refcnt_size);
2438 }
2439 if (PL_perlio_fd_refcnt[fd] <= 0) {
2440 Perl_croak(aTHX_ "refcnt_dec: fd %d: %d <= 0\n",
2441 fd, PL_perlio_fd_refcnt[fd]);
2442 }
27da23d5 2443 cnt = --PL_perlio_fd_refcnt[fd];
8b84d7dd
RGS
2444 PerlIO_debug("refcnt_dec: fd %d refcnt=%d\n", fd, cnt);
2445#ifdef USE_ITHREADS
6cb8cb21 2446 MUTEX_UNLOCK(&PL_perlio_mutex);
168d5872 2447#endif
8b84d7dd
RGS
2448 } else {
2449 Perl_croak(aTHX_ "refcnt_dec: fd %d < 0\n", fd);
168d5872
NIS
2450 }
2451 return cnt;
2452}
2453
694c95cf
JH
2454void
2455PerlIO_cleanup(pTHX)
2456{
97aff369 2457 dVAR;
694c95cf
JH
2458 int i;
2459#ifdef USE_ITHREADS
a25429c6 2460 PerlIO_debug("Cleanup layers for %p\n",(void*)aTHX);
9f4bd222
NIS
2461#else
2462 PerlIO_debug("Cleanup layers\n");
694c95cf 2463#endif
e47547a8 2464
694c95cf
JH
2465 /* Raise STDIN..STDERR refcount so we don't close them */
2466 for (i=0; i < 3; i++)
2467 PerlIOUnix_refcnt_inc(i);
2468 PerlIO_cleantable(aTHX_ &PL_perlio);
2469 /* Restore STDIN..STDERR refcount */
2470 for (i=0; i < 3; i++)
2471 PerlIOUnix_refcnt_dec(i);
9f4bd222
NIS
2472
2473 if (PL_known_layers) {
2474 PerlIO_list_free(aTHX_ PL_known_layers);
2475 PL_known_layers = NULL;
2476 }
27da23d5 2477 if (PL_def_layerlist) {
9f4bd222
NIS
2478 PerlIO_list_free(aTHX_ PL_def_layerlist);
2479 PL_def_layerlist = NULL;
2480 }
6cb8cb21
RGS
2481}
2482
0934c9d9 2483void PerlIO_teardown(void) /* Call only from PERL_SYS_TERM(). */
6cb8cb21 2484{
53d44271 2485 dVAR;
4f3da17a
DM
2486#if 0
2487/* XXX we can't rely on an interpreter being present at this late stage,
2488 XXX so we can't use a function like PerlLIO_write that relies on one
2489 being present (at least in win32) :-(.
2490 Disable for now.
2491*/
6cb8cb21
RGS
2492#ifdef DEBUGGING
2493 {
2494 /* By now all filehandles should have been closed, so any
2495 * stray (non-STD-)filehandles indicate *possible* (PerlIO)
2496 * errors. */
77db880c
JH
2497#define PERLIO_TEARDOWN_MESSAGE_BUF_SIZE 64
2498#define PERLIO_TEARDOWN_MESSAGE_FD 2
2499 char buf[PERLIO_TEARDOWN_MESSAGE_BUF_SIZE];
6cb8cb21
RGS
2500 int i;
2501 for (i = 3; i < PL_perlio_fd_refcnt_size; i++) {
77db880c
JH
2502 if (PL_perlio_fd_refcnt[i]) {
2503 const STRLEN len =
2504 my_snprintf(buf, sizeof(buf),
2505 "PerlIO_teardown: fd %d refcnt=%d\n",
2506 i, PL_perlio_fd_refcnt[i]);
2507 PerlLIO_write(PERLIO_TEARDOWN_MESSAGE_FD, buf, len);
2508 }
6cb8cb21
RGS
2509 }
2510 }
2511#endif
4f3da17a 2512#endif
eae082a0
JH
2513 /* Not bothering with PL_perlio_mutex since by now
2514 * all the interpreters are gone. */
1cd82952
RGS
2515 if (PL_perlio_fd_refcnt_size /* Assuming initial size of zero. */
2516 && PL_perlio_fd_refcnt) {
eae082a0 2517 free(PL_perlio_fd_refcnt); /* To match realloc() in S_more_refcounted_fds(). */
432ce874
YO
2518 PL_perlio_fd_refcnt = NULL;
2519 PL_perlio_fd_refcnt_size = 0;
1cd82952 2520 }
694c95cf
JH
2521}
2522
9e353e3b 2523/*--------------------------------------------------------------------------------------*/
14a5cf38 2524/*
71200d45 2525 * Bottom-most level for UNIX-like case
14a5cf38 2526 */
9e353e3b 2527
14a5cf38 2528typedef struct {
22569500
NIS
2529 struct _PerlIO base; /* The generic part */
2530 int fd; /* UNIX like file descriptor */
2531 int oflags; /* open/fcntl flags */
9e353e3b
NIS
2532} PerlIOUnix;
2533
abf9167d
DM
2534static void
2535S_lockcnt_dec(pTHX_ const void* f)
2536{
2537 PerlIO_lockcnt((PerlIO*)f)--;
2538}
2539
2540
2541/* call the signal handler, and if that handler happens to clear
2542 * this handle, free what we can and return true */
2543
2544static bool
2545S_perlio_async_run(pTHX_ PerlIO* f) {
2546 ENTER;
2547 SAVEDESTRUCTOR_X(S_lockcnt_dec, (void*)f);
2548 PerlIO_lockcnt(f)++;
2549 PERL_ASYNC_CHECK();
2550 if ( !(PerlIOBase(f)->flags & PERLIO_F_CLEARED) )
2551 return 0;
2552 /* we've just run some perl-level code that could have done
2553 * anything, including closing the file or clearing this layer.
2554 * If so, free any lower layers that have already been
2555 * cleared, then return an error. */
2556 while (PerlIOValid(f) &&
2557 (PerlIOBase(f)->flags & PERLIO_F_CLEARED))
2558 {
2559 const PerlIOl *l = *f;
2560 *f = l->next;
2561 Safefree(l);
2562 }
2563 return 1;
2564}
2565
6f9d8c32 2566int
9e353e3b 2567PerlIOUnix_oflags(const char *mode)
760ac839 2568{
14a5cf38 2569 int oflags = -1;
3b6c1aba 2570 if (*mode == IoTYPE_IMPLICIT || *mode == IoTYPE_NUMERIC)
14a5cf38
JH
2571 mode++;
2572 switch (*mode) {
2573 case 'r':
2574 oflags = O_RDONLY;
2575 if (*++mode == '+') {
2576 oflags = O_RDWR;
2577 mode++;
2578 }
2579 break;
2580
2581 case 'w':
2582 oflags = O_CREAT | O_TRUNC;
2583 if (*++mode == '+') {
2584 oflags |= O_RDWR;
2585 mode++;
2586 }
2587 else
2588 oflags |= O_WRONLY;
2589 break;
2590
2591 case 'a':
2592 oflags = O_CREAT | O_APPEND;
2593 if (*++mode == '+') {
2594 oflags |= O_RDWR;
2595 mode++;
2596 }
2597 else
2598 oflags |= O_WRONLY;
2599 break;
2600 }
2601 if (*mode == 'b') {
2602 oflags |= O_BINARY;
2603 oflags &= ~O_TEXT;
2604 mode++;
2605 }
2606 else if (*mode == 't') {
2607 oflags |= O_TEXT;
2608 oflags &= ~O_BINARY;
2609 mode++;
2610 }
2611 /*
71200d45 2612 * Always open in binary mode
14a5cf38
JH
2613 */
2614 oflags |= O_BINARY;
2615 if (*mode || oflags == -1) {
93189314 2616 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38
JH
2617 oflags = -1;
2618 }
2619 return oflags;
9e353e3b
NIS
2620}
2621
2622IV
f62ce20a 2623PerlIOUnix_fileno(pTHX_ PerlIO *f)
9e353e3b 2624{
96a5add6 2625 PERL_UNUSED_CONTEXT;
14a5cf38 2626 return PerlIOSelf(f, PerlIOUnix)->fd;
9e353e3b
NIS
2627}
2628
aa063c35
NIS
2629static void
2630PerlIOUnix_setfd(pTHX_ PerlIO *f, int fd, int imode)
4b803d04 2631{
de009b76 2632 PerlIOUnix * const s = PerlIOSelf(f, PerlIOUnix);
6caa5a9c 2633#if defined(WIN32)
aa063c35
NIS
2634 Stat_t st;
2635 if (PerlLIO_fstat(fd, &st) == 0) {
6caa5a9c 2636 if (!S_ISREG(st.st_mode)) {
aa063c35 2637 PerlIO_debug("%d is not regular file\n",fd);
6caa5a9c
NIS
2638 PerlIOBase(f)->flags |= PERLIO_F_NOTREG;
2639 }
aa063c35
NIS
2640 else {
2641 PerlIO_debug("%d _is_ a regular file\n",fd);
2642 }
6caa5a9c
NIS
2643 }
2644#endif
aa063c35
NIS
2645 s->fd = fd;
2646 s->oflags = imode;
2647 PerlIOUnix_refcnt_inc(fd);
96a5add6 2648 PERL_UNUSED_CONTEXT;
aa063c35
NIS
2649}
2650
2651IV
2652PerlIOUnix_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
2653{
2654 IV code = PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
14a5cf38 2655 if (*PerlIONext(f)) {
4b069b44 2656 /* We never call down so do any pending stuff now */
03c0554d 2657 PerlIO_flush(PerlIONext(f));
14a5cf38 2658 /*
71200d45 2659 * XXX could (or should) we retrieve the oflags from the open file
14a5cf38 2660 * handle rather than believing the "mode" we are passed in? XXX
71200d45 2661 * Should the value on NULL mode be 0 or -1?
14a5cf38 2662 */
acbd16bf 2663 PerlIOUnix_setfd(aTHX_ f, PerlIO_fileno(PerlIONext(f)),
aa063c35 2664 mode ? PerlIOUnix_oflags(mode) : -1);
14a5cf38
JH
2665 }
2666 PerlIOBase(f)->flags |= PERLIO_F_OPEN;
6caa5a9c 2667
14a5cf38 2668 return code;
4b803d04
NIS
2669}
2670
c2fcde81
JH
2671IV
2672PerlIOUnix_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
2673{
de009b76 2674 const int fd = PerlIOSelf(f, PerlIOUnix)->fd;
0723351e 2675 Off_t new_loc;
96a5add6 2676 PERL_UNUSED_CONTEXT;
c2fcde81
JH
2677 if (PerlIOBase(f)->flags & PERLIO_F_NOTREG) {
2678#ifdef ESPIPE
2679 SETERRNO(ESPIPE, LIB_INVARG);
2680#else
2681 SETERRNO(EINVAL, LIB_INVARG);
2682#endif
2683 return -1;
2684 }
0723351e
NC
2685 new_loc = PerlLIO_lseek(fd, offset, whence);
2686 if (new_loc == (Off_t) - 1)
dcda55fc 2687 return -1;
c2fcde81
JH
2688 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
2689 return 0;
2690}
2691
9e353e3b 2692PerlIO *
14a5cf38
JH
2693PerlIOUnix_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
2694 IV n, const char *mode, int fd, int imode,
2695 int perm, PerlIO *f, int narg, SV **args)
2696{
d9dac8cd 2697 if (PerlIOValid(f)) {
cc6623a8 2698 if (PerlIOBase(f)->tab && PerlIOBase(f)->flags & PERLIO_F_OPEN)
f62ce20a 2699 (*PerlIOBase(f)->tab->Close)(aTHX_ f);
14a5cf38
JH
2700 }
2701 if (narg > 0) {
3b6c1aba 2702 if (*mode == IoTYPE_NUMERIC)
14a5cf38
JH
2703 mode++;
2704 else {
2705 imode = PerlIOUnix_oflags(mode);
5e2ce0f3
CB
2706#ifdef VMS
2707 perm = 0777; /* preserve RMS defaults, ACL inheritance, etc. */
2708#else
14a5cf38 2709 perm = 0666;
5e2ce0f3 2710#endif
14a5cf38
JH
2711 }
2712 if (imode != -1) {
e62f0680 2713 const char *path = SvPV_nolen_const(*args);
14a5cf38
JH
2714 fd = PerlLIO_open3(path, imode, perm);
2715 }
2716 }
2717 if (fd >= 0) {
3b6c1aba 2718 if (*mode == IoTYPE_IMPLICIT)
14a5cf38
JH
2719 mode++;
2720 if (!f) {
2721 f = PerlIO_allocate(aTHX);
d9dac8cd
NIS
2722 }
2723 if (!PerlIOValid(f)) {
a33cf58c
NIS
2724 if (!(f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg))) {
2725 return NULL;
2726 }
d9dac8cd 2727 }
aa063c35 2728 PerlIOUnix_setfd(aTHX_ f, fd, imode);
14a5cf38 2729 PerlIOBase(f)->flags |= PERLIO_F_OPEN;
c2fcde81
JH
2730 if (*mode == IoTYPE_APPEND)
2731 PerlIOUnix_seek(aTHX_ f, 0, SEEK_END);
14a5cf38
JH
2732 return f;
2733 }
2734 else {
2735 if (f) {
6f207bd3 2736 NOOP;
14a5cf38 2737 /*
71200d45 2738 * FIXME: pop layers ???
14a5cf38
JH
2739 */
2740 }
2741 return NULL;
2742 }
9e353e3b
NIS
2743}
2744
71200d45 2745PerlIO *
ecdeb87c 2746PerlIOUnix_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 2747{
dcda55fc 2748 const PerlIOUnix * const os = PerlIOSelf(o, PerlIOUnix);
93a8090d 2749 int fd = os->fd;
ecdeb87c
NIS
2750 if (flags & PERLIO_DUP_FD) {
2751 fd = PerlLIO_dup(fd);
2752 }
22c96fc1 2753 if (fd >= 0) {
ecdeb87c 2754 f = PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
2755 if (f) {
2756 /* If all went well overwrite fd in dup'ed lay with the dup()'ed fd */
aa063c35 2757 PerlIOUnix_setfd(aTHX_ f, fd, os->oflags);
71200d45
NIS
2758 return f;
2759 }
71200d45
NIS
2760 }
2761 return NULL;
2762}
2763
2764
9e353e3b 2765SSize_t
f62ce20a 2766PerlIOUnix_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
9e353e3b 2767{
97aff369 2768 dVAR;
abf9167d
DM
2769 int fd;
2770 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
2771 return -1;
2772 fd = PerlIOSelf(f, PerlIOUnix)->fd;
27da23d5
JH
2773#ifdef PERLIO_STD_SPECIAL
2774 if (fd == 0)
2775 return PERLIO_STD_IN(fd, vbuf, count);
2776#endif
81428673 2777 if (!(PerlIOBase(f)->flags & PERLIO_F_CANREAD) ||
1fd8f4ce 2778 PerlIOBase(f)->flags & (PERLIO_F_EOF|PERLIO_F_ERROR)) {
263df5f1 2779 return 0;
1fd8f4ce 2780 }
14a5cf38 2781 while (1) {
b464bac0 2782 const SSize_t len = PerlLIO_read(fd, vbuf, count);
14a5cf38 2783 if (len >= 0 || errno != EINTR) {
ba85f2ea
NIS
2784 if (len < 0) {
2785 if (errno != EAGAIN) {
2786 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2787 }
2788 }
2789 else if (len == 0 && count != 0) {
14a5cf38 2790 PerlIOBase(f)->flags |= PERLIO_F_EOF;
ba85f2ea
NIS
2791 SETERRNO(0,0);
2792 }
14a5cf38
JH
2793 return len;
2794 }
abf9167d
DM
2795 /* EINTR */
2796 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2797 return -1;
14a5cf38 2798 }
b464bac0 2799 /*NOTREACHED*/
9e353e3b
NIS
2800}
2801
2802SSize_t
f62ce20a 2803PerlIOUnix_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 2804{
97aff369 2805 dVAR;
abf9167d
DM
2806 int fd;
2807 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
2808 return -1;
2809 fd = PerlIOSelf(f, PerlIOUnix)->fd;
27da23d5
JH
2810#ifdef PERLIO_STD_SPECIAL
2811 if (fd == 1 || fd == 2)
2812 return PERLIO_STD_OUT(fd, vbuf, count);
2813#endif
14a5cf38 2814 while (1) {
de009b76 2815 const SSize_t len = PerlLIO_write(fd, vbuf, count);
14a5cf38 2816 if (len >= 0 || errno != EINTR) {
ba85f2ea
NIS
2817 if (len < 0) {
2818 if (errno != EAGAIN) {
2819 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
2820 }
2821 }
14a5cf38
JH
2822 return len;
2823 }
abf9167d
DM
2824 /* EINTR */
2825 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2826 return -1;
06da4f11 2827 }
1b6737cc 2828 /*NOTREACHED*/
9e353e3b
NIS
2829}
2830
9e353e3b 2831Off_t
f62ce20a 2832PerlIOUnix_tell(pTHX_ PerlIO *f)
9e353e3b 2833{
96a5add6
AL
2834 PERL_UNUSED_CONTEXT;
2835
14a5cf38 2836 return PerlLIO_lseek(PerlIOSelf(f, PerlIOUnix)->fd, 0, SEEK_CUR);
9e353e3b
NIS
2837}
2838
2556f95e
GF
2839
2840IV
2376d97d 2841PerlIOUnix_close(pTHX_ PerlIO *f)
2556f95e 2842{
97aff369 2843 dVAR;
de009b76 2844 const int fd = PerlIOSelf(f, PerlIOUnix)->fd;
14a5cf38 2845 int code = 0;
168d5872
NIS
2846 if (PerlIOBase(f)->flags & PERLIO_F_OPEN) {
2847 if (PerlIOUnix_refcnt_dec(fd) > 0) {
93a8090d
NIS
2848 PerlIOBase(f)->flags &= ~PERLIO_F_OPEN;
2849 return 0;
22569500 2850 }
93a8090d
NIS
2851 }
2852 else {
93189314 2853 SETERRNO(EBADF,SS_IVCHAN);
93a8090d
NIS
2854 return -1;
2855 }
14a5cf38
JH
2856 while (PerlLIO_close(fd) != 0) {
2857 if (errno != EINTR) {
2858 code = -1;
2859 break;
2860 }
abf9167d
DM
2861 /* EINTR */
2862 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
2863 return -1;
14a5cf38
JH
2864 }
2865 if (code == 0) {
2866 PerlIOBase(f)->flags &= ~PERLIO_F_OPEN;
2867 }
2868 return code;
9e353e3b
NIS
2869}
2870
27da23d5 2871PERLIO_FUNCS_DECL(PerlIO_unix) = {
2dc2558e 2872 sizeof(PerlIO_funcs),
14a5cf38
JH
2873 "unix",
2874 sizeof(PerlIOUnix),
2875 PERLIO_K_RAW,
2876 PerlIOUnix_pushed,
2376d97d 2877 PerlIOBase_popped,
14a5cf38 2878 PerlIOUnix_open,
86e05cf2 2879 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
2880 NULL,
2881 PerlIOUnix_fileno,
71200d45 2882 PerlIOUnix_dup,
14a5cf38
JH
2883 PerlIOUnix_read,
2884 PerlIOBase_unread,
2885 PerlIOUnix_write,
2886 PerlIOUnix_seek,
2887 PerlIOUnix_tell,
2888 PerlIOUnix_close,
22569500
NIS
2889 PerlIOBase_noop_ok, /* flush */
2890 PerlIOBase_noop_fail, /* fill */
14a5cf38
JH
2891 PerlIOBase_eof,
2892 PerlIOBase_error,
2893 PerlIOBase_clearerr,
2894 PerlIOBase_setlinebuf,
22569500
NIS
2895 NULL, /* get_base */
2896 NULL, /* get_bufsiz */
2897 NULL, /* get_ptr */
2898 NULL, /* get_cnt */
2899 NULL, /* set_ptrcnt */
9e353e3b
NIS
2900};
2901
2902/*--------------------------------------------------------------------------------------*/
14a5cf38 2903/*
71200d45 2904 * stdio as a layer
14a5cf38 2905 */
9e353e3b 2906
313e59c8
NIS
2907#if defined(VMS) && !defined(STDIO_BUFFER_WRITABLE)
2908/* perl5.8 - This ensures the last minute VMS ungetc fix is not
2909 broken by the last second glibc 2.3 fix
2910 */
2911#define STDIO_BUFFER_WRITABLE
2912#endif
2913
2914
14a5cf38
JH
2915typedef struct {
2916 struct _PerlIO base;
22569500 2917 FILE *stdio; /* The stream */
9e353e3b
NIS
2918} PerlIOStdio;
2919
2920IV
f62ce20a 2921PerlIOStdio_fileno(pTHX_ PerlIO *f)
9e353e3b 2922{
96a5add6
AL
2923 PERL_UNUSED_CONTEXT;
2924
c4420975
AL
2925 if (PerlIOValid(f)) {
2926 FILE * const s = PerlIOSelf(f, PerlIOStdio)->stdio;
2927 if (s)
2928 return PerlSIO_fileno(s);
439ba545
NIS
2929 }
2930 errno = EBADF;
2931 return -1;
9e353e3b
NIS
2932}
2933
766a733e 2934char *
14a5cf38
JH
2935PerlIOStdio_mode(const char *mode, char *tmode)
2936{
de009b76 2937 char * const ret = tmode;
a0625d38
SR
2938 if (mode) {
2939 while (*mode) {
2940 *tmode++ = *mode++;
2941 }
14a5cf38 2942 }
95005ad8 2943#if defined(PERLIO_USING_CRLF) || defined(__CYGWIN__)
6ce75a77
JH
2944 *tmode++ = 'b';
2945#endif
14a5cf38
JH
2946 *tmode = '\0';
2947 return ret;
2948}
2949
4b803d04 2950IV
2dc2558e 2951PerlIOStdio_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
4b803d04 2952{
1fd8f4ce
NIS
2953 PerlIO *n;
2954 if (PerlIOValid(f) && PerlIOValid(n = PerlIONext(f))) {
46c461b5 2955 PerlIO_funcs * const toptab = PerlIOBase(n)->tab;
1fd8f4ce
NIS
2956 if (toptab == tab) {
2957 /* Top is already stdio - pop self (duplicate) and use original */
2958 PerlIO_pop(aTHX_ f);
2959 return 0;
2960 } else {
de009b76 2961 const int fd = PerlIO_fileno(n);
1fd8f4ce
NIS
2962 char tmode[8];
2963 FILE *stdio;
81428673 2964 if (fd >= 0 && (stdio = PerlSIO_fdopen(fd,
1fd8f4ce
NIS
2965 mode = PerlIOStdio_mode(mode, tmode)))) {
2966 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
2967 /* We never call down so do any pending stuff now */
2968 PerlIO_flush(PerlIONext(f));
81428673 2969 }
1fd8f4ce
NIS
2970 else {
2971 return -1;
2972 }
2973 }
14a5cf38 2974 }
2dc2558e 2975 return PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
4b803d04
NIS
2976}
2977
22569500 2978
9e353e3b 2979PerlIO *
4b069b44 2980PerlIO_importFILE(FILE *stdio, const char *mode)
9e353e3b 2981{
14a5cf38
JH
2982 dTHX;
2983 PerlIO *f = NULL;
2984 if (stdio) {
22569500 2985 PerlIOStdio *s;
4b069b44
NIS
2986 if (!mode || !*mode) {
2987 /* We need to probe to see how we can open the stream
2988 so start with read/write and then try write and read
2989 we dup() so that we can fclose without loosing the fd.
2990
2991 Note that the errno value set by a failing fdopen
2992 varies between stdio implementations.
2993 */
de009b76 2994 const int fd = PerlLIO_dup(fileno(stdio));
a33cf58c 2995 FILE *f2 = PerlSIO_fdopen(fd, (mode = "r+"));
4b069b44 2996 if (!f2) {
a33cf58c 2997 f2 = PerlSIO_fdopen(fd, (mode = "w"));
4b069b44
NIS
2998 }
2999 if (!f2) {
a33cf58c 3000 f2 = PerlSIO_fdopen(fd, (mode = "r"));
4b069b44
NIS
3001 }
3002 if (!f2) {
3003 /* Don't seem to be able to open */
3004 PerlLIO_close(fd);
3005 return f;
3006 }
3007 fclose(f2);
22569500 3008 }
a0714e2c 3009 if ((f = PerlIO_push(aTHX_(f = PerlIO_allocate(aTHX)), PERLIO_FUNCS_CAST(&PerlIO_stdio), mode, NULL))) {
a33cf58c
NIS
3010 s = PerlIOSelf(f, PerlIOStdio);
3011 s->stdio = stdio;
c586124f 3012 PerlIOUnix_refcnt_inc(fileno(stdio));
a33cf58c 3013 }
14a5cf38
JH
3014 }
3015 return f;
9e353e3b
NIS
3016}
3017
3018PerlIO *
14a5cf38
JH
3019PerlIOStdio_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
3020 IV n, const char *mode, int fd, int imode,
3021 int perm, PerlIO *f, int narg, SV **args)
3022{
3023 char tmode[8];
d9dac8cd 3024 if (PerlIOValid(f)) {
dcda55fc
AL
3025 const char * const path = SvPV_nolen_const(*args);
3026 PerlIOStdio * const s = PerlIOSelf(f, PerlIOStdio);
1751d015
NIS
3027 FILE *stdio;
3028 PerlIOUnix_refcnt_dec(fileno(s->stdio));
3029 stdio = PerlSIO_freopen(path, (mode = PerlIOStdio_mode(mode, tmode)),
14a5cf38
JH
3030 s->stdio);
3031 if (!s->stdio)
3032 return NULL;
3033 s->stdio = stdio;
1751d015 3034 PerlIOUnix_refcnt_inc(fileno(s->stdio));
14a5cf38
JH
3035 return f;
3036 }
3037 else {
3038 if (narg > 0) {
dcda55fc 3039 const char * const path = SvPV_nolen_const(*args);
3b6c1aba 3040 if (*mode == IoTYPE_NUMERIC) {
14a5cf38
JH
3041 mode++;
3042 fd = PerlLIO_open3(path, imode, perm);
3043 }
3044 else {
95005ad8
GH
3045 FILE *stdio;
3046 bool appended = FALSE;
3047#ifdef __CYGWIN__
3048 /* Cygwin wants its 'b' early. */
3049 appended = TRUE;
3050 mode = PerlIOStdio_mode(mode, tmode);
3051#endif
3052 stdio = PerlSIO_fopen(path, mode);
6f0313ac 3053 if (stdio) {
6f0313ac
JH
3054 if (!f) {
3055 f = PerlIO_allocate(aTHX);
3056 }
95005ad8
GH
3057 if (!appended)
3058 mode = PerlIOStdio_mode(mode, tmode);
3059 f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg);
3060 if (f) {
0f0f9e2b
JH
3061 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
3062 PerlIOUnix_refcnt_inc(fileno(stdio));
3063 } else {
3064 PerlSIO_fclose(stdio);
6f0313ac
JH
3065 }
3066 return f;
3067 }
3068 else {
3069 return NULL;
3070 }
14a5cf38
JH
3071 }
3072 }
3073 if (fd >= 0) {
3074 FILE *stdio = NULL;
3075 int init = 0;
3b6c1aba 3076 if (*mode == IoTYPE_IMPLICIT) {
14a5cf38
JH
3077 init = 1;
3078 mode++;
3079 }
3080 if (init) {
3081 switch (fd) {
3082 case 0:
3083 stdio = PerlSIO_stdin;
3084 break;
3085 case 1:
3086 stdio = PerlSIO_stdout;
3087 break;
3088 case 2:
3089 stdio = PerlSIO_stderr;
3090 break;
3091 }
3092 }
3093 else {
3094 stdio = PerlSIO_fdopen(fd, mode =
3095 PerlIOStdio_mode(mode, tmode));
3096 }
3097 if (stdio) {
d9dac8cd
NIS
3098 if (!f) {
3099 f = PerlIO_allocate(aTHX);
3100 }
a33cf58c 3101 if ((f = PerlIO_push(aTHX_ f, self, mode, PerlIOArg))) {
1a159fba
JH
3102 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
3103 PerlIOUnix_refcnt_inc(fileno(stdio));
a33cf58c 3104 }
14a5cf38
JH
3105 return f;
3106 }
3107 }
3108 }
ee518936 3109 return NULL;
9e353e3b
NIS
3110}
3111
1751d015 3112PerlIO *
ecdeb87c 3113PerlIOStdio_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
1751d015
NIS
3114{
3115 /* This assumes no layers underneath - which is what
3116 happens, but is not how I remember it. NI-S 2001/10/16
3117 */
ecdeb87c 3118 if ((f = PerlIOBase_dup(aTHX_ f, o, param, flags))) {
694c95cf 3119 FILE *stdio = PerlIOSelf(o, PerlIOStdio)->stdio;
de009b76 3120 const int fd = fileno(stdio);
9217ff3f 3121 char mode[8];
ecdeb87c 3122 if (flags & PERLIO_DUP_FD) {
de009b76 3123 const int dfd = PerlLIO_dup(fileno(stdio));
9217ff3f
NIS
3124 if (dfd >= 0) {
3125 stdio = PerlSIO_fdopen(dfd, PerlIO_modestr(o,mode));
3126 goto set_this;
ecdeb87c
NIS
3127 }
3128 else {
6f207bd3 3129 NOOP;
ecdeb87c
NIS
3130 /* FIXME: To avoid messy error recovery if dup fails
3131 re-use the existing stdio as though flag was not set
3132 */
3133 }
3134 }
9217ff3f
NIS
3135 stdio = PerlSIO_fdopen(fd, PerlIO_modestr(o,mode));
3136 set_this:
694c95cf 3137 PerlIOSelf(f, PerlIOStdio)->stdio = stdio;
40596bc5
SP
3138 if(stdio) {
3139 PerlIOUnix_refcnt_inc(fileno(stdio));
3140 }
1751d015
NIS
3141 }
3142 return f;
3143}
3144
0d7a5398
NIS
3145static int
3146PerlIOStdio_invalidate_fileno(pTHX_ FILE *f)
3147{
96a5add6
AL
3148 PERL_UNUSED_CONTEXT;
3149
0d7a5398 3150 /* XXX this could use PerlIO_canset_fileno() and
37725cdc 3151 * PerlIO_set_fileno() support from Configure
0d7a5398 3152 */
ef8eacb8
AT
3153# if defined(__UCLIBC__)
3154 /* uClibc must come before glibc because it defines __GLIBC__ as well. */
3155 f->__filedes = -1;
3156 return 1;
3157# elif defined(__GLIBC__)
0d7a5398 3158 /* There may be a better way for GLIBC:
37725cdc 3159 - libio.h defines a flag to not close() on cleanup
0d7a5398
NIS
3160 */
3161 f->_fileno = -1;
3162 return 1;
3163# elif defined(__sun__)
f5992bc4 3164 PERL_UNUSED_ARG(f);
cfedb851 3165 return 0;
0d7a5398
NIS
3166# elif defined(__hpux)
3167 f->__fileH = 0xff;
3168 f->__fileL = 0xff;
3169 return 1;
9837d373 3170 /* Next one ->_file seems to be a reasonable fallback, i.e. if
37725cdc 3171 your platform does not have special entry try this one.
9837d373
NIS
3172 [For OSF only have confirmation for Tru64 (alpha)
3173 but assume other OSFs will be similar.]
37725cdc 3174 */
9837d373 3175# elif defined(_AIX) || defined(__osf__) || defined(__irix__)
0d7a5398
NIS
3176 f->_file = -1;
3177 return 1;
3178# elif defined(__FreeBSD__)
3179 /* There may be a better way on FreeBSD:
37725cdc
NIS
3180 - we could insert a dummy func in the _close function entry
3181 f->_close = (int (*)(void *)) dummy_close;
0d7a5398
NIS
3182 */
3183 f->_file = -1;
0c49ea6a
SU
3184 return 1;
3185# elif defined(__OpenBSD__)
3186 /* There may be a better way on OpenBSD:
3187 - we could insert a dummy func in the _close function entry
3188 f->_close = (int (*)(void *)) dummy_close;
3189 */
3190 f->_file = -1;
0d7a5398 3191 return 1;
59ad941d
IZ
3192# elif defined(__EMX__)
3193 /* f->_flags &= ~_IOOPEN; */ /* Will leak stream->_buffer */
3194 f->_handle = -1;
3195 return 1;
0d7a5398
NIS
3196# elif defined(__CYGWIN__)
3197 /* There may be a better way on CYGWIN:
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;
3202 return 1;
3203# elif defined(WIN32)
3204# if defined(__BORLANDC__)
3205 f->fd = PerlLIO_dup(fileno(f));
b475b3e6
JH
3206# elif defined(UNDER_CE)
3207 /* WIN_CE does not have access to FILE internals, it hardly has FILE
3208 structure at all
3209 */
0d7a5398
NIS
3210# else
3211 f->_file = -1;
3212# endif
3213 return 1;
3214# else
3215#if 0
37725cdc 3216 /* Sarathy's code did this - we fall back to a dup/dup2 hack
0d7a5398 3217 (which isn't thread safe) instead
37725cdc 3218 */
0d7a5398
NIS
3219# error "Don't know how to set FILE.fileno on your platform"
3220#endif
8772537c 3221 PERL_UNUSED_ARG(f);
0d7a5398
NIS
3222 return 0;
3223# endif
3224}
3225
1751d015 3226IV
f62ce20a 3227PerlIOStdio_close(pTHX_ PerlIO *f)
1751d015 3228{
c4420975 3229 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
439ba545
NIS
3230 if (!stdio) {
3231 errno = EBADF;
3232 return -1;
3233 }
9217ff3f 3234 else {
de009b76 3235 const int fd = fileno(stdio);
0d7a5398 3236 int invalidate = 0;
bbfd922f 3237 IV result = 0;
1d791a44 3238 int dupfd = -1;
4ee39169 3239 dSAVEDERRNO;
a2e578da
MHM
3240#ifdef USE_ITHREADS
3241 dVAR;
3242#endif
0d7a5398 3243#ifdef SOCKS5_VERSION_NAME
37725cdc
NIS
3244 /* Socks lib overrides close() but stdio isn't linked to
3245 that library (though we are) - so we must call close()
3246 on sockets on stdio's behalf.
3247 */
0d7a5398
NIS
3248 int optval;
3249 Sock_size_t optlen = sizeof(int);
6b4ce6c8 3250 if (getsockopt(fd, SOL_SOCKET, SO_TYPE, (void *) &optval, &optlen) == 0)
37725cdc 3251 invalidate = 1;
0d7a5398 3252#endif
d8723f43
NC
3253 /* Test for -1, as *BSD stdio (at least) on fclose sets the FILE* such
3254 that a subsequent fileno() on it returns -1. Don't want to croak()
3255 from within PerlIOUnix_refcnt_dec() if some buggy caller code is
3256 trying to close an already closed handle which somehow it still has
3257 a reference to. (via.xs, I'm looking at you). */
3258 if (fd != -1 && PerlIOUnix_refcnt_dec(fd) > 0) {
3259 /* File descriptor still in use */
0d7a5398 3260 invalidate = 1;
d8723f43 3261 }
0d7a5398 3262 if (invalidate) {
6b4ce6c8
AL
3263 /* For STD* handles, don't close stdio, since we shared the FILE *, too. */
3264 if (stdio == stdin) /* Some stdios are buggy fflush-ing inputs */
3265 return 0;
3266 if (stdio == stdout || stdio == stderr)
3267 return PerlIO_flush(f);
37725cdc
NIS
3268 /* Tricky - must fclose(stdio) to free memory but not close(fd)
3269 Use Sarathy's trick from maint-5.6 to invalidate the
3270 fileno slot of the FILE *
3271 */
bbfd922f 3272 result = PerlIO_flush(f);
4ee39169 3273 SAVE_ERRNO;
6b4ce6c8 3274 invalidate = PerlIOStdio_invalidate_fileno(aTHX_ stdio);
711e8db2 3275 if (!invalidate) {
9bab90c0
NC
3276#ifdef USE_ITHREADS
3277 MUTEX_LOCK(&PL_perlio_mutex);
5ca745d2
NC
3278 /* Right. We need a mutex here because for a brief while we
3279 will have the situation that fd is actually closed. Hence if
3280 a second thread were to get into this block, its dup() would
3281 likely return our fd as its dupfd. (after all, it is closed)
9bab90c0
NC
3282 Then if we get to the dup2() first, we blat the fd back
3283 (messing up its temporary as a side effect) only for it to
3284 then close its dupfd (== our fd) in its close(dupfd) */
3285
3286 /* There is, of course, a race condition, that any other thread
3287 trying to input/output/whatever on this fd will be stuffed
5ca745d2
NC
3288 for the duration of this little manoeuvrer. Perhaps we
3289 should hold an IO mutex for the duration of every IO
3290 operation if we know that invalidate doesn't work on this
3291 platform, but that would suck, and could kill performance.
9bab90c0
NC
3292
3293 Except that correctness trumps speed.
3294 Advice from klortho #11912. */
3295#endif
6b4ce6c8 3296 dupfd = PerlLIO_dup(fd);
711e8db2 3297#ifdef USE_ITHREADS
9bab90c0
NC
3298 if (dupfd < 0) {
3299 MUTEX_UNLOCK(&PL_perlio_mutex);
711e8db2
NC
3300 /* Oh cXap. This isn't going to go well. Not sure if we can
3301 recover from here, or if closing this particular FILE *
3302 is a good idea now. */
3303 }
3304#endif
3305 }
94ccb807
JH
3306 } else {
3307 SAVE_ERRNO; /* This is here only to silence compiler warnings */
37725cdc 3308 }
0d7a5398 3309 result = PerlSIO_fclose(stdio);
37725cdc
NIS
3310 /* We treat error from stdio as success if we invalidated
3311 errno may NOT be expected EBADF
e8529473
NIS
3312 */
3313 if (invalidate && result != 0) {
4ee39169 3314 RESTORE_ERRNO;
0d7a5398 3315 result = 0;
37725cdc 3316 }
6b4ce6c8
AL
3317#ifdef SOCKS5_VERSION_NAME
3318 /* in SOCKS' case, let close() determine return value */
3319 result = close(fd);
3320#endif
1d791a44 3321 if (dupfd >= 0) {
0d7a5398 3322 PerlLIO_dup2(dupfd,fd);
9bab90c0 3323 PerlLIO_close(dupfd);
711e8db2 3324#ifdef USE_ITHREADS
9bab90c0 3325 MUTEX_UNLOCK(&PL_perlio_mutex);
711e8db2 3326#endif
9217ff3f
NIS
3327 }
3328 return result;
37725cdc 3329 }
1751d015
NIS
3330}
3331
9e353e3b 3332SSize_t
f62ce20a 3333PerlIOStdio_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
9e353e3b 3334{
97aff369 3335 dVAR;
abf9167d 3336 FILE * s;
14a5cf38 3337 SSize_t got = 0;
abf9167d
DM
3338 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3339 return -1;
3340 s = PerlIOSelf(f, PerlIOStdio)->stdio;
4d948241
NIS
3341 for (;;) {
3342 if (count == 1) {
3343 STDCHAR *buf = (STDCHAR *) vbuf;
3344 /*
3345 * Perl is expecting PerlIO_getc() to fill the buffer Linux's
3346 * stdio does not do that for fread()
3347 */
de009b76 3348 const int ch = PerlSIO_fgetc(s);
4d948241
NIS
3349 if (ch != EOF) {
3350 *buf = ch;
3351 got = 1;
3352 }
14a5cf38 3353 }
4d948241
NIS
3354 else
3355 got = PerlSIO_fread(vbuf, 1, count, s);
b1d8b47a
CS
3356 if (got == 0 && PerlSIO_ferror(s))
3357 got = -1;
42a7a32f 3358 if (got >= 0 || errno != EINTR)
4d948241 3359 break;
abf9167d
DM
3360 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3361 return -1;
42a7a32f 3362 SETERRNO(0,0); /* just in case */
14a5cf38 3363 }
14a5cf38 3364 return got;
9e353e3b
NIS
3365}
3366
3367SSize_t
f62ce20a 3368PerlIOStdio_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 3369{
14a5cf38 3370 SSize_t unread = 0;
c4420975 3371 FILE * const s = PerlIOSelf(f, PerlIOStdio)->stdio;
93679785 3372
313e59c8 3373#ifdef STDIO_BUFFER_WRITABLE
9f7cd136 3374 if (PerlIO_fast_gets(f) && PerlIO_has_base(f)) {
93679785
NIS
3375 STDCHAR *buf = ((STDCHAR *) vbuf) + count;
3376 STDCHAR *base = PerlIO_get_base(f);
3377 SSize_t cnt = PerlIO_get_cnt(f);
3378 STDCHAR *ptr = PerlIO_get_ptr(f);
3379 SSize_t avail = ptr - base;
3380 if (avail > 0) {
3381 if (avail > count) {
3382 avail = count;
3383 }
3384 ptr -= avail;
3385 Move(buf-avail,ptr,avail,STDCHAR);
3386 count -= avail;
3387 unread += avail;
3388 PerlIO_set_ptrcnt(f,ptr,cnt+avail);
9f7cd136
NIS
3389 if (PerlSIO_feof(s) && unread >= 0)
3390 PerlSIO_clearerr(s);
3391 }
3392 }
313e59c8
NIS
3393 else
3394#endif
3395 if (PerlIO_has_cntptr(f)) {
9f7cd136
NIS
3396 /* We can get pointer to buffer but not its base
3397 Do ungetc() but check chars are ending up in the
3398 buffer
3399 */
3400 STDCHAR *eptr = (STDCHAR*)PerlSIO_get_ptr(s);
3401 STDCHAR *buf = ((STDCHAR *) vbuf) + count;
3402 while (count > 0) {
de009b76 3403 const int ch = *--buf & 0xFF;
9f7cd136
NIS
3404 if (ungetc(ch,s) != ch) {
3405 /* ungetc did not work */
3406 break;
3407 }
3408 if ((STDCHAR*)PerlSIO_get_ptr(s) != --eptr || ((*eptr & 0xFF) != ch)) {
3409 /* Did not change pointer as expected */
3410 fgetc(s); /* get char back again */
3411 break;
3412 }
3413 /* It worked ! */
3414 count--;
3415 unread++;
93679785
NIS
3416 }
3417 }
3418
3419 if (count > 0) {
3420 unread += PerlIOBase_unread(aTHX_ f, vbuf, count);
14a5cf38
JH
3421 }
3422 return unread;
9e353e3b
NIS
3423}
3424
3425SSize_t
f62ce20a 3426PerlIOStdio_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
9e353e3b 3427{
97aff369 3428 dVAR;
4d948241 3429 SSize_t got;
abf9167d
DM
3430 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3431 return -1;
4d948241
NIS
3432 for (;;) {
3433 got = PerlSIO_fwrite(vbuf, 1, count,
3434 PerlIOSelf(f, PerlIOStdio)->stdio);
42a7a32f 3435 if (got >= 0 || errno != EINTR)
4d948241 3436 break;
abf9167d
DM
3437 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3438 return -1;
42a7a32f 3439 SETERRNO(0,0); /* just in case */
4d948241
NIS
3440 }
3441 return got;
9e353e3b
NIS
3442}
3443
94a175e1 3444IV
f62ce20a 3445PerlIOStdio_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
9e353e3b 3446{
c4420975 3447 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3448 PERL_UNUSED_CONTEXT;
3449
94a175e1 3450 return PerlSIO_fseek(stdio, offset, whence);
9e353e3b
NIS
3451}
3452
3453Off_t
f62ce20a 3454PerlIOStdio_tell(pTHX_ PerlIO *f)
9e353e3b 3455{
c4420975 3456 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3457 PERL_UNUSED_CONTEXT;
3458
94a175e1 3459 return PerlSIO_ftell(stdio);
9e353e3b
NIS
3460}
3461
3462IV
f62ce20a 3463PerlIOStdio_flush(pTHX_ PerlIO *f)
9e353e3b 3464{
c4420975 3465 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6
AL
3466 PERL_UNUSED_CONTEXT;
3467
14a5cf38
JH
3468 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) {
3469 return PerlSIO_fflush(stdio);
3470 }
3471 else {
6f207bd3 3472 NOOP;
88b61e10 3473#if 0
14a5cf38
JH
3474 /*
3475 * FIXME: This discards ungetc() and pre-read stuff which is not
71200d45 3476 * right if this is just a "sync" from a layer above Suspect right
14a5cf38 3477 * design is to do _this_ but not have layer above flush this
71200d45 3478 * layer read-to-read
14a5cf38
JH
3479 */
3480 /*
71200d45 3481 * Not writeable - sync by attempting a seek
14a5cf38 3482 */
4ee39169 3483 dSAVE_ERRNO;
14a5cf38 3484 if (PerlSIO_fseek(stdio, (Off_t) 0, SEEK_CUR) != 0)
4ee39169 3485 RESTORE_ERRNO;
88b61e10 3486#endif
14a5cf38
JH
3487 }
3488 return 0;
9e353e3b
NIS
3489}
3490
3491IV
f62ce20a 3492PerlIOStdio_eof(pTHX_ PerlIO *f)
9e353e3b 3493{
96a5add6
AL
3494 PERL_UNUSED_CONTEXT;
3495
14a5cf38 3496 return PerlSIO_feof(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3497}
3498
3499IV
f62ce20a 3500PerlIOStdio_error(pTHX_ PerlIO *f)
9e353e3b 3501{
96a5add6
AL
3502 PERL_UNUSED_CONTEXT;
3503
263df5f1 3504 return PerlSIO_ferror(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3505}
3506
3507void
f62ce20a 3508PerlIOStdio_clearerr(pTHX_ PerlIO *f)
9e353e3b 3509{
96a5add6
AL
3510 PERL_UNUSED_CONTEXT;
3511
14a5cf38 3512 PerlSIO_clearerr(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b
NIS
3513}
3514
3515void
f62ce20a 3516PerlIOStdio_setlinebuf(pTHX_ PerlIO *f)
9e353e3b 3517{
96a5add6
AL
3518 PERL_UNUSED_CONTEXT;
3519
9e353e3b 3520#ifdef HAS_SETLINEBUF
14a5cf38 3521 PerlSIO_setlinebuf(PerlIOSelf(f, PerlIOStdio)->stdio);
9e353e3b 3522#else
bd61b366 3523 PerlSIO_setvbuf(PerlIOSelf(f, PerlIOStdio)->stdio, NULL, _IOLBF, 0);
9e353e3b
NIS
3524#endif
3525}
3526
3527#ifdef FILE_base
3528STDCHAR *
f62ce20a 3529PerlIOStdio_get_base(pTHX_ PerlIO *f)
9e353e3b 3530{
c4420975 3531 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
cc00df79 3532 return (STDCHAR*)PerlSIO_get_base(stdio);
9e353e3b
NIS
3533}
3534
3535Size_t
f62ce20a 3536PerlIOStdio_get_bufsiz(pTHX_ PerlIO *f)
9e353e3b 3537{
c4420975 3538 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3539 return PerlSIO_get_bufsiz(stdio);
9e353e3b
NIS
3540}
3541#endif
3542
3543#ifdef USE_STDIO_PTR
3544STDCHAR *
f62ce20a 3545PerlIOStdio_get_ptr(pTHX_ PerlIO *f)
9e353e3b 3546{
c4420975 3547 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
cc00df79 3548 return (STDCHAR*)PerlSIO_get_ptr(stdio);
9e353e3b
NIS
3549}
3550
3551SSize_t
f62ce20a 3552PerlIOStdio_get_cnt(pTHX_ PerlIO *f)
9e353e3b 3553{
c4420975 3554 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3555 return PerlSIO_get_cnt(stdio);
9e353e3b
NIS
3556}
3557
3558void
f62ce20a 3559PerlIOStdio_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
9e353e3b 3560{
c4420975 3561 FILE * const stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
14a5cf38 3562 if (ptr != NULL) {
9e353e3b 3563#ifdef STDIO_PTR_LVALUE
d06fc7d4 3564 PerlSIO_set_ptr(stdio, ptr); /* LHS STDCHAR* cast non-portable */
9e353e3b 3565#ifdef STDIO_PTR_LVAL_SETS_CNT
f8a4dbc5 3566 assert(PerlSIO_get_cnt(stdio) == (cnt));
9e353e3b
NIS
3567#endif
3568#if (!defined(STDIO_PTR_LVAL_NOCHANGE_CNT))
14a5cf38 3569 /*
71200d45 3570 * Setting ptr _does_ change cnt - we are done
14a5cf38
JH
3571 */
3572 return;
9e353e3b 3573#endif
22569500 3574#else /* STDIO_PTR_LVALUE */
14a5cf38 3575 PerlProc_abort();
22569500 3576#endif /* STDIO_PTR_LVALUE */
14a5cf38
JH
3577 }
3578 /*
71200d45 3579 * Now (or only) set cnt
14a5cf38 3580 */
9e353e3b 3581#ifdef STDIO_CNT_LVALUE
14a5cf38 3582 PerlSIO_set_cnt(stdio, cnt);
22569500 3583#else /* STDIO_CNT_LVALUE */
9e353e3b 3584#if (defined(STDIO_PTR_LVALUE) && defined(STDIO_PTR_LVAL_SETS_CNT))
14a5cf38
JH
3585 PerlSIO_set_ptr(stdio,
3586 PerlSIO_get_ptr(stdio) + (PerlSIO_get_cnt(stdio) -
3587 cnt));
22569500 3588#else /* STDIO_PTR_LVAL_SETS_CNT */
14a5cf38 3589 PerlProc_abort();
22569500
NIS
3590#endif /* STDIO_PTR_LVAL_SETS_CNT */
3591#endif /* STDIO_CNT_LVALUE */
9e353e3b
NIS
3592}
3593
93679785 3594
9e353e3b
NIS
3595#endif
3596
93679785
NIS
3597IV
3598PerlIOStdio_fill(pTHX_ PerlIO *f)
3599{
abf9167d 3600 FILE * stdio;
93679785 3601 int c;
96a5add6 3602 PERL_UNUSED_CONTEXT;
abf9167d
DM
3603 if (PerlIO_lockcnt(f)) /* in use: abort ungracefully */
3604 return -1;
3605 stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
96a5add6 3606
93679785
NIS
3607 /*
3608 * fflush()ing read-only streams can cause trouble on some stdio-s
3609 */
3610 if ((PerlIOBase(f)->flags & PERLIO_F_CANWRITE)) {
3611 if (PerlSIO_fflush(stdio) != 0)
3612 return EOF;
3613 }
f3be3723
BL
3614 for (;;) {
3615 c = PerlSIO_fgetc(stdio);
3616 if (c != EOF)
3617 break;
3618 if (! PerlSIO_ferror(stdio) || errno != EINTR)
3619 return EOF;
abf9167d
DM
3620 if (PL_sig_pending && S_perlio_async_run(aTHX_ f))
3621 return -1;
f3be3723
BL
3622 SETERRNO(0,0);
3623 }
93679785
NIS
3624
3625#if (defined(STDIO_PTR_LVALUE) && (defined(STDIO_CNT_LVALUE) || defined(STDIO_PTR_LVAL_SETS_CNT)))
313e59c8
NIS
3626
3627#ifdef STDIO_BUFFER_WRITABLE
9f7cd136 3628 if (PerlIO_fast_gets(f) && PerlIO_has_base(f)) {
93679785
NIS
3629 /* Fake ungetc() to the real buffer in case system's ungetc
3630 goes elsewhere
3631 */
3632 STDCHAR *base = (STDCHAR*)PerlSIO_get_base(stdio);
3633 SSize_t cnt = PerlSIO_get_cnt(stdio);
3634 STDCHAR *ptr = (STDCHAR*)PerlSIO_get_ptr(stdio);
3635 if (ptr == base+1) {
3636 *--ptr = (STDCHAR) c;
3637 PerlIOStdio_set_ptrcnt(aTHX_ f,ptr,cnt+1);
3638 if (PerlSIO_feof(stdio))
3639 PerlSIO_clearerr(stdio);
3640 return 0;
3641 }
3642 }
313e59c8
NIS
3643 else
3644#endif
3645 if (PerlIO_has_cntptr(f)) {
9f7cd136
NIS
3646 STDCHAR ch = c;
3647 if (PerlIOStdio_unread(aTHX_ f,&ch,1) == 1) {
3648 return 0;
3649 }
3650 }
93679785
NIS
3651#endif
3652
3653#if defined(VMS)
3654 /* An ungetc()d char is handled separately from the regular
3655 * buffer, so we stuff it in the buffer ourselves.
3656 * Should never get called as should hit code above
3657 */
bad9695d
NIS
3658 *(--((*stdio)->_ptr)) = (unsigned char) c;
3659 (*stdio)->_cnt++;
93679785
NIS
3660#else
3661 /* If buffer snoop scheme above fails fall back to
9f7cd136 3662 using ungetc().
93679785
NIS
3663 */
3664 if (PerlSIO_ungetc(c, stdio) != c)
3665 return EOF;
3666#endif
3667 return 0;
3668}
3669
3670
3671
27da23d5 3672PERLIO_FUNCS_DECL(PerlIO_stdio) = {
2dc2558e 3673 sizeof(PerlIO_funcs),
14a5cf38
JH
3674 "stdio",
3675 sizeof(PerlIOStdio),
86e05cf2 3676 PERLIO_K_BUFFERED|PERLIO_K_RAW,
1fd8f4ce 3677 PerlIOStdio_pushed,
2376d97d 3678 PerlIOBase_popped,
14a5cf38 3679 PerlIOStdio_open,
86e05cf2 3680 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
3681 NULL,
3682 PerlIOStdio_fileno,
71200d45 3683 PerlIOStdio_dup,
14a5cf38
JH
3684 PerlIOStdio_read,
3685 PerlIOStdio_unread,
3686 PerlIOStdio_write,
3687 PerlIOStdio_seek,
3688 PerlIOStdio_tell,
3689 PerlIOStdio_close,
3690 PerlIOStdio_flush,
3691 PerlIOStdio_fill,
3692 PerlIOStdio_eof,
3693 PerlIOStdio_error,
3694 PerlIOStdio_clearerr,
3695 PerlIOStdio_setlinebuf,
9e353e3b 3696#ifdef FILE_base
14a5cf38
JH
3697 PerlIOStdio_get_base,
3698 PerlIOStdio_get_bufsiz,
9e353e3b 3699#else
14a5cf38
JH
3700 NULL,
3701 NULL,
9e353e3b
NIS
3702#endif
3703#ifdef USE_STDIO_PTR
14a5cf38
JH
3704 PerlIOStdio_get_ptr,
3705 PerlIOStdio_get_cnt,
15b61c98 3706# if defined(HAS_FAST_STDIO) && defined(USE_FAST_STDIO)
79ed0f43 3707 PerlIOStdio_set_ptrcnt,
15b61c98
JH
3708# else
3709 NULL,
3710# endif /* HAS_FAST_STDIO && USE_FAST_STDIO */
3711#else
3712 NULL,
14a5cf38
JH
3713 NULL,
3714 NULL,
15b61c98 3715#endif /* USE_STDIO_PTR */
9e353e3b
NIS
3716};
3717
b9d6bf13
JH
3718/* Note that calls to PerlIO_exportFILE() are reversed using
3719 * PerlIO_releaseFILE(), not importFILE. */
9e353e3b 3720FILE *
81428673 3721PerlIO_exportFILE(PerlIO * f, const char *mode)
9e353e3b 3722{
e87a358a 3723 dTHX;
81428673
NIS
3724 FILE *stdio = NULL;
3725 if (PerlIOValid(f)) {
3726 char buf[8];
3727 PerlIO_flush(f);
3728 if (!mode || !*mode) {
3729 mode = PerlIO_modestr(f, buf);
3730 }
3731 stdio = PerlSIO_fdopen(PerlIO_fileno(f), mode);
3732 if (stdio) {
3733 PerlIOl *l = *f;
9f75cc58 3734 PerlIO *f2;
81428673
NIS
3735 /* De-link any lower layers so new :stdio sticks */
3736 *f = NULL;
a0714e2c 3737 if ((f2 = PerlIO_push(aTHX_ f, PERLIO_FUNCS_CAST(&PerlIO_stdio), buf, NULL))) {
9f75cc58 3738 PerlIOStdio *s = PerlIOSelf((f = f2), PerlIOStdio);
81428673 3739 s->stdio = stdio;
6b54a403 3740 PerlIOUnix_refcnt_inc(fileno(stdio));
81428673
NIS
3741 /* Link previous lower layers under new one */
3742 *PerlIONext(f) = l;
3743 }
3744 else {
3745 /* restore layers list */
3746 *f = l;
3747 }
a33cf58c 3748 }
14a5cf38
JH
3749 }
3750 return stdio;
9e353e3b
NIS
3751}
3752
81428673 3753
9e353e3b
NIS
3754FILE *
3755PerlIO_findFILE(PerlIO *f)
3756{
14a5cf38 3757 PerlIOl *l = *f;
bbbc33d0 3758 FILE *stdio;
14a5cf38
JH
3759 while (l) {
3760 if (l->tab == &PerlIO_stdio) {
3761 PerlIOStdio *s = PerlIOSelf(&l, PerlIOStdio);
3762 return s->stdio;
3763 }
3764 l = *PerlIONext(&l);
f7e7eb72 3765 }
4b069b44 3766 /* Uses fallback "mode" via PerlIO_modestr() in PerlIO_exportFILE */
bbbc33d0
NC
3767 /* However, we're not really exporting a FILE * to someone else (who
3768 becomes responsible for closing it, or calling PerlIO_releaseFILE())
486ec47a 3769 So we need to undo its reference count increase on the underlying file
bbbc33d0
NC
3770 descriptor. We have to do this, because if the loop above returns you
3771 the FILE *, then *it* didn't increase any reference count. So there's
3772 only one way to be consistent. */
3773 stdio = PerlIO_exportFILE(f, NULL);
3774 if (stdio) {
3775 const int fd = fileno(stdio);
3776 if (fd >= 0)
3777 PerlIOUnix_refcnt_dec(fd);
3778 }
3779 return stdio;
9e353e3b
NIS
3780}
3781
b9d6bf13 3782/* Use this to reverse PerlIO_exportFILE calls. */
9e353e3b
NIS
3783void
3784PerlIO_releaseFILE(PerlIO *p, FILE *f)
3785{
27da23d5 3786 dVAR;
22569500
NIS
3787 PerlIOl *l;
3788 while ((l = *p)) {
3789 if (l->tab == &PerlIO_stdio) {
3790 PerlIOStdio *s = PerlIOSelf(&l, PerlIOStdio);
3791 if (s->stdio == f) {
3792 dTHX;
6b54a403
NC
3793 const int fd = fileno(f);
3794 if (fd >= 0)
3795 PerlIOUnix_refcnt_dec(fd);
22569500
NIS
3796 PerlIO_pop(aTHX_ p);
3797 return;
3798 }
3799 }
3800 p = PerlIONext(p);
3801 }
3802 return;
9e353e3b
NIS
3803}
3804
3805/*--------------------------------------------------------------------------------------*/
14a5cf38 3806/*
71200d45 3807 * perlio buffer layer
14a5cf38 3808 */
9e353e3b 3809
5e2ab84b 3810IV
2dc2558e 3811PerlIOBuf_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
5e2ab84b 3812{
14a5cf38 3813 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
de009b76 3814 const int fd = PerlIO_fileno(f);
14a5cf38
JH
3815 if (fd >= 0 && PerlLIO_isatty(fd)) {
3816 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF | PERLIO_F_TTY;
3817 }
4b069b44 3818 if (*PerlIONext(f)) {
de009b76 3819 const Off_t posn = PerlIO_tell(PerlIONext(f));
4b069b44
NIS
3820 if (posn != (Off_t) - 1) {
3821 b->posn = posn;
3822 }
14a5cf38 3823 }
2dc2558e 3824 return PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
5e2ab84b
NIS
3825}
3826
9e353e3b 3827PerlIO *
14a5cf38
JH
3828PerlIOBuf_open(pTHX_ PerlIO_funcs *self, PerlIO_list_t *layers,
3829 IV n, const char *mode, int fd, int imode, int perm,
3830 PerlIO *f, int narg, SV **args)
3831{
04892f78 3832 if (PerlIOValid(f)) {
14a5cf38 3833 PerlIO *next = PerlIONext(f);
67363c0d
JH
3834 PerlIO_funcs *tab =
3835 PerlIO_layer_fetch(aTHX_ layers, n - 1, PerlIOBase(next)->tab);
3836 if (tab && tab->Open)
3837 next =
3838 (*tab->Open)(aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
3839 next, narg, args);
2dc2558e 3840 if (!next || (*PerlIOBase(f)->tab->Pushed) (aTHX_ f, mode, PerlIOArg, self) != 0) {
14a5cf38
JH
3841 return NULL;
3842 }
3843 }
3844 else {
04892f78 3845 PerlIO_funcs *tab = PerlIO_layer_fetch(aTHX_ layers, n - 1, PerlIO_default_btm());
14a5cf38 3846 int init = 0;
3b6c1aba 3847 if (*mode == IoTYPE_IMPLICIT) {
14a5cf38
JH
3848 init = 1;
3849 /*
71200d45 3850 * mode++;
14a5cf38
JH
3851 */
3852 }
67363c0d
JH
3853 if (tab && tab->Open)
3854 f = (*tab->Open)(aTHX_ tab, layers, n - 1, mode, fd, imode, perm,
3855 f, narg, args);
3856 else
3857 SETERRNO(EINVAL, LIB_INVARG);
14a5cf38 3858 if (f) {
22569500 3859 if (PerlIO_push(aTHX_ f, self, mode, PerlIOArg) == 0) {
b26b1ab5
NC
3860 /*
3861 * if push fails during open, open fails. close will pop us.
3862 */
3863 PerlIO_close (f);
3864 return NULL;
3865 } else {
3866 fd = PerlIO_fileno(f);
b26b1ab5
NC
3867 if (init && fd == 2) {
3868 /*
3869 * Initial stderr is unbuffered
3870 */
3871 PerlIOBase(f)->flags |= PERLIO_F_UNBUF;
3872 }
23b84778
IZ
3873#ifdef PERLIO_USING_CRLF
3874# ifdef PERLIO_IS_BINMODE_FD
3875 if (PERLIO_IS_BINMODE_FD(fd))
bd61b366 3876 PerlIO_binmode(aTHX_ f, '<'/*not used*/, O_BINARY, NULL);
23b84778
IZ
3877 else
3878# endif
3879 /*
3880 * do something about failing setmode()? --jhi
3881 */
3882 PerlLIO_setmode(fd, O_BINARY);
3883#endif
8c8488cd
CB
3884#ifdef VMS
3885#include <rms.h>
3886 /* Enable line buffering with record-oriented regular files
3887 * so we don't introduce an extraneous record boundary when
3888 * the buffer fills up.
3889 */
3890 if (PerlIOBase(f)->flags & PERLIO_F_CANWRITE) {
3891 Stat_t st;
3892 if (PerlLIO_fstat(fd, &st) == 0
3893 && S_ISREG(st.st_mode)
3894 && (st.st_fab_rfm == FAB$C_VAR
3895 || st.st_fab_rfm == FAB$C_VFC)) {
3896 PerlIOBase(f)->flags |= PERLIO_F_LINEBUF;
3897 }
3898 }
3899#endif
14a5cf38
JH
3900 }
3901 }
ee518936 3902 }
14a5cf38 3903 return f;
9e353e3b
NIS
3904}
3905
14a5cf38
JH
3906/*
3907 * This "flush" is akin to sfio's sync in that it handles files in either
93c2c2ec
IZ
3908 * read or write state. For write state, we put the postponed data through
3909 * the next layers. For read state, we seek() the next layers to the
3910 * offset given by current position in the buffer, and discard the buffer
3911 * state (XXXX supposed to be for seek()able buffers only, but now it is done
3912 * in any case?). Then the pass the stick further in chain.
14a5cf38 3913 */
9e353e3b 3914IV
f62ce20a 3915PerlIOBuf_flush(pTHX_ PerlIO *f)
6f9d8c32 3916{
dcda55fc 3917 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 3918 int code = 0;
04892f78 3919 PerlIO *n = PerlIONext(f);
14a5cf38
JH
3920 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF) {
3921 /*
71200d45 3922 * write() the buffer
14a5cf38 3923 */
de009b76
AL
3924 const STDCHAR *buf = b->buf;
3925 const STDCHAR *p = buf;
14a5cf38
JH
3926 while (p < b->ptr) {
3927 SSize_t count = PerlIO_write(n, p, b->ptr - p);
3928 if (count > 0) {
3929 p += count;
3930 }
3931 else if (count < 0 || PerlIO_error(n)) {
3932 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
3933 code = -1;
3934 break;
3935 }
3936 }
3937 b->posn += (p - buf);
3938 }
3939 else if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
3940 STDCHAR *buf = PerlIO_get_base(f);
3941 /*
71200d45 3942 * Note position change
14a5cf38
JH
3943 */
3944 b->posn += (b->ptr - buf);
3945 if (b->ptr < b->end) {
4b069b44
NIS
3946 /* We did not consume all of it - try and seek downstream to
3947 our logical position
14a5cf38 3948 */
4b069b44 3949 if (PerlIOValid(n) && PerlIO_seek(n, b->posn, SEEK_SET) == 0) {
04892f78
NIS
3950 /* Reload n as some layers may pop themselves on seek */
3951 b->posn = PerlIO_tell(n = PerlIONext(f));
14a5cf38 3952 }
ba5c3fe9 3953 else {
4b069b44
NIS
3954 /* Seek failed (e.g. pipe or tty). Do NOT clear buffer or pre-read
3955 data is lost for good - so return saying "ok" having undone
3956 the position adjust
3957 */
3958 b->posn -= (b->ptr - buf);
ba5c3fe9
NIS
3959 return code;
3960 }
14a5cf38
JH
3961 }
3962 }
3963 b->ptr = b->end = b->buf;
3964 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
04892f78 3965 /* We check for Valid because of dubious decision to make PerlIO_flush(NULL) flush all */
04892f78 3966 if (PerlIOValid(n) && PerlIO_flush(n) != 0)
14a5cf38
JH
3967 code = -1;
3968 return code;
6f9d8c32
NIS
3969}
3970
93c2c2ec
IZ
3971/* This discards the content of the buffer after b->ptr, and rereads
3972 * the buffer from the position off in the layer downstream; here off
3973 * is at offset corresponding to b->ptr - b->buf.
3974 */
06da4f11 3975IV
f62ce20a 3976PerlIOBuf_fill(pTHX_ PerlIO *f)
06da4f11 3977{
dcda55fc 3978 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
3979 PerlIO *n = PerlIONext(f);
3980 SSize_t avail;
3981 /*
4b069b44
NIS
3982 * Down-stream flush is defined not to loose read data so is harmless.
3983 * we would not normally be fill'ing if there was data left in anycase.
14a5cf38 3984 */
93c2c2ec 3985 if (PerlIO_flush(f) != 0) /* XXXX Check that its seek() succeeded?! */
14a5cf38
JH
3986 return -1;
3987 if (PerlIOBase(f)->flags & PERLIO_F_TTY)
f62ce20a 3988 PerlIOBase_flush_linebuf(aTHX);
14a5cf38
JH
3989
3990 if (!b->buf)
22569500 3991 PerlIO_get_base(f); /* allocate via vtable */
14a5cf38 3992
0f0eef27 3993 assert(b->buf); /* The b->buf does get allocated via the vtable system. */
ec6fa4f0 3994
14a5cf38 3995 b->ptr = b->end = b->buf;
4b069b44
NIS
3996
3997 if (!PerlIOValid(n)) {
3998 PerlIOBase(f)->flags |= PERLIO_F_EOF;
3999 return -1;
4000 }
4001
14a5cf38
JH
4002 if (PerlIO_fast_gets(n)) {
4003 /*
04892f78 4004 * Layer below is also buffered. We do _NOT_ want to call its
14a5cf38
JH
4005 * ->Read() because that will loop till it gets what we asked for
4006 * which may hang on a pipe etc. Instead take anything it has to
71200d45 4007 * hand, or ask it to fill _once_.
14a5cf38
JH
4008 */
4009 avail = PerlIO_get_cnt(n);
4010 if (avail <= 0) {
4011 avail = PerlIO_fill(n);
4012 if (avail == 0)
4013 avail = PerlIO_get_cnt(n);
4014 else {
4015 if (!PerlIO_error(n) && PerlIO_eof(n))
4016 avail = 0;
4017 }
4018 }
4019 if (avail > 0) {
4020 STDCHAR *ptr = PerlIO_get_ptr(n);
dcda55fc 4021 const SSize_t cnt = avail;
eb160463 4022 if (avail > (SSize_t)b->bufsiz)
14a5cf38
JH
4023 avail = b->bufsiz;
4024 Copy(ptr, b->buf, avail, STDCHAR);
4025 PerlIO_set_ptrcnt(n, ptr + avail, cnt - avail);
4026 }
4027 }
4028 else {
4029 avail = PerlIO_read(n, b->ptr, b->bufsiz);
4030 }
4031 if (avail <= 0) {
4032 if (avail == 0)
4033 PerlIOBase(f)->flags |= PERLIO_F_EOF;
4034 else
4035 PerlIOBase(f)->flags |= PERLIO_F_ERROR;
4036 return -1;
4037 }
4038 b->end = b->buf + avail;
4039 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4040 return 0;
06da4f11
NIS
4041}
4042
6f9d8c32 4043SSize_t
f62ce20a 4044PerlIOBuf_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
6f9d8c32 4045{
04892f78 4046 if (PerlIOValid(f)) {
dcda55fc 4047 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4048 if (!b->ptr)
4049 PerlIO_get_base(f);
f62ce20a 4050 return PerlIOBase_read(aTHX_ f, vbuf, count);
14a5cf38
JH
4051 }
4052 return 0;
6f9d8c32
NIS
4053}
4054
9e353e3b 4055SSize_t
f62ce20a 4056PerlIOBuf_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 4057{
14a5cf38 4058 const STDCHAR *buf = (const STDCHAR *) vbuf + count;
dcda55fc 4059 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4060 SSize_t unread = 0;
4061 SSize_t avail;
4062 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4063 PerlIO_flush(f);
4064 if (!b->buf)
4065 PerlIO_get_base(f);
4066 if (b->buf) {
4067 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
4068 /*
4069 * Buffer is already a read buffer, we can overwrite any chars
71200d45 4070 * which have been read back to buffer start
14a5cf38
JH
4071 */
4072 avail = (b->ptr - b->buf);
4073 }
4074 else {
4075 /*
4076 * Buffer is idle, set it up so whole buffer is available for
71200d45 4077 * unread
14a5cf38
JH
4078 */
4079 avail = b->bufsiz;
4080 b->end = b->buf + avail;
4081 b->ptr = b->end;
4082 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4083 /*
71200d45 4084 * Buffer extends _back_ from where we are now
14a5cf38
JH
4085 */
4086 b->posn -= b->bufsiz;
4087 }
4088 if (avail > (SSize_t) count) {
4089 /*
71200d45 4090 * If we have space for more than count, just move count
14a5cf38
JH
4091 */
4092 avail = count;
4093 }
4094 if (avail > 0) {
4095 b->ptr -= avail;
4096 buf -= avail;
4097 /*
4098 * In simple stdio-like ungetc() case chars will be already
71200d45 4099 * there
14a5cf38
JH
4100 */
4101 if (buf != b->ptr) {
4102 Copy(buf, b->ptr, avail, STDCHAR);
4103 }
4104 count -= avail;
4105 unread += avail;
4106 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4107 }
4108 }
93679785
NIS
4109 if (count > 0) {
4110 unread += PerlIOBase_unread(aTHX_ f, vbuf, count);
4111 }
14a5cf38 4112 return unread;
760ac839
LW
4113}
4114
9e353e3b 4115SSize_t
f62ce20a 4116PerlIOBuf_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
760ac839 4117{
de009b76 4118 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4119 const STDCHAR *buf = (const STDCHAR *) vbuf;
ee56a6b9 4120 const STDCHAR *flushptr = buf;
14a5cf38
JH
4121 Size_t written = 0;
4122 if (!b->buf)
4123 PerlIO_get_base(f);
4124 if (!(PerlIOBase(f)->flags & PERLIO_F_CANWRITE))
4125 return 0;
0678cb22
NIS
4126 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
4127 if (PerlIO_flush(f) != 0) {
4128 return 0;
4129 }
4130 }
ee56a6b9
CS
4131 if (PerlIOBase(f)->flags & PERLIO_F_LINEBUF) {
4132 flushptr = buf + count;
4133 while (flushptr > buf && *(flushptr - 1) != '\n')
4134 --flushptr;
4135 }
14a5cf38
JH
4136 while (count > 0) {
4137 SSize_t avail = b->bufsiz - (b->ptr - b->buf);
4138 if ((SSize_t) count < avail)
4139 avail = count;
ee56a6b9
CS
4140 if (flushptr > buf && flushptr <= buf + avail)
4141 avail = flushptr - buf;
14a5cf38 4142 PerlIOBase(f)->flags |= PERLIO_F_WRBUF;
ee56a6b9
CS
4143 if (avail) {
4144 Copy(buf, b->ptr, avail, STDCHAR);
4145 count -= avail;
4146 buf += avail;
4147 written += avail;
4148 b->ptr += avail;
4149 if (buf == flushptr)
4150 PerlIO_flush(f);
14a5cf38
JH
4151 }
4152 if (b->ptr >= (b->buf + b->bufsiz))
abf9167d
DM
4153 if (PerlIO_flush(f) == -1)
4154 return -1;
14a5cf38
JH
4155 }
4156 if (PerlIOBase(f)->flags & PERLIO_F_UNBUF)
4157 PerlIO_flush(f);
4158 return written;
9e353e3b
NIS
4159}
4160
94a175e1 4161IV
f62ce20a 4162PerlIOBuf_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
9e353e3b 4163{
14a5cf38
JH
4164 IV code;
4165 if ((code = PerlIO_flush(f)) == 0) {
14a5cf38
JH
4166 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4167 code = PerlIO_seek(PerlIONext(f), offset, whence);
4168 if (code == 0) {
de009b76 4169 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4170 b->posn = PerlIO_tell(PerlIONext(f));
4171 }
9e353e3b 4172 }
14a5cf38 4173 return code;
9e353e3b
NIS
4174}
4175
4176Off_t
f62ce20a 4177PerlIOBuf_tell(pTHX_ PerlIO *f)
9e353e3b 4178{
dcda55fc 4179 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4180 /*
71200d45 4181 * b->posn is file position where b->buf was read, or will be written
14a5cf38
JH
4182 */
4183 Off_t posn = b->posn;
37725cdc 4184 if ((PerlIOBase(f)->flags & PERLIO_F_APPEND) &&
0678cb22
NIS
4185 (PerlIOBase(f)->flags & PERLIO_F_WRBUF)) {
4186#if 1
4187 /* As O_APPEND files are normally shared in some sense it is better
4188 to flush :
4189 */
4190 PerlIO_flush(f);
4191#else
37725cdc 4192 /* when file is NOT shared then this is sufficient */
0678cb22
NIS
4193 PerlIO_seek(PerlIONext(f),0, SEEK_END);
4194#endif
4195 posn = b->posn = PerlIO_tell(PerlIONext(f));
4196 }
14a5cf38
JH
4197 if (b->buf) {
4198 /*
71200d45 4199 * If buffer is valid adjust position by amount in buffer
14a5cf38
JH
4200 */
4201 posn += (b->ptr - b->buf);
4202 }
4203 return posn;
9e353e3b
NIS
4204}
4205
4206IV
44798d05
NIS
4207PerlIOBuf_popped(pTHX_ PerlIO *f)
4208{
de009b76
AL
4209 const IV code = PerlIOBase_popped(aTHX_ f);
4210 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
44798d05
NIS
4211 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
4212 Safefree(b->buf);
4213 }
dcda55fc 4214 b->ptr = b->end = b->buf = NULL;
44798d05
NIS
4215 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4216 return code;
4217}
4218
4219IV
f62ce20a 4220PerlIOBuf_close(pTHX_ PerlIO *f)
9e353e3b 4221{
de009b76
AL
4222 const IV code = PerlIOBase_close(aTHX_ f);
4223 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4224 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
3a1ee7e8 4225 Safefree(b->buf);
14a5cf38 4226 }
dcda55fc 4227 b->ptr = b->end = b->buf = NULL;
14a5cf38
JH
4228 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4229 return code;
760ac839
LW
4230}
4231
9e353e3b 4232STDCHAR *
f62ce20a 4233PerlIOBuf_get_ptr(pTHX_ PerlIO *f)
9e353e3b 4234{
dcda55fc 4235 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4236 if (!b->buf)
4237 PerlIO_get_base(f);
4238 return b->ptr;
9e353e3b
NIS
4239}
4240
05d1247b 4241SSize_t
f62ce20a 4242PerlIOBuf_get_cnt(pTHX_ PerlIO *f)
9e353e3b 4243{
dcda55fc 4244 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4245 if (!b->buf)
4246 PerlIO_get_base(f);
4247 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF)
4248 return (b->end - b->ptr);
4249 return 0;
9e353e3b
NIS
4250}
4251
4252STDCHAR *
f62ce20a 4253PerlIOBuf_get_base(pTHX_ PerlIO *f)
9e353e3b 4254{
dcda55fc 4255 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
96a5add6
AL
4256 PERL_UNUSED_CONTEXT;
4257
14a5cf38
JH
4258 if (!b->buf) {
4259 if (!b->bufsiz)
1810cd7c 4260 b->bufsiz = PERLIOBUF_DEFAULT_BUFSIZ;
e05a0d74 4261 Newxz(b->buf,b->bufsiz, STDCHAR);
14a5cf38
JH
4262 if (!b->buf) {
4263 b->buf = (STDCHAR *) & b->oneword;
4264 b->bufsiz = sizeof(b->oneword);
4265 }
dcda55fc 4266 b->end = b->ptr = b->buf;
06da4f11 4267 }
14a5cf38 4268 return b->buf;
9e353e3b
NIS
4269}
4270
4271Size_t
f62ce20a 4272PerlIOBuf_bufsiz(pTHX_ PerlIO *f)
9e353e3b 4273{
dcda55fc 4274 const PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4275 if (!b->buf)
4276 PerlIO_get_base(f);
4277 return (b->end - b->buf);
9e353e3b
NIS
4278}
4279
4280void
f62ce20a 4281PerlIOBuf_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
9e353e3b 4282{
dcda55fc 4283 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
babfacb9
JH
4284#ifndef DEBUGGING
4285 PERL_UNUSED_ARG(cnt);
4286#endif
14a5cf38
JH
4287 if (!b->buf)
4288 PerlIO_get_base(f);
4289 b->ptr = ptr;
b727803b
RGS
4290 assert(PerlIO_get_cnt(f) == cnt);
4291 assert(b->ptr >= b->buf);
14a5cf38 4292 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
760ac839
LW
4293}
4294
71200d45 4295PerlIO *
ecdeb87c 4296PerlIOBuf_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 4297{
ecdeb87c 4298 return PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
4299}
4300
4301
4302
27da23d5 4303PERLIO_FUNCS_DECL(PerlIO_perlio) = {
2dc2558e 4304 sizeof(PerlIO_funcs),
14a5cf38
JH
4305 "perlio",
4306 sizeof(PerlIOBuf),
86e05cf2 4307 PERLIO_K_BUFFERED|PERLIO_K_RAW,
14a5cf38 4308 PerlIOBuf_pushed,
44798d05 4309 PerlIOBuf_popped,
14a5cf38 4310 PerlIOBuf_open,
86e05cf2 4311 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
4312 NULL,
4313 PerlIOBase_fileno,
71200d45 4314 PerlIOBuf_dup,
14a5cf38
JH
4315 PerlIOBuf_read,
4316 PerlIOBuf_unread,
4317 PerlIOBuf_write,
4318 PerlIOBuf_seek,
4319 PerlIOBuf_tell,
4320 PerlIOBuf_close,
4321 PerlIOBuf_flush,
4322 PerlIOBuf_fill,
4323 PerlIOBase_eof,
4324 PerlIOBase_error,
4325 PerlIOBase_clearerr,
4326 PerlIOBase_setlinebuf,
4327 PerlIOBuf_get_base,
4328 PerlIOBuf_bufsiz,
4329 PerlIOBuf_get_ptr,
4330 PerlIOBuf_get_cnt,
4331 PerlIOBuf_set_ptrcnt,
9e353e3b
NIS
4332};
4333
66ecd56b 4334/*--------------------------------------------------------------------------------------*/
14a5cf38 4335/*
71200d45 4336 * Temp layer to hold unread chars when cannot do it any other way
14a5cf38 4337 */
5e2ab84b
NIS
4338
4339IV
f62ce20a 4340PerlIOPending_fill(pTHX_ PerlIO *f)
5e2ab84b 4341{
14a5cf38 4342 /*
71200d45 4343 * Should never happen
14a5cf38
JH
4344 */
4345 PerlIO_flush(f);
4346 return 0;
5e2ab84b
NIS
4347}
4348
4349IV
f62ce20a 4350PerlIOPending_close(pTHX_ PerlIO *f)
5e2ab84b 4351{
14a5cf38 4352 /*
71200d45 4353 * A tad tricky - flush pops us, then we close new top
14a5cf38
JH
4354 */
4355 PerlIO_flush(f);
4356 return PerlIO_close(f);
5e2ab84b
NIS
4357}
4358
94a175e1 4359IV
f62ce20a 4360PerlIOPending_seek(pTHX_ PerlIO *f, Off_t offset, int whence)
5e2ab84b 4361{
14a5cf38 4362 /*
71200d45 4363 * A tad tricky - flush pops us, then we seek new top
14a5cf38
JH
4364 */
4365 PerlIO_flush(f);
4366 return PerlIO_seek(f, offset, whence);
5e2ab84b
NIS
4367}
4368
4369
4370IV
f62ce20a 4371PerlIOPending_flush(pTHX_ PerlIO *f)
5e2ab84b 4372{
dcda55fc 4373 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4374 if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
3a1ee7e8 4375 Safefree(b->buf);
14a5cf38
JH
4376 b->buf = NULL;
4377 }
4378 PerlIO_pop(aTHX_ f);
4379 return 0;
5e2ab84b
NIS
4380}
4381
4382void
f62ce20a 4383PerlIOPending_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
5e2ab84b 4384{
14a5cf38
JH
4385 if (cnt <= 0) {
4386 PerlIO_flush(f);
4387 }
4388 else {
f62ce20a 4389 PerlIOBuf_set_ptrcnt(aTHX_ f, ptr, cnt);
14a5cf38 4390 }
5e2ab84b
NIS
4391}
4392
4393IV
2dc2558e 4394PerlIOPending_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
5e2ab84b 4395{
de009b76 4396 const IV code = PerlIOBase_pushed(aTHX_ f, mode, arg, tab);
dcda55fc 4397 PerlIOl * const l = PerlIOBase(f);
14a5cf38 4398 /*
71200d45
NIS
4399 * Our PerlIO_fast_gets must match what we are pushed on, or sv_gets()
4400 * etc. get muddled when it changes mid-string when we auto-pop.
14a5cf38
JH
4401 */
4402 l->flags = (l->flags & ~(PERLIO_F_FASTGETS | PERLIO_F_UTF8)) |
4403 (PerlIOBase(PerlIONext(f))->
4404 flags & (PERLIO_F_FASTGETS | PERLIO_F_UTF8));
4405 return code;
5e2ab84b
NIS
4406}
4407
4408SSize_t
f62ce20a 4409PerlIOPending_read(pTHX_ PerlIO *f, void *vbuf, Size_t count)
5e2ab84b 4410{
14a5cf38
JH
4411 SSize_t avail = PerlIO_get_cnt(f);
4412 SSize_t got = 0;
eb160463 4413 if ((SSize_t)count < avail)
14a5cf38
JH
4414 avail = count;
4415 if (avail > 0)
f62ce20a 4416 got = PerlIOBuf_read(aTHX_ f, vbuf, avail);
eb160463 4417 if (got >= 0 && got < (SSize_t)count) {
de009b76 4418 const SSize_t more =
14a5cf38
JH
4419 PerlIO_read(f, ((STDCHAR *) vbuf) + got, count - got);
4420 if (more >= 0 || got == 0)
4421 got += more;
4422 }
4423 return got;
5e2ab84b
NIS
4424}
4425
27da23d5 4426PERLIO_FUNCS_DECL(PerlIO_pending) = {
2dc2558e 4427 sizeof(PerlIO_funcs),
14a5cf38
JH
4428 "pending",
4429 sizeof(PerlIOBuf),
86e05cf2 4430 PERLIO_K_BUFFERED|PERLIO_K_RAW, /* not sure about RAW here */
14a5cf38 4431 PerlIOPending_pushed,
44798d05 4432 PerlIOBuf_popped,
14a5cf38 4433 NULL,
86e05cf2 4434 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
4435 NULL,
4436 PerlIOBase_fileno,
71200d45 4437 PerlIOBuf_dup,
14a5cf38
JH
4438 PerlIOPending_read,
4439 PerlIOBuf_unread,
4440 PerlIOBuf_write,
4441 PerlIOPending_seek,
4442 PerlIOBuf_tell,
4443 PerlIOPending_close,
4444 PerlIOPending_flush,
4445 PerlIOPending_fill,
4446 PerlIOBase_eof,
4447 PerlIOBase_error,
4448 PerlIOBase_clearerr,
4449 PerlIOBase_setlinebuf,
4450 PerlIOBuf_get_base,
4451 PerlIOBuf_bufsiz,
4452 PerlIOBuf_get_ptr,
4453 PerlIOBuf_get_cnt,
4454 PerlIOPending_set_ptrcnt,
5e2ab84b
NIS
4455};
4456
4457
4458
4459/*--------------------------------------------------------------------------------------*/
14a5cf38
JH
4460/*
4461 * crlf - translation On read translate CR,LF to "\n" we do this by
4462 * overriding ptr/cnt entries to hand back a line at a time and keeping a
71200d45 4463 * record of which nl we "lied" about. On write translate "\n" to CR,LF
93c2c2ec
IZ
4464 *
4465 * c->nl points on the first byte of CR LF pair when it is temporarily
4466 * replaced by LF, or to the last CR of the buffer. In the former case
4467 * the caller thinks that the buffer ends at c->nl + 1, in the latter
4468 * that it ends at c->nl; these two cases can be distinguished by
4469 * *c->nl. c->nl is set during _getcnt() call, and unset during
4470 * _unread() and _flush() calls.
4471 * It only matters for read operations.
66ecd56b
NIS
4472 */
4473
14a5cf38 4474typedef struct {
22569500
NIS
4475 PerlIOBuf base; /* PerlIOBuf stuff */
4476 STDCHAR *nl; /* Position of crlf we "lied" about in the
14a5cf38 4477 * buffer */
99efab12
NIS
4478} PerlIOCrlf;
4479
ff1e3883
JD
4480/* Inherit the PERLIO_F_UTF8 flag from previous layer.
4481 * Otherwise the :crlf layer would always revert back to
4482 * raw mode.
4483 */
4484static void
4485S_inherit_utf8_flag(PerlIO *f)
4486{
4487 PerlIO *g = PerlIONext(f);
4488 if (PerlIOValid(g)) {
4489 if (PerlIOBase(g)->flags & PERLIO_F_UTF8) {
4490 PerlIOBase(f)->flags |= PERLIO_F_UTF8;
4491 }
4492 }
4493}
4494
f5b9d040 4495IV
2dc2558e 4496PerlIOCrlf_pushed(pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
f5b9d040 4497{
14a5cf38
JH
4498 IV code;
4499 PerlIOBase(f)->flags |= PERLIO_F_CRLF;
2dc2558e 4500 code = PerlIOBuf_pushed(aTHX_ f, mode, arg, tab);
5e2ab84b 4501#if 0
14a5cf38 4502 PerlIO_debug("PerlIOCrlf_pushed f=%p %s %s fl=%08" UVxf "\n",
6c9570dc 4503 (void*)f, PerlIOBase(f)->tab->name, (mode) ? mode : "(Null)",
14a5cf38 4504 PerlIOBase(f)->flags);
5e2ab84b 4505#endif
8229d19f
JH
4506 {
4507 /* Enable the first CRLF capable layer you can find, but if none
4508 * found, the one we just pushed is fine. This results in at
4509 * any given moment at most one CRLF-capable layer being enabled
4510 * in the whole layer stack. */
4511 PerlIO *g = PerlIONext(f);
ff1e3883 4512 while (PerlIOValid(g)) {
8229d19f
JH
4513 PerlIOl *b = PerlIOBase(g);
4514 if (b && b->tab == &PerlIO_crlf) {
4515 if (!(b->flags & PERLIO_F_CRLF))
4516 b->flags |= PERLIO_F_CRLF;
ff1e3883 4517 S_inherit_utf8_flag(g);
8229d19f
JH
4518 PerlIO_pop(aTHX_ f);
4519 return code;
4520 }
4521 g = PerlIONext(g);
4522 }
4523 }
ff1e3883 4524 S_inherit_utf8_flag(f);
14a5cf38 4525 return code;
f5b9d040
NIS
4526}
4527
4528
99efab12 4529SSize_t
f62ce20a 4530PerlIOCrlf_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
99efab12 4531{
dcda55fc 4532 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
93c2c2ec 4533 if (c->nl) { /* XXXX Shouldn't it be done only if b->ptr > c->nl? */
14a5cf38
JH
4534 *(c->nl) = 0xd;
4535 c->nl = NULL;
4536 }
4537 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF))
f62ce20a 4538 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
14a5cf38
JH
4539 else {
4540 const STDCHAR *buf = (const STDCHAR *) vbuf + count;
4541 PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
4542 SSize_t unread = 0;
4543 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4544 PerlIO_flush(f);
4545 if (!b->buf)
4546 PerlIO_get_base(f);
4547 if (b->buf) {
4548 if (!(PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
4549 b->end = b->ptr = b->buf + b->bufsiz;
4550 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
4551 b->posn -= b->bufsiz;
4552 }
4553 while (count > 0 && b->ptr > b->buf) {
dcda55fc 4554 const int ch = *--buf;
14a5cf38
JH
4555 if (ch == '\n') {
4556 if (b->ptr - 2 >= b->buf) {
4557 *--(b->ptr) = 0xa;
4558 *--(b->ptr) = 0xd;
4559 unread++;
4560 count--;
4561 }
4562 else {
93c2c2ec
IZ
4563 /* If b->ptr - 1 == b->buf, we are undoing reading 0xa */
4564 *--(b->ptr) = 0xa; /* Works even if 0xa == '\r' */
4565 unread++;
4566 count--;
14a5cf38
JH
4567 }
4568 }
4569 else {
4570 *--(b->ptr) = ch;
4571 unread++;
4572 count--;
4573 }
4574 }
4575 }
4576 return unread;
4577 }
99efab12
NIS
4578}
4579
93c2c2ec 4580/* XXXX This code assumes that buffer size >=2, but does not check it... */
99efab12 4581SSize_t
f62ce20a 4582PerlIOCrlf_get_cnt(pTHX_ PerlIO *f)
99efab12 4583{
dcda55fc 4584 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
4585 if (!b->buf)
4586 PerlIO_get_base(f);
4587 if (PerlIOBase(f)->flags & PERLIO_F_RDBUF) {
dcda55fc 4588 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
23b3c6af
NIS
4589 if ((PerlIOBase(f)->flags & PERLIO_F_CRLF) && (!c->nl || *c->nl == 0xd)) {
4590 STDCHAR *nl = (c->nl) ? c->nl : b->ptr;
14a5cf38
JH
4591 scan:
4592 while (nl < b->end && *nl != 0xd)
4593 nl++;
4594 if (nl < b->end && *nl == 0xd) {
4595 test:
4596 if (nl + 1 < b->end) {
4597 if (nl[1] == 0xa) {
4598 *nl = '\n';
4599 c->nl = nl;
4600 }
4601 else {
4602 /*
71200d45 4603 * Not CR,LF but just CR
14a5cf38
JH
4604 */
4605 nl++;
4606 goto scan;
4607 }
4608 }
4609 else {
4610 /*
71200d45 4611 * Blast - found CR as last char in buffer
14a5cf38 4612 */
e87a358a 4613
14a5cf38
JH
4614 if (b->ptr < nl) {
4615 /*
4616 * They may not care, defer work as long as
71200d45 4617 * possible
14a5cf38 4618 */
a0d1d361 4619 c->nl = nl;
14a5cf38
JH
4620 return (nl - b->ptr);
4621 }
4622 else {
4623 int code;
22569500 4624 b->ptr++; /* say we have read it as far as
14a5cf38 4625 * flush() is concerned */
22569500 4626 b->buf++; /* Leave space in front of buffer */
e949e37c
NIS
4627 /* Note as we have moved buf up flush's
4628 posn += ptr-buf
4629 will naturally make posn point at CR
4630 */
22569500
NIS
4631 b->bufsiz--; /* Buffer is thus smaller */
4632 code = PerlIO_fill(f); /* Fetch some more */
4633 b->bufsiz++; /* Restore size for next time */
4634 b->buf--; /* Point at space */
4635 b->ptr = nl = b->buf; /* Which is what we hand
14a5cf38 4636 * off */
22569500 4637 *nl = 0xd; /* Fill in the CR */
14a5cf38 4638 if (code == 0)
22569500 4639 goto test; /* fill() call worked */
14a5cf38 4640 /*
71200d45 4641 * CR at EOF - just fall through
14a5cf38 4642 */
a0d1d361 4643 /* Should we clear EOF though ??? */
14a5cf38
JH
4644 }
4645 }
4646 }
4647 }
4648 return (((c->nl) ? (c->nl + 1) : b->end) - b->ptr);
4649 }
4650 return 0;
99efab12
NIS
4651}
4652
4653void
f62ce20a 4654PerlIOCrlf_set_ptrcnt(pTHX_ PerlIO *f, STDCHAR * ptr, SSize_t cnt)
14a5cf38 4655{
dcda55fc
AL
4656 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
4657 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
14a5cf38
JH
4658 if (!b->buf)
4659 PerlIO_get_base(f);
4660 if (!ptr) {
a0d1d361 4661 if (c->nl) {
14a5cf38 4662 ptr = c->nl + 1;
22569500 4663 if (ptr == b->end && *c->nl == 0xd) {
486ec47a 4664 /* Deferred CR at end of buffer case - we lied about count */
22569500
NIS
4665 ptr--;
4666 }
4667 }
14a5cf38
JH
4668 else {
4669 ptr = b->end;
14a5cf38
JH
4670 }
4671 ptr -= cnt;
4672 }
4673 else {
6f207bd3 4674 NOOP;
3b4bd3fd 4675#if 0
14a5cf38 4676 /*
71200d45 4677 * Test code - delete when it works ...
14a5cf38 4678 */
3b4bd3fd 4679 IV flags = PerlIOBase(f)->flags;
ba7abf9d 4680 STDCHAR *chk = (c->nl) ? (c->nl+1) : b->end;
22569500 4681 if (ptr+cnt == c->nl && c->nl+1 == b->end && *c->nl == 0xd) {
486ec47a 4682 /* Deferred CR at end of buffer case - we lied about count */
a0d1d361 4683 chk--;
22569500 4684 }
14a5cf38
JH
4685 chk -= cnt;
4686
a0d1d361 4687 if (ptr != chk ) {
99ef548b 4688 Perl_croak(aTHX_ "ptr wrong %p != %p fl=%08" UVxf
6c9570dc
MHM
4689 " nl=%p e=%p for %d", (void*)ptr, (void*)chk,
4690 flags, c->nl, b->end, cnt);
14a5cf38 4691 }
99ef548b 4692#endif
14a5cf38
JH
4693 }
4694 if (c->nl) {
4695 if (ptr > c->nl) {
4696 /*
71200d45 4697 * They have taken what we lied about
14a5cf38
JH
4698 */
4699 *(c->nl) = 0xd;
4700 c->nl = NULL;
4701 ptr++;
4702 }
4703 }
4704 b->ptr = ptr;
4705 PerlIOBase(f)->flags |= PERLIO_F_RDBUF;
99efab12
NIS
4706}
4707
4708SSize_t
f62ce20a 4709PerlIOCrlf_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
99efab12 4710{
14a5cf38 4711 if (!(PerlIOBase(f)->flags & PERLIO_F_CRLF))
f62ce20a 4712 return PerlIOBuf_write(aTHX_ f, vbuf, count);
14a5cf38 4713 else {
dcda55fc 4714 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38 4715 const STDCHAR *buf = (const STDCHAR *) vbuf;
dcda55fc 4716 const STDCHAR * const ebuf = buf + count;
14a5cf38
JH
4717 if (!b->buf)
4718 PerlIO_get_base(f);
4719 if (!(PerlIOBase(f)->flags & PERLIO_F_CANWRITE))
4720 return 0;
4721 while (buf < ebuf) {
dcda55fc 4722 const STDCHAR * const eptr = b->buf + b->bufsiz;
14a5cf38
JH
4723 PerlIOBase(f)->flags |= PERLIO_F_WRBUF;
4724 while (buf < ebuf && b->ptr < eptr) {
4725 if (*buf == '\n') {
4726 if ((b->ptr + 2) > eptr) {
4727 /*
71200d45 4728 * Not room for both
14a5cf38
JH
4729 */
4730 PerlIO_flush(f);
4731 break;
4732 }
4733 else {
22569500
NIS
4734 *(b->ptr)++ = 0xd; /* CR */
4735 *(b->ptr)++ = 0xa; /* LF */
14a5cf38
JH
4736 buf++;
4737 if (PerlIOBase(f)->flags & PERLIO_F_LINEBUF) {
4738 PerlIO_flush(f);
4739 break;
4740 }
4741 }
4742 }
4743 else {
dcda55fc 4744 *(b->ptr)++ = *buf++;
14a5cf38
JH
4745 }
4746 if (b->ptr >= eptr) {
4747 PerlIO_flush(f);
4748 break;
4749 }
4750 }
4751 }
4752 if (PerlIOBase(f)->flags & PERLIO_F_UNBUF)
4753 PerlIO_flush(f);
4754 return (buf - (STDCHAR *) vbuf);
4755 }
99efab12
NIS
4756}
4757
4758IV
f62ce20a 4759PerlIOCrlf_flush(pTHX_ PerlIO *f)
99efab12 4760{
dcda55fc 4761 PerlIOCrlf * const c = PerlIOSelf(f, PerlIOCrlf);
14a5cf38
JH
4762 if (c->nl) {
4763 *(c->nl) = 0xd;
4764 c->nl = NULL;
4765 }
f62ce20a 4766 return PerlIOBuf_flush(aTHX_ f);
99efab12
NIS
4767}
4768
86e05cf2
NIS
4769IV
4770PerlIOCrlf_binmode(pTHX_ PerlIO *f)
4771{
4772 if ((PerlIOBase(f)->flags & PERLIO_F_CRLF)) {
4773 /* In text mode - flush any pending stuff and flip it */
4774 PerlIOBase(f)->flags &= ~PERLIO_F_CRLF;
4775#ifndef PERLIO_USING_CRLF
4776 /* CRLF is unusual case - if this is just the :crlf layer pop it */
5fae6dc1 4777 PerlIO_pop(aTHX_ f);
86e05cf2
NIS
4778#endif
4779 }
4780 return 0;
4781}
4782
27da23d5 4783PERLIO_FUNCS_DECL(PerlIO_crlf) = {
2dc2558e 4784 sizeof(PerlIO_funcs),
14a5cf38
JH
4785 "crlf",
4786 sizeof(PerlIOCrlf),
86e05cf2 4787 PERLIO_K_BUFFERED | PERLIO_K_CANCRLF | PERLIO_K_RAW,
14a5cf38 4788 PerlIOCrlf_pushed,
44798d05 4789 PerlIOBuf_popped, /* popped */
14a5cf38 4790 PerlIOBuf_open,
86e05cf2 4791 PerlIOCrlf_binmode, /* binmode */
14a5cf38
JH
4792 NULL,
4793 PerlIOBase_fileno,
71200d45 4794 PerlIOBuf_dup,
de009b76 4795 PerlIOBuf_read, /* generic read works with ptr/cnt lies */
22569500
NIS
4796 PerlIOCrlf_unread, /* Put CR,LF in buffer for each '\n' */
4797 PerlIOCrlf_write, /* Put CR,LF in buffer for each '\n' */
14a5cf38
JH
4798 PerlIOBuf_seek,
4799 PerlIOBuf_tell,
4800 PerlIOBuf_close,
4801 PerlIOCrlf_flush,
4802 PerlIOBuf_fill,
4803 PerlIOBase_eof,
4804 PerlIOBase_error,
4805 PerlIOBase_clearerr,
4806 PerlIOBase_setlinebuf,
4807 PerlIOBuf_get_base,
4808 PerlIOBuf_bufsiz,
4809 PerlIOBuf_get_ptr,
4810 PerlIOCrlf_get_cnt,
4811 PerlIOCrlf_set_ptrcnt,
66ecd56b
NIS
4812};
4813
06da4f11
NIS
4814#ifdef HAS_MMAP
4815/*--------------------------------------------------------------------------------------*/
14a5cf38 4816/*
71200d45 4817 * mmap as "buffer" layer
14a5cf38 4818 */
06da4f11 4819
14a5cf38 4820typedef struct {
22569500
NIS
4821 PerlIOBuf base; /* PerlIOBuf stuff */
4822 Mmap_t mptr; /* Mapped address */
4823 Size_t len; /* mapped length */
4824 STDCHAR *bbuf; /* malloced buffer if map fails */
06da4f11
NIS
4825} PerlIOMmap;
4826
4827IV
f62ce20a 4828PerlIOMmap_map(pTHX_ PerlIO *f)
06da4f11 4829{
27da23d5 4830 dVAR;
de009b76
AL
4831 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4832 const IV flags = PerlIOBase(f)->flags;
14a5cf38
JH
4833 IV code = 0;
4834 if (m->len)
4835 abort();
4836 if (flags & PERLIO_F_CANREAD) {
dcda55fc 4837 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
de009b76 4838 const int fd = PerlIO_fileno(f);
10eefe7f
CB
4839 Stat_t st;
4840 code = Fstat(fd, &st);
14a5cf38
JH
4841 if (code == 0 && S_ISREG(st.st_mode)) {
4842 SSize_t len = st.st_size - b->posn;
4843 if (len > 0) {
4844 Off_t posn;
27da23d5
JH
4845 if (PL_mmap_page_size <= 0)
4846 Perl_croak(aTHX_ "panic: bad pagesize %" IVdf,
4847 PL_mmap_page_size);
14a5cf38
JH
4848 if (b->posn < 0) {
4849 /*
4850 * This is a hack - should never happen - open should
71200d45 4851 * have set it !
14a5cf38
JH
4852 */
4853 b->posn = PerlIO_tell(PerlIONext(f));
4854 }
27da23d5 4855 posn = (b->posn / PL_mmap_page_size) * PL_mmap_page_size;
14a5cf38 4856 len = st.st_size - posn;
b91fbb93 4857 m->mptr = (Mmap_t)mmap(NULL, len, PROT_READ, MAP_SHARED, fd, posn);
14a5cf38 4858 if (m->mptr && m->mptr != (Mmap_t) - 1) {
a5262162 4859#if 0 && defined(HAS_MADVISE) && defined(MADV_SEQUENTIAL)
14a5cf38 4860 madvise(m->mptr, len, MADV_SEQUENTIAL);
06da4f11 4861#endif
a5262162 4862#if 0 && defined(HAS_MADVISE) && defined(MADV_WILLNEED)
14a5cf38 4863 madvise(m->mptr, len, MADV_WILLNEED);
a5262162 4864#endif
14a5cf38
JH
4865 PerlIOBase(f)->flags =
4866 (flags & ~PERLIO_F_EOF) | PERLIO_F_RDBUF;
4867 b->end = ((STDCHAR *) m->mptr) + len;
4868 b->buf = ((STDCHAR *) m->mptr) + (b->posn - posn);
4869 b->ptr = b->buf;
4870 m->len = len;
4871 }
4872 else {
4873 b->buf = NULL;
4874 }
4875 }
4876 else {
4877 PerlIOBase(f)->flags =
4878 flags | PERLIO_F_EOF | PERLIO_F_RDBUF;
4879 b->buf = NULL;
4880 b->ptr = b->end = b->ptr;
4881 code = -1;
4882 }
4883 }
4884 }
4885 return code;
06da4f11
NIS
4886}
4887
4888IV
e87a358a 4889PerlIOMmap_unmap(pTHX_ PerlIO *f)
06da4f11 4890{
dcda55fc 4891 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
14a5cf38
JH
4892 IV code = 0;
4893 if (m->len) {
dcda55fc 4894 PerlIOBuf * const b = &m->base;
14a5cf38 4895 if (b->buf) {
1ccb7c8d
JH
4896 /* The munmap address argument is tricky: depending on the
4897 * standard it is either "void *" or "caddr_t" (which is
4898 * usually "char *" (signed or unsigned). If we cast it
4899 * to "void *", those that have it caddr_t and an uptight
4900 * C++ compiler, will freak out. But casting it as char*
4901 * should work. Maybe. (Using Mmap_t figured out by
4902 * Configure doesn't always work, apparently.) */
4903 code = munmap((char*)m->mptr, m->len);
14a5cf38
JH
4904 b->buf = NULL;
4905 m->len = 0;
4906 m->mptr = NULL;
4907 if (PerlIO_seek(PerlIONext(f), b->posn, SEEK_SET) != 0)
4908 code = -1;
4909 }
4910 b->ptr = b->end = b->buf;
4911 PerlIOBase(f)->flags &= ~(PERLIO_F_RDBUF | PERLIO_F_WRBUF);
4912 }
4913 return code;
06da4f11
NIS
4914}
4915
4916STDCHAR *
f62ce20a 4917PerlIOMmap_get_base(pTHX_ PerlIO *f)
06da4f11 4918{
dcda55fc
AL
4919 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4920 PerlIOBuf * const b = &m->base;
14a5cf38
JH
4921 if (b->buf && (PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
4922 /*
71200d45 4923 * Already have a readbuffer in progress
14a5cf38
JH
4924 */
4925 return b->buf;
4926 }
4927 if (b->buf) {
4928 /*
71200d45 4929 * We have a write buffer or flushed PerlIOBuf read buffer
14a5cf38 4930 */
22569500
NIS
4931 m->bbuf = b->buf; /* save it in case we need it again */
4932 b->buf = NULL; /* Clear to trigger below */
14a5cf38
JH
4933 }
4934 if (!b->buf) {
22569500 4935 PerlIOMmap_map(aTHX_ f); /* Try and map it */
14a5cf38
JH
4936 if (!b->buf) {
4937 /*
71200d45 4938 * Map did not work - recover PerlIOBuf buffer if we have one
14a5cf38
JH
4939 */
4940 b->buf = m->bbuf;
4941 }
4942 }
4943 b->ptr = b->end = b->buf;
4944 if (b->buf)
4945 return b->buf;
f62ce20a 4946 return PerlIOBuf_get_base(aTHX_ f);
06da4f11
NIS
4947}
4948
4949SSize_t
f62ce20a 4950PerlIOMmap_unread(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
06da4f11 4951{
dcda55fc
AL
4952 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4953 PerlIOBuf * const b = &m->base;
14a5cf38
JH
4954 if (PerlIOBase(f)->flags & PERLIO_F_WRBUF)
4955 PerlIO_flush(f);
4956 if (b->ptr && (b->ptr - count) >= b->buf
4957 && memEQ(b->ptr - count, vbuf, count)) {
4958 b->ptr -= count;
4959 PerlIOBase(f)->flags &= ~PERLIO_F_EOF;
4960 return count;
4961 }
4962 if (m->len) {
4963 /*
71200d45 4964 * Loose the unwritable mapped buffer
14a5cf38
JH
4965 */
4966 PerlIO_flush(f);
4967 /*
71200d45 4968 * If flush took the "buffer" see if we have one from before
14a5cf38
JH
4969 */
4970 if (!b->buf && m->bbuf)
4971 b->buf = m->bbuf;
4972 if (!b->buf) {
f62ce20a 4973 PerlIOBuf_get_base(aTHX_ f);
14a5cf38
JH
4974 m->bbuf = b->buf;
4975 }
4976 }
f62ce20a 4977 return PerlIOBuf_unread(aTHX_ f, vbuf, count);
06da4f11
NIS
4978}
4979
4980SSize_t
f62ce20a 4981PerlIOMmap_write(pTHX_ PerlIO *f, const void *vbuf, Size_t count)
06da4f11 4982{
de009b76
AL
4983 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
4984 PerlIOBuf * const b = &m->base;
4985
14a5cf38
JH
4986 if (!b->buf || !(PerlIOBase(f)->flags & PERLIO_F_WRBUF)) {
4987 /*
71200d45 4988 * No, or wrong sort of, buffer
14a5cf38
JH
4989 */
4990 if (m->len) {
e87a358a 4991 if (PerlIOMmap_unmap(aTHX_ f) != 0)
14a5cf38
JH
4992 return 0;
4993 }
4994 /*
71200d45 4995 * If unmap took the "buffer" see if we have one from before
14a5cf38
JH
4996 */
4997 if (!b->buf && m->bbuf)
4998 b->buf = m->bbuf;
4999 if (!b->buf) {
f62ce20a 5000 PerlIOBuf_get_base(aTHX_ f);
14a5cf38
JH
5001 m->bbuf = b->buf;
5002 }
06da4f11 5003 }
f62ce20a 5004 return PerlIOBuf_write(aTHX_ f, vbuf, count);
06da4f11
NIS
5005}
5006
5007IV
f62ce20a 5008PerlIOMmap_flush(pTHX_ PerlIO *f)
06da4f11 5009{
dcda55fc
AL
5010 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
5011 PerlIOBuf * const b = &m->base;
f62ce20a 5012 IV code = PerlIOBuf_flush(aTHX_ f);
14a5cf38 5013 /*
71200d45 5014 * Now we are "synced" at PerlIOBuf level
14a5cf38
JH
5015 */
5016 if (b->buf) {
5017 if (m->len) {
5018 /*
71200d45 5019 * Unmap the buffer
14a5cf38 5020 */
e87a358a 5021 if (PerlIOMmap_unmap(aTHX_ f) != 0)
14a5cf38
JH
5022 code = -1;
5023 }
5024 else {
5025 /*
5026 * We seem to have a PerlIOBuf buffer which was not mapped
71200d45 5027 * remember it in case we need one later
14a5cf38
JH
5028 */
5029 m->bbuf = b->buf;
5030 }
5031 }
5032 return code;
06da4f11
NIS
5033}
5034
5035IV
f62ce20a 5036PerlIOMmap_fill(pTHX_ PerlIO *f)
06da4f11 5037{
dcda55fc 5038 PerlIOBuf * const b = PerlIOSelf(f, PerlIOBuf);
14a5cf38
JH
5039 IV code = PerlIO_flush(f);
5040 if (code == 0 && !b->buf) {
f62ce20a 5041 code = PerlIOMmap_map(aTHX_ f);
14a5cf38
JH
5042 }
5043 if (code == 0 && !(PerlIOBase(f)->flags & PERLIO_F_RDBUF)) {
f62ce20a 5044 code = PerlIOBuf_fill(aTHX_ f);
14a5cf38
JH
5045 }
5046 return code;
06da4f11
NIS
5047}
5048
5049IV
f62ce20a 5050PerlIOMmap_close(pTHX_ PerlIO *f)
06da4f11 5051{
dcda55fc
AL
5052 PerlIOMmap * const m = PerlIOSelf(f, PerlIOMmap);
5053 PerlIOBuf * const b = &m->base;
14a5cf38
JH
5054 IV code = PerlIO_flush(f);
5055 if (m->bbuf) {
5056 b->buf = m->bbuf;
5057 m->bbuf = NULL;
5058 b->ptr = b->end = b->buf;
5059 }
f62ce20a 5060 if (PerlIOBuf_close(aTHX_ f) != 0)
14a5cf38
JH
5061 code = -1;
5062 return code;
06da4f11
NIS
5063}
5064
71200d45 5065PerlIO *
ecdeb87c 5066PerlIOMmap_dup(pTHX_ PerlIO *f, PerlIO *o, CLONE_PARAMS *param, int flags)
71200d45 5067{
ecdeb87c 5068 return PerlIOBase_dup(aTHX_ f, o, param, flags);
71200d45
NIS
5069}
5070
06da4f11 5071
27da23d5 5072PERLIO_FUNCS_DECL(PerlIO_mmap) = {
2dc2558e 5073 sizeof(PerlIO_funcs),
14a5cf38
JH
5074 "mmap",
5075 sizeof(PerlIOMmap),
86e05cf2 5076 PERLIO_K_BUFFERED|PERLIO_K_RAW,
14a5cf38 5077 PerlIOBuf_pushed,
44798d05 5078 PerlIOBuf_popped,
14a5cf38 5079 PerlIOBuf_open,
86e05cf2 5080 PerlIOBase_binmode, /* binmode */
14a5cf38
JH
5081 NULL,
5082 PerlIOBase_fileno,
71200d45 5083 PerlIOMmap_dup,
14a5cf38
JH
5084 PerlIOBuf_read,
5085 PerlIOMmap_unread,
5086 PerlIOMmap_write,
5087 PerlIOBuf_seek,
5088 PerlIOBuf_tell,
5089 PerlIOBuf_close,
5090 PerlIOMmap_flush,
5091 PerlIOMmap_fill,
5092 PerlIOBase_eof,
5093 PerlIOBase_error,
5094 PerlIOBase_clearerr,
5095 PerlIOBase_setlinebuf,
5096 PerlIOMmap_get_base,
5097 PerlIOBuf_bufsiz,
5098 PerlIOBuf_get_ptr,
5099 PerlIOBuf_get_cnt,
5100 PerlIOBuf_set_ptrcnt,
06da4f11
NIS
5101};
5102
22569500 5103#endif /* HAS_MMAP */
06da4f11 5104
9e353e3b 5105PerlIO *
e87a358a 5106Perl_PerlIO_stdin(pTHX)
9e353e3b 5107{
97aff369 5108 dVAR;
a1ea730d 5109 if (!PL_perlio) {
14a5cf38
JH
5110 PerlIO_stdstreams(aTHX);
5111 }
303f2dc3 5112 return (PerlIO*)&PL_perlio[1];
9e353e3b
NIS
5113}
5114
9e353e3b 5115PerlIO *
e87a358a 5116Perl_PerlIO_stdout(pTHX)
9e353e3b 5117{
97aff369 5118 dVAR;
a1ea730d 5119 if (!PL_perlio) {
14a5cf38
JH
5120 PerlIO_stdstreams(aTHX);
5121 }
303f2dc3 5122 return (PerlIO*)&PL_perlio[2];
9e353e3b
NIS
5123}
5124
9e353e3b 5125PerlIO *
e87a358a 5126Perl_PerlIO_stderr(pTHX)
9e353e3b 5127{
97aff369 5128 dVAR;
a1ea730d 5129 if (!PL_perlio) {
14a5cf38
JH
5130 PerlIO_stdstreams(aTHX);
5131 }
303f2dc3 5132 return (PerlIO*)&PL_perlio[3];
9e353e3b
NIS
5133}
5134
5135/*--------------------------------------------------------------------------------------*/
5136
9e353e3b
NIS
5137char *
5138PerlIO_getname(PerlIO *f, char *buf)
5139{
14a5cf38 5140 dTHX;
a15cef0c 5141#ifdef VMS
73d840c0 5142 char *name = NULL;
7659f319 5143 bool exported = FALSE;
14a5cf38 5144 FILE *stdio = PerlIOSelf(f, PerlIOStdio)->stdio;
7659f319
CB
5145 if (!stdio) {
5146 stdio = PerlIO_exportFILE(f,0);
5147 exported = TRUE;
5148 }
5149 if (stdio) {
14a5cf38 5150 name = fgetname(stdio, buf);
7659f319
CB
5151 if (exported) PerlIO_releaseFILE(f,stdio);
5152 }
73d840c0 5153 return name;
a15cef0c 5154#else
8772537c
AL
5155 PERL_UNUSED_ARG(f);
5156 PERL_UNUSED_ARG(buf);
14a5cf38 5157 Perl_croak(aTHX_ "Don't know how to get file name");
bd61b366 5158 return NULL;
a15cef0c 5159#endif
9e353e3b
NIS
5160}
5161
5162
5163/*--------------------------------------------------------------------------------------*/
14a5cf38
JH
5164/*
5165 * Functions which can be called on any kind of PerlIO implemented in
71200d45 5166 * terms of above
14a5cf38 5167 */
9e353e3b 5168
e87a358a
NIS
5169#undef PerlIO_fdopen
5170PerlIO *
5171PerlIO_fdopen(int fd, const char *mode)
5172{
5173 dTHX;
bd61b366 5174 return PerlIO_openn(aTHX_ NULL, mode, fd, 0, 0, NULL, 0, NULL);
e87a358a
NIS
5175}
5176
5177#undef PerlIO_open
5178PerlIO *
5179PerlIO_open(const char *path, const char *mode)
5180{
5181 dTHX;
42d9b98d 5182 SV *name = sv_2mortal(newSVpv(path, 0));
bd61b366 5183 return PerlIO_openn(aTHX_ NULL, mode, -1, 0, 0, NULL, 1, &name);
e87a358a
NIS
5184}
5185
5186#undef Perlio_reopen
5187PerlIO *
5188PerlIO_reopen(const char *path, const char *mode, PerlIO *f)
5189{
5190 dTHX;
42d9b98d 5191 SV *name = sv_2mortal(newSVpv(path,0));
bd61b366 5192 return PerlIO_openn(aTHX_ NULL, mode, -1, 0, 0, f, 1, &name);
e87a358a
NIS
5193}
5194
9e353e3b 5195#undef PerlIO_getc
6f9d8c32 5196int
9e353e3b 5197PerlIO_getc(PerlIO *f)
760ac839 5198{
e87a358a 5199 dTHX;
14a5cf38 5200 STDCHAR buf[1];
de009b76 5201 if ( 1 == PerlIO_read(f, buf, 1) ) {
14a5cf38
JH
5202 return (unsigned char) buf[0];
5203 }
5204 return EOF;
313ca112
NIS
5205}
5206
5207#undef PerlIO_ungetc
5208int
5209PerlIO_ungetc(PerlIO *f, int ch)
5210{
e87a358a 5211 dTHX;
14a5cf38
JH
5212 if (ch != EOF) {
5213 STDCHAR buf = ch;
5214 if (PerlIO_unread(f, &buf, 1) == 1)
5215 return ch;
5216 }
5217 return EOF;
760ac839
LW
5218}
5219
9e353e3b
NIS
5220#undef PerlIO_putc
5221int
5222PerlIO_putc(PerlIO *f, int ch)
760ac839 5223{
e87a358a 5224 dTHX;
14a5cf38
JH
5225 STDCHAR buf = ch;
5226 return PerlIO_write(f, &buf, 1);
760ac839
LW
5227}
5228
9e353e3b 5229#undef PerlIO_puts
760ac839 5230int
9e353e3b 5231PerlIO_puts(PerlIO *f, const char *s)
760ac839 5232{
e87a358a 5233 dTHX;
dcda55fc 5234 return PerlIO_write(f, s, strlen(s));
760ac839
LW
5235}
5236
5237#undef PerlIO_rewind
5238void
c78749f2 5239PerlIO_rewind(PerlIO *f)
760ac839 5240{
e87a358a 5241 dTHX;
14a5cf38
JH
5242 PerlIO_seek(f, (Off_t) 0, SEEK_SET);
5243 PerlIO_clearerr(f);
6f9d8c32
NIS
5244}
5245
5246#undef PerlIO_vprintf
5247int
5248PerlIO_vprintf(PerlIO *f, const char *fmt, va_list ap)
5249{
14a5cf38 5250 dTHX;
53ce71d3 5251 SV * sv;
b83604b4 5252 const char *s;
14a5cf38
JH
5253 STRLEN len;
5254 SSize_t wrote;
2cc61e15 5255#ifdef NEED_VA_COPY
14a5cf38
JH
5256 va_list apc;
5257 Perl_va_copy(ap, apc);
53ce71d3 5258 sv = vnewSVpvf(fmt, &apc);
2cc61e15 5259#else
53ce71d3 5260 sv = vnewSVpvf(fmt, &ap);
2cc61e15 5261#endif
b83604b4 5262 s = SvPV_const(sv, len);
14a5cf38
JH
5263 wrote = PerlIO_write(f, s, len);
5264 SvREFCNT_dec(sv);
5265 return wrote;
760ac839
LW
5266}
5267
5268#undef PerlIO_printf
6f9d8c32 5269int
14a5cf38 5270PerlIO_printf(PerlIO *f, const char *fmt, ...)
760ac839 5271{
14a5cf38
JH
5272 va_list ap;
5273 int result;
5274 va_start(ap, fmt);
5275 result = PerlIO_vprintf(f, fmt, ap);
5276 va_end(ap);
5277 return result;
760ac839
LW
5278}
5279
5280#undef PerlIO_stdoutf
6f9d8c32 5281int
14a5cf38 5282PerlIO_stdoutf(const char *fmt, ...)
760ac839 5283{
e87a358a 5284 dTHX;
14a5cf38
JH
5285 va_list ap;
5286 int result;
5287 va_start(ap, fmt);
5288 result = PerlIO_vprintf(PerlIO_stdout(), fmt, ap);
5289 va_end(ap);
5290 return result;
760ac839
LW
5291}
5292
5293#undef PerlIO_tmpfile
5294PerlIO *
c78749f2 5295PerlIO_tmpfile(void)
760ac839 5296{
2941a2e1
JH
5297 dTHX;
5298 PerlIO *f = NULL;
2941a2e1 5299#ifdef WIN32
de009b76 5300 const int fd = win32_tmpfd();
2941a2e1
JH
5301 if (fd >= 0)
5302 f = PerlIO_fdopen(fd, "w+b");
5303#else /* WIN32 */
460c8493 5304# if defined(HAS_MKSTEMP) && ! defined(VMS) && ! defined(OS2)
0b99e986
RGS
5305 int fd = -1;
5306 char tempname[] = "/tmp/PerlIO_XXXXXX";
5307 const char * const tmpdir = PL_tainting ? NULL : PerlEnv_getenv("TMPDIR");
525f6fe9 5308 SV * sv = NULL;
2941a2e1
JH
5309 /*
5310 * I have no idea how portable mkstemp() is ... NI-S
5311 */
7299ca58 5312 if (tmpdir && *tmpdir) {
0b99e986 5313 /* if TMPDIR is set and not empty, we try that first */
7299ca58 5314 sv = newSVpv(tmpdir, 0);
0b99e986
RGS
5315 sv_catpv(sv, tempname + 4);
5316 fd = mkstemp(SvPVX(sv));
5317 }
5318 if (fd < 0) {
7299ca58 5319 sv = NULL;
0b99e986
RGS
5320 /* else we try /tmp */
5321 fd = mkstemp(tempname);
5322 }
2941a2e1
JH
5323 if (fd >= 0) {
5324 f = PerlIO_fdopen(fd, "w+");
5325 if (f)
5326 PerlIOBase(f)->flags |= PERLIO_F_TEMP;
0b99e986 5327 PerlLIO_unlink(sv ? SvPVX_const(sv) : tempname);
2941a2e1 5328 }
ef8d46e8 5329 SvREFCNT_dec(sv);
2941a2e1 5330# else /* !HAS_MKSTEMP, fallback to stdio tmpfile(). */
c4420975 5331 FILE * const stdio = PerlSIO_tmpfile();
2941a2e1 5332
085e731f
CB
5333 if (stdio)
5334 f = PerlIO_fdopen(fileno(stdio), "w+");
5335
2941a2e1
JH
5336# endif /* else HAS_MKSTEMP */
5337#endif /* else WIN32 */
5338 return f;
760ac839
LW
5339}
5340
6f9d8c32
NIS
5341#undef HAS_FSETPOS
5342#undef HAS_FGETPOS
5343
22569500
NIS
5344#endif /* USE_SFIO */
5345#endif /* PERLIO_IS_STDIO */
760ac839 5346
9e353e3b 5347/*======================================================================================*/
14a5cf38 5348/*
71200d45
NIS
5349 * Now some functions in terms of above which may be needed even if we are
5350 * not in true PerlIO mode
9e353e3b 5351 */
188f0c84
YO
5352const char *
5353Perl_PerlIO_context_layers(pTHX_ const char *mode)
5354{
5355 dVAR;
8b850bd5
NC
5356 const char *direction = NULL;
5357 SV *layers;
188f0c84
YO
5358 /*
5359 * Need to supply default layer info from open.pm
5360 */
8b850bd5
NC
5361
5362 if (!PL_curcop)
5363 return NULL;
5364
5365 if (mode && mode[0] != 'r') {
5366 if (PL_curcop->cop_hints & HINT_LEXICAL_IO_OUT)
5367 direction = "open>";
5368 } else {
5369 if (PL_curcop->cop_hints & HINT_LEXICAL_IO_IN)
5370 direction = "open<";
188f0c84 5371 }
8b850bd5
NC
5372 if (!direction)
5373 return NULL;
5374
20439bc7 5375 layers = cop_hints_fetch_pvn(PL_curcop, direction, 5, 0, 0);
8b850bd5
NC
5376
5377 assert(layers);
5378 return SvOK(layers) ? SvPV_nolen_const(layers) : NULL;
188f0c84
YO
5379}
5380
9e353e3b 5381
760ac839
LW
5382#ifndef HAS_FSETPOS
5383#undef PerlIO_setpos
5384int
766a733e 5385PerlIO_setpos(PerlIO *f, SV *pos)
760ac839 5386{
14a5cf38
JH
5387 dTHX;
5388 if (SvOK(pos)) {
5389 STRLEN len;
c4420975 5390 const Off_t * const posn = (Off_t *) SvPV(pos, len);
14a5cf38
JH
5391 if (f && len == sizeof(Off_t))
5392 return PerlIO_seek(f, *posn, SEEK_SET);
5393 }
93189314 5394 SETERRNO(EINVAL, SS_IVCHAN);
14a5cf38 5395 return -1;
760ac839 5396}
c411622e 5397#else
c411622e 5398#undef PerlIO_setpos
5399int
766a733e 5400PerlIO_setpos(PerlIO *f, SV *pos)
c411622e 5401{
14a5cf38
JH
5402 dTHX;
5403 if (SvOK(pos)) {
5404 STRLEN len;
c4420975 5405 Fpos_t * const fpos = (Fpos_t *) SvPV(pos, len);
14a5cf38 5406 if (f && len == sizeof(Fpos_t)) {
2d4389e4 5407#if defined(USE_64_BIT_STDIO) && defined(USE_FSETPOS64)
14a5cf38 5408 return fsetpos64(f, fpos);
d9b3e12d 5409#else
14a5cf38 5410 return fsetpos(f, fpos);
d9b3e12d 5411#endif
14a5cf38 5412 }
766a733e 5413 }
93189314 5414 SETERRNO(EINVAL, SS_IVCHAN);
14a5cf38 5415 return -1;
c411622e 5416}
5417#endif
760ac839
LW
5418
5419#ifndef HAS_FGETPOS
5420#undef PerlIO_getpos
5421int
766a733e 5422PerlIO_getpos(PerlIO *f, SV *pos)
760ac839 5423{
14a5cf38
JH
5424 dTHX;
5425 Off_t posn = PerlIO_tell(f);
5426 sv_setpvn(pos, (char *) &posn, sizeof(posn));
5427 return (posn == (Off_t) - 1) ? -1 : 0;
760ac839 5428}
c411622e 5429#else
c411622e 5430#undef PerlIO_getpos
5431int
766a733e 5432PerlIO_getpos(PerlIO *f, SV *pos)
c411622e 5433{
14a5cf38
JH
5434 dTHX;
5435 Fpos_t fpos;
5436 int code;
2d4389e4 5437#if defined(USE_64_BIT_STDIO) && defined(USE_FSETPOS64)
14a5cf38 5438 code = fgetpos64(f, &fpos);
d9b3e12d 5439#else
14a5cf38 5440 code = fgetpos(f, &fpos);
d9b3e12d 5441#endif
14a5cf38
JH
5442 sv_setpvn(pos, (char *) &fpos, sizeof(fpos));
5443 return code;
c411622e 5444}
5445#endif
760ac839
LW
5446
5447#if (defined(PERLIO_IS_STDIO) || !defined(USE_SFIO)) && !defined(HAS_VPRINTF)
5448
5449int
c78749f2 5450vprintf(char *pat, char *args)
662a7e3f
CS
5451{
5452 _doprnt(pat, args, stdout);
22569500 5453 return 0; /* wrong, but perl doesn't use the return
14a5cf38 5454 * value */
662a7e3f
CS
5455}
5456
5457int
c78749f2 5458vfprintf(FILE *fd, char *pat, char *args)
760ac839
LW
5459{
5460 _doprnt(pat, args, fd);
22569500 5461 return 0; /* wrong, but perl doesn't use the return
14a5cf38 5462 * value */
760ac839
LW
5463}
5464
5465#endif
5466
5467#ifndef PerlIO_vsprintf
6f9d8c32 5468int
8ac85365 5469PerlIO_vsprintf(char *s, int n, const char *fmt, va_list ap)
760ac839 5470{
8ff9a42b 5471 dTHX;
d9fad198 5472 const int val = my_vsnprintf(s, n > 0 ? n : 0, fmt, ap);
14333449
AL
5473 PERL_UNUSED_CONTEXT;
5474
1208b3dd
JH
5475#ifndef PERL_MY_VSNPRINTF_GUARDED
5476 if (val < 0 || (n > 0 ? val >= n : 0)) {
37405f90 5477 Perl_croak(aTHX_ "panic: my_vsnprintf overflow in PerlIO_vsprintf\n");
760ac839 5478 }
1208b3dd 5479#endif
14a5cf38 5480 return val;
760ac839
LW
5481}
5482#endif
5483
5484#ifndef PerlIO_sprintf
6f9d8c32 5485int
14a5cf38 5486PerlIO_sprintf(char *s, int n, const char *fmt, ...)
760ac839 5487{
14a5cf38
JH
5488 va_list ap;
5489 int result;
5490 va_start(ap, fmt);
5491 result = PerlIO_vsprintf(s, n, fmt, ap);
5492 va_end(ap);
5493 return result;
760ac839
LW
5494}
5495#endif
9cfa90c0
NC
5496
5497/*
5498 * Local variables:
5499 * c-indentation-style: bsd
5500 * c-basic-offset: 4
5501 * indent-tabs-mode: t
5502 * End:
5503 *
37442d52
RGS
5504 * ex: set ts=8 sts=4 sw=4 noet:
5505 */