This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
Re: [PATCH scope.c] Re: local($tied->{foo}) leaks
[perl5.git] / util.c
1 /*    util.c
2  *
3  *    Copyright (c) 1991-2002, Larry Wall
4  *
5  *    You may distribute under the terms of either the GNU General Public
6  *    License or the Artistic License, as specified in the README file.
7  *
8  */
9
10 /*
11  * "Very useful, no doubt, that was to Saruman; yet it seems that he was
12  * not content."  --Gandalf
13  */
14
15 #include "EXTERN.h"
16 #define PERL_IN_UTIL_C
17 #include "perl.h"
18
19 #ifndef PERL_MICRO
20 #if !defined(NSIG) || defined(M_UNIX) || defined(M_XENIX)
21 #include <signal.h>
22 #endif
23
24 #ifndef SIG_ERR
25 # define SIG_ERR ((Sighandler_t) -1)
26 #endif
27 #endif
28
29 #ifdef I_SYS_WAIT
30 #  include <sys/wait.h>
31 #endif
32
33 #ifdef HAS_SELECT
34 # ifdef I_SYS_SELECT
35 #  include <sys/select.h>
36 # endif
37 #endif
38
39 #define FLUSH
40
41 #ifdef LEAKTEST
42
43 long xcount[MAXXCOUNT];
44 long lastxcount[MAXXCOUNT];
45 long xycount[MAXXCOUNT][MAXYCOUNT];
46 long lastxycount[MAXXCOUNT][MAXYCOUNT];
47
48 #endif
49
50 #if defined(HAS_FCNTL) && defined(F_SETFD) && !defined(FD_CLOEXEC)
51 #  define FD_CLOEXEC 1                  /* NeXT needs this */
52 #endif
53
54 /* NOTE:  Do not call the next three routines directly.  Use the macros
55  * in handy.h, so that we can easily redefine everything to do tracking of
56  * allocated hunks back to the original New to track down any memory leaks.
57  * XXX This advice seems to be widely ignored :-(   --AD  August 1996.
58  */
59
60 /* paranoid version of system's malloc() */
61
62 Malloc_t
63 Perl_safesysmalloc(MEM_SIZE size)
64 {
65     dTHX;
66     Malloc_t ptr;
67 #ifdef HAS_64K_LIMIT
68         if (size > 0xffff) {
69             PerlIO_printf(Perl_error_log,
70                           "Allocation too large: %lx\n", size) FLUSH;
71             my_exit(1);
72         }
73 #endif /* HAS_64K_LIMIT */
74 #ifdef DEBUGGING
75     if ((long)size < 0)
76         Perl_croak_nocontext("panic: malloc");
77 #endif
78     ptr = (Malloc_t)PerlMem_malloc(size?size:1);        /* malloc(0) is NASTY on our system */
79     PERL_ALLOC_CHECK(ptr);
80     DEBUG_m(PerlIO_printf(Perl_debug_log, "0x%"UVxf": (%05ld) malloc %ld bytes\n",PTR2UV(ptr),(long)PL_an++,(long)size));
81     if (ptr != Nullch)
82         return ptr;
83     else if (PL_nomemok)
84         return Nullch;
85     else {
86         PerlIO_puts(Perl_error_log,PL_no_mem) FLUSH;
87         my_exit(1);
88         return Nullch;
89     }
90     /*NOTREACHED*/
91 }
92
93 /* paranoid version of system's realloc() */
94
95 Malloc_t
96 Perl_safesysrealloc(Malloc_t where,MEM_SIZE size)
97 {
98     dTHX;
99     Malloc_t ptr;
100 #if !defined(STANDARD_C) && !defined(HAS_REALLOC_PROTOTYPE) && !defined(PERL_MICRO)
101     Malloc_t PerlMem_realloc();
102 #endif /* !defined(STANDARD_C) && !defined(HAS_REALLOC_PROTOTYPE) */
103
104 #ifdef HAS_64K_LIMIT
105     if (size > 0xffff) {
106         PerlIO_printf(Perl_error_log,
107                       "Reallocation too large: %lx\n", size) FLUSH;
108         my_exit(1);
109     }
110 #endif /* HAS_64K_LIMIT */
111     if (!size) {
112         safesysfree(where);
113         return NULL;
114     }
115
116     if (!where)
117         return safesysmalloc(size);
118 #ifdef DEBUGGING
119     if ((long)size < 0)
120         Perl_croak_nocontext("panic: realloc");
121 #endif
122     ptr = (Malloc_t)PerlMem_realloc(where,size);
123     PERL_ALLOC_CHECK(ptr);
124
125     DEBUG_m(PerlIO_printf(Perl_debug_log, "0x%"UVxf": (%05ld) rfree\n",PTR2UV(where),(long)PL_an++));
126     DEBUG_m(PerlIO_printf(Perl_debug_log, "0x%"UVxf": (%05ld) realloc %ld bytes\n",PTR2UV(ptr),(long)PL_an++,(long)size));
127
128     if (ptr != Nullch)
129         return ptr;
130     else if (PL_nomemok)
131         return Nullch;
132     else {
133         PerlIO_puts(Perl_error_log,PL_no_mem) FLUSH;
134         my_exit(1);
135         return Nullch;
136     }
137     /*NOTREACHED*/
138 }
139
140 /* safe version of system's free() */
141
142 Free_t
143 Perl_safesysfree(Malloc_t where)
144 {
145 #ifdef PERL_IMPLICIT_SYS
146     dTHX;
147 #endif
148     DEBUG_m( PerlIO_printf(Perl_debug_log, "0x%"UVxf": (%05ld) free\n",PTR2UV(where),(long)PL_an++));
149     if (where) {
150         /*SUPPRESS 701*/
151         PerlMem_free(where);
152     }
153 }
154
155 /* safe version of system's calloc() */
156
157 Malloc_t
158 Perl_safesyscalloc(MEM_SIZE count, MEM_SIZE size)
159 {
160     dTHX;
161     Malloc_t ptr;
162
163 #ifdef HAS_64K_LIMIT
164     if (size * count > 0xffff) {
165         PerlIO_printf(Perl_error_log,
166                       "Allocation too large: %lx\n", size * count) FLUSH;
167         my_exit(1);
168     }
169 #endif /* HAS_64K_LIMIT */
170 #ifdef DEBUGGING
171     if ((long)size < 0 || (long)count < 0)
172         Perl_croak_nocontext("panic: calloc");
173 #endif
174     size *= count;
175     ptr = (Malloc_t)PerlMem_malloc(size?size:1);        /* malloc(0) is NASTY on our system */
176     PERL_ALLOC_CHECK(ptr);
177     DEBUG_m(PerlIO_printf(Perl_debug_log, "0x%"UVxf": (%05ld) calloc %ld x %ld bytes\n",PTR2UV(ptr),(long)PL_an++,(long)count,(long)size));
178     if (ptr != Nullch) {
179         memset((void*)ptr, 0, size);
180         return ptr;
181     }
182     else if (PL_nomemok)
183         return Nullch;
184     else {
185         PerlIO_puts(Perl_error_log,PL_no_mem) FLUSH;
186         my_exit(1);
187         return Nullch;
188     }
189     /*NOTREACHED*/
190 }
191
192 #ifdef LEAKTEST
193
194 struct mem_test_strut {
195     union {
196         long type;
197         char c[2];
198     } u;
199     long size;
200 };
201
202 #    define ALIGN sizeof(struct mem_test_strut)
203
204 #    define sizeof_chunk(ch) (((struct mem_test_strut*) (ch))->size)
205 #    define typeof_chunk(ch) \
206         (((struct mem_test_strut*) (ch))->u.c[0] + ((struct mem_test_strut*) (ch))->u.c[1]*100)
207 #    define set_typeof_chunk(ch,t) \
208         (((struct mem_test_strut*) (ch))->u.c[0] = t % 100, ((struct mem_test_strut*) (ch))->u.c[1] = t / 100)
209 #define SIZE_TO_Y(size) ( (size) > MAXY_SIZE                            \
210                           ? MAXYCOUNT - 1                               \
211                           : ( (size) > 40                               \
212                               ? ((size) - 1)/8 + 5                      \
213                               : ((size) - 1)/4))
214
215 Malloc_t
216 Perl_safexmalloc(I32 x, MEM_SIZE size)
217 {
218     register char* where = (char*)safemalloc(size + ALIGN);
219
220     xcount[x] += size;
221     xycount[x][SIZE_TO_Y(size)]++;
222     set_typeof_chunk(where, x);
223     sizeof_chunk(where) = size;
224     return (Malloc_t)(where + ALIGN);
225 }
226
227 Malloc_t
228 Perl_safexrealloc(Malloc_t wh, MEM_SIZE size)
229 {
230     char *where = (char*)wh;
231
232     if (!wh)
233         return safexmalloc(0,size);
234
235     {
236         MEM_SIZE old = sizeof_chunk(where - ALIGN);
237         int t = typeof_chunk(where - ALIGN);
238         register char* new = (char*)saferealloc(where - ALIGN, size + ALIGN);
239
240         xycount[t][SIZE_TO_Y(old)]--;
241         xycount[t][SIZE_TO_Y(size)]++;
242         xcount[t] += size - old;
243         sizeof_chunk(new) = size;
244         return (Malloc_t)(new + ALIGN);
245     }
246 }
247
248 void
249 Perl_safexfree(Malloc_t wh)
250 {
251     I32 x;
252     char *where = (char*)wh;
253     MEM_SIZE size;
254
255     if (!where)
256         return;
257     where -= ALIGN;
258     size = sizeof_chunk(where);
259     x = where[0] + 100 * where[1];
260     xcount[x] -= size;
261     xycount[x][SIZE_TO_Y(size)]--;
262     safefree(where);
263 }
264
265 Malloc_t
266 Perl_safexcalloc(I32 x,MEM_SIZE count, MEM_SIZE size)
267 {
268     register char * where = (char*)safexmalloc(x, size * count + ALIGN);
269     xcount[x] += size;
270     xycount[x][SIZE_TO_Y(size)]++;
271     memset((void*)(where + ALIGN), 0, size * count);
272     set_typeof_chunk(where, x);
273     sizeof_chunk(where) = size;
274     return (Malloc_t)(where + ALIGN);
275 }
276
277 STATIC void
278 S_xstat(pTHX_ int flag)
279 {
280     register I32 i, j, total = 0;
281     I32 subtot[MAXYCOUNT];
282
283     for (j = 0; j < MAXYCOUNT; j++) {
284         subtot[j] = 0;
285     }
286
287     PerlIO_printf(Perl_debug_log, "   Id  subtot   4   8  12  16  20  24  28  32  36  40  48  56  64  72  80 80+\n", total);
288     for (i = 0; i < MAXXCOUNT; i++) {
289         total += xcount[i];
290         for (j = 0; j < MAXYCOUNT; j++) {
291             subtot[j] += xycount[i][j];
292         }
293         if (flag == 0
294             ? xcount[i]                 /* Have something */
295             : (flag == 2
296                ? xcount[i] != lastxcount[i] /* Changed */
297                : xcount[i] > lastxcount[i])) { /* Growed */
298             PerlIO_printf(Perl_debug_log,"%2d %02d %7ld ", i / 100, i % 100,
299                           flag == 2 ? xcount[i] - lastxcount[i] : xcount[i]);
300             lastxcount[i] = xcount[i];
301             for (j = 0; j < MAXYCOUNT; j++) {
302                 if ( flag == 0
303                      ? xycount[i][j]    /* Have something */
304                      : (flag == 2
305                         ? xycount[i][j] != lastxycount[i][j] /* Changed */
306                         : xycount[i][j] > lastxycount[i][j])) { /* Growed */
307                     PerlIO_printf(Perl_debug_log,"%3ld ",
308                                   flag == 2
309                                   ? xycount[i][j] - lastxycount[i][j]
310                                   : xycount[i][j]);
311                     lastxycount[i][j] = xycount[i][j];
312                 } else {
313                     PerlIO_printf(Perl_debug_log, "  . ", xycount[i][j]);
314                 }
315             }
316             PerlIO_printf(Perl_debug_log, "\n");
317         }
318     }
319     if (flag != 2) {
320         PerlIO_printf(Perl_debug_log, "Total %7ld ", total);
321         for (j = 0; j < MAXYCOUNT; j++) {
322             if (subtot[j]) {
323                 PerlIO_printf(Perl_debug_log, "%3ld ", subtot[j]);
324             } else {
325                 PerlIO_printf(Perl_debug_log, "  . ");
326             }
327         }
328         PerlIO_printf(Perl_debug_log, "\n");    
329     }
330 }
331
332 #endif /* LEAKTEST */
333
334 /* These must be defined when not using Perl's malloc for binary
335  * compatibility */
336
337 #ifndef MYMALLOC
338
339 Malloc_t Perl_malloc (MEM_SIZE nbytes)
340 {
341     dTHXs;
342     return (Malloc_t)PerlMem_malloc(nbytes);
343 }
344
345 Malloc_t Perl_calloc (MEM_SIZE elements, MEM_SIZE size)
346 {
347     dTHXs;
348     return (Malloc_t)PerlMem_calloc(elements, size);
349 }
350
351 Malloc_t Perl_realloc (Malloc_t where, MEM_SIZE nbytes)
352 {
353     dTHXs;
354     return (Malloc_t)PerlMem_realloc(where, nbytes);
355 }
356
357 Free_t   Perl_mfree (Malloc_t where)
358 {
359     dTHXs;
360     PerlMem_free(where);
361 }
362
363 #endif
364
365 /* copy a string up to some (non-backslashed) delimiter, if any */
366
367 char *
368 Perl_delimcpy(pTHX_ register char *to, register char *toend, register char *from, register char *fromend, register int delim, I32 *retlen)
369 {
370     register I32 tolen;
371     for (tolen = 0; from < fromend; from++, tolen++) {
372         if (*from == '\\') {
373             if (from[1] == delim)
374                 from++;
375             else {
376                 if (to < toend)
377                     *to++ = *from;
378                 tolen++;
379                 from++;
380             }
381         }
382         else if (*from == delim)
383             break;
384         if (to < toend)
385             *to++ = *from;
386     }
387     if (to < toend)
388         *to = '\0';
389     *retlen = tolen;
390     return from;
391 }
392
393 /* return ptr to little string in big string, NULL if not found */
394 /* This routine was donated by Corey Satten. */
395
396 char *
397 Perl_instr(pTHX_ register const char *big, register const char *little)
398 {
399     register const char *s, *x;
400     register I32 first;
401
402     if (!little)
403         return (char*)big;
404     first = *little++;
405     if (!first)
406         return (char*)big;
407     while (*big) {
408         if (*big++ != first)
409             continue;
410         for (x=big,s=little; *s; /**/ ) {
411             if (!*x)
412                 return Nullch;
413             if (*s++ != *x++) {
414                 s--;
415                 break;
416             }
417         }
418         if (!*s)
419             return (char*)(big-1);
420     }
421     return Nullch;
422 }
423
424 /* same as instr but allow embedded nulls */
425
426 char *
427 Perl_ninstr(pTHX_ register const char *big, register const char *bigend, const char *little, const char *lend)
428 {
429     register const char *s, *x;
430     register I32 first = *little;
431     register const char *littleend = lend;
432
433     if (!first && little >= littleend)
434         return (char*)big;
435     if (bigend - big < littleend - little)
436         return Nullch;
437     bigend -= littleend - little++;
438     while (big <= bigend) {
439         if (*big++ != first)
440             continue;
441         for (x=big,s=little; s < littleend; /**/ ) {
442             if (*s++ != *x++) {
443                 s--;
444                 break;
445             }
446         }
447         if (s >= littleend)
448             return (char*)(big-1);
449     }
450     return Nullch;
451 }
452
453 /* reverse of the above--find last substring */
454
455 char *
456 Perl_rninstr(pTHX_ register const char *big, const char *bigend, const char *little, const char *lend)
457 {
458     register const char *bigbeg;
459     register const char *s, *x;
460     register I32 first = *little;
461     register const char *littleend = lend;
462
463     if (!first && little >= littleend)
464         return (char*)bigend;
465     bigbeg = big;
466     big = bigend - (littleend - little++);
467     while (big >= bigbeg) {
468         if (*big-- != first)
469             continue;
470         for (x=big+2,s=little; s < littleend; /**/ ) {
471             if (*s++ != *x++) {
472                 s--;
473                 break;
474             }
475         }
476         if (s >= littleend)
477             return (char*)(big+1);
478     }
479     return Nullch;
480 }
481
482 #define FBM_TABLE_OFFSET 2      /* Number of bytes between EOS and table*/
483
484 /* As a space optimization, we do not compile tables for strings of length
485    0 and 1, and for strings of length 2 unless FBMcf_TAIL.  These are
486    special-cased in fbm_instr().
487
488    If FBMcf_TAIL, the table is created as if the string has a trailing \n. */
489
490 /*
491 =head1 Miscellaneous Functions
492
493 =for apidoc fbm_compile
494
495 Analyses the string in order to make fast searches on it using fbm_instr()
496 -- the Boyer-Moore algorithm.
497
498 =cut
499 */
500
501 void
502 Perl_fbm_compile(pTHX_ SV *sv, U32 flags)
503 {
504     register U8 *s;
505     register U8 *table;
506     register U32 i;
507     STRLEN len;
508     I32 rarest = 0;
509     U32 frequency = 256;
510
511     if (flags & FBMcf_TAIL)
512         sv_catpvn(sv, "\n", 1);         /* Taken into account in fbm_instr() */
513     s = (U8*)SvPV_force(sv, len);
514     (void)SvUPGRADE(sv, SVt_PVBM);
515     if (len == 0)               /* TAIL might be on a zero-length string. */
516         return;
517     if (len > 2) {
518         U8 mlen;
519         unsigned char *sb;
520
521         if (len > 255)
522             mlen = 255;
523         else
524             mlen = (U8)len;
525         Sv_Grow(sv, len + 256 + FBM_TABLE_OFFSET);
526         table = (unsigned char*)(SvPVX(sv) + len + FBM_TABLE_OFFSET);
527         s = table - 1 - FBM_TABLE_OFFSET;       /* last char */
528         memset((void*)table, mlen, 256);
529         table[-1] = (U8)flags;
530         i = 0;
531         sb = s - mlen + 1;                      /* first char (maybe) */
532         while (s >= sb) {
533             if (table[*s] == mlen)
534                 table[*s] = (U8)i;
535             s--, i++;
536         }
537     }
538     sv_magic(sv, Nullsv, PERL_MAGIC_bm, Nullch, 0);     /* deep magic */
539     SvVALID_on(sv);
540
541     s = (unsigned char*)(SvPVX(sv));            /* deeper magic */
542     for (i = 0; i < len; i++) {
543         if (PL_freq[s[i]] < frequency) {
544             rarest = i;
545             frequency = PL_freq[s[i]];
546         }
547     }
548     BmRARE(sv) = s[rarest];
549     BmPREVIOUS(sv) = (U16)rarest;
550     BmUSEFUL(sv) = 100;                 /* Initial value */
551     if (flags & FBMcf_TAIL)
552         SvTAIL_on(sv);
553     DEBUG_r(PerlIO_printf(Perl_debug_log, "rarest char %c at %d\n",
554                           BmRARE(sv),BmPREVIOUS(sv)));
555 }
556
557 /* If SvTAIL(littlestr), it has a fake '\n' at end. */
558 /* If SvTAIL is actually due to \Z or \z, this gives false positives
559    if multiline */
560
561 /*
562 =for apidoc fbm_instr
563
564 Returns the location of the SV in the string delimited by C<str> and
565 C<strend>.  It returns C<Nullch> if the string can't be found.  The C<sv>
566 does not have to be fbm_compiled, but the search will not be as fast
567 then.
568
569 =cut
570 */
571
572 char *
573 Perl_fbm_instr(pTHX_ unsigned char *big, register unsigned char *bigend, SV *littlestr, U32 flags)
574 {
575     register unsigned char *s;
576     STRLEN l;
577     register unsigned char *little = (unsigned char *)SvPV(littlestr,l);
578     register STRLEN littlelen = l;
579     register I32 multiline = flags & FBMrf_MULTILINE;
580
581     if ((STRLEN)(bigend - big) < littlelen) {
582         if ( SvTAIL(littlestr)
583              && ((STRLEN)(bigend - big) == littlelen - 1)
584              && (littlelen == 1
585                  || (*big == *little &&
586                      memEQ((char *)big, (char *)little, littlelen - 1))))
587             return (char*)big;
588         return Nullch;
589     }
590
591     if (littlelen <= 2) {               /* Special-cased */
592
593         if (littlelen == 1) {
594             if (SvTAIL(littlestr) && !multiline) { /* Anchor only! */
595                 /* Know that bigend != big.  */
596                 if (bigend[-1] == '\n')
597                     return (char *)(bigend - 1);
598                 return (char *) bigend;
599             }
600             s = big;
601             while (s < bigend) {
602                 if (*s == *little)
603                     return (char *)s;
604                 s++;
605             }
606             if (SvTAIL(littlestr))
607                 return (char *) bigend;
608             return Nullch;
609         }
610         if (!littlelen)
611             return (char*)big;          /* Cannot be SvTAIL! */
612
613         /* littlelen is 2 */
614         if (SvTAIL(littlestr) && !multiline) {
615             if (bigend[-1] == '\n' && bigend[-2] == *little)
616                 return (char*)bigend - 2;
617             if (bigend[-1] == *little)
618                 return (char*)bigend - 1;
619             return Nullch;
620         }
621         {
622             /* This should be better than FBM if c1 == c2, and almost
623                as good otherwise: maybe better since we do less indirection.
624                And we save a lot of memory by caching no table. */
625             register unsigned char c1 = little[0];
626             register unsigned char c2 = little[1];
627
628             s = big + 1;
629             bigend--;
630             if (c1 != c2) {
631                 while (s <= bigend) {
632                     if (s[0] == c2) {
633                         if (s[-1] == c1)
634                             return (char*)s - 1;
635                         s += 2;
636                         continue;
637                     }
638                   next_chars:
639                     if (s[0] == c1) {
640                         if (s == bigend)
641                             goto check_1char_anchor;
642                         if (s[1] == c2)
643                             return (char*)s;
644                         else {
645                             s++;
646                             goto next_chars;
647                         }
648                     }
649                     else
650                         s += 2;
651                 }
652                 goto check_1char_anchor;
653             }
654             /* Now c1 == c2 */
655             while (s <= bigend) {
656                 if (s[0] == c1) {
657                     if (s[-1] == c1)
658                         return (char*)s - 1;
659                     if (s == bigend)
660                         goto check_1char_anchor;
661                     if (s[1] == c1)
662                         return (char*)s;
663                     s += 3;
664                 }
665                 else
666                     s += 2;
667             }
668         }
669       check_1char_anchor:               /* One char and anchor! */
670         if (SvTAIL(littlestr) && (*bigend == *little))
671             return (char *)bigend;      /* bigend is already decremented. */
672         return Nullch;
673     }
674     if (SvTAIL(littlestr) && !multiline) {      /* tail anchored? */
675         s = bigend - littlelen;
676         if (s >= big && bigend[-1] == '\n' && *s == *little
677             /* Automatically of length > 2 */
678             && memEQ((char*)s + 1, (char*)little + 1, littlelen - 2))
679         {
680             return (char*)s;            /* how sweet it is */
681         }
682         if (s[1] == *little
683             && memEQ((char*)s + 2, (char*)little + 1, littlelen - 2))
684         {
685             return (char*)s + 1;        /* how sweet it is */
686         }
687         return Nullch;
688     }
689     if (SvTYPE(littlestr) != SVt_PVBM || !SvVALID(littlestr)) {
690         char *b = ninstr((char*)big,(char*)bigend,
691                          (char*)little, (char*)little + littlelen);
692
693         if (!b && SvTAIL(littlestr)) {  /* Automatically multiline!  */
694             /* Chop \n from littlestr: */
695             s = bigend - littlelen + 1;
696             if (*s == *little
697                 && memEQ((char*)s + 1, (char*)little + 1, littlelen - 2))
698             {
699                 return (char*)s;
700             }
701             return Nullch;
702         }
703         return b;
704     }
705
706     {   /* Do actual FBM.  */
707         register unsigned char *table = little + littlelen + FBM_TABLE_OFFSET;
708         register unsigned char *oldlittle;
709
710         if (littlelen > (STRLEN)(bigend - big))
711             return Nullch;
712         --littlelen;                    /* Last char found by table lookup */
713
714         s = big + littlelen;
715         little += littlelen;            /* last char */
716         oldlittle = little;
717         if (s < bigend) {
718             register I32 tmp;
719
720           top2:
721             /*SUPPRESS 560*/
722             if ((tmp = table[*s])) {
723                 if ((s += tmp) < bigend)
724                     goto top2;
725                 goto check_end;
726             }
727             else {              /* less expensive than calling strncmp() */
728                 register unsigned char *olds = s;
729
730                 tmp = littlelen;
731
732                 while (tmp--) {
733                     if (*--s == *--little)
734                         continue;
735                     s = olds + 1;       /* here we pay the price for failure */
736                     little = oldlittle;
737                     if (s < bigend)     /* fake up continue to outer loop */
738                         goto top2;
739                     goto check_end;
740                 }
741                 return (char *)s;
742             }
743         }
744       check_end:
745         if ( s == bigend && (table[-1] & FBMcf_TAIL)
746              && memEQ((char *)(bigend - littlelen),
747                       (char *)(oldlittle - littlelen), littlelen) )
748             return (char*)bigend - littlelen;
749         return Nullch;
750     }
751 }
752
753 /* start_shift, end_shift are positive quantities which give offsets
754    of ends of some substring of bigstr.
755    If `last' we want the last occurence.
756    old_posp is the way of communication between consequent calls if
757    the next call needs to find the .
758    The initial *old_posp should be -1.
759
760    Note that we take into account SvTAIL, so one can get extra
761    optimizations if _ALL flag is set.
762  */
763
764 /* If SvTAIL is actually due to \Z or \z, this gives false positives
765    if PL_multiline.  In fact if !PL_multiline the authoritative answer
766    is not supported yet. */
767
768 char *
769 Perl_screaminstr(pTHX_ SV *bigstr, SV *littlestr, I32 start_shift, I32 end_shift, I32 *old_posp, I32 last)
770 {
771     register unsigned char *s, *x;
772     register unsigned char *big;
773     register I32 pos;
774     register I32 previous;
775     register I32 first;
776     register unsigned char *little;
777     register I32 stop_pos;
778     register unsigned char *littleend;
779     I32 found = 0;
780
781     if (*old_posp == -1
782         ? (pos = PL_screamfirst[BmRARE(littlestr)]) < 0
783         : (((pos = *old_posp), pos += PL_screamnext[pos]) == 0)) {
784       cant_find:
785         if ( BmRARE(littlestr) == '\n'
786              && BmPREVIOUS(littlestr) == SvCUR(littlestr) - 1) {
787             little = (unsigned char *)(SvPVX(littlestr));
788             littleend = little + SvCUR(littlestr);
789             first = *little++;
790             goto check_tail;
791         }
792         return Nullch;
793     }
794
795     little = (unsigned char *)(SvPVX(littlestr));
796     littleend = little + SvCUR(littlestr);
797     first = *little++;
798     /* The value of pos we can start at: */
799     previous = BmPREVIOUS(littlestr);
800     big = (unsigned char *)(SvPVX(bigstr));
801     /* The value of pos we can stop at: */
802     stop_pos = SvCUR(bigstr) - end_shift - (SvCUR(littlestr) - 1 - previous);
803     if (previous + start_shift > stop_pos) {
804 /*
805   stop_pos does not include SvTAIL in the count, so this check is incorrect
806   (I think) - see [ID 20010618.006] and t/op/study.t. HVDS 2001/06/19
807 */
808 #if 0
809         if (previous + start_shift == stop_pos + 1) /* A fake '\n'? */
810             goto check_tail;
811 #endif
812         return Nullch;
813     }
814     while (pos < previous + start_shift) {
815         if (!(pos += PL_screamnext[pos]))
816             goto cant_find;
817     }
818     big -= previous;
819     do {
820         if (pos >= stop_pos) break;
821         if (big[pos] != first)
822             continue;
823         for (x=big+pos+1,s=little; s < littleend; /**/ ) {
824             if (*s++ != *x++) {
825                 s--;
826                 break;
827             }
828         }
829         if (s == littleend) {
830             *old_posp = pos;
831             if (!last) return (char *)(big+pos);
832             found = 1;
833         }
834     } while ( pos += PL_screamnext[pos] );
835     if (last && found)
836         return (char *)(big+(*old_posp));
837   check_tail:
838     if (!SvTAIL(littlestr) || (end_shift > 0))
839         return Nullch;
840     /* Ignore the trailing "\n".  This code is not microoptimized */
841     big = (unsigned char *)(SvPVX(bigstr) + SvCUR(bigstr));
842     stop_pos = littleend - little;      /* Actual littlestr len */
843     if (stop_pos == 0)
844         return (char*)big;
845     big -= stop_pos;
846     if (*big == first
847         && ((stop_pos == 1) ||
848             memEQ((char *)(big + 1), (char *)little, stop_pos - 1)))
849         return (char*)big;
850     return Nullch;
851 }
852
853 I32
854 Perl_ibcmp(pTHX_ const char *s1, const char *s2, register I32 len)
855 {
856     register U8 *a = (U8 *)s1;
857     register U8 *b = (U8 *)s2;
858     while (len--) {
859         if (*a != *b && *a != PL_fold[*b])
860             return 1;
861         a++,b++;
862     }
863     return 0;
864 }
865
866 I32
867 Perl_ibcmp_locale(pTHX_ const char *s1, const char *s2, register I32 len)
868 {
869     register U8 *a = (U8 *)s1;
870     register U8 *b = (U8 *)s2;
871     while (len--) {
872         if (*a != *b && *a != PL_fold_locale[*b])
873             return 1;
874         a++,b++;
875     }
876     return 0;
877 }
878
879 /* copy a string to a safe spot */
880
881 /*
882 =head1 Memory Management
883
884 =for apidoc savepv
885
886 Perl's version of C<strdup()>. Returns a pointer to a newly allocated
887 string which is a duplicate of C<pv>. The size of the string is
888 determined by C<strlen()>. The memory allocated for the new string can
889 be freed with the C<Safefree()> function.
890
891 =cut
892 */
893
894 char *
895 Perl_savepv(pTHX_ const char *pv)
896 {
897     register char *newaddr = Nullch;
898     if (pv) {
899         New(902,newaddr,strlen(pv)+1,char);
900         (void)strcpy(newaddr,pv);
901     }
902     return newaddr;
903 }
904
905 /* same thing but with a known length */
906
907 /*
908 =for apidoc savepvn
909
910 Perl's version of what C<strndup()> would be if it existed. Returns a
911 pointer to a newly allocated string which is a duplicate of the first
912 C<len> bytes from C<pv>. The memory allocated for the new string can be
913 freed with the C<Safefree()> function.
914
915 =cut
916 */
917
918 char *
919 Perl_savepvn(pTHX_ const char *pv, register I32 len)
920 {
921     register char *newaddr;
922
923     New(903,newaddr,len+1,char);
924     /* Give a meaning to NULL pointer mainly for the use in sv_magic() */
925     if (pv) {
926         Copy(pv,newaddr,len,char);      /* might not be null terminated */
927         newaddr[len] = '\0';            /* is now */
928     }
929     else {
930         Zero(newaddr,len+1,char);
931     }
932     return newaddr;
933 }
934
935 /*
936 =for apidoc savesharedpv
937
938 A version of C<savepv()> which allocates the duplicate string in memory
939 which is shared between threads.
940
941 =cut
942 */
943 char *
944 Perl_savesharedpv(pTHX_ const char *pv)
945 {
946     register char *newaddr = Nullch;
947     if (pv) {
948         newaddr = (char*)PerlMemShared_malloc(strlen(pv)+1);
949         (void)strcpy(newaddr,pv);
950     }
951     return newaddr;
952 }
953
954
955
956 /* the SV for Perl_form() and mess() is not kept in an arena */
957
958 STATIC SV *
959 S_mess_alloc(pTHX)
960 {
961     SV *sv;
962     XPVMG *any;
963
964     if (!PL_dirty)
965         return sv_2mortal(newSVpvn("",0));
966
967     if (PL_mess_sv)
968         return PL_mess_sv;
969
970     /* Create as PVMG now, to avoid any upgrading later */
971     New(905, sv, 1, SV);
972     Newz(905, any, 1, XPVMG);
973     SvFLAGS(sv) = SVt_PVMG;
974     SvANY(sv) = (void*)any;
975     SvREFCNT(sv) = 1 << 30; /* practically infinite */
976     PL_mess_sv = sv;
977     return sv;
978 }
979
980 #if defined(PERL_IMPLICIT_CONTEXT)
981 char *
982 Perl_form_nocontext(const char* pat, ...)
983 {
984     dTHX;
985     char *retval;
986     va_list args;
987     va_start(args, pat);
988     retval = vform(pat, &args);
989     va_end(args);
990     return retval;
991 }
992 #endif /* PERL_IMPLICIT_CONTEXT */
993
994 /*
995 =head1 Miscellaneous Functions
996 =for apidoc form
997
998 Takes a sprintf-style format pattern and conventional
999 (non-SV) arguments and returns the formatted string.
1000
1001     (char *) Perl_form(pTHX_ const char* pat, ...)
1002
1003 can be used any place a string (char *) is required:
1004
1005     char * s = Perl_form("%d.%d",major,minor);
1006
1007 Uses a single private buffer so if you want to format several strings you
1008 must explicitly copy the earlier strings away (and free the copies when you
1009 are done).
1010
1011 =cut
1012 */
1013
1014 char *
1015 Perl_form(pTHX_ const char* pat, ...)
1016 {
1017     char *retval;
1018     va_list args;
1019     va_start(args, pat);
1020     retval = vform(pat, &args);
1021     va_end(args);
1022     return retval;
1023 }
1024
1025 char *
1026 Perl_vform(pTHX_ const char *pat, va_list *args)
1027 {
1028     SV *sv = mess_alloc();
1029     sv_vsetpvfn(sv, pat, strlen(pat), args, Null(SV**), 0, Null(bool*));
1030     return SvPVX(sv);
1031 }
1032
1033 #if defined(PERL_IMPLICIT_CONTEXT)
1034 SV *
1035 Perl_mess_nocontext(const char *pat, ...)
1036 {
1037     dTHX;
1038     SV *retval;
1039     va_list args;
1040     va_start(args, pat);
1041     retval = vmess(pat, &args);
1042     va_end(args);
1043     return retval;
1044 }
1045 #endif /* PERL_IMPLICIT_CONTEXT */
1046
1047 SV *
1048 Perl_mess(pTHX_ const char *pat, ...)
1049 {
1050     SV *retval;
1051     va_list args;
1052     va_start(args, pat);
1053     retval = vmess(pat, &args);
1054     va_end(args);
1055     return retval;
1056 }
1057
1058 STATIC COP*
1059 S_closest_cop(pTHX_ COP *cop, OP *o)
1060 {
1061     /* Look for PL_op starting from o.  cop is the last COP we've seen. */
1062
1063     if (!o || o == PL_op) return cop;
1064
1065     if (o->op_flags & OPf_KIDS) {
1066         OP *kid;
1067         for (kid = cUNOPo->op_first; kid; kid = kid->op_sibling)
1068         {
1069             COP *new_cop;
1070
1071             /* If the OP_NEXTSTATE has been optimised away we can still use it
1072              * the get the file and line number. */
1073
1074             if (kid->op_type == OP_NULL && kid->op_targ == OP_NEXTSTATE)
1075                 cop = (COP *)kid;
1076
1077             /* Keep searching, and return when we've found something. */
1078
1079             new_cop = closest_cop(cop, kid);
1080             if (new_cop) return new_cop;
1081         }
1082     }
1083
1084     /* Nothing found. */
1085
1086     return 0;
1087 }
1088
1089 SV *
1090 Perl_vmess(pTHX_ const char *pat, va_list *args)
1091 {
1092     SV *sv = mess_alloc();
1093     static char dgd[] = " during global destruction.\n";
1094     COP *cop;
1095
1096     sv_vsetpvfn(sv, pat, strlen(pat), args, Null(SV**), 0, Null(bool*));
1097     if (!SvCUR(sv) || *(SvEND(sv) - 1) != '\n') {
1098
1099         /*
1100          * Try and find the file and line for PL_op.  This will usually be
1101          * PL_curcop, but it might be a cop that has been optimised away.  We
1102          * can try to find such a cop by searching through the optree starting
1103          * from the sibling of PL_curcop.
1104          */
1105
1106         cop = closest_cop(PL_curcop, PL_curcop->op_sibling);
1107         if (!cop) cop = PL_curcop;
1108
1109         if (CopLINE(cop))
1110             Perl_sv_catpvf(aTHX_ sv, " at %s line %"IVdf,
1111            OutCopFILE(cop), (IV)CopLINE(cop));
1112         if (GvIO(PL_last_in_gv) && IoLINES(GvIOp(PL_last_in_gv))) {
1113             bool line_mode = (RsSIMPLE(PL_rs) &&
1114                               SvCUR(PL_rs) == 1 && *SvPVX(PL_rs) == '\n');
1115             Perl_sv_catpvf(aTHX_ sv, ", <%s> %s %"IVdf,
1116                            PL_last_in_gv == PL_argvgv ?
1117                            "" : GvNAME(PL_last_in_gv),
1118                            line_mode ? "line" : "chunk",
1119                            (IV)IoLINES(GvIOp(PL_last_in_gv)));
1120         }
1121 #ifdef USE_5005THREADS
1122         if (thr->tid)
1123             Perl_sv_catpvf(aTHX_ sv, " thread %ld", thr->tid);
1124 #endif
1125         sv_catpv(sv, PL_dirty ? dgd : ".\n");
1126     }
1127     return sv;
1128 }
1129
1130 OP *
1131 Perl_vdie(pTHX_ const char* pat, va_list *args)
1132 {
1133     char *message;
1134     int was_in_eval = PL_in_eval;
1135     HV *stash;
1136     GV *gv;
1137     CV *cv;
1138     SV *msv;
1139     STRLEN msglen;
1140
1141     DEBUG_S(PerlIO_printf(Perl_debug_log,
1142                           "%p: die: curstack = %p, mainstack = %p\n",
1143                           thr, PL_curstack, PL_mainstack));
1144
1145     if (pat) {
1146         msv = vmess(pat, args);
1147         if (PL_errors && SvCUR(PL_errors)) {
1148             sv_catsv(PL_errors, msv);
1149             message = SvPV(PL_errors, msglen);
1150             SvCUR_set(PL_errors, 0);
1151         }
1152         else
1153             message = SvPV(msv,msglen);
1154     }
1155     else {
1156         message = Nullch;
1157         msglen = 0;
1158     }
1159
1160     DEBUG_S(PerlIO_printf(Perl_debug_log,
1161                           "%p: die: message = %s\ndiehook = %p\n",
1162                           thr, message, PL_diehook));
1163     if (PL_diehook) {
1164         /* sv_2cv might call Perl_croak() */
1165         SV *olddiehook = PL_diehook;
1166         ENTER;
1167         SAVESPTR(PL_diehook);
1168         PL_diehook = Nullsv;
1169         cv = sv_2cv(olddiehook, &stash, &gv, 0);
1170         LEAVE;
1171         if (cv && !CvDEPTH(cv) && (CvROOT(cv) || CvXSUB(cv))) {
1172             dSP;
1173             SV *msg;
1174
1175             ENTER;
1176             save_re_context();
1177             if (message) {
1178                 msg = newSVpvn(message, msglen);
1179                 SvREADONLY_on(msg);
1180                 SAVEFREESV(msg);
1181             }
1182             else {
1183                 msg = ERRSV;
1184             }
1185
1186             PUSHSTACKi(PERLSI_DIEHOOK);
1187             PUSHMARK(SP);
1188             XPUSHs(msg);
1189             PUTBACK;
1190             call_sv((SV*)cv, G_DISCARD);
1191             POPSTACK;
1192             LEAVE;
1193         }
1194     }
1195
1196     PL_restartop = die_where(message, msglen);
1197     DEBUG_S(PerlIO_printf(Perl_debug_log,
1198           "%p: die: restartop = %p, was_in_eval = %d, top_env = %p\n",
1199           thr, PL_restartop, was_in_eval, PL_top_env));
1200     if ((!PL_restartop && was_in_eval) || PL_top_env->je_prev)
1201         JMPENV_JUMP(3);
1202     return PL_restartop;
1203 }
1204
1205 #if defined(PERL_IMPLICIT_CONTEXT)
1206 OP *
1207 Perl_die_nocontext(const char* pat, ...)
1208 {
1209     dTHX;
1210     OP *o;
1211     va_list args;
1212     va_start(args, pat);
1213     o = vdie(pat, &args);
1214     va_end(args);
1215     return o;
1216 }
1217 #endif /* PERL_IMPLICIT_CONTEXT */
1218
1219 OP *
1220 Perl_die(pTHX_ const char* pat, ...)
1221 {
1222     OP *o;
1223     va_list args;
1224     va_start(args, pat);
1225     o = vdie(pat, &args);
1226     va_end(args);
1227     return o;
1228 }
1229
1230 void
1231 Perl_vcroak(pTHX_ const char* pat, va_list *args)
1232 {
1233     char *message;
1234     HV *stash;
1235     GV *gv;
1236     CV *cv;
1237     SV *msv;
1238     STRLEN msglen;
1239
1240     if (pat) {
1241         msv = vmess(pat, args);
1242         if (PL_errors && SvCUR(PL_errors)) {
1243             sv_catsv(PL_errors, msv);
1244             message = SvPV(PL_errors, msglen);
1245             SvCUR_set(PL_errors, 0);
1246         }
1247         else
1248             message = SvPV(msv,msglen);
1249     }
1250     else {
1251         message = Nullch;
1252         msglen = 0;
1253     }
1254
1255     DEBUG_S(PerlIO_printf(Perl_debug_log, "croak: 0x%"UVxf" %s",
1256                           PTR2UV(thr), message));
1257
1258     if (PL_diehook) {
1259         /* sv_2cv might call Perl_croak() */
1260         SV *olddiehook = PL_diehook;
1261         ENTER;
1262         SAVESPTR(PL_diehook);
1263         PL_diehook = Nullsv;
1264         cv = sv_2cv(olddiehook, &stash, &gv, 0);
1265         LEAVE;
1266         if (cv && !CvDEPTH(cv) && (CvROOT(cv) || CvXSUB(cv))) {
1267             dSP;
1268             SV *msg;
1269
1270             ENTER;
1271             save_re_context();
1272             if (message) {
1273                 msg = newSVpvn(message, msglen);
1274                 SvREADONLY_on(msg);
1275                 SAVEFREESV(msg);
1276             }
1277             else {
1278                 msg = ERRSV;
1279             }
1280
1281             PUSHSTACKi(PERLSI_DIEHOOK);
1282             PUSHMARK(SP);
1283             XPUSHs(msg);
1284             PUTBACK;
1285             call_sv((SV*)cv, G_DISCARD);
1286             POPSTACK;
1287             LEAVE;
1288         }
1289     }
1290     if (PL_in_eval) {
1291         PL_restartop = die_where(message, msglen);
1292         JMPENV_JUMP(3);
1293     }
1294     else if (!message)
1295         message = SvPVx(ERRSV, msglen);
1296
1297     {
1298 #ifdef USE_SFIO
1299         /* SFIO can really mess with your errno */
1300         int e = errno;
1301 #endif
1302         PerlIO *serr = Perl_error_log;
1303
1304         PERL_WRITE_MSG_TO_CONSOLE(serr, message, msglen);
1305         (void)PerlIO_flush(serr);
1306 #ifdef USE_SFIO
1307         errno = e;
1308 #endif
1309     }
1310     my_failure_exit();
1311 }
1312
1313 #if defined(PERL_IMPLICIT_CONTEXT)
1314 void
1315 Perl_croak_nocontext(const char *pat, ...)
1316 {
1317     dTHX;
1318     va_list args;
1319     va_start(args, pat);
1320     vcroak(pat, &args);
1321     /* NOTREACHED */
1322     va_end(args);
1323 }
1324 #endif /* PERL_IMPLICIT_CONTEXT */
1325
1326 /*
1327 =head1 Warning and Dieing
1328
1329 =for apidoc croak
1330
1331 This is the XSUB-writer's interface to Perl's C<die> function.
1332 Normally use this function the same way you use the C C<printf>
1333 function.  See C<warn>.
1334
1335 If you want to throw an exception object, assign the object to
1336 C<$@> and then pass C<Nullch> to croak():
1337
1338    errsv = get_sv("@", TRUE);
1339    sv_setsv(errsv, exception_object);
1340    croak(Nullch);
1341
1342 =cut
1343 */
1344
1345 void
1346 Perl_croak(pTHX_ const char *pat, ...)
1347 {
1348     va_list args;
1349     va_start(args, pat);
1350     vcroak(pat, &args);
1351     /* NOTREACHED */
1352     va_end(args);
1353 }
1354
1355 void
1356 Perl_vwarn(pTHX_ const char* pat, va_list *args)
1357 {
1358     char *message;
1359     HV *stash;
1360     GV *gv;
1361     CV *cv;
1362     SV *msv;
1363     STRLEN msglen;
1364     IO *io;
1365     MAGIC *mg;
1366
1367     msv = vmess(pat, args);
1368     message = SvPV(msv, msglen);
1369
1370     if (PL_warnhook) {
1371         /* sv_2cv might call Perl_warn() */
1372         SV *oldwarnhook = PL_warnhook;
1373         ENTER;
1374         SAVESPTR(PL_warnhook);
1375         PL_warnhook = Nullsv;
1376         cv = sv_2cv(oldwarnhook, &stash, &gv, 0);
1377         LEAVE;
1378         if (cv && !CvDEPTH(cv) && (CvROOT(cv) || CvXSUB(cv))) {
1379             dSP;
1380             SV *msg;
1381
1382             ENTER;
1383             save_re_context();
1384             msg = newSVpvn(message, msglen);
1385             SvREADONLY_on(msg);
1386             SAVEFREESV(msg);
1387
1388             PUSHSTACKi(PERLSI_WARNHOOK);
1389             PUSHMARK(SP);
1390             XPUSHs(msg);
1391             PUTBACK;
1392             call_sv((SV*)cv, G_DISCARD);
1393             POPSTACK;
1394             LEAVE;
1395             return;
1396         }
1397     }
1398
1399     /* if STDERR is tied, use it instead */
1400     if (PL_stderrgv && (io = GvIOp(PL_stderrgv))
1401         && (mg = SvTIED_mg((SV*)io, PERL_MAGIC_tiedscalar))) {
1402         dSP; ENTER;
1403         PUSHMARK(SP);
1404         XPUSHs(SvTIED_obj((SV*)io, mg));
1405         XPUSHs(sv_2mortal(newSVpvn(message, msglen)));
1406         PUTBACK;
1407         call_method("PRINT", G_SCALAR);
1408         LEAVE;
1409         return;
1410     }
1411
1412     {
1413         PerlIO *serr = Perl_error_log;
1414
1415         PERL_WRITE_MSG_TO_CONSOLE(serr, message, msglen);
1416 #ifdef LEAKTEST
1417         DEBUG_L(*message == '!'
1418                 ? (xstat(message[1]=='!'
1419                          ? (message[2]=='!' ? 2 : 1)
1420                          : 0)
1421                    , 0)
1422                 : 0);
1423 #endif
1424         (void)PerlIO_flush(serr);
1425     }
1426 }
1427
1428 #if defined(PERL_IMPLICIT_CONTEXT)
1429 void
1430 Perl_warn_nocontext(const char *pat, ...)
1431 {
1432     dTHX;
1433     va_list args;
1434     va_start(args, pat);
1435     vwarn(pat, &args);
1436     va_end(args);
1437 }
1438 #endif /* PERL_IMPLICIT_CONTEXT */
1439
1440 /*
1441 =for apidoc warn
1442
1443 This is the XSUB-writer's interface to Perl's C<warn> function.  Use this
1444 function the same way you use the C C<printf> function.  See
1445 C<croak>.
1446
1447 =cut
1448 */
1449
1450 void
1451 Perl_warn(pTHX_ const char *pat, ...)
1452 {
1453     va_list args;
1454     va_start(args, pat);
1455     vwarn(pat, &args);
1456     va_end(args);
1457 }
1458
1459 #if defined(PERL_IMPLICIT_CONTEXT)
1460 void
1461 Perl_warner_nocontext(U32 err, const char *pat, ...)
1462 {
1463     dTHX;
1464     va_list args;
1465     va_start(args, pat);
1466     vwarner(err, pat, &args);
1467     va_end(args);
1468 }
1469 #endif /* PERL_IMPLICIT_CONTEXT */
1470
1471 void
1472 Perl_warner(pTHX_ U32  err, const char* pat,...)
1473 {
1474     va_list args;
1475     va_start(args, pat);
1476     vwarner(err, pat, &args);
1477     va_end(args);
1478 }
1479
1480 void
1481 Perl_vwarner(pTHX_ U32  err, const char* pat, va_list* args)
1482 {
1483     char *message;
1484     HV *stash;
1485     GV *gv;
1486     CV *cv;
1487     SV *msv;
1488     STRLEN msglen;
1489
1490     msv = vmess(pat, args);
1491     message = SvPV(msv, msglen);
1492
1493     if (ckDEAD(err)) {
1494 #ifdef USE_5005THREADS
1495         DEBUG_S(PerlIO_printf(Perl_debug_log, "croak: 0x%"UVxf" %s", PTR2UV(thr), message));
1496 #endif /* USE_5005THREADS */
1497         if (PL_diehook) {
1498             /* sv_2cv might call Perl_croak() */
1499             SV *olddiehook = PL_diehook;
1500             ENTER;
1501             SAVESPTR(PL_diehook);
1502             PL_diehook = Nullsv;
1503             cv = sv_2cv(olddiehook, &stash, &gv, 0);
1504             LEAVE;
1505             if (cv && !CvDEPTH(cv) && (CvROOT(cv) || CvXSUB(cv))) {
1506                 dSP;
1507                 SV *msg;
1508
1509                 ENTER;
1510                 save_re_context();
1511                 msg = newSVpvn(message, msglen);
1512                 SvREADONLY_on(msg);
1513                 SAVEFREESV(msg);
1514
1515                 PUSHSTACKi(PERLSI_DIEHOOK);
1516                 PUSHMARK(sp);
1517                 XPUSHs(msg);
1518                 PUTBACK;
1519                 call_sv((SV*)cv, G_DISCARD);
1520                 POPSTACK;
1521                 LEAVE;
1522             }
1523         }
1524         if (PL_in_eval) {
1525             PL_restartop = die_where(message, msglen);
1526             JMPENV_JUMP(3);
1527         }
1528         {
1529             PerlIO *serr = Perl_error_log;
1530             PERL_WRITE_MSG_TO_CONSOLE(serr, message, msglen);
1531             (void)PerlIO_flush(serr);
1532         }
1533         my_failure_exit();
1534
1535     }
1536     else {
1537         if (PL_warnhook) {
1538             /* sv_2cv might call Perl_warn() */
1539             SV *oldwarnhook = PL_warnhook;
1540             ENTER;
1541             SAVESPTR(PL_warnhook);
1542             PL_warnhook = Nullsv;
1543             cv = sv_2cv(oldwarnhook, &stash, &gv, 0);
1544             LEAVE;
1545             if (cv && !CvDEPTH(cv) && (CvROOT(cv) || CvXSUB(cv))) {
1546                 dSP;
1547                 SV *msg;
1548
1549                 ENTER;
1550                 save_re_context();
1551                 msg = newSVpvn(message, msglen);
1552                 SvREADONLY_on(msg);
1553                 SAVEFREESV(msg);
1554
1555                 PUSHSTACKi(PERLSI_WARNHOOK);
1556                 PUSHMARK(sp);
1557                 XPUSHs(msg);
1558                 PUTBACK;
1559                 call_sv((SV*)cv, G_DISCARD);
1560                 POPSTACK;
1561                 LEAVE;
1562                 return;
1563             }
1564         }
1565         {
1566             PerlIO *serr = Perl_error_log;
1567             PERL_WRITE_MSG_TO_CONSOLE(serr, message, msglen);
1568 #ifdef LEAKTEST
1569             DEBUG_L(*message == '!'
1570                 ? (xstat(message[1]=='!'
1571                          ? (message[2]=='!' ? 2 : 1)
1572                          : 0)
1573                    , 0)
1574                 : 0);
1575 #endif
1576             (void)PerlIO_flush(serr);
1577         }
1578     }
1579 }
1580
1581 /* since we've already done strlen() for both nam and val
1582  * we can use that info to make things faster than
1583  * sprintf(s, "%s=%s", nam, val)
1584  */
1585 #define my_setenv_format(s, nam, nlen, val, vlen) \
1586    Copy(nam, s, nlen, char); \
1587    *(s+nlen) = '='; \
1588    Copy(val, s+(nlen+1), vlen, char); \
1589    *(s+(nlen+1+vlen)) = '\0'
1590
1591 #ifdef USE_ENVIRON_ARRAY
1592        /* VMS' my_setenv() is in vms.c */
1593 #if !defined(WIN32) && !defined(NETWARE)
1594 void
1595 Perl_my_setenv(pTHX_ char *nam, char *val)
1596 {
1597 #ifdef USE_ITHREADS
1598   /* only parent thread can modify process environment */
1599   if (PL_curinterp == aTHX)
1600 #endif
1601   {
1602 #ifndef PERL_USE_SAFE_PUTENV
1603     /* most putenv()s leak, so we manipulate environ directly */
1604     register I32 i=setenv_getix(nam);           /* where does it go? */
1605     int nlen, vlen;
1606
1607     if (environ == PL_origenviron) {    /* need we copy environment? */
1608         I32 j;
1609         I32 max;
1610         char **tmpenv;
1611
1612         /*SUPPRESS 530*/
1613         for (max = i; environ[max]; max++) ;
1614         tmpenv = (char**)safesysmalloc((max+2) * sizeof(char*));
1615         for (j=0; j<max; j++) {         /* copy environment */
1616             int len = strlen(environ[j]);
1617             tmpenv[j] = (char*)safesysmalloc((len+1)*sizeof(char));
1618             Copy(environ[j], tmpenv[j], len+1, char);
1619         }
1620         tmpenv[max] = Nullch;
1621         environ = tmpenv;               /* tell exec where it is now */
1622     }
1623     if (!val) {
1624         safesysfree(environ[i]);
1625         while (environ[i]) {
1626             environ[i] = environ[i+1];
1627             i++;
1628         }
1629         return;
1630     }
1631     if (!environ[i]) {                  /* does not exist yet */
1632         environ = (char**)safesysrealloc(environ, (i+2) * sizeof(char*));
1633         environ[i+1] = Nullch;  /* make sure it's null terminated */
1634     }
1635     else
1636         safesysfree(environ[i]);
1637     nlen = strlen(nam);
1638     vlen = strlen(val);
1639
1640     environ[i] = (char*)safesysmalloc((nlen+vlen+2) * sizeof(char));
1641     /* all that work just for this */
1642     my_setenv_format(environ[i], nam, nlen, val, vlen);
1643
1644 #else   /* PERL_USE_SAFE_PUTENV */
1645 #   if defined(__CYGWIN__) || defined( EPOC)
1646     setenv(nam, val, 1);
1647 #   else
1648     char *new_env;
1649     int nlen = strlen(nam), vlen;
1650     if (!val) {
1651         val = "";
1652     }
1653     vlen = strlen(val);
1654     new_env = (char*)safesysmalloc((nlen + vlen + 2) * sizeof(char));
1655     /* all that work just for this */
1656     my_setenv_format(new_env, nam, nlen, val, vlen);
1657     (void)putenv(new_env);
1658 #   endif /* __CYGWIN__ */
1659 #endif  /* PERL_USE_SAFE_PUTENV */
1660   }
1661 }
1662
1663 #else /* WIN32 || NETWARE */
1664
1665 void
1666 Perl_my_setenv(pTHX_ char *nam,char *val)
1667 {
1668     register char *envstr;
1669     int nlen = strlen(nam), vlen;
1670
1671     if (!val) {
1672         val = "";
1673     }
1674     vlen = strlen(val);
1675     New(904, envstr, nlen+vlen+2, char);
1676     my_setenv_format(envstr, nam, nlen, val, vlen);
1677     (void)PerlEnv_putenv(envstr);
1678     Safefree(envstr);
1679 }
1680
1681 #endif /* WIN32 || NETWARE */
1682
1683 I32
1684 Perl_setenv_getix(pTHX_ char *nam)
1685 {
1686     register I32 i, len = strlen(nam);
1687
1688     for (i = 0; environ[i]; i++) {
1689         if (
1690 #ifdef WIN32
1691             strnicmp(environ[i],nam,len) == 0
1692 #else
1693             strnEQ(environ[i],nam,len)
1694 #endif
1695             && environ[i][len] == '=')
1696             break;                      /* strnEQ must come first to avoid */
1697     }                                   /* potential SEGV's */
1698     return i;
1699 }
1700
1701 #endif /* !VMS && !EPOC*/
1702
1703 #ifdef UNLINK_ALL_VERSIONS
1704 I32
1705 Perl_unlnk(pTHX_ char *f)       /* unlink all versions of a file */
1706 {
1707     I32 i;
1708
1709     for (i = 0; PerlLIO_unlink(f) >= 0; i++) ;
1710     return i ? 0 : -1;
1711 }
1712 #endif
1713
1714 /* this is a drop-in replacement for bcopy() */
1715 #if (!defined(HAS_MEMCPY) && !defined(HAS_BCOPY)) || (!defined(HAS_MEMMOVE) && !defined(HAS_SAFE_MEMCPY) && !defined(HAS_SAFE_BCOPY))
1716 char *
1717 Perl_my_bcopy(register const char *from,register char *to,register I32 len)
1718 {
1719     char *retval = to;
1720
1721     if (from - to >= 0) {
1722         while (len--)
1723             *to++ = *from++;
1724     }
1725     else {
1726         to += len;
1727         from += len;
1728         while (len--)
1729             *(--to) = *(--from);
1730     }
1731     return retval;
1732 }
1733 #endif
1734
1735 /* this is a drop-in replacement for memset() */
1736 #ifndef HAS_MEMSET
1737 void *
1738 Perl_my_memset(register char *loc, register I32 ch, register I32 len)
1739 {
1740     char *retval = loc;
1741
1742     while (len--)
1743         *loc++ = ch;
1744     return retval;
1745 }
1746 #endif
1747
1748 /* this is a drop-in replacement for bzero() */
1749 #if !defined(HAS_BZERO) && !defined(HAS_MEMSET)
1750 char *
1751 Perl_my_bzero(register char *loc, register I32 len)
1752 {
1753     char *retval = loc;
1754
1755     while (len--)
1756         *loc++ = 0;
1757     return retval;
1758 }
1759 #endif
1760
1761 /* this is a drop-in replacement for memcmp() */
1762 #if !defined(HAS_MEMCMP) || !defined(HAS_SANE_MEMCMP)
1763 I32
1764 Perl_my_memcmp(const char *s1, const char *s2, register I32 len)
1765 {
1766     register U8 *a = (U8 *)s1;
1767     register U8 *b = (U8 *)s2;
1768     register I32 tmp;
1769
1770     while (len--) {
1771         if (tmp = *a++ - *b++)
1772             return tmp;
1773     }
1774     return 0;
1775 }
1776 #endif /* !HAS_MEMCMP || !HAS_SANE_MEMCMP */
1777
1778 #ifndef HAS_VPRINTF
1779
1780 #ifdef USE_CHAR_VSPRINTF
1781 char *
1782 #else
1783 int
1784 #endif
1785 vsprintf(char *dest, const char *pat, char *args)
1786 {
1787     FILE fakebuf;
1788
1789     fakebuf._ptr = dest;
1790     fakebuf._cnt = 32767;
1791 #ifndef _IOSTRG
1792 #define _IOSTRG 0
1793 #endif
1794     fakebuf._flag = _IOWRT|_IOSTRG;
1795     _doprnt(pat, args, &fakebuf);       /* what a kludge */
1796     (void)putc('\0', &fakebuf);
1797 #ifdef USE_CHAR_VSPRINTF
1798     return(dest);
1799 #else
1800     return 0;           /* perl doesn't use return value */
1801 #endif
1802 }
1803
1804 #endif /* HAS_VPRINTF */
1805
1806 #ifdef MYSWAP
1807 #if BYTEORDER != 0x4321
1808 short
1809 Perl_my_swap(pTHX_ short s)
1810 {
1811 #if (BYTEORDER & 1) == 0
1812     short result;
1813
1814     result = ((s & 255) << 8) + ((s >> 8) & 255);
1815     return result;
1816 #else
1817     return s;
1818 #endif
1819 }
1820
1821 long
1822 Perl_my_htonl(pTHX_ long l)
1823 {
1824     union {
1825         long result;
1826         char c[sizeof(long)];
1827     } u;
1828
1829 #if BYTEORDER == 0x1234
1830     u.c[0] = (l >> 24) & 255;
1831     u.c[1] = (l >> 16) & 255;
1832     u.c[2] = (l >> 8) & 255;
1833     u.c[3] = l & 255;
1834     return u.result;
1835 #else
1836 #if ((BYTEORDER - 0x1111) & 0x444) || !(BYTEORDER & 0xf)
1837     Perl_croak(aTHX_ "Unknown BYTEORDER\n");
1838 #else
1839     register I32 o;
1840     register I32 s;
1841
1842     for (o = BYTEORDER - 0x1111, s = 0; s < (sizeof(long)*8); o >>= 4, s += 8) {
1843         u.c[o & 0xf] = (l >> s) & 255;
1844     }
1845     return u.result;
1846 #endif
1847 #endif
1848 }
1849
1850 long
1851 Perl_my_ntohl(pTHX_ long l)
1852 {
1853     union {
1854         long l;
1855         char c[sizeof(long)];
1856     } u;
1857
1858 #if BYTEORDER == 0x1234
1859     u.c[0] = (l >> 24) & 255;
1860     u.c[1] = (l >> 16) & 255;
1861     u.c[2] = (l >> 8) & 255;
1862     u.c[3] = l & 255;
1863     return u.l;
1864 #else
1865 #if ((BYTEORDER - 0x1111) & 0x444) || !(BYTEORDER & 0xf)
1866     Perl_croak(aTHX_ "Unknown BYTEORDER\n");
1867 #else
1868     register I32 o;
1869     register I32 s;
1870
1871     u.l = l;
1872     l = 0;
1873     for (o = BYTEORDER - 0x1111, s = 0; s < (sizeof(long)*8); o >>= 4, s += 8) {
1874         l |= (u.c[o & 0xf] & 255) << s;
1875     }
1876     return l;
1877 #endif
1878 #endif
1879 }
1880
1881 #endif /* BYTEORDER != 0x4321 */
1882 #endif /* MYSWAP */
1883
1884 /*
1885  * Little-endian byte order functions - 'v' for 'VAX', or 'reVerse'.
1886  * If these functions are defined,
1887  * the BYTEORDER is neither 0x1234 nor 0x4321.
1888  * However, this is not assumed.
1889  * -DWS
1890  */
1891
1892 #define HTOV(name,type)                                         \
1893         type                                                    \
1894         name (register type n)                                  \
1895         {                                                       \
1896             union {                                             \
1897                 type value;                                     \
1898                 char c[sizeof(type)];                           \
1899             } u;                                                \
1900             register I32 i;                                     \
1901             register I32 s;                                     \
1902             for (i = 0, s = 0; i < sizeof(u.c); i++, s += 8) {  \
1903                 u.c[i] = (n >> s) & 0xFF;                       \
1904             }                                                   \
1905             return u.value;                                     \
1906         }
1907
1908 #define VTOH(name,type)                                         \
1909         type                                                    \
1910         name (register type n)                                  \
1911         {                                                       \
1912             union {                                             \
1913                 type value;                                     \
1914                 char c[sizeof(type)];                           \
1915             } u;                                                \
1916             register I32 i;                                     \
1917             register I32 s;                                     \
1918             u.value = n;                                        \
1919             n = 0;                                              \
1920             for (i = 0, s = 0; i < sizeof(u.c); i++, s += 8) {  \
1921                 n += (u.c[i] & 0xFF) << s;                      \
1922             }                                                   \
1923             return n;                                           \
1924         }
1925
1926 #if defined(HAS_HTOVS) && !defined(htovs)
1927 HTOV(htovs,short)
1928 #endif
1929 #if defined(HAS_HTOVL) && !defined(htovl)
1930 HTOV(htovl,long)
1931 #endif
1932 #if defined(HAS_VTOHS) && !defined(vtohs)
1933 VTOH(vtohs,short)
1934 #endif
1935 #if defined(HAS_VTOHL) && !defined(vtohl)
1936 VTOH(vtohl,long)
1937 #endif
1938
1939 PerlIO *
1940 Perl_my_popen_list(pTHX_ char *mode, int n, SV **args)
1941 {
1942 #if (!defined(DOSISH) || defined(HAS_FORK) || defined(AMIGAOS)) && !defined(OS2) && !defined(VMS) && !defined(__OPEN_VM) && !defined(EPOC) && !defined(MACOS_TRADITIONAL) && !defined(NETWARE)
1943     int p[2];
1944     register I32 This, that;
1945     register Pid_t pid;
1946     SV *sv;
1947     I32 did_pipes = 0;
1948     int pp[2];
1949
1950     PERL_FLUSHALL_FOR_CHILD;
1951     This = (*mode == 'w');
1952     that = !This;
1953     if (PL_tainting) {
1954         taint_env();
1955         taint_proper("Insecure %s%s", "EXEC");
1956     }
1957     if (PerlProc_pipe(p) < 0)
1958         return Nullfp;
1959     /* Try for another pipe pair for error return */
1960     if (PerlProc_pipe(pp) >= 0)
1961         did_pipes = 1;
1962     while ((pid = PerlProc_fork()) < 0) {
1963         if (errno != EAGAIN) {
1964             PerlLIO_close(p[This]);
1965             if (did_pipes) {
1966                 PerlLIO_close(pp[0]);
1967                 PerlLIO_close(pp[1]);
1968             }
1969             return Nullfp;
1970         }
1971         sleep(5);
1972     }
1973     if (pid == 0) {
1974         /* Child */
1975 #undef THIS
1976 #undef THAT
1977 #define THIS that
1978 #define THAT This
1979         /* Close parent's end of _the_ pipe */
1980         PerlLIO_close(p[THAT]);
1981         /* Close parent's end of error status pipe (if any) */
1982         if (did_pipes) {
1983             PerlLIO_close(pp[0]);
1984 #if defined(HAS_FCNTL) && defined(F_SETFD)
1985             /* Close error pipe automatically if exec works */
1986             fcntl(pp[1], F_SETFD, FD_CLOEXEC);
1987 #endif
1988         }
1989         /* Now dup our end of _the_ pipe to right position */
1990         if (p[THIS] != (*mode == 'r')) {
1991             PerlLIO_dup2(p[THIS], *mode == 'r');
1992             PerlLIO_close(p[THIS]);
1993         }
1994 #if !defined(HAS_FCNTL) || !defined(F_SETFD)
1995         /* No automatic close - do it by hand */
1996 #  ifndef NOFILE
1997 #  define NOFILE 20
1998 #  endif
1999         {
2000             int fd;
2001
2002             for (fd = PL_maxsysfd + 1; fd < NOFILE; fd++) {
2003                 if (fd != pp[1])
2004                     PerlLIO_close(fd);
2005             }
2006         }
2007 #endif
2008         do_aexec5(Nullsv, args-1, args-1+n, pp[1], did_pipes);
2009         PerlProc__exit(1);
2010 #undef THIS
2011 #undef THAT
2012     }
2013     /* Parent */
2014     do_execfree();      /* free any memory malloced by child on fork */
2015     /* Close child's end of pipe */
2016     PerlLIO_close(p[that]);
2017     if (did_pipes)
2018         PerlLIO_close(pp[1]);
2019     /* Keep the lower of the two fd numbers */
2020     if (p[that] < p[This]) {
2021         PerlLIO_dup2(p[This], p[that]);
2022         PerlLIO_close(p[This]);
2023         p[This] = p[that];
2024     }
2025     LOCK_FDPID_MUTEX;
2026     sv = *av_fetch(PL_fdpid,p[This],TRUE);
2027     UNLOCK_FDPID_MUTEX;
2028     (void)SvUPGRADE(sv,SVt_IV);
2029     SvIVX(sv) = pid;
2030     PL_forkprocess = pid;
2031     /* If we managed to get status pipe check for exec fail */
2032     if (did_pipes && pid > 0) {
2033         int errkid;
2034         int n = 0, n1;
2035
2036         while (n < sizeof(int)) {
2037             n1 = PerlLIO_read(pp[0],
2038                               (void*)(((char*)&errkid)+n),
2039                               (sizeof(int)) - n);
2040             if (n1 <= 0)
2041                 break;
2042             n += n1;
2043         }
2044         PerlLIO_close(pp[0]);
2045         did_pipes = 0;
2046         if (n) {                        /* Error */
2047             int pid2, status;
2048             PerlLIO_close(p[This]);
2049             if (n != sizeof(int))
2050                 Perl_croak(aTHX_ "panic: kid popen errno read");
2051             do {
2052                 pid2 = wait4pid(pid, &status, 0);
2053             } while (pid2 == -1 && errno == EINTR);
2054             errno = errkid;             /* Propagate errno from kid */
2055             return Nullfp;
2056         }
2057     }
2058     if (did_pipes)
2059          PerlLIO_close(pp[0]);
2060     return PerlIO_fdopen(p[This], mode);
2061 #else
2062     Perl_croak(aTHX_ "List form of piped open not implemented");
2063     return (PerlIO *) NULL;
2064 #endif
2065 }
2066
2067     /* VMS' my_popen() is in VMS.c, same with OS/2. */
2068 #if (!defined(DOSISH) || defined(HAS_FORK) || defined(AMIGAOS)) && !defined(VMS) && !defined(__OPEN_VM) && !defined(EPOC) && !defined(MACOS_TRADITIONAL)
2069 PerlIO *
2070 Perl_my_popen(pTHX_ char *cmd, char *mode)
2071 {
2072     int p[2];
2073     register I32 This, that;
2074     register Pid_t pid;
2075     SV *sv;
2076     I32 doexec = strNE(cmd,"-");
2077     I32 did_pipes = 0;
2078     int pp[2];
2079
2080     PERL_FLUSHALL_FOR_CHILD;
2081 #ifdef OS2
2082     if (doexec) {
2083         return my_syspopen(aTHX_ cmd,mode);
2084     }
2085 #endif
2086     This = (*mode == 'w');
2087     that = !This;
2088     if (doexec && PL_tainting) {
2089         taint_env();
2090         taint_proper("Insecure %s%s", "EXEC");
2091     }
2092     if (PerlProc_pipe(p) < 0)
2093         return Nullfp;
2094     if (doexec && PerlProc_pipe(pp) >= 0)
2095         did_pipes = 1;
2096     while ((pid = PerlProc_fork()) < 0) {
2097         if (errno != EAGAIN) {
2098             PerlLIO_close(p[This]);
2099             if (did_pipes) {
2100                 PerlLIO_close(pp[0]);
2101                 PerlLIO_close(pp[1]);
2102             }
2103             if (!doexec)
2104                 Perl_croak(aTHX_ "Can't fork");
2105             return Nullfp;
2106         }
2107         sleep(5);
2108     }
2109     if (pid == 0) {
2110         GV* tmpgv;
2111
2112 #undef THIS
2113 #undef THAT
2114 #define THIS that
2115 #define THAT This
2116         PerlLIO_close(p[THAT]);
2117         if (did_pipes) {
2118             PerlLIO_close(pp[0]);
2119 #if defined(HAS_FCNTL) && defined(F_SETFD)
2120             fcntl(pp[1], F_SETFD, FD_CLOEXEC);
2121 #endif
2122         }
2123         if (p[THIS] != (*mode == 'r')) {
2124             PerlLIO_dup2(p[THIS], *mode == 'r');
2125             PerlLIO_close(p[THIS]);
2126         }
2127 #ifndef OS2
2128         if (doexec) {
2129 #if !defined(HAS_FCNTL) || !defined(F_SETFD)
2130             int fd;
2131
2132 #ifndef NOFILE
2133 #define NOFILE 20
2134 #endif
2135             {
2136                 int fd;
2137
2138                 for (fd = PL_maxsysfd + 1; fd < NOFILE; fd++)
2139                     if (fd != pp[1])
2140                         PerlLIO_close(fd);
2141             }
2142 #endif
2143             /* may or may not use the shell */
2144             do_exec3(cmd, pp[1], did_pipes);
2145             PerlProc__exit(1);
2146         }
2147 #endif  /* defined OS2 */
2148         /*SUPPRESS 560*/
2149         if ((tmpgv = gv_fetchpv("$",TRUE, SVt_PV))) {
2150         SvREADONLY_off(GvSV(tmpgv));
2151             sv_setiv(GvSV(tmpgv), PerlProc_getpid());
2152         SvREADONLY_on(GvSV(tmpgv));
2153     }
2154         PL_forkprocess = 0;
2155         hv_clear(PL_pidstatus); /* we have no children */
2156         return Nullfp;
2157 #undef THIS
2158 #undef THAT
2159     }
2160     do_execfree();      /* free any memory malloced by child on fork */
2161     PerlLIO_close(p[that]);
2162     if (did_pipes)
2163         PerlLIO_close(pp[1]);
2164     if (p[that] < p[This]) {
2165         PerlLIO_dup2(p[This], p[that]);
2166         PerlLIO_close(p[This]);
2167         p[This] = p[that];
2168     }
2169     LOCK_FDPID_MUTEX;
2170     sv = *av_fetch(PL_fdpid,p[This],TRUE);
2171     UNLOCK_FDPID_MUTEX;
2172     (void)SvUPGRADE(sv,SVt_IV);
2173     SvIVX(sv) = pid;
2174     PL_forkprocess = pid;
2175     if (did_pipes && pid > 0) {
2176         int errkid;
2177         int n = 0, n1;
2178
2179         while (n < sizeof(int)) {
2180             n1 = PerlLIO_read(pp[0],
2181                               (void*)(((char*)&errkid)+n),
2182                               (sizeof(int)) - n);
2183             if (n1 <= 0)
2184                 break;
2185             n += n1;
2186         }
2187         PerlLIO_close(pp[0]);
2188         did_pipes = 0;
2189         if (n) {                        /* Error */
2190             int pid2, status;
2191             PerlLIO_close(p[This]);
2192             if (n != sizeof(int))
2193                 Perl_croak(aTHX_ "panic: kid popen errno read");
2194             do {
2195                 pid2 = wait4pid(pid, &status, 0);
2196             } while (pid2 == -1 && errno == EINTR);
2197             errno = errkid;             /* Propagate errno from kid */
2198             return Nullfp;
2199         }
2200     }
2201     if (did_pipes)
2202          PerlLIO_close(pp[0]);
2203     return PerlIO_fdopen(p[This], mode);
2204 }
2205 #else
2206 #if defined(atarist) || defined(EPOC)
2207 FILE *popen();
2208 PerlIO *
2209 Perl_my_popen(pTHX_ char *cmd, char *mode)
2210 {
2211     PERL_FLUSHALL_FOR_CHILD;
2212     /* Call system's popen() to get a FILE *, then import it.
2213        used 0 for 2nd parameter to PerlIO_importFILE;
2214        apparently not used
2215     */
2216     return PerlIO_importFILE(popen(cmd, mode), 0);
2217 }
2218 #else
2219 #if defined(DJGPP)
2220 FILE *djgpp_popen();
2221 PerlIO *
2222 Perl_my_popen(pTHX_ char *cmd, char *mode)
2223 {
2224     PERL_FLUSHALL_FOR_CHILD;
2225     /* Call system's popen() to get a FILE *, then import it.
2226        used 0 for 2nd parameter to PerlIO_importFILE;
2227        apparently not used
2228     */
2229     return PerlIO_importFILE(djgpp_popen(cmd, mode), 0);
2230 }
2231 #endif
2232 #endif
2233
2234 #endif /* !DOSISH */
2235
2236 /* this is called in parent before the fork() */
2237 void
2238 Perl_atfork_lock(void)
2239 {
2240 #if defined(USE_5005THREADS) || defined(USE_ITHREADS)
2241     /* locks must be held in locking order (if any) */
2242 #  ifdef MYMALLOC
2243     MUTEX_LOCK(&PL_malloc_mutex);
2244 #  endif
2245     OP_REFCNT_LOCK;
2246 #endif
2247 }
2248
2249 /* this is called in both parent and child after the fork() */
2250 void
2251 Perl_atfork_unlock(void)
2252 {
2253 #if defined(USE_5005THREADS) || defined(USE_ITHREADS)
2254     /* locks must be released in same order as in atfork_lock() */
2255 #  ifdef MYMALLOC
2256     MUTEX_UNLOCK(&PL_malloc_mutex);
2257 #  endif
2258     OP_REFCNT_UNLOCK;
2259 #endif
2260 }
2261
2262 Pid_t
2263 Perl_my_fork(void)
2264 {
2265 #if defined(HAS_FORK)
2266     Pid_t pid;
2267 #if (defined(USE_5005THREADS) || defined(USE_ITHREADS)) && !defined(HAS_PTHREAD_ATFORK)
2268     atfork_lock();
2269     pid = fork();
2270     atfork_unlock();
2271 #else
2272     /* atfork_lock() and atfork_unlock() are installed as pthread_atfork()
2273      * handlers elsewhere in the code */
2274     pid = fork();
2275 #endif
2276     return pid;
2277 #else
2278     /* this "canna happen" since nothing should be calling here if !HAS_FORK */
2279     Perl_croak_nocontext("fork() not available");
2280     return 0;
2281 #endif /* HAS_FORK */
2282 }
2283
2284 #ifdef DUMP_FDS
2285 void
2286 Perl_dump_fds(pTHX_ char *s)
2287 {
2288     int fd;
2289     Stat_t tmpstatbuf;
2290
2291     PerlIO_printf(Perl_debug_log,"%s", s);
2292     for (fd = 0; fd < 32; fd++) {
2293         if (PerlLIO_fstat(fd,&tmpstatbuf) >= 0)
2294             PerlIO_printf(Perl_debug_log," %d",fd);
2295     }
2296     PerlIO_printf(Perl_debug_log,"\n");
2297 }
2298 #endif  /* DUMP_FDS */
2299
2300 #ifndef HAS_DUP2
2301 int
2302 dup2(int oldfd, int newfd)
2303 {
2304 #if defined(HAS_FCNTL) && defined(F_DUPFD)
2305     if (oldfd == newfd)
2306         return oldfd;
2307     PerlLIO_close(newfd);
2308     return fcntl(oldfd, F_DUPFD, newfd);
2309 #else
2310 #define DUP2_MAX_FDS 256
2311     int fdtmp[DUP2_MAX_FDS];
2312     I32 fdx = 0;
2313     int fd;
2314
2315     if (oldfd == newfd)
2316         return oldfd;
2317     PerlLIO_close(newfd);
2318     /* good enough for low fd's... */
2319     while ((fd = PerlLIO_dup(oldfd)) != newfd && fd >= 0) {
2320         if (fdx >= DUP2_MAX_FDS) {
2321             PerlLIO_close(fd);
2322             fd = -1;
2323             break;
2324         }
2325         fdtmp[fdx++] = fd;
2326     }
2327     while (fdx > 0)
2328         PerlLIO_close(fdtmp[--fdx]);
2329     return fd;
2330 #endif
2331 }
2332 #endif
2333
2334 #ifndef PERL_MICRO
2335 #ifdef HAS_SIGACTION
2336
2337 Sighandler_t
2338 Perl_rsignal(pTHX_ int signo, Sighandler_t handler)
2339 {
2340     struct sigaction act, oact;
2341
2342     act.sa_handler = handler;
2343     sigemptyset(&act.sa_mask);
2344     act.sa_flags = 0;
2345 #ifdef SA_RESTART
2346 #if defined(PERL_OLD_SIGNALS)
2347     act.sa_flags |= SA_RESTART; /* SVR4, 4.3+BSD */
2348 #endif
2349 #endif
2350 #ifdef SA_NOCLDWAIT
2351     if (signo == SIGCHLD && handler == (Sighandler_t)SIG_IGN)
2352         act.sa_flags |= SA_NOCLDWAIT;
2353 #endif
2354     if (sigaction(signo, &act, &oact) == -1)
2355         return SIG_ERR;
2356     else
2357         return oact.sa_handler;
2358 }
2359
2360 Sighandler_t
2361 Perl_rsignal_state(pTHX_ int signo)
2362 {
2363     struct sigaction oact;
2364
2365     if (sigaction(signo, (struct sigaction *)NULL, &oact) == -1)
2366         return SIG_ERR;
2367     else
2368         return oact.sa_handler;
2369 }
2370
2371 int
2372 Perl_rsignal_save(pTHX_ int signo, Sighandler_t handler, Sigsave_t *save)
2373 {
2374     struct sigaction act;
2375
2376     act.sa_handler = handler;
2377     sigemptyset(&act.sa_mask);
2378     act.sa_flags = 0;
2379 #ifdef SA_RESTART
2380 #if defined(PERL_OLD_SIGNALS)
2381     act.sa_flags |= SA_RESTART; /* SVR4, 4.3+BSD */
2382 #endif
2383 #endif
2384 #ifdef SA_NOCLDWAIT
2385     if (signo == SIGCHLD && handler == (Sighandler_t)SIG_IGN)
2386         act.sa_flags |= SA_NOCLDWAIT;
2387 #endif
2388     return sigaction(signo, &act, save);
2389 }
2390
2391 int
2392 Perl_rsignal_restore(pTHX_ int signo, Sigsave_t *save)
2393 {
2394     return sigaction(signo, save, (struct sigaction *)NULL);
2395 }
2396
2397 #else /* !HAS_SIGACTION */
2398
2399 Sighandler_t
2400 Perl_rsignal(pTHX_ int signo, Sighandler_t handler)
2401 {
2402     return PerlProc_signal(signo, handler);
2403 }
2404
2405 static int sig_trapped; /* XXX signals are process-wide anyway, so we
2406                            ignore the implications of this for threading */
2407
2408 static
2409 Signal_t
2410 sig_trap(int signo)
2411 {
2412     sig_trapped++;
2413 }
2414
2415 Sighandler_t
2416 Perl_rsignal_state(pTHX_ int signo)
2417 {
2418     Sighandler_t oldsig;
2419
2420     sig_trapped = 0;
2421     oldsig = PerlProc_signal(signo, sig_trap);
2422     PerlProc_signal(signo, oldsig);
2423     if (sig_trapped)
2424         PerlProc_kill(PerlProc_getpid(), signo);
2425     return oldsig;
2426 }
2427
2428 int
2429 Perl_rsignal_save(pTHX_ int signo, Sighandler_t handler, Sigsave_t *save)
2430 {
2431     *save = PerlProc_signal(signo, handler);
2432     return (*save == SIG_ERR) ? -1 : 0;
2433 }
2434
2435 int
2436 Perl_rsignal_restore(pTHX_ int signo, Sigsave_t *save)
2437 {
2438     return (PerlProc_signal(signo, *save) == SIG_ERR) ? -1 : 0;
2439 }
2440
2441 #endif /* !HAS_SIGACTION */
2442 #endif /* !PERL_MICRO */
2443
2444     /* VMS' my_pclose() is in VMS.c; same with OS/2 */
2445 #if (!defined(DOSISH) || defined(HAS_FORK) || defined(AMIGAOS)) && !defined(VMS) && !defined(__OPEN_VM) && !defined(EPOC) && !defined(MACOS_TRADITIONAL)
2446 I32
2447 Perl_my_pclose(pTHX_ PerlIO *ptr)
2448 {
2449     Sigsave_t hstat, istat, qstat;
2450     int status;
2451     SV **svp;
2452     Pid_t pid;
2453     Pid_t pid2;
2454     bool close_failed;
2455     int saved_errno = 0;
2456 #ifdef VMS
2457     int saved_vaxc_errno;
2458 #endif
2459 #ifdef WIN32
2460     int saved_win32_errno;
2461 #endif
2462
2463     LOCK_FDPID_MUTEX;
2464     svp = av_fetch(PL_fdpid,PerlIO_fileno(ptr),TRUE);
2465     UNLOCK_FDPID_MUTEX;
2466     pid = (SvTYPE(*svp) == SVt_IV) ? SvIVX(*svp) : -1;
2467     SvREFCNT_dec(*svp);
2468     *svp = &PL_sv_undef;
2469 #ifdef OS2
2470     if (pid == -1) {                    /* Opened by popen. */
2471         return my_syspclose(ptr);
2472     }
2473 #endif
2474     if ((close_failed = (PerlIO_close(ptr) == EOF))) {
2475         saved_errno = errno;
2476 #ifdef VMS
2477         saved_vaxc_errno = vaxc$errno;
2478 #endif
2479 #ifdef WIN32
2480         saved_win32_errno = GetLastError();
2481 #endif
2482     }
2483 #ifdef UTS
2484     if(PerlProc_kill(pid, 0) < 0) { return(pid); }   /* HOM 12/23/91 */
2485 #endif
2486 #ifndef PERL_MICRO
2487     rsignal_save(SIGHUP, SIG_IGN, &hstat);
2488     rsignal_save(SIGINT, SIG_IGN, &istat);
2489     rsignal_save(SIGQUIT, SIG_IGN, &qstat);
2490 #endif
2491     do {
2492         pid2 = wait4pid(pid, &status, 0);
2493     } while (pid2 == -1 && errno == EINTR);
2494 #ifndef PERL_MICRO
2495     rsignal_restore(SIGHUP, &hstat);
2496     rsignal_restore(SIGINT, &istat);
2497     rsignal_restore(SIGQUIT, &qstat);
2498 #endif
2499     if (close_failed) {
2500         SETERRNO(saved_errno, saved_vaxc_errno);
2501         return -1;
2502     }
2503     return(pid2 < 0 ? pid2 : status == 0 ? 0 : (errno = 0, status));
2504 }
2505 #endif /* !DOSISH */
2506
2507 #if  (!defined(DOSISH) || defined(OS2) || defined(WIN32) || defined(NETWARE)) && !defined(MACOS_TRADITIONAL)
2508 I32
2509 Perl_wait4pid(pTHX_ Pid_t pid, int *statusp, int flags)
2510 {
2511     I32 result;
2512     if (!pid)
2513         return -1;
2514 #if !defined(HAS_WAITPID) && !defined(HAS_WAIT4) || defined(HAS_WAITPID_RUNTIME)
2515     {
2516     SV *sv;
2517     SV** svp;
2518     char spid[TYPE_CHARS(int)];
2519
2520     if (pid > 0) {
2521         sprintf(spid, "%"IVdf, (IV)pid);
2522         svp = hv_fetch(PL_pidstatus,spid,strlen(spid),FALSE);
2523         if (svp && *svp != &PL_sv_undef) {
2524             *statusp = SvIVX(*svp);
2525             (void)hv_delete(PL_pidstatus,spid,strlen(spid),G_DISCARD);
2526             return pid;
2527         }
2528     }
2529     else {
2530         HE *entry;
2531
2532         hv_iterinit(PL_pidstatus);
2533         if ((entry = hv_iternext(PL_pidstatus))) {
2534             SV *sv;
2535             char spid[TYPE_CHARS(int)];
2536
2537             pid = atoi(hv_iterkey(entry,(I32*)statusp));
2538             sv = hv_iterval(PL_pidstatus,entry);
2539             *statusp = SvIVX(sv);
2540             sprintf(spid, "%"IVdf, (IV)pid);
2541             (void)hv_delete(PL_pidstatus,spid,strlen(spid),G_DISCARD);
2542             return pid;
2543         }
2544         }
2545     }
2546 #endif
2547 #ifdef HAS_WAITPID
2548 #  ifdef HAS_WAITPID_RUNTIME
2549     if (!HAS_WAITPID_RUNTIME)
2550         goto hard_way;
2551 #  endif
2552     result = PerlProc_waitpid(pid,statusp,flags);
2553     goto finish;
2554 #endif
2555 #if !defined(HAS_WAITPID) && defined(HAS_WAIT4)
2556     result = wait4((pid==-1)?0:pid,statusp,flags,Null(struct rusage *));
2557     goto finish;
2558 #endif
2559 #if !defined(HAS_WAITPID) && !defined(HAS_WAIT4) || defined(HAS_WAITPID_RUNTIME)
2560   hard_way:
2561     {
2562         if (flags)
2563             Perl_croak(aTHX_ "Can't do waitpid with flags");
2564         else {
2565             while ((result = PerlProc_wait(statusp)) != pid && pid > 0 && result >= 0)
2566                 pidgone(result,*statusp);
2567             if (result < 0)
2568                 *statusp = -1;
2569         }
2570     }
2571 #endif
2572   finish:
2573     if (result < 0 && errno == EINTR) {
2574         PERL_ASYNC_CHECK();
2575     }
2576     return result;
2577 }
2578 #endif /* !DOSISH || OS2 || WIN32 || NETWARE */
2579
2580 void
2581 /*SUPPRESS 590*/
2582 Perl_pidgone(pTHX_ Pid_t pid, int status)
2583 {
2584     register SV *sv;
2585     char spid[TYPE_CHARS(int)];
2586
2587     sprintf(spid, "%"IVdf, (IV)pid);
2588     sv = *hv_fetch(PL_pidstatus,spid,strlen(spid),TRUE);
2589     (void)SvUPGRADE(sv,SVt_IV);
2590     SvIVX(sv) = status;
2591     return;
2592 }
2593
2594 #if defined(atarist) || defined(OS2) || defined(EPOC)
2595 int pclose();
2596 #ifdef HAS_FORK
2597 int                                     /* Cannot prototype with I32
2598                                            in os2ish.h. */
2599 my_syspclose(PerlIO *ptr)
2600 #else
2601 I32
2602 Perl_my_pclose(pTHX_ PerlIO *ptr)
2603 #endif
2604 {
2605     /* Needs work for PerlIO ! */
2606     FILE *f = PerlIO_findFILE(ptr);
2607     I32 result = pclose(f);
2608     PerlIO_releaseFILE(ptr,f);
2609     return result;
2610 }
2611 #endif
2612
2613 #if defined(DJGPP)
2614 int djgpp_pclose();
2615 I32
2616 Perl_my_pclose(pTHX_ PerlIO *ptr)
2617 {
2618     /* Needs work for PerlIO ! */
2619     FILE *f = PerlIO_findFILE(ptr);
2620     I32 result = djgpp_pclose(f);
2621     result = (result << 8) & 0xff00;
2622     PerlIO_releaseFILE(ptr,f);
2623     return result;
2624 }
2625 #endif
2626
2627 void
2628 Perl_repeatcpy(pTHX_ register char *to, register const char *from, I32 len, register I32 count)
2629 {
2630     register I32 todo;
2631     register const char *frombase = from;
2632
2633     if (len == 1) {
2634         register const char c = *from;
2635         while (count-- > 0)
2636             *to++ = c;
2637         return;
2638     }
2639     while (count-- > 0) {
2640         for (todo = len; todo > 0; todo--) {
2641             *to++ = *from++;
2642         }
2643         from = frombase;
2644     }
2645 }
2646
2647 #ifndef HAS_RENAME
2648 I32
2649 Perl_same_dirent(pTHX_ char *a, char *b)
2650 {
2651     char *fa = strrchr(a,'/');
2652     char *fb = strrchr(b,'/');
2653     Stat_t tmpstatbuf1;
2654     Stat_t tmpstatbuf2;
2655     SV *tmpsv = sv_newmortal();
2656
2657     if (fa)
2658         fa++;
2659     else
2660         fa = a;
2661     if (fb)
2662         fb++;
2663     else
2664         fb = b;
2665     if (strNE(a,b))
2666         return FALSE;
2667     if (fa == a)
2668         sv_setpv(tmpsv, ".");
2669     else
2670         sv_setpvn(tmpsv, a, fa - a);
2671     if (PerlLIO_stat(SvPVX(tmpsv), &tmpstatbuf1) < 0)
2672         return FALSE;
2673     if (fb == b)
2674         sv_setpv(tmpsv, ".");
2675     else
2676         sv_setpvn(tmpsv, b, fb - b);
2677     if (PerlLIO_stat(SvPVX(tmpsv), &tmpstatbuf2) < 0)
2678         return FALSE;
2679     return tmpstatbuf1.st_dev == tmpstatbuf2.st_dev &&
2680            tmpstatbuf1.st_ino == tmpstatbuf2.st_ino;
2681 }
2682 #endif /* !HAS_RENAME */
2683
2684 char*
2685 Perl_find_script(pTHX_ char *scriptname, bool dosearch, char **search_ext, I32 flags)
2686 {
2687     char *xfound = Nullch;
2688     char *xfailed = Nullch;
2689     char tmpbuf[MAXPATHLEN];
2690     register char *s;
2691     I32 len = 0;
2692     int retval;
2693 #if defined(DOSISH) && !defined(OS2) && !defined(atarist)
2694 #  define SEARCH_EXTS ".bat", ".cmd", NULL
2695 #  define MAX_EXT_LEN 4
2696 #endif
2697 #ifdef OS2
2698 #  define SEARCH_EXTS ".cmd", ".btm", ".bat", ".pl", NULL
2699 #  define MAX_EXT_LEN 4
2700 #endif
2701 #ifdef VMS
2702 #  define SEARCH_EXTS ".pl", ".com", NULL
2703 #  define MAX_EXT_LEN 4
2704 #endif
2705     /* additional extensions to try in each dir if scriptname not found */
2706 #ifdef SEARCH_EXTS
2707     char *exts[] = { SEARCH_EXTS };
2708     char **ext = search_ext ? search_ext : exts;
2709     int extidx = 0, i = 0;
2710     char *curext = Nullch;
2711 #else
2712 #  define MAX_EXT_LEN 0
2713 #endif
2714
2715     /*
2716      * If dosearch is true and if scriptname does not contain path
2717      * delimiters, search the PATH for scriptname.
2718      *
2719      * If SEARCH_EXTS is also defined, will look for each
2720      * scriptname{SEARCH_EXTS} whenever scriptname is not found
2721      * while searching the PATH.
2722      *
2723      * Assuming SEARCH_EXTS is C<".foo",".bar",NULL>, PATH search
2724      * proceeds as follows:
2725      *   If DOSISH or VMSISH:
2726      *     + look for ./scriptname{,.foo,.bar}
2727      *     + search the PATH for scriptname{,.foo,.bar}
2728      *
2729      *   If !DOSISH:
2730      *     + look *only* in the PATH for scriptname{,.foo,.bar} (note
2731      *       this will not look in '.' if it's not in the PATH)
2732      */
2733     tmpbuf[0] = '\0';
2734
2735 #ifdef VMS
2736 #  ifdef ALWAYS_DEFTYPES
2737     len = strlen(scriptname);
2738     if (!(len == 1 && *scriptname == '-') && scriptname[len-1] != ':') {
2739         int hasdir, idx = 0, deftypes = 1;
2740         bool seen_dot = 1;
2741
2742         hasdir = !dosearch || (strpbrk(scriptname,":[</") != Nullch) ;
2743 #  else
2744     if (dosearch) {
2745         int hasdir, idx = 0, deftypes = 1;
2746         bool seen_dot = 1;
2747
2748         hasdir = (strpbrk(scriptname,":[</") != Nullch) ;
2749 #  endif
2750         /* The first time through, just add SEARCH_EXTS to whatever we
2751          * already have, so we can check for default file types. */
2752         while (deftypes ||
2753                (!hasdir && my_trnlnm("DCL$PATH",tmpbuf,idx++)) )
2754         {
2755             if (deftypes) {
2756                 deftypes = 0;
2757                 *tmpbuf = '\0';
2758             }
2759             if ((strlen(tmpbuf) + strlen(scriptname)
2760                  + MAX_EXT_LEN) >= sizeof tmpbuf)
2761                 continue;       /* don't search dir with too-long name */
2762             strcat(tmpbuf, scriptname);
2763 #else  /* !VMS */
2764
2765 #ifdef DOSISH
2766     if (strEQ(scriptname, "-"))
2767         dosearch = 0;
2768     if (dosearch) {             /* Look in '.' first. */
2769         char *cur = scriptname;
2770 #ifdef SEARCH_EXTS
2771         if ((curext = strrchr(scriptname,'.'))) /* possible current ext */
2772             while (ext[i])
2773                 if (strEQ(ext[i++],curext)) {
2774                     extidx = -1;                /* already has an ext */
2775                     break;
2776                 }
2777         do {
2778 #endif
2779             DEBUG_p(PerlIO_printf(Perl_debug_log,
2780                                   "Looking for %s\n",cur));
2781             if (PerlLIO_stat(cur,&PL_statbuf) >= 0
2782                 && !S_ISDIR(PL_statbuf.st_mode)) {
2783                 dosearch = 0;
2784                 scriptname = cur;
2785 #ifdef SEARCH_EXTS
2786                 break;
2787 #endif
2788             }
2789 #ifdef SEARCH_EXTS
2790             if (cur == scriptname) {
2791                 len = strlen(scriptname);
2792                 if (len+MAX_EXT_LEN+1 >= sizeof(tmpbuf))
2793                     break;
2794                 cur = strcpy(tmpbuf, scriptname);
2795             }
2796         } while (extidx >= 0 && ext[extidx]     /* try an extension? */
2797                  && strcpy(tmpbuf+len, ext[extidx++]));
2798 #endif
2799     }
2800 #endif
2801
2802 #ifdef MACOS_TRADITIONAL
2803     if (dosearch && !strchr(scriptname, ':') &&
2804         (s = PerlEnv_getenv("Commands")))
2805 #else
2806     if (dosearch && !strchr(scriptname, '/')
2807 #ifdef DOSISH
2808                  && !strchr(scriptname, '\\')
2809 #endif
2810                  && (s = PerlEnv_getenv("PATH")))
2811 #endif
2812     {
2813         bool seen_dot = 0;
2814         
2815         PL_bufend = s + strlen(s);
2816         while (s < PL_bufend) {
2817 #ifdef MACOS_TRADITIONAL
2818             s = delimcpy(tmpbuf, tmpbuf + sizeof tmpbuf, s, PL_bufend,
2819                         ',',
2820                         &len);
2821 #else
2822 #if defined(atarist) || defined(DOSISH)
2823             for (len = 0; *s
2824 #  ifdef atarist
2825                     && *s != ','
2826 #  endif
2827                     && *s != ';'; len++, s++) {
2828                 if (len < sizeof tmpbuf)
2829                     tmpbuf[len] = *s;
2830             }
2831             if (len < sizeof tmpbuf)
2832                 tmpbuf[len] = '\0';
2833 #else  /* ! (atarist || DOSISH) */
2834             s = delimcpy(tmpbuf, tmpbuf + sizeof tmpbuf, s, PL_bufend,
2835                         ':',
2836                         &len);
2837 #endif /* ! (atarist || DOSISH) */
2838 #endif /* MACOS_TRADITIONAL */
2839             if (s < PL_bufend)
2840                 s++;
2841             if (len + 1 + strlen(scriptname) + MAX_EXT_LEN >= sizeof tmpbuf)
2842                 continue;       /* don't search dir with too-long name */
2843 #ifdef MACOS_TRADITIONAL
2844             if (len && tmpbuf[len - 1] != ':')
2845                 tmpbuf[len++] = ':';
2846 #else
2847             if (len
2848 #if defined(atarist) || defined(__MINT__) || defined(DOSISH)
2849                 && tmpbuf[len - 1] != '/'
2850                 && tmpbuf[len - 1] != '\\'
2851 #endif
2852                )
2853                 tmpbuf[len++] = '/';
2854             if (len == 2 && tmpbuf[0] == '.')
2855                 seen_dot = 1;
2856 #endif
2857             (void)strcpy(tmpbuf + len, scriptname);
2858 #endif  /* !VMS */
2859
2860 #ifdef SEARCH_EXTS
2861             len = strlen(tmpbuf);
2862             if (extidx > 0)     /* reset after previous loop */
2863                 extidx = 0;
2864             do {
2865 #endif
2866                 DEBUG_p(PerlIO_printf(Perl_debug_log, "Looking for %s\n",tmpbuf));
2867                 retval = PerlLIO_stat(tmpbuf,&PL_statbuf);
2868                 if (S_ISDIR(PL_statbuf.st_mode)) {
2869                     retval = -1;
2870                 }
2871 #ifdef SEARCH_EXTS
2872             } while (  retval < 0               /* not there */
2873                     && extidx>=0 && ext[extidx] /* try an extension? */
2874                     && strcpy(tmpbuf+len, ext[extidx++])
2875                 );
2876 #endif
2877             if (retval < 0)
2878                 continue;
2879             if (S_ISREG(PL_statbuf.st_mode)
2880                 && cando(S_IRUSR,TRUE,&PL_statbuf)
2881 #if !defined(DOSISH) && !defined(MACOS_TRADITIONAL)
2882                 && cando(S_IXUSR,TRUE,&PL_statbuf)
2883 #endif
2884                 )
2885             {
2886                 xfound = tmpbuf;              /* bingo! */
2887                 break;
2888             }
2889             if (!xfailed)
2890                 xfailed = savepv(tmpbuf);
2891         }
2892 #ifndef DOSISH
2893         if (!xfound && !seen_dot && !xfailed &&
2894             (PerlLIO_stat(scriptname,&PL_statbuf) < 0
2895              || S_ISDIR(PL_statbuf.st_mode)))
2896 #endif
2897             seen_dot = 1;                       /* Disable message. */
2898         if (!xfound) {
2899             if (flags & 1) {                    /* do or die? */
2900                 Perl_croak(aTHX_ "Can't %s %s%s%s",
2901                       (xfailed ? "execute" : "find"),
2902                       (xfailed ? xfailed : scriptname),
2903                       (xfailed ? "" : " on PATH"),
2904                       (xfailed || seen_dot) ? "" : ", '.' not in PATH");
2905             }
2906             scriptname = Nullch;
2907         }
2908         if (xfailed)
2909             Safefree(xfailed);
2910         scriptname = xfound;
2911     }
2912     return (scriptname ? savepv(scriptname) : Nullch);
2913 }
2914
2915 #ifndef PERL_GET_CONTEXT_DEFINED
2916
2917 void *
2918 Perl_get_context(void)
2919 {
2920 #if defined(USE_5005THREADS) || defined(USE_ITHREADS)
2921 #  ifdef OLD_PTHREADS_API
2922     pthread_addr_t t;
2923     if (pthread_getspecific(PL_thr_key, &t))
2924         Perl_croak_nocontext("panic: pthread_getspecific");
2925     return (void*)t;
2926 #  else
2927 #    ifdef I_MACH_CTHREADS
2928     return (void*)cthread_data(cthread_self());
2929 #    else
2930     return (void*)PTHREAD_GETSPECIFIC(PL_thr_key);
2931 #    endif
2932 #  endif
2933 #else
2934     return (void*)NULL;
2935 #endif
2936 }
2937
2938 void
2939 Perl_set_context(void *t)
2940 {
2941 #if defined(USE_5005THREADS) || defined(USE_ITHREADS)
2942 #  ifdef I_MACH_CTHREADS
2943     cthread_set_data(cthread_self(), t);
2944 #  else
2945     if (pthread_setspecific(PL_thr_key, t))
2946         Perl_croak_nocontext("panic: pthread_setspecific");
2947 #  endif
2948 #endif
2949 }
2950
2951 #endif /* !PERL_GET_CONTEXT_DEFINED */
2952
2953 #ifdef USE_5005THREADS
2954
2955 #ifdef FAKE_THREADS
2956 /* Very simplistic scheduler for now */
2957 void
2958 schedule(void)
2959 {
2960     thr = thr->i.next_run;
2961 }
2962
2963 void
2964 Perl_cond_init(pTHX_ perl_cond *cp)
2965 {
2966     *cp = 0;
2967 }
2968
2969 void
2970 Perl_cond_signal(pTHX_ perl_cond *cp)
2971 {
2972     perl_os_thread t;
2973     perl_cond cond = *cp;
2974
2975     if (!cond)
2976         return;
2977     t = cond->thread;
2978     /* Insert t in the runnable queue just ahead of us */
2979     t->i.next_run = thr->i.next_run;
2980     thr->i.next_run->i.prev_run = t;
2981     t->i.prev_run = thr;
2982     thr->i.next_run = t;
2983     thr->i.wait_queue = 0;
2984     /* Remove from the wait queue */
2985     *cp = cond->next;
2986     Safefree(cond);
2987 }
2988
2989 void
2990 Perl_cond_broadcast(pTHX_ perl_cond *cp)
2991 {
2992     perl_os_thread t;
2993     perl_cond cond, cond_next;
2994
2995     for (cond = *cp; cond; cond = cond_next) {
2996         t = cond->thread;
2997         /* Insert t in the runnable queue just ahead of us */
2998         t->i.next_run = thr->i.next_run;
2999         thr->i.next_run->i.prev_run = t;
3000         t->i.prev_run = thr;
3001         thr->i.next_run = t;
3002         thr->i.wait_queue = 0;
3003         /* Remove from the wait queue */
3004         cond_next = cond->next;
3005         Safefree(cond);
3006     }
3007     *cp = 0;
3008 }
3009
3010 void
3011 Perl_cond_wait(pTHX_ perl_cond *cp)
3012 {
3013     perl_cond cond;
3014
3015     if (thr->i.next_run == thr)
3016         Perl_croak(aTHX_ "panic: perl_cond_wait called by last runnable thread");
3017
3018     New(666, cond, 1, struct perl_wait_queue);
3019     cond->thread = thr;
3020     cond->next = *cp;
3021     *cp = cond;
3022     thr->i.wait_queue = cond;
3023     /* Remove ourselves from runnable queue */
3024     thr->i.next_run->i.prev_run = thr->i.prev_run;
3025     thr->i.prev_run->i.next_run = thr->i.next_run;
3026 }
3027 #endif /* FAKE_THREADS */
3028
3029 MAGIC *
3030 Perl_condpair_magic(pTHX_ SV *sv)
3031 {
3032     MAGIC *mg;
3033
3034     (void)SvUPGRADE(sv, SVt_PVMG);
3035     mg = mg_find(sv, PERL_MAGIC_mutex);
3036     if (!mg) {
3037         condpair_t *cp;
3038
3039         New(53, cp, 1, condpair_t);
3040         MUTEX_INIT(&cp->mutex);
3041         COND_INIT(&cp->owner_cond);
3042         COND_INIT(&cp->cond);
3043         cp->owner = 0;
3044         LOCK_CRED_MUTEX;                /* XXX need separate mutex? */
3045         mg = mg_find(sv, PERL_MAGIC_mutex);
3046         if (mg) {
3047             /* someone else beat us to initialising it */
3048             UNLOCK_CRED_MUTEX;          /* XXX need separate mutex? */
3049             MUTEX_DESTROY(&cp->mutex);
3050             COND_DESTROY(&cp->owner_cond);
3051             COND_DESTROY(&cp->cond);
3052             Safefree(cp);
3053         }
3054         else {
3055             sv_magic(sv, Nullsv, PERL_MAGIC_mutex, 0, 0);
3056             mg = SvMAGIC(sv);
3057             mg->mg_ptr = (char *)cp;
3058             mg->mg_len = sizeof(cp);
3059             UNLOCK_CRED_MUTEX;          /* XXX need separate mutex? */
3060             DEBUG_S(WITH_THR(PerlIO_printf(Perl_debug_log,
3061                                            "%p: condpair_magic %p\n", thr, sv)));
3062         }
3063     }
3064     return mg;
3065 }
3066
3067 SV *
3068 Perl_sv_lock(pTHX_ SV *osv)
3069 {
3070     MAGIC *mg;
3071     SV *sv = osv;
3072
3073     LOCK_SV_LOCK_MUTEX;
3074     if (SvROK(sv)) {
3075         sv = SvRV(sv);
3076     }
3077
3078     mg = condpair_magic(sv);
3079     MUTEX_LOCK(MgMUTEXP(mg));
3080     if (MgOWNER(mg) == thr)
3081         MUTEX_UNLOCK(MgMUTEXP(mg));
3082     else {
3083         while (MgOWNER(mg))
3084             COND_WAIT(MgOWNERCONDP(mg), MgMUTEXP(mg));
3085         MgOWNER(mg) = thr;
3086         DEBUG_S(PerlIO_printf(Perl_debug_log,
3087                               "0x%"UVxf": Perl_lock lock 0x%"UVxf"\n",
3088                               PTR2UV(thr), PTR2UV(sv)));
3089         MUTEX_UNLOCK(MgMUTEXP(mg));
3090         SAVEDESTRUCTOR_X(Perl_unlock_condpair, sv);
3091     }
3092     UNLOCK_SV_LOCK_MUTEX;
3093     return sv;
3094 }
3095
3096 /*
3097  * Make a new perl thread structure using t as a prototype. Some of the
3098  * fields for the new thread are copied from the prototype thread, t,
3099  * so t should not be running in perl at the time this function is
3100  * called. The use by ext/Thread/Thread.xs in core perl (where t is the
3101  * thread calling new_struct_thread) clearly satisfies this constraint.
3102  */
3103 struct perl_thread *
3104 Perl_new_struct_thread(pTHX_ struct perl_thread *t)
3105 {
3106 #if !defined(PERL_IMPLICIT_CONTEXT)
3107     struct perl_thread *thr;
3108 #endif
3109     SV *sv;
3110     SV **svp;
3111     I32 i;
3112
3113     sv = newSVpvn("", 0);
3114     SvGROW(sv, sizeof(struct perl_thread) + 1);
3115     SvCUR_set(sv, sizeof(struct perl_thread));
3116     thr = (Thread) SvPVX(sv);
3117 #ifdef DEBUGGING
3118     memset(thr, 0xab, sizeof(struct perl_thread));
3119     PL_markstack = 0;
3120     PL_scopestack = 0;
3121     PL_savestack = 0;
3122     PL_retstack = 0;
3123     PL_dirty = 0;
3124     PL_localizing = 0;
3125     Zero(&PL_hv_fetch_ent_mh, 1, HE);
3126     PL_efloatbuf = (char*)NULL;
3127     PL_efloatsize = 0;
3128 #else
3129     Zero(thr, 1, struct perl_thread);
3130 #endif
3131
3132     thr->oursv = sv;
3133     init_stacks();
3134
3135     PL_curcop = &PL_compiling;
3136     thr->interp = t->interp;
3137     thr->cvcache = newHV();
3138     thr->threadsv = newAV();
3139     thr->specific = newAV();
3140     thr->errsv = newSVpvn("", 0);
3141     thr->flags = THRf_R_JOINABLE;
3142     thr->thr_done = 0;
3143     MUTEX_INIT(&thr->mutex);
3144
3145     JMPENV_BOOTSTRAP;
3146
3147     PL_in_eval = EVAL_NULL;     /* ~(EVAL_INEVAL|EVAL_WARNONLY|EVAL_KEEPERR|EVAL_INREQUIRE) */
3148     PL_restartop = 0;
3149
3150     PL_statname = NEWSV(66,0);
3151     PL_errors = newSVpvn("", 0);
3152     PL_maxscream = -1;
3153     PL_regcompp = MEMBER_TO_FPTR(Perl_pregcomp);
3154     PL_regexecp = MEMBER_TO_FPTR(Perl_regexec_flags);
3155     PL_regint_start = MEMBER_TO_FPTR(Perl_re_intuit_start);
3156     PL_regint_string = MEMBER_TO_FPTR(Perl_re_intuit_string);
3157     PL_regfree = MEMBER_TO_FPTR(Perl_pregfree);
3158     PL_regindent = 0;
3159     PL_reginterp_cnt = 0;
3160     PL_lastscream = Nullsv;
3161     PL_screamfirst = 0;
3162     PL_screamnext = 0;
3163     PL_reg_start_tmp = 0;
3164     PL_reg_start_tmpl = 0;
3165     PL_reg_poscache = Nullch;
3166
3167     PL_peepp = MEMBER_TO_FPTR(Perl_peep);
3168
3169     /* parent thread's data needs to be locked while we make copy */
3170     MUTEX_LOCK(&t->mutex);
3171
3172 #ifdef PERL_FLEXIBLE_EXCEPTIONS
3173     PL_protect = t->Tprotect;
3174 #endif
3175
3176     PL_curcop = t->Tcurcop;       /* XXX As good a guess as any? */
3177     PL_defstash = t->Tdefstash;   /* XXX maybe these should */
3178     PL_curstash = t->Tcurstash;   /* always be set to main? */
3179
3180     PL_tainted = t->Ttainted;
3181     PL_curpm = t->Tcurpm;         /* XXX No PMOP ref count */
3182     PL_rs = newSVsv(t->Trs);
3183     PL_last_in_gv = Nullgv;
3184     PL_ofs_sv = t->Tofs_sv ? SvREFCNT_inc(PL_ofs_sv) : Nullsv;
3185     PL_defoutgv = (GV*)SvREFCNT_inc(t->Tdefoutgv);
3186     PL_chopset = t->Tchopset;
3187     PL_bodytarget = newSVsv(t->Tbodytarget);
3188     PL_toptarget = newSVsv(t->Ttoptarget);
3189     if (t->Tformtarget == t->Ttoptarget)
3190         PL_formtarget = PL_toptarget;
3191     else
3192         PL_formtarget = PL_bodytarget;
3193
3194     /* Initialise all per-thread SVs that the template thread used */
3195     svp = AvARRAY(t->threadsv);
3196     for (i = 0; i <= AvFILLp(t->threadsv); i++, svp++) {
3197         if (*svp && *svp != &PL_sv_undef) {
3198             SV *sv = newSVsv(*svp);
3199             av_store(thr->threadsv, i, sv);
3200             sv_magic(sv, 0, PERL_MAGIC_sv, &PL_threadsv_names[i], 1);
3201             DEBUG_S(PerlIO_printf(Perl_debug_log,
3202                 "new_struct_thread: copied threadsv %"IVdf" %p->%p\n",
3203                                   (IV)i, t, thr));
3204         }
3205     }
3206     thr->threadsvp = AvARRAY(thr->threadsv);
3207
3208     MUTEX_LOCK(&PL_threads_mutex);
3209     PL_nthreads++;
3210     thr->tid = ++PL_threadnum;
3211     thr->next = t->next;
3212     thr->prev = t;
3213     t->next = thr;
3214     thr->next->prev = thr;
3215     MUTEX_UNLOCK(&PL_threads_mutex);
3216
3217     /* done copying parent's state */
3218     MUTEX_UNLOCK(&t->mutex);
3219
3220 #ifdef HAVE_THREAD_INTERN
3221     Perl_init_thread_intern(thr);
3222 #endif /* HAVE_THREAD_INTERN */
3223     return thr;
3224 }
3225 #endif /* USE_5005THREADS */
3226
3227 #ifdef PERL_GLOBAL_STRUCT
3228 struct perl_vars *
3229 Perl_GetVars(pTHX)
3230 {
3231  return &PL_Vars;
3232 }
3233 #endif
3234
3235 char **
3236 Perl_get_op_names(pTHX)
3237 {
3238  return PL_op_name;
3239 }
3240
3241 char **
3242 Perl_get_op_descs(pTHX)
3243 {
3244  return PL_op_desc;
3245 }
3246
3247 char *
3248 Perl_get_no_modify(pTHX)
3249 {
3250  return (char*)PL_no_modify;
3251 }
3252
3253 U32 *
3254 Perl_get_opargs(pTHX)
3255 {
3256  return PL_opargs;
3257 }
3258
3259 PPADDR_t*
3260 Perl_get_ppaddr(pTHX)
3261 {
3262  return (PPADDR_t*)PL_ppaddr;
3263 }
3264
3265 #ifndef HAS_GETENV_LEN
3266 char *
3267 Perl_getenv_len(pTHX_ const char *env_elem, unsigned long *len)
3268 {
3269     char *env_trans = PerlEnv_getenv(env_elem);
3270     if (env_trans)
3271         *len = strlen(env_trans);
3272     return env_trans;
3273 }
3274 #endif
3275
3276
3277 MGVTBL*
3278 Perl_get_vtbl(pTHX_ int vtbl_id)
3279 {
3280     MGVTBL* result = Null(MGVTBL*);
3281
3282     switch(vtbl_id) {
3283     case want_vtbl_sv:
3284         result = &PL_vtbl_sv;
3285         break;
3286     case want_vtbl_env:
3287         result = &PL_vtbl_env;
3288         break;
3289     case want_vtbl_envelem:
3290         result = &PL_vtbl_envelem;
3291         break;
3292     case want_vtbl_sig:
3293         result = &PL_vtbl_sig;
3294         break;
3295     case want_vtbl_sigelem:
3296         result = &PL_vtbl_sigelem;
3297         break;
3298     case want_vtbl_pack:
3299         result = &PL_vtbl_pack;
3300         break;
3301     case want_vtbl_packelem:
3302         result = &PL_vtbl_packelem;
3303         break;
3304     case want_vtbl_dbline:
3305         result = &PL_vtbl_dbline;
3306         break;
3307     case want_vtbl_isa:
3308         result = &PL_vtbl_isa;
3309         break;
3310     case want_vtbl_isaelem:
3311         result = &PL_vtbl_isaelem;
3312         break;
3313     case want_vtbl_arylen:
3314         result = &PL_vtbl_arylen;
3315         break;
3316     case want_vtbl_glob:
3317         result = &PL_vtbl_glob;
3318         break;
3319     case want_vtbl_mglob:
3320         result = &PL_vtbl_mglob;
3321         break;
3322     case want_vtbl_nkeys:
3323         result = &PL_vtbl_nkeys;
3324         break;
3325     case want_vtbl_taint:
3326         result = &PL_vtbl_taint;
3327         break;
3328     case want_vtbl_substr:
3329         result = &PL_vtbl_substr;
3330         break;
3331     case want_vtbl_vec:
3332         result = &PL_vtbl_vec;
3333         break;
3334     case want_vtbl_pos:
3335         result = &PL_vtbl_pos;
3336         break;
3337     case want_vtbl_bm:
3338         result = &PL_vtbl_bm;
3339         break;
3340     case want_vtbl_fm:
3341         result = &PL_vtbl_fm;
3342         break;
3343     case want_vtbl_uvar:
3344         result = &PL_vtbl_uvar;
3345         break;
3346 #ifdef USE_5005THREADS
3347     case want_vtbl_mutex:
3348         result = &PL_vtbl_mutex;
3349         break;
3350 #endif
3351     case want_vtbl_defelem:
3352         result = &PL_vtbl_defelem;
3353         break;
3354     case want_vtbl_regexp:
3355         result = &PL_vtbl_regexp;
3356         break;
3357     case want_vtbl_regdata:
3358         result = &PL_vtbl_regdata;
3359         break;
3360     case want_vtbl_regdatum:
3361         result = &PL_vtbl_regdatum;
3362         break;
3363 #ifdef USE_LOCALE_COLLATE
3364     case want_vtbl_collxfrm:
3365         result = &PL_vtbl_collxfrm;
3366         break;
3367 #endif
3368     case want_vtbl_amagic:
3369         result = &PL_vtbl_amagic;
3370         break;
3371     case want_vtbl_amagicelem:
3372         result = &PL_vtbl_amagicelem;
3373         break;
3374     case want_vtbl_backref:
3375         result = &PL_vtbl_backref;
3376         break;
3377     }
3378     return result;
3379 }
3380
3381 I32
3382 Perl_my_fflush_all(pTHX)
3383 {
3384 #if defined(FFLUSH_NULL)
3385     return PerlIO_flush(NULL);
3386 #else
3387 # if defined(HAS__FWALK)
3388     /* undocumented, unprototyped, but very useful BSDism */
3389     extern void _fwalk(int (*)(FILE *));
3390     _fwalk(&fflush);
3391     return 0;
3392 # else
3393 #  if defined(FFLUSH_ALL) && defined(HAS_STDIO_STREAM_ARRAY)
3394     long open_max = -1;
3395 #   ifdef PERL_FFLUSH_ALL_FOPEN_MAX
3396     open_max = PERL_FFLUSH_ALL_FOPEN_MAX;
3397 #   else
3398 #    if defined(HAS_SYSCONF) && defined(_SC_OPEN_MAX)
3399     open_max = sysconf(_SC_OPEN_MAX);
3400 #     else
3401 #      ifdef FOPEN_MAX
3402     open_max = FOPEN_MAX;
3403 #      else
3404 #       ifdef OPEN_MAX
3405     open_max = OPEN_MAX;
3406 #       else
3407 #        ifdef _NFILE
3408     open_max = _NFILE;
3409 #        endif
3410 #       endif
3411 #      endif
3412 #     endif
3413 #    endif
3414     if (open_max > 0) {
3415       long i;
3416       for (i = 0; i < open_max; i++)
3417             if (STDIO_STREAM_ARRAY[i]._file >= 0 &&
3418                 STDIO_STREAM_ARRAY[i]._file < open_max &&
3419                 STDIO_STREAM_ARRAY[i]._flag)
3420                 PerlIO_flush(&STDIO_STREAM_ARRAY[i]);
3421       return 0;
3422     }
3423 #  endif
3424     SETERRNO(EBADF,RMS$_IFI);
3425     return EOF;
3426 # endif
3427 #endif
3428 }
3429
3430 void
3431 Perl_report_evil_fh(pTHX_ GV *gv, IO *io, I32 op)
3432 {
3433     char *vile;
3434     I32   warn_type;
3435     char *func =
3436         op == OP_READLINE   ? "readline"  :     /* "<HANDLE>" not nice */
3437         op == OP_LEAVEWRITE ? "write" :         /* "write exit" not nice */
3438         PL_op_desc[op];
3439     char *pars = OP_IS_FILETEST(op) ? "" : "()";
3440     char *type = OP_IS_SOCKET(op) ||
3441                  (gv && io && IoTYPE(io) == IoTYPE_SOCKET) ?
3442                      "socket" : "filehandle";
3443     char *name = NULL;
3444
3445     if (gv && io && IoTYPE(io) == IoTYPE_CLOSED) {
3446         vile = "closed";
3447         warn_type = WARN_CLOSED;
3448     }
3449     else {
3450         vile = "unopened";
3451         warn_type = WARN_UNOPENED;
3452     }
3453
3454     if (gv && isGV(gv)) {
3455         SV *sv = sv_newmortal();
3456         gv_efullname4(sv, gv, Nullch, FALSE);
3457         if (SvOK(sv))
3458             name = SvPVX(sv);
3459     }
3460
3461     if (op == OP_phoney_OUTPUT_ONLY || op == OP_phoney_INPUT_ONLY) {
3462         if (name && *name)
3463             Perl_warner(aTHX_ packWARN(WARN_IO), "Filehandle %s opened only for %sput",
3464                         name,
3465                         (op == OP_phoney_INPUT_ONLY ? "in" : "out"));
3466         else
3467             Perl_warner(aTHX_ packWARN(WARN_IO), "Filehandle opened only for %sput",
3468                         (op == OP_phoney_INPUT_ONLY ? "in" : "out"));
3469     } else if (name && *name) {
3470         Perl_warner(aTHX_ packWARN(warn_type),
3471                     "%s%s on %s %s %s", func, pars, vile, type, name);
3472         if (io && IoDIRP(io) && !(IoFLAGS(io) & IOf_FAKE_DIRP))
3473             Perl_warner(aTHX_ packWARN(warn_type),
3474                         "\t(Are you trying to call %s%s on dirhandle %s?)\n",
3475                         func, pars, name);
3476     }
3477     else {
3478         Perl_warner(aTHX_ packWARN(warn_type),
3479                     "%s%s on %s %s", func, pars, vile, type);
3480         if (gv && io && IoDIRP(io) && !(IoFLAGS(io) & IOf_FAKE_DIRP))
3481             Perl_warner(aTHX_ packWARN(warn_type),
3482                         "\t(Are you trying to call %s%s on dirhandle?)\n",
3483                         func, pars);
3484     }
3485 }
3486
3487 #ifdef EBCDIC
3488 /* in ASCII order, not that it matters */
3489 static const char controllablechars[] = "?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^_";
3490
3491 int
3492 Perl_ebcdic_control(pTHX_ int ch)
3493 {
3494         if (ch > 'a') {
3495                 char *ctlp;
3496
3497                if (islower(ch))
3498                       ch = toupper(ch);
3499
3500                if ((ctlp = strchr(controllablechars, ch)) == 0) {
3501                       Perl_die(aTHX_ "unrecognised control character '%c'\n", ch);
3502                }
3503
3504                 if (ctlp == controllablechars)
3505                        return('\177'); /* DEL */
3506                 else
3507                        return((unsigned char)(ctlp - controllablechars - 1));
3508         } else { /* Want uncontrol */
3509                 if (ch == '\177' || ch == -1)
3510                         return('?');
3511                 else if (ch == '\157')
3512                         return('\177');
3513                 else if (ch == '\174')
3514                         return('\000');
3515                 else if (ch == '^')    /* '\137' in 1047, '\260' in 819 */
3516                         return('\036');
3517                 else if (ch == '\155')
3518                         return('\037');
3519                 else if (0 < ch && ch < (sizeof(controllablechars) - 1))
3520                         return(controllablechars[ch+1]);
3521                 else
3522                         Perl_die(aTHX_ "invalid control request: '\\%03o'\n", ch & 0xFF);
3523         }
3524 }
3525 #endif
3526
3527 /* To workaround core dumps from the uninitialised tm_zone we get the
3528  * system to give us a reasonable struct to copy.  This fix means that
3529  * strftime uses the tm_zone and tm_gmtoff values returned by
3530  * localtime(time()). That should give the desired result most of the
3531  * time. But probably not always!
3532  *
3533  * This does not address tzname aspects of NETaa14816.
3534  *
3535  */
3536
3537 #ifdef HAS_GNULIBC
3538 # ifndef STRUCT_TM_HASZONE
3539 #    define STRUCT_TM_HASZONE
3540 # endif
3541 #endif
3542
3543 #ifdef STRUCT_TM_HASZONE /* Backward compat */
3544 # ifndef HAS_TM_TM_ZONE
3545 #    define HAS_TM_TM_ZONE
3546 # endif
3547 #endif
3548
3549 void
3550 Perl_init_tm(pTHX_ struct tm *ptm)      /* see mktime, strftime and asctime */
3551 {
3552 #ifdef HAS_TM_TM_ZONE
3553     Time_t now;
3554     (void)time(&now);
3555     Copy(localtime(&now), ptm, 1, struct tm);
3556 #endif
3557 }
3558
3559 /*
3560  * mini_mktime - normalise struct tm values without the localtime()
3561  * semantics (and overhead) of mktime().
3562  */
3563 void
3564 Perl_mini_mktime(pTHX_ struct tm *ptm)
3565 {
3566     int yearday;
3567     int secs;
3568     int month, mday, year, jday;
3569     int odd_cent, odd_year;
3570
3571 #define DAYS_PER_YEAR   365
3572 #define DAYS_PER_QYEAR  (4*DAYS_PER_YEAR+1)
3573 #define DAYS_PER_CENT   (25*DAYS_PER_QYEAR-1)
3574 #define DAYS_PER_QCENT  (4*DAYS_PER_CENT+1)
3575 #define SECS_PER_HOUR   (60*60)
3576 #define SECS_PER_DAY    (24*SECS_PER_HOUR)
3577 /* parentheses deliberately absent on these two, otherwise they don't work */
3578 #define MONTH_TO_DAYS   153/5
3579 #define DAYS_TO_MONTH   5/153
3580 /* offset to bias by March (month 4) 1st between month/mday & year finding */
3581 #define YEAR_ADJUST     (4*MONTH_TO_DAYS+1)
3582 /* as used here, the algorithm leaves Sunday as day 1 unless we adjust it */
3583 #define WEEKDAY_BIAS    6       /* (1+6)%7 makes Sunday 0 again */
3584
3585 /*
3586  * Year/day algorithm notes:
3587  *
3588  * With a suitable offset for numeric value of the month, one can find
3589  * an offset into the year by considering months to have 30.6 (153/5) days,
3590  * using integer arithmetic (i.e., with truncation).  To avoid too much
3591  * messing about with leap days, we consider January and February to be
3592  * the 13th and 14th month of the previous year.  After that transformation,
3593  * we need the month index we use to be high by 1 from 'normal human' usage,
3594  * so the month index values we use run from 4 through 15.
3595  *
3596  * Given that, and the rules for the Gregorian calendar (leap years are those
3597  * divisible by 4 unless also divisible by 100, when they must be divisible
3598  * by 400 instead), we can simply calculate the number of days since some
3599  * arbitrary 'beginning of time' by futzing with the (adjusted) year number,
3600  * the days we derive from our month index, and adding in the day of the
3601  * month.  The value used here is not adjusted for the actual origin which
3602  * it normally would use (1 January A.D. 1), since we're not exposing it.
3603  * We're only building the value so we can turn around and get the
3604  * normalised values for the year, month, day-of-month, and day-of-year.
3605  *
3606  * For going backward, we need to bias the value we're using so that we find
3607  * the right year value.  (Basically, we don't want the contribution of
3608  * March 1st to the number to apply while deriving the year).  Having done
3609  * that, we 'count up' the contribution to the year number by accounting for
3610  * full quadracenturies (400-year periods) with their extra leap days, plus
3611  * the contribution from full centuries (to avoid counting in the lost leap
3612  * days), plus the contribution from full quad-years (to count in the normal
3613  * leap days), plus the leftover contribution from any non-leap years.
3614  * At this point, if we were working with an actual leap day, we'll have 0
3615  * days left over.  This is also true for March 1st, however.  So, we have
3616  * to special-case that result, and (earlier) keep track of the 'odd'
3617  * century and year contributions.  If we got 4 extra centuries in a qcent,
3618  * or 4 extra years in a qyear, then it's a leap day and we call it 29 Feb.
3619  * Otherwise, we add back in the earlier bias we removed (the 123 from
3620  * figuring in March 1st), find the month index (integer division by 30.6),
3621  * and the remainder is the day-of-month.  We then have to convert back to
3622  * 'real' months (including fixing January and February from being 14/15 in
3623  * the previous year to being in the proper year).  After that, to get
3624  * tm_yday, we work with the normalised year and get a new yearday value for
3625  * January 1st, which we subtract from the yearday value we had earlier,
3626  * representing the date we've re-built.  This is done from January 1
3627  * because tm_yday is 0-origin.
3628  *
3629  * Since POSIX time routines are only guaranteed to work for times since the
3630  * UNIX epoch (00:00:00 1 Jan 1970 UTC), the fact that this algorithm
3631  * applies Gregorian calendar rules even to dates before the 16th century
3632  * doesn't bother me.  Besides, you'd need cultural context for a given
3633  * date to know whether it was Julian or Gregorian calendar, and that's
3634  * outside the scope for this routine.  Since we convert back based on the
3635  * same rules we used to build the yearday, you'll only get strange results
3636  * for input which needed normalising, or for the 'odd' century years which
3637  * were leap years in the Julian calander but not in the Gregorian one.
3638  * I can live with that.
3639  *
3640  * This algorithm also fails to handle years before A.D. 1 gracefully, but
3641  * that's still outside the scope for POSIX time manipulation, so I don't
3642  * care.
3643  */
3644
3645     year = 1900 + ptm->tm_year;
3646     month = ptm->tm_mon;
3647     mday = ptm->tm_mday;
3648     /* allow given yday with no month & mday to dominate the result */
3649     if (ptm->tm_yday >= 0 && mday <= 0 && month <= 0) {
3650         month = 0;
3651         mday = 0;
3652         jday = 1 + ptm->tm_yday;
3653     }
3654     else {
3655         jday = 0;
3656     }
3657     if (month >= 2)
3658         month+=2;
3659     else
3660         month+=14, year--;
3661     yearday = DAYS_PER_YEAR * year + year/4 - year/100 + year/400;
3662     yearday += month*MONTH_TO_DAYS + mday + jday;
3663     /*
3664      * Note that we don't know when leap-seconds were or will be,
3665      * so we have to trust the user if we get something which looks
3666      * like a sensible leap-second.  Wild values for seconds will
3667      * be rationalised, however.
3668      */
3669     if ((unsigned) ptm->tm_sec <= 60) {
3670         secs = 0;
3671     }
3672     else {
3673         secs = ptm->tm_sec;
3674         ptm->tm_sec = 0;
3675     }
3676     secs += 60 * ptm->tm_min;
3677     secs += SECS_PER_HOUR * ptm->tm_hour;
3678     if (secs < 0) {
3679         if (secs-(secs/SECS_PER_DAY*SECS_PER_DAY) < 0) {
3680             /* got negative remainder, but need positive time */
3681             /* back off an extra day to compensate */
3682             yearday += (secs/SECS_PER_DAY)-1;
3683             secs -= SECS_PER_DAY * (secs/SECS_PER_DAY - 1);
3684         }
3685         else {
3686             yearday += (secs/SECS_PER_DAY);
3687             secs -= SECS_PER_DAY * (secs/SECS_PER_DAY);
3688         }
3689     }
3690     else if (secs >= SECS_PER_DAY) {
3691         yearday += (secs/SECS_PER_DAY);
3692         secs %= SECS_PER_DAY;
3693     }
3694     ptm->tm_hour = secs/SECS_PER_HOUR;
3695     secs %= SECS_PER_HOUR;
3696     ptm->tm_min = secs/60;
3697     secs %= 60;
3698     ptm->tm_sec += secs;
3699     /* done with time of day effects */
3700     /*
3701      * The algorithm for yearday has (so far) left it high by 428.
3702      * To avoid mistaking a legitimate Feb 29 as Mar 1, we need to
3703      * bias it by 123 while trying to figure out what year it
3704      * really represents.  Even with this tweak, the reverse
3705      * translation fails for years before A.D. 0001.
3706      * It would still fail for Feb 29, but we catch that one below.
3707      */
3708     jday = yearday;     /* save for later fixup vis-a-vis Jan 1 */
3709     yearday -= YEAR_ADJUST;
3710     year = (yearday / DAYS_PER_QCENT) * 400;
3711     yearday %= DAYS_PER_QCENT;
3712     odd_cent = yearday / DAYS_PER_CENT;
3713     year += odd_cent * 100;
3714     yearday %= DAYS_PER_CENT;
3715     year += (yearday / DAYS_PER_QYEAR) * 4;
3716     yearday %= DAYS_PER_QYEAR;
3717     odd_year = yearday / DAYS_PER_YEAR;
3718     year += odd_year;
3719     yearday %= DAYS_PER_YEAR;
3720     if (!yearday && (odd_cent==4 || odd_year==4)) { /* catch Feb 29 */
3721         month = 1;
3722         yearday = 29;
3723     }
3724     else {
3725         yearday += YEAR_ADJUST; /* recover March 1st crock */
3726         month = yearday*DAYS_TO_MONTH;
3727         yearday -= month*MONTH_TO_DAYS;
3728         /* recover other leap-year adjustment */
3729         if (month > 13) {
3730             month-=14;
3731             year++;
3732         }
3733         else {
3734             month-=2;
3735         }
3736     }
3737     ptm->tm_year = year - 1900;
3738     if (yearday) {
3739       ptm->tm_mday = yearday;
3740       ptm->tm_mon = month;
3741     }
3742     else {
3743       ptm->tm_mday = 31;
3744       ptm->tm_mon = month - 1;
3745     }
3746     /* re-build yearday based on Jan 1 to get tm_yday */
3747     year--;
3748     yearday = year*DAYS_PER_YEAR + year/4 - year/100 + year/400;
3749     yearday += 14*MONTH_TO_DAYS + 1;
3750     ptm->tm_yday = jday - yearday;
3751     /* fix tm_wday if not overridden by caller */
3752     if ((unsigned)ptm->tm_wday > 6)
3753         ptm->tm_wday = (jday + WEEKDAY_BIAS) % 7;
3754 }
3755
3756 char *
3757 Perl_my_strftime(pTHX_ char *fmt, int sec, int min, int hour, int mday, int mon, int year, int wday, int yday, int isdst)
3758 {
3759 #ifdef HAS_STRFTIME
3760   char *buf;
3761   int buflen;
3762   struct tm mytm;
3763   int len;
3764
3765   init_tm(&mytm);       /* XXX workaround - see init_tm() above */
3766   mytm.tm_sec = sec;
3767   mytm.tm_min = min;
3768   mytm.tm_hour = hour;
3769   mytm.tm_mday = mday;
3770   mytm.tm_mon = mon;
3771   mytm.tm_year = year;
3772   mytm.tm_wday = wday;
3773   mytm.tm_yday = yday;
3774   mytm.tm_isdst = isdst;
3775   mini_mktime(&mytm);
3776   buflen = 64;
3777   New(0, buf, buflen, char);
3778   len = strftime(buf, buflen, fmt, &mytm);
3779   /*
3780   ** The following is needed to handle to the situation where
3781   ** tmpbuf overflows.  Basically we want to allocate a buffer
3782   ** and try repeatedly.  The reason why it is so complicated
3783   ** is that getting a return value of 0 from strftime can indicate
3784   ** one of the following:
3785   ** 1. buffer overflowed,
3786   ** 2. illegal conversion specifier, or
3787   ** 3. the format string specifies nothing to be returned(not
3788   **      an error).  This could be because format is an empty string
3789   **    or it specifies %p that yields an empty string in some locale.
3790   ** If there is a better way to make it portable, go ahead by
3791   ** all means.
3792   */
3793   if ((len > 0 && len < buflen) || (len == 0 && *fmt == '\0'))
3794     return buf;
3795   else {
3796     /* Possibly buf overflowed - try again with a bigger buf */
3797     int     fmtlen = strlen(fmt);
3798     int     bufsize = fmtlen + buflen;
3799
3800     New(0, buf, bufsize, char);
3801     while (buf) {
3802       buflen = strftime(buf, bufsize, fmt, &mytm);
3803       if (buflen > 0 && buflen < bufsize)
3804         break;
3805       /* heuristic to prevent out-of-memory errors */
3806       if (bufsize > 100*fmtlen) {
3807         Safefree(buf);
3808         buf = NULL;
3809         break;
3810       }
3811       bufsize *= 2;
3812       Renew(buf, bufsize, char);
3813     }
3814     return buf;
3815   }
3816 #else
3817   Perl_croak(aTHX_ "panic: no strftime");
3818 #endif
3819 }
3820
3821
3822 #define SV_CWD_RETURN_UNDEF \
3823 sv_setsv(sv, &PL_sv_undef); \
3824 return FALSE
3825
3826 #define SV_CWD_ISDOT(dp) \
3827     (dp->d_name[0] == '.' && (dp->d_name[1] == '\0' || \
3828         (dp->d_name[1] == '.' && dp->d_name[2] == '\0')))
3829
3830 /*
3831 =head1 Miscellaneous Functions
3832
3833 =for apidoc getcwd_sv
3834
3835 Fill the sv with current working directory
3836
3837 =cut
3838 */
3839
3840 /* Originally written in Perl by John Bazik; rewritten in C by Ben Sugars.
3841  * rewritten again by dougm, optimized for use with xs TARG, and to prefer
3842  * getcwd(3) if available
3843  * Comments from the orignal:
3844  *     This is a faster version of getcwd.  It's also more dangerous
3845  *     because you might chdir out of a directory that you can't chdir
3846  *     back into. */
3847
3848 int
3849 Perl_getcwd_sv(pTHX_ register SV *sv)
3850 {
3851 #ifndef PERL_MICRO
3852
3853 #ifndef INCOMPLETE_TAINTS
3854     SvTAINTED_on(sv);
3855 #endif
3856
3857 #ifdef HAS_GETCWD
3858     {
3859         char buf[MAXPATHLEN];
3860
3861         /* Some getcwd()s automatically allocate a buffer of the given
3862          * size from the heap if they are given a NULL buffer pointer.
3863          * The problem is that this behaviour is not portable. */
3864         if (getcwd(buf, sizeof(buf) - 1)) {
3865             STRLEN len = strlen(buf);
3866             sv_setpvn(sv, buf, len);
3867             return TRUE;
3868         }
3869         else {
3870             sv_setsv(sv, &PL_sv_undef);
3871             return FALSE;
3872         }
3873     }
3874
3875 #else
3876
3877     Stat_t statbuf;
3878     int orig_cdev, orig_cino, cdev, cino, odev, oino, tdev, tino;
3879     int namelen, pathlen=0;
3880     DIR *dir;
3881     Direntry_t *dp;
3882
3883     (void)SvUPGRADE(sv, SVt_PV);
3884
3885     if (PerlLIO_lstat(".", &statbuf) < 0) {
3886         SV_CWD_RETURN_UNDEF;
3887     }
3888
3889     orig_cdev = statbuf.st_dev;
3890     orig_cino = statbuf.st_ino;
3891     cdev = orig_cdev;
3892     cino = orig_cino;
3893
3894     for (;;) {
3895         odev = cdev;
3896         oino = cino;
3897
3898         if (PerlDir_chdir("..") < 0) {
3899             SV_CWD_RETURN_UNDEF;
3900         }
3901         if (PerlLIO_stat(".", &statbuf) < 0) {
3902             SV_CWD_RETURN_UNDEF;
3903         }
3904
3905         cdev = statbuf.st_dev;
3906         cino = statbuf.st_ino;
3907
3908         if (odev == cdev && oino == cino) {
3909             break;
3910         }
3911         if (!(dir = PerlDir_open("."))) {
3912             SV_CWD_RETURN_UNDEF;
3913         }
3914
3915         while ((dp = PerlDir_read(dir)) != NULL) {
3916 #ifdef DIRNAMLEN
3917             namelen = dp->d_namlen;
3918 #else
3919             namelen = strlen(dp->d_name);
3920 #endif
3921             /* skip . and .. */
3922             if (SV_CWD_ISDOT(dp)) {
3923                 continue;
3924             }
3925
3926             if (PerlLIO_lstat(dp->d_name, &statbuf) < 0) {
3927                 SV_CWD_RETURN_UNDEF;
3928             }
3929
3930             tdev = statbuf.st_dev;
3931             tino = statbuf.st_ino;
3932             if (tino == oino && tdev == odev) {
3933                 break;
3934             }
3935         }
3936
3937         if (!dp) {
3938             SV_CWD_RETURN_UNDEF;
3939         }
3940
3941         if (pathlen + namelen + 1 >= MAXPATHLEN) {
3942             SV_CWD_RETURN_UNDEF;
3943         }
3944
3945         SvGROW(sv, pathlen + namelen + 1);
3946
3947         if (pathlen) {
3948             /* shift down */
3949             Move(SvPVX(sv), SvPVX(sv) + namelen + 1, pathlen, char);
3950         }
3951
3952         /* prepend current directory to the front */
3953         *SvPVX(sv) = '/';
3954         Move(dp->d_name, SvPVX(sv)+1, namelen, char);
3955         pathlen += (namelen + 1);
3956
3957 #ifdef VOID_CLOSEDIR
3958         PerlDir_close(dir);
3959 #else
3960         if (PerlDir_close(dir) < 0) {
3961             SV_CWD_RETURN_UNDEF;
3962         }
3963 #endif
3964     }
3965
3966     if (pathlen) {
3967         SvCUR_set(sv, pathlen);
3968         *SvEND(sv) = '\0';
3969         SvPOK_only(sv);
3970
3971         if (PerlDir_chdir(SvPVX(sv)) < 0) {
3972             SV_CWD_RETURN_UNDEF;
3973         }
3974     }
3975     if (PerlLIO_stat(".", &statbuf) < 0) {
3976         SV_CWD_RETURN_UNDEF;
3977     }
3978
3979     cdev = statbuf.st_dev;
3980     cino = statbuf.st_ino;
3981
3982     if (cdev != orig_cdev || cino != orig_cino) {
3983         Perl_croak(aTHX_ "Unstable directory path, "
3984                    "current directory changed unexpectedly");
3985     }
3986
3987     return TRUE;
3988 #endif
3989
3990 #else
3991     return FALSE;
3992 #endif
3993 }
3994
3995 /*
3996 =head1 SV Manipulation Functions
3997
3998 =for apidoc new_vstring
3999
4000 Returns a pointer to the next character after the parsed
4001 vstring, as well as updating the passed in sv.
4002
4003 Function must be called like
4004
4005         sv = NEWSV(92,5);
4006         s = new_vstring(s,sv);
4007
4008 The sv must already be large enough to store the vstring
4009 passed in.
4010
4011 =cut
4012 */
4013
4014 char *
4015 Perl_new_vstring(pTHX_ char *s, SV *sv)
4016 {
4017     char *pos = s;
4018     if (*pos == 'v') pos++;  /* get past 'v' */
4019     while (isDIGIT(*pos) || *pos == '_')
4020     pos++;
4021     if (!isALPHA(*pos)) {
4022         UV rev;
4023         U8 tmpbuf[UTF8_MAXLEN+1];
4024         U8 *tmpend;
4025
4026         if (*s == 'v') s++;  /* get past 'v' */
4027
4028         sv_setpvn(sv, "", 0);
4029
4030         for (;;) {
4031             rev = 0;
4032             {
4033                  /* this is atoi() that tolerates underscores */
4034                  char *end = pos;
4035                  UV mult = 1;
4036                  if ( s > pos && *(s-1) == '_') {
4037                       mult = 10;
4038                  }
4039                  while (--end >= s) {
4040                       UV orev;
4041                       orev = rev;
4042                       rev += (*end - '0') * mult;
4043                       mult *= 10;
4044                       if (orev > rev && ckWARN_d(WARN_OVERFLOW))
4045                            Perl_warner(aTHX_ packWARN(WARN_OVERFLOW),
4046                                        "Integer overflow in decimal number");
4047                  }
4048             }
4049 #ifdef EBCDIC
4050             if (rev > 0x7FFFFFFF)
4051                  Perl_croak(aTHX "In EBCDIC the v-string components cannot exceed 2147483647");
4052 #endif
4053             /* Append native character for the rev point */
4054             tmpend = uvchr_to_utf8(tmpbuf, rev);
4055             sv_catpvn(sv, (const char*)tmpbuf, tmpend - tmpbuf);
4056             if (!UNI_IS_INVARIANT(NATIVE_TO_UNI(rev)))
4057                  SvUTF8_on(sv);
4058             if ( (*pos == '.' || *pos == '_') && isDIGIT(pos[1]))
4059                  s = ++pos;
4060             else {
4061                  s = pos;
4062                  break;
4063             }
4064             while (isDIGIT(*pos) )
4065                  pos++;
4066         }
4067         SvPOK_on(sv);
4068         SvREADONLY_on(sv);
4069     }
4070     return s;
4071 }
4072
4073 #if !defined(HAS_SOCKETPAIR) && defined(HAS_SOCKET) && defined(AF_INET) && defined(PF_INET) && defined(SOCK_DGRAM) && defined(HAS_SELECT)
4074 #   define EMULATE_SOCKETPAIR_UDP
4075 #endif
4076
4077 #ifdef EMULATE_SOCKETPAIR_UDP
4078 static int
4079 S_socketpair_udp (int fd[2]) {
4080     dTHX;
4081     /* Fake a datagram socketpair using UDP to localhost.  */
4082     int sockets[2] = {-1, -1};
4083     struct sockaddr_in addresses[2];
4084     int i;
4085     Sock_size_t size = sizeof (struct sockaddr_in);
4086     unsigned short port;
4087     int got;
4088
4089     memset (&addresses, 0, sizeof (addresses));
4090     i = 1;
4091     do {
4092         sockets[i] = PerlSock_socket (AF_INET, SOCK_DGRAM, PF_INET);
4093         if (sockets[i] == -1)
4094             goto tidy_up_and_fail;
4095
4096         addresses[i].sin_family = AF_INET;
4097         addresses[i].sin_addr.s_addr = htonl (INADDR_LOOPBACK);
4098         addresses[i].sin_port = 0;      /* kernel choses port.  */
4099         if (PerlSock_bind (sockets[i], (struct sockaddr *) &addresses[i],
4100                   sizeof (struct sockaddr_in))
4101             == -1)
4102             goto tidy_up_and_fail;
4103     } while (i--);
4104
4105     /* Now have 2 UDP sockets. Find out which port each is connected to, and
4106        for each connect the other socket to it.  */
4107     i = 1;
4108     do {
4109         if (PerlSock_getsockname (sockets[i], (struct sockaddr *) &addresses[i], &size)
4110             == -1)
4111             goto tidy_up_and_fail;
4112         if (size != sizeof (struct sockaddr_in))
4113             goto abort_tidy_up_and_fail;
4114         /* !1 is 0, !0 is 1 */
4115         if (PerlSock_connect(sockets[!i], (struct sockaddr *) &addresses[i],
4116                     sizeof (struct sockaddr_in)) == -1)
4117             goto tidy_up_and_fail;
4118     } while (i--);
4119
4120     /* Now we have 2 sockets connected to each other. I don't trust some other
4121        process not to have already sent a packet to us (by random) so send
4122        a packet from each to the other.  */
4123     i = 1;
4124     do {
4125         /* I'm going to send my own port number.  As a short.
4126            (Who knows if someone somewhere has sin_port as a bitfield and needs
4127            this routine. (I'm assuming crays have socketpair)) */
4128         port = addresses[i].sin_port;
4129         got = PerlLIO_write (sockets[i], &port, sizeof(port));
4130         if (got != sizeof(port)) {
4131             if (got == -1)
4132                 goto tidy_up_and_fail;
4133             goto abort_tidy_up_and_fail;
4134         }
4135     } while (i--);
4136
4137     /* Packets sent. I don't trust them to have arrived though.
4138        (As I understand it Solaris TCP stack is multithreaded. Non-blocking
4139        connect to localhost will use a second kernel thread. In 2.6 the
4140        first thread running the connect() returns before the second completes,
4141        so EINPROGRESS> In 2.7 the improved stack is faster and connect()
4142        returns 0. Poor programs have tripped up. One poor program's authors'
4143        had a 50-1 reverse stock split. Not sure how connected these were.)
4144        So I don't trust someone not to have an unpredictable UDP stack.
4145     */
4146
4147     {
4148         struct timeval waitfor = {0, 100000}; /* You have 0.1 seconds */
4149         int max = sockets[1] > sockets[0] ? sockets[1] : sockets[0];
4150         fd_set rset;
4151
4152         FD_ZERO (&rset);
4153         FD_SET (sockets[0], &rset);
4154         FD_SET (sockets[1], &rset);
4155
4156         got = PerlSock_select (max + 1, &rset, NULL, NULL, &waitfor);
4157         if (got != 2 || !FD_ISSET (sockets[0], &rset)
4158             || !FD_ISSET (sockets[1], &rset)) {
4159              /* I hope this is portable and appropriate.  */
4160             if (got == -1)
4161                 goto tidy_up_and_fail;
4162             goto abort_tidy_up_and_fail;
4163         }
4164     }
4165
4166     /* And the paranoia department even now doesn't trust it to have arrive
4167        (hence MSG_DONTWAIT). Or that what arrives was sent by us.  */
4168     {
4169         struct sockaddr_in readfrom;
4170         unsigned short buffer[2];
4171
4172         i = 1;
4173         do {
4174 #ifdef MSG_DONTWAIT
4175             got = PerlSock_recvfrom (sockets[i], (char *) &buffer, sizeof(buffer),
4176                             MSG_DONTWAIT,
4177                             (struct sockaddr *) &readfrom, &size);
4178 #else
4179             got = PerlSock_recvfrom (sockets[i], (char *) &buffer, sizeof(buffer),
4180                             0,
4181                             (struct sockaddr *) &readfrom, &size);
4182 #endif
4183
4184             if (got == -1)
4185                     goto tidy_up_and_fail;
4186             if (got != sizeof(port)
4187                 || size != sizeof (struct sockaddr_in)
4188                 /* Check other socket sent us its port.  */
4189                 || buffer[0] != (unsigned short) addresses[!i].sin_port
4190                 /* Check kernel says we got the datagram from that socket.  */
4191                 || readfrom.sin_family != addresses[!i].sin_family
4192                 || readfrom.sin_addr.s_addr != addresses[!i].sin_addr.s_addr
4193                 || readfrom.sin_port != addresses[!i].sin_port)
4194                 goto abort_tidy_up_and_fail;
4195         } while (i--);
4196     }
4197     /* My caller (my_socketpair) has validated that this is non-NULL  */
4198     fd[0] = sockets[0];
4199     fd[1] = sockets[1];
4200     /* I hereby declare this connection open.  May God bless all who cross
4201        her.  */
4202     return 0;
4203
4204   abort_tidy_up_and_fail:
4205     errno = ECONNABORTED;
4206   tidy_up_and_fail:
4207     {
4208         int save_errno = errno;
4209         if (sockets[0] != -1)
4210             PerlLIO_close (sockets[0]);
4211         if (sockets[1] != -1)
4212             PerlLIO_close (sockets[1]);
4213         errno = save_errno;
4214         return -1;
4215     }
4216 }
4217 #endif /*  EMULATE_SOCKETPAIR_UDP */
4218
4219 #if !defined(HAS_SOCKETPAIR) && defined(HAS_SOCKET) && defined(AF_INET) && defined(PF_INET) 
4220 int
4221 Perl_my_socketpair (int family, int type, int protocol, int fd[2]) {
4222     /* Stevens says that family must be AF_LOCAL, protocol 0.
4223        I'm going to enforce that, then ignore it, and use TCP (or UDP).  */
4224     dTHX;
4225     int listener = -1;
4226     int connector = -1;
4227     int acceptor = -1;
4228     struct sockaddr_in listen_addr;
4229     struct sockaddr_in connect_addr;
4230     Sock_size_t size;
4231
4232     if (protocol
4233 #ifdef AF_UNIX
4234         || family != AF_UNIX
4235 #endif
4236         ) {
4237         errno = EAFNOSUPPORT;
4238         return -1;
4239     }
4240     if (!fd) {
4241         errno = EINVAL;
4242         return -1;
4243     }
4244
4245 #ifdef EMULATE_SOCKETPAIR_UDP
4246     if (type == SOCK_DGRAM)
4247         return S_socketpair_udp (fd);
4248 #endif
4249
4250     listener = PerlSock_socket (AF_INET, type, 0);
4251     if (listener == -1)
4252         return -1;
4253     memset (&listen_addr, 0, sizeof (listen_addr));
4254     listen_addr.sin_family = AF_INET;
4255     listen_addr.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
4256     listen_addr.sin_port = 0;   /* kernel choses port.  */
4257     if (PerlSock_bind (listener, (struct sockaddr *) &listen_addr, sizeof (listen_addr))
4258         == -1)
4259         goto tidy_up_and_fail;
4260     if (PerlSock_listen(listener, 1) == -1)
4261         goto tidy_up_and_fail;
4262
4263     connector = PerlSock_socket (AF_INET, type, 0);
4264     if (connector == -1)
4265         goto tidy_up_and_fail;
4266     /* We want to find out the port number to connect to.  */
4267     size = sizeof (connect_addr);
4268     if (PerlSock_getsockname (listener, (struct sockaddr *) &connect_addr, &size) == -1)
4269         goto tidy_up_and_fail;
4270     if (size != sizeof (connect_addr))
4271         goto abort_tidy_up_and_fail;
4272     if (PerlSock_connect(connector, (struct sockaddr *) &connect_addr,
4273                 sizeof (connect_addr)) == -1)
4274         goto tidy_up_and_fail;
4275
4276     size = sizeof (listen_addr);
4277     acceptor = PerlSock_accept (listener, (struct sockaddr *) &listen_addr, &size);
4278     if (acceptor == -1)
4279         goto tidy_up_and_fail;
4280     if (size != sizeof (listen_addr))
4281         goto abort_tidy_up_and_fail;
4282     PerlLIO_close (listener);
4283     /* Now check we are talking to ourself by matching port and host on the
4284        two sockets.  */
4285     if (PerlSock_getsockname (connector, (struct sockaddr *) &connect_addr, &size) == -1)
4286         goto tidy_up_and_fail;
4287     if (size != sizeof (connect_addr)
4288         || listen_addr.sin_family != connect_addr.sin_family
4289         || listen_addr.sin_addr.s_addr != connect_addr.sin_addr.s_addr
4290         || listen_addr.sin_port != connect_addr.sin_port) {
4291         goto abort_tidy_up_and_fail;
4292     }
4293     fd[0] = connector;
4294     fd[1] = acceptor;
4295     return 0;
4296
4297   abort_tidy_up_and_fail:
4298   errno = ECONNABORTED; /* I hope this is portable and appropriate.  */
4299   tidy_up_and_fail:
4300     {
4301         int save_errno = errno;
4302         if (listener != -1)
4303             PerlLIO_close (listener);
4304         if (connector != -1)
4305             PerlLIO_close (connector);
4306         if (acceptor != -1)
4307             PerlLIO_close (acceptor);
4308         errno = save_errno;
4309         return -1;
4310     }
4311 }
4312 #else
4313 /* In any case have a stub so that there's code corresponding
4314  * to the my_socketpair in global.sym. */
4315 int
4316 Perl_my_socketpair (int family, int type, int protocol, int fd[2]) {
4317 #ifdef HAS_SOCKETPAIR
4318     return socketpair(family, type, protocol, fd);
4319 #else
4320     return -1;
4321 #endif
4322 }
4323 #endif
4324
4325 /*
4326
4327 =for apidoc sv_nosharing
4328
4329 Dummy routine which "shares" an SV when there is no sharing module present.
4330 Exists to avoid test for a NULL function pointer and because it could potentially warn under
4331 some level of strict-ness.
4332
4333 =cut
4334 */
4335
4336 void
4337 Perl_sv_nosharing(pTHX_ SV *sv)
4338 {
4339 }
4340
4341 /*
4342 =for apidoc sv_nolocking
4343
4344 Dummy routine which "locks" an SV when there is no locking module present.
4345 Exists to avoid test for a NULL function pointer and because it could potentially warn under
4346 some level of strict-ness.
4347
4348 =cut
4349 */
4350
4351 void
4352 Perl_sv_nolocking(pTHX_ SV *sv)
4353 {
4354 }
4355
4356
4357 /*
4358 =for apidoc sv_nounlocking
4359
4360 Dummy routine which "unlocks" an SV when there is no locking module present.
4361 Exists to avoid test for a NULL function pointer and because it could potentially warn under
4362 some level of strict-ness.
4363
4364 =cut
4365 */
4366
4367 void
4368 Perl_sv_nounlocking(pTHX_ SV *sv)
4369 {
4370 }
4371