This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
add missing dTHR; notes for test failures due to small stacksize
[perl5.git] / doio.c
1 /*    doio.c
2  *
3  *    Copyright (c) 1991-1997, 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  * "Far below them they saw the white waters pour into a foaming bowl, and
12  * then swirl darkly about a deep oval basin in the rocks, until they found
13  * their way out again through a narrow gate, and flowed away, fuming and
14  * chattering, into calmer and more level reaches."
15  */
16
17 #include "EXTERN.h"
18 #include "perl.h"
19
20 #if defined(HAS_MSG) || defined(HAS_SEM) || defined(HAS_SHM)
21 #include <sys/ipc.h>
22 #ifdef HAS_MSG
23 #include <sys/msg.h>
24 #endif
25 #ifdef HAS_SEM
26 #include <sys/sem.h>
27 #endif
28 #ifdef HAS_SHM
29 #include <sys/shm.h>
30 # ifndef HAS_SHMAT_PROTOTYPE
31     extern Shmat_t shmat _((int, char *, int));
32 # endif
33 #endif
34 #endif
35
36 #ifdef I_UTIME
37 #  if defined(_MSC_VER) || defined(__MINGW32__)
38 #    include <sys/utime.h>
39 #  else
40 #    include <utime.h>
41 #  endif
42 #endif
43
44 #ifdef I_FCNTL
45 #include <fcntl.h>
46 #endif
47 #ifdef I_SYS_FILE
48 #include <sys/file.h>
49 #endif
50 #ifdef O_EXCL
51 #  define OPEN_EXCL O_EXCL
52 #else
53 #  define OPEN_EXCL 0
54 #endif
55
56 #if !defined(NSIG) || defined(M_UNIX) || defined(M_XENIX)
57 #include <signal.h>
58 #endif
59
60 /* XXX If this causes problems, set i_unistd=undef in the hint file.  */
61 #ifdef I_UNISTD
62 #  include <unistd.h>
63 #endif
64
65 #if defined(HAS_SOCKET) && !defined(VMS) /* VMS handles sockets via vmsish.h */
66 # include <sys/socket.h>
67 # include <netdb.h>
68 # ifndef ENOTSOCK
69 #  ifdef I_NET_ERRNO
70 #   include <net/errno.h>
71 #  endif
72 # endif
73 #endif
74
75 /* Put this after #includes because <unistd.h> defines _XOPEN_*. */
76 #ifndef Sock_size_t
77 #  if _XOPEN_VERSION >= 5 || defined(_XOPEN_SOURCE_EXTENDED) || defined(__GLIBC__)
78 #    define Sock_size_t Size_t
79 #  else
80 #    define Sock_size_t int
81 #  endif
82 #endif
83
84 bool
85 do_open(GV *gv, register char *name, I32 len, int as_raw, int rawmode, int rawperm, PerlIO *supplied_fp)
86 {
87     register IO *io = GvIOn(gv);
88     PerlIO *saveifp = Nullfp;
89     PerlIO *saveofp = Nullfp;
90     char savetype = ' ';
91     int writing = 0;
92     PerlIO *fp;
93     int fd;
94     int result;
95     bool was_fdopen = FALSE;
96
97     PL_forkprocess = 1;         /* assume true if no fork */
98
99     if (IoIFP(io)) {
100         fd = PerlIO_fileno(IoIFP(io));
101         if (IoTYPE(io) == '-')
102             result = 0;
103         else if (fd <= PL_maxsysfd) {
104             saveifp = IoIFP(io);
105             saveofp = IoOFP(io);
106             savetype = IoTYPE(io);
107             result = 0;
108         }
109         else if (IoTYPE(io) == '|')
110             result = PerlProc_pclose(IoIFP(io));
111         else if (IoIFP(io) != IoOFP(io)) {
112             if (IoOFP(io)) {
113                 result = PerlIO_close(IoOFP(io));
114                 PerlIO_close(IoIFP(io));        /* clear stdio, fd already closed */
115             }
116             else
117                 result = PerlIO_close(IoIFP(io));
118         }
119         else
120             result = PerlIO_close(IoIFP(io));
121         if (result == EOF && fd > PL_maxsysfd)
122             PerlIO_printf(PerlIO_stderr(), "Warning: unable to close filehandle %s properly.\n",
123               GvENAME(gv));
124         IoOFP(io) = IoIFP(io) = Nullfp;
125     }
126
127     if (as_raw) {
128 #ifndef O_ACCMODE
129 #define O_ACCMODE 3             /* Assume traditional implementation */
130 #endif
131         switch (result = rawmode & O_ACCMODE) {
132         case O_RDONLY:
133              IoTYPE(io) = '<';
134              break;
135         case O_WRONLY:
136              IoTYPE(io) = '>';
137              break;
138         case O_RDWR:
139         default:
140              IoTYPE(io) = '+';
141              break;
142         }
143
144         writing = (result > 0);
145         fd = PerlLIO_open3(name, rawmode, rawperm);
146
147         if (fd == -1)
148             fp = NULL;
149         else {
150             char *fpmode;
151             if (result == O_RDONLY)
152                 fpmode = "r";
153 #ifdef O_APPEND
154             else if (rawmode & O_APPEND)
155                 fpmode = (result == O_WRONLY) ? "a" : "a+";
156 #endif
157             else
158                 fpmode = (result == O_WRONLY) ? "w" : "r+";
159             fp = PerlIO_fdopen(fd, fpmode);
160             if (!fp)
161                 PerlLIO_close(fd);
162         }
163     }
164     else {
165         char *myname;
166         char mode[3];           /* stdio file mode ("r\0" or "r+\0") */
167         int dodup;
168
169         myname = savepvn(name, len);
170         SAVEFREEPV(myname);
171         name = myname;
172         while (len && isSPACE(name[len-1]))
173             name[--len] = '\0';
174
175         mode[0] = mode[1] = mode[2] = '\0';
176         IoTYPE(io) = *name;
177         if (*name == '+' && len > 1 && name[len-1] != '|') { /* scary */
178             mode[1] = *name++;
179             --len;
180             writing = 1;
181         }
182
183         if (*name == '|') {
184             /*SUPPRESS 530*/
185             for (name++; isSPACE(*name); name++) ;
186             if (strNE(name,"-"))
187                 TAINT_ENV();
188             TAINT_PROPER("piped open");
189             if (name[strlen(name)-1] == '|') {
190                 dTHR;
191                 name[strlen(name)-1] = '\0' ;
192                 if (ckWARN(WARN_PIPE))
193                     warner(WARN_PIPE, "Can't do bidirectional pipe");
194             }
195             fp = PerlProc_popen(name,"w");
196             writing = 1;
197         }
198         else if (*name == '>') {
199             TAINT_PROPER("open");
200             name++;
201             if (*name == '>') {
202                 mode[0] = IoTYPE(io) = 'a';
203                 name++;
204             }
205             else
206                 mode[0] = 'w';
207             writing = 1;
208
209             if (*name == '&') {
210               duplicity:
211                 dodup = 1;
212                 name++;
213                 if (*name == '=') {
214                     dodup = 0;
215                     name++;
216                 }
217                 if (!*name && supplied_fp)
218                     fp = supplied_fp;
219                 else {
220                     /*SUPPRESS 530*/
221                     for (; isSPACE(*name); name++) ;
222                     if (isDIGIT(*name))
223                         fd = atoi(name);
224                     else {
225                         IO* thatio;
226                         gv = gv_fetchpv(name,FALSE,SVt_PVIO);
227                         thatio = GvIO(gv);
228                         if (!thatio) {
229 #ifdef EINVAL
230                             SETERRNO(EINVAL,SS$_IVCHAN);
231 #endif
232                             goto say_false;
233                         }
234                         if (IoIFP(thatio)) {
235                             fd = PerlIO_fileno(IoIFP(thatio));
236                             if (IoTYPE(thatio) == 's')
237                                 IoTYPE(io) = 's';
238                         }
239                         else
240                             fd = -1;
241                     }
242                     if (dodup)
243                         fd = PerlLIO_dup(fd);
244                     else
245                         was_fdopen = TRUE;
246                     if (!(fp = PerlIO_fdopen(fd,mode))) {
247                         if (dodup)
248                             PerlLIO_close(fd);
249                         }
250                 }
251             }
252             else {
253                 /*SUPPRESS 530*/
254                 for (; isSPACE(*name); name++) ;
255                 if (strEQ(name,"-")) {
256                     fp = PerlIO_stdout();
257                     IoTYPE(io) = '-';
258                 }
259                 else  {
260                     fp = PerlIO_open(name,mode);
261                 }
262             }
263         }
264         else if (*name == '<') {
265             /*SUPPRESS 530*/
266             for (name++; isSPACE(*name); name++) ;
267             mode[0] = 'r';
268             if (*name == '&')
269                 goto duplicity;
270             if (strEQ(name,"-")) {
271                 fp = PerlIO_stdin();
272                 IoTYPE(io) = '-';
273             }
274             else
275                 fp = PerlIO_open(name,mode);
276         }
277         else if (len > 1 && name[len-1] == '|') {
278             name[--len] = '\0';
279             while (len && isSPACE(name[len-1]))
280                 name[--len] = '\0';
281             /*SUPPRESS 530*/
282             for (; isSPACE(*name); name++) ;
283             if (strNE(name,"-"))
284                 TAINT_ENV();
285             TAINT_PROPER("piped open");
286             fp = PerlProc_popen(name,"r");
287             IoTYPE(io) = '|';
288         }
289         else {
290             IoTYPE(io) = '<';
291             /*SUPPRESS 530*/
292             for (; isSPACE(*name); name++) ;
293             if (strEQ(name,"-")) {
294                 fp = PerlIO_stdin();
295                 IoTYPE(io) = '-';
296             }
297             else
298                 fp = PerlIO_open(name,"r");
299         }
300     }
301     if (!fp) {
302         dTHR;
303         if (ckWARN(WARN_NEWLINE) && IoTYPE(io) == '<' && strchr(name, '\n'))
304             warner(WARN_NEWLINE, warn_nl, "open");
305         goto say_false;
306     }
307     if (IoTYPE(io) &&
308       IoTYPE(io) != '|' && IoTYPE(io) != '-') {
309         dTHR;
310         if (PerlLIO_fstat(PerlIO_fileno(fp),&PL_statbuf) < 0) {
311             (void)PerlIO_close(fp);
312             goto say_false;
313         }
314         if (S_ISSOCK(PL_statbuf.st_mode))
315             IoTYPE(io) = 's';   /* in case a socket was passed in to us */
316 #ifdef HAS_SOCKET
317         else if (
318 #ifdef S_IFMT
319             !(PL_statbuf.st_mode & S_IFMT)
320 #else
321             !PL_statbuf.st_mode
322 #endif
323         ) {
324             char tmpbuf[256];
325             Sock_size_t buflen = sizeof tmpbuf;
326             if (PerlSock_getsockname(PerlIO_fileno(fp), (struct sockaddr *)tmpbuf,
327                             &buflen) >= 0
328                   || errno != ENOTSOCK)
329                 IoTYPE(io) = 's'; /* some OS's return 0 on fstat()ed socket */
330                                 /* but some return 0 for streams too, sigh */
331         }
332 #endif
333     }
334     if (saveifp) {              /* must use old fp? */
335         fd = PerlIO_fileno(saveifp);
336         if (saveofp) {
337             PerlIO_flush(saveofp);              /* emulate PerlIO_close() */
338             if (saveofp != saveifp) {   /* was a socket? */
339                 PerlIO_close(saveofp);
340                 if (fd > 2)
341                     Safefree(saveofp);
342             }
343         }
344         if (fd != PerlIO_fileno(fp)) {
345             int pid;
346             SV *sv;
347
348             PerlLIO_dup2(PerlIO_fileno(fp), fd);
349             sv = *av_fetch(PL_fdpid,PerlIO_fileno(fp),TRUE);
350             (void)SvUPGRADE(sv, SVt_IV);
351             pid = SvIVX(sv);
352             SvIVX(sv) = 0;
353             sv = *av_fetch(PL_fdpid,fd,TRUE);
354             (void)SvUPGRADE(sv, SVt_IV);
355             SvIVX(sv) = pid;
356             if (!was_fdopen)
357                 PerlIO_close(fp);
358
359         }
360         fp = saveifp;
361         PerlIO_clearerr(fp);
362     }
363 #if defined(HAS_FCNTL) && defined(F_SETFD)
364     fd = PerlIO_fileno(fp);
365     fcntl(fd,F_SETFD,fd > PL_maxsysfd);
366 #endif
367     IoIFP(io) = fp;
368     if (writing) {
369         dTHR;
370         if (IoTYPE(io) == 's'
371           || (IoTYPE(io) == '>' && S_ISCHR(PL_statbuf.st_mode)) ) {
372             if (!(IoOFP(io) = PerlIO_fdopen(PerlIO_fileno(fp),"w"))) {
373                 PerlIO_close(fp);
374                 IoIFP(io) = Nullfp;
375                 goto say_false;
376             }
377         }
378         else
379             IoOFP(io) = fp;
380     }
381     return TRUE;
382
383 say_false:
384     IoIFP(io) = saveifp;
385     IoOFP(io) = saveofp;
386     IoTYPE(io) = savetype;
387     return FALSE;
388 }
389
390 PerlIO *
391 nextargv(register GV *gv)
392 {
393     register SV *sv;
394 #ifndef FLEXFILENAMES
395     int filedev;
396     int fileino;
397 #endif
398     int fileuid;
399     int filegid;
400
401     if (!PL_argvoutgv)
402         PL_argvoutgv = gv_fetchpv("ARGVOUT",TRUE,SVt_PVIO);
403     if (PL_filemode & (S_ISUID|S_ISGID)) {
404         PerlIO_flush(IoIFP(GvIOn(PL_argvoutgv)));  /* chmod must follow last write */
405 #ifdef HAS_FCHMOD
406         (void)fchmod(PL_lastfd,PL_filemode);
407 #else
408         (void)PerlLIO_chmod(PL_oldname,PL_filemode);
409 #endif
410     }
411     PL_filemode = 0;
412     while (av_len(GvAV(gv)) >= 0) {
413         dTHR;
414         STRLEN oldlen;
415         sv = av_shift(GvAV(gv));
416         SAVEFREESV(sv);
417         sv_setsv(GvSV(gv),sv);
418         SvSETMAGIC(GvSV(gv));
419         PL_oldname = SvPVx(GvSV(gv), oldlen);
420         if (do_open(gv,PL_oldname,oldlen,PL_inplace!=0,O_RDONLY,0,Nullfp)) {
421             if (PL_inplace) {
422                 TAINT_PROPER("inplace open");
423                 if (oldlen == 1 && *PL_oldname == '-') {
424                     setdefout(gv_fetchpv("STDOUT",TRUE,SVt_PVIO));
425                     return IoIFP(GvIOp(gv));
426                 }
427 #ifndef FLEXFILENAMES
428                 filedev = PL_statbuf.st_dev;
429                 fileino = PL_statbuf.st_ino;
430 #endif
431                 PL_filemode = PL_statbuf.st_mode;
432                 fileuid = PL_statbuf.st_uid;
433                 filegid = PL_statbuf.st_gid;
434                 if (!S_ISREG(PL_filemode)) {
435                     warn("Can't do inplace edit: %s is not a regular file",
436                       PL_oldname );
437                     do_close(gv,FALSE);
438                     continue;
439                 }
440                 if (*PL_inplace) {
441                     char *star = strchr(PL_inplace, '*');
442                     if (star) {
443                         char *begin = PL_inplace;
444                         sv_setpvn(sv, "", 0);
445                         do {
446                             sv_catpvn(sv, begin, star - begin);
447                             sv_catpvn(sv, PL_oldname, oldlen);
448                             begin = ++star;
449                         } while ((star = strchr(begin, '*')));
450                         if (*begin)
451                             sv_catpv(sv,begin);
452                     }
453                     else {
454                         sv_catpv(sv,PL_inplace);
455                     }
456 #ifndef FLEXFILENAMES
457                     if (PerlLIO_stat(SvPVX(sv),&PL_statbuf) >= 0
458                       && PL_statbuf.st_dev == filedev
459                       && PL_statbuf.st_ino == fileino
460 #ifdef DJGPP
461                       || (_djstat_fail_bits & _STFAIL_TRUENAME)!=0
462 #endif
463                       ) {
464                         warn("Can't do inplace edit: %s would not be uniq",
465                           SvPVX(sv) );
466                         do_close(gv,FALSE);
467                         continue;
468                     }
469 #endif
470 #ifdef HAS_RENAME
471 #ifndef DOSISH
472                     if (PerlLIO_rename(PL_oldname,SvPVX(sv)) < 0) {
473                         warn("Can't rename %s to %s: %s, skipping file",
474                           PL_oldname, SvPVX(sv), Strerror(errno) );
475                         do_close(gv,FALSE);
476                         continue;
477                     }
478 #else
479                     do_close(gv,FALSE);
480                     (void)PerlLIO_unlink(SvPVX(sv));
481                     (void)PerlLIO_rename(PL_oldname,SvPVX(sv));
482                     do_open(gv,SvPVX(sv),SvCUR(sv),PL_inplace!=0,O_RDONLY,0,Nullfp);
483 #endif /* DOSISH */
484 #else
485                     (void)UNLINK(SvPVX(sv));
486                     if (link(PL_oldname,SvPVX(sv)) < 0) {
487                         warn("Can't rename %s to %s: %s, skipping file",
488                           PL_oldname, SvPVX(sv), Strerror(errno) );
489                         do_close(gv,FALSE);
490                         continue;
491                     }
492                     (void)UNLINK(PL_oldname);
493 #endif
494                 }
495                 else {
496 #if !defined(DOSISH) && !defined(AMIGAOS)
497 #  ifndef VMS  /* Don't delete; use automatic file versioning */
498                     if (UNLINK(PL_oldname) < 0) {
499                         warn("Can't remove %s: %s, skipping file",
500                           PL_oldname, Strerror(errno) );
501                         do_close(gv,FALSE);
502                         continue;
503                     }
504 #  endif
505 #else
506                     croak("Can't do inplace edit without backup");
507 #endif
508                 }
509
510                 sv_setpvn(sv,">",!PL_inplace);
511                 sv_catpvn(sv,PL_oldname,oldlen);
512                 SETERRNO(0,0);          /* in case sprintf set errno */
513 #ifdef VMS
514                 if (!do_open(PL_argvoutgv,SvPVX(sv),SvCUR(sv),PL_inplace!=0,
515                  O_WRONLY|O_CREAT|O_TRUNC,0,Nullfp)) { 
516 #else
517                 if (!do_open(PL_argvoutgv,SvPVX(sv),SvCUR(sv),PL_inplace!=0,
518                              O_WRONLY|O_CREAT|OPEN_EXCL,0666,Nullfp)) {
519 #endif
520                     warn("Can't do inplace edit on %s: %s",
521                       PL_oldname, Strerror(errno) );
522                     do_close(gv,FALSE);
523                     continue;
524                 }
525                 setdefout(PL_argvoutgv);
526                 PL_lastfd = PerlIO_fileno(IoIFP(GvIOp(PL_argvoutgv)));
527                 (void)PerlLIO_fstat(PL_lastfd,&PL_statbuf);
528 #ifdef HAS_FCHMOD
529                 (void)fchmod(PL_lastfd,PL_filemode);
530 #else
531 #  if !(defined(WIN32) && defined(__BORLANDC__))
532                 /* Borland runtime creates a readonly file! */
533                 (void)PerlLIO_chmod(PL_oldname,PL_filemode);
534 #  endif
535 #endif
536                 if (fileuid != PL_statbuf.st_uid || filegid != PL_statbuf.st_gid) {
537 #ifdef HAS_FCHOWN
538                     (void)fchown(PL_lastfd,fileuid,filegid);
539 #else
540 #ifdef HAS_CHOWN
541                     (void)PerlLIO_chown(PL_oldname,fileuid,filegid);
542 #endif
543 #endif
544                 }
545             }
546             return IoIFP(GvIOp(gv));
547         }
548         else
549             PerlIO_printf(PerlIO_stderr(), "Can't open %s: %s\n",
550               SvPV(sv, PL_na), Strerror(errno));
551     }
552     if (PL_inplace) {
553         (void)do_close(PL_argvoutgv,FALSE);
554         setdefout(gv_fetchpv("STDOUT",TRUE,SVt_PVIO));
555     }
556     return Nullfp;
557 }
558
559 #ifdef HAS_PIPE
560 void
561 do_pipe(SV *sv, GV *rgv, GV *wgv)
562 {
563     register IO *rstio;
564     register IO *wstio;
565     int fd[2];
566
567     if (!rgv)
568         goto badexit;
569     if (!wgv)
570         goto badexit;
571
572     rstio = GvIOn(rgv);
573     wstio = GvIOn(wgv);
574
575     if (IoIFP(rstio))
576         do_close(rgv,FALSE);
577     if (IoIFP(wstio))
578         do_close(wgv,FALSE);
579
580     if (PerlProc_pipe(fd) < 0)
581         goto badexit;
582     IoIFP(rstio) = PerlIO_fdopen(fd[0], "r");
583     IoOFP(wstio) = PerlIO_fdopen(fd[1], "w");
584     IoIFP(wstio) = IoOFP(wstio);
585     IoTYPE(rstio) = '<';
586     IoTYPE(wstio) = '>';
587     if (!IoIFP(rstio) || !IoOFP(wstio)) {
588         if (IoIFP(rstio)) PerlIO_close(IoIFP(rstio));
589         else PerlLIO_close(fd[0]);
590         if (IoOFP(wstio)) PerlIO_close(IoOFP(wstio));
591         else PerlLIO_close(fd[1]);
592         goto badexit;
593     }
594
595     sv_setsv(sv,&PL_sv_yes);
596     return;
597
598 badexit:
599     sv_setsv(sv,&PL_sv_undef);
600     return;
601 }
602 #endif
603
604 /* explicit renamed to avoid C++ conflict    -- kja */
605 bool
606 do_close(GV *gv, bool not_implicit)
607 {
608     bool retval;
609     IO *io;
610
611     if (!gv)
612         gv = PL_argvgv;
613     if (!gv || SvTYPE(gv) != SVt_PVGV) {
614         if (not_implicit)
615             SETERRNO(EBADF,SS$_IVCHAN);
616         return FALSE;
617     }
618     io = GvIO(gv);
619     if (!io) {          /* never opened */
620         if (not_implicit) {
621             dTHR;
622             if (ckWARN(WARN_UNOPENED))
623                 warner(WARN_UNOPENED, 
624                        "Close on unopened file <%s>",GvENAME(gv));
625             SETERRNO(EBADF,SS$_IVCHAN);
626         }
627         return FALSE;
628     }
629     retval = io_close(io);
630     if (not_implicit) {
631         IoLINES(io) = 0;
632         IoPAGE(io) = 0;
633         IoLINES_LEFT(io) = IoPAGE_LEN(io);
634     }
635     IoTYPE(io) = ' ';
636     return retval;
637 }
638
639 bool
640 io_close(IO *io)
641 {
642     bool retval = FALSE;
643     int status;
644
645     if (IoIFP(io)) {
646         if (IoTYPE(io) == '|') {
647             status = PerlProc_pclose(IoIFP(io));
648             STATUS_NATIVE_SET(status);
649             retval = (STATUS_POSIX == 0);
650         }
651         else if (IoTYPE(io) == '-')
652             retval = TRUE;
653         else {
654             if (IoOFP(io) && IoOFP(io) != IoIFP(io)) {          /* a socket */
655                 retval = (PerlIO_close(IoOFP(io)) != EOF);
656                 PerlIO_close(IoIFP(io));        /* clear stdio, fd already closed */
657             }
658             else
659                 retval = (PerlIO_close(IoIFP(io)) != EOF);
660         }
661         IoOFP(io) = IoIFP(io) = Nullfp;
662     }
663     else {
664         SETERRNO(EBADF,SS$_IVCHAN);
665     }
666
667     return retval;
668 }
669
670 bool
671 do_eof(GV *gv)
672 {
673     dTHR;
674     register IO *io;
675     int ch;
676
677     io = GvIO(gv);
678
679     if (!io)
680         return TRUE;
681
682     while (IoIFP(io)) {
683
684         if (PerlIO_has_cntptr(IoIFP(io))) {     /* (the code works without this) */
685             if (PerlIO_get_cnt(IoIFP(io)) > 0)  /* cheat a little, since */
686                 return FALSE;                   /* this is the most usual case */
687         }
688
689         ch = PerlIO_getc(IoIFP(io));
690         if (ch != EOF) {
691             (void)PerlIO_ungetc(IoIFP(io),ch);
692             return FALSE;
693         }
694         if (PerlIO_has_cntptr(IoIFP(io)) && PerlIO_canset_cnt(IoIFP(io))) {
695             if (PerlIO_get_cnt(IoIFP(io)) < -1)
696                 PerlIO_set_cnt(IoIFP(io),-1);
697         }
698         if (PL_op->op_flags & OPf_SPECIAL) { /* not necessarily a real EOF yet? */
699             if (!nextargv(PL_argvgv))   /* get another fp handy */
700                 return TRUE;
701         }
702         else
703             return TRUE;                /* normal fp, definitely end of file */
704     }
705     return TRUE;
706 }
707
708 long
709 do_tell(GV *gv)
710 {
711     register IO *io;
712     register PerlIO *fp;
713
714     if (gv && (io = GvIO(gv)) && (fp = IoIFP(io))) {
715 #ifdef ULTRIX_STDIO_BOTCH
716         if (PerlIO_eof(fp))
717             (void)PerlIO_seek(fp, 0L, 2);       /* ultrix 1.2 workaround */
718 #endif
719         return PerlIO_tell(fp);
720     }
721     {
722         dTHR;
723         if (ckWARN(WARN_UNOPENED))
724             warner(WARN_UNOPENED, "tell() on unopened file");
725     }
726     SETERRNO(EBADF,RMS$_IFI);
727     return -1L;
728 }
729
730 bool
731 do_seek(GV *gv, long int pos, int whence)
732 {
733     register IO *io;
734     register PerlIO *fp;
735
736     if (gv && (io = GvIO(gv)) && (fp = IoIFP(io))) {
737 #ifdef ULTRIX_STDIO_BOTCH
738         if (PerlIO_eof(fp))
739             (void)PerlIO_seek(fp, 0L, 2);       /* ultrix 1.2 workaround */
740 #endif
741         return PerlIO_seek(fp, pos, whence) >= 0;
742     }
743     {
744         dTHR;
745         if (ckWARN(WARN_UNOPENED))
746             warner(WARN_UNOPENED, "seek() on unopened file");
747     }
748     SETERRNO(EBADF,RMS$_IFI);
749     return FALSE;
750 }
751
752 long
753 do_sysseek(GV *gv, long int pos, int whence)
754 {
755     register IO *io;
756     register PerlIO *fp;
757
758     if (gv && (io = GvIO(gv)) && (fp = IoIFP(io)))
759         return PerlLIO_lseek(PerlIO_fileno(fp), pos, whence);
760     {
761         dTHR;
762         if (ckWARN(WARN_UNOPENED))
763             warner(WARN_UNOPENED, "sysseek() on unopened file");
764     }
765     SETERRNO(EBADF,RMS$_IFI);
766     return -1L;
767 }
768
769 int
770 do_binmode(PerlIO *fp, int iotype, int flag)
771 {
772     if (flag != TRUE)
773         croak("panic: unsetting binmode"); /* Not implemented yet */
774 #ifdef DOSISH
775 #ifdef atarist
776     if (!PerlIO_flush(fp) && (fp->_flag |= _IOBIN))
777         return 1;
778     else
779         return 0;
780 #else
781     if (PerlLIO_setmode(PerlIO_fileno(fp), OP_BINARY) != -1) {
782 #if defined(WIN32) && defined(__BORLANDC__)
783         /* The translation mode of the stream is maintained independent
784          * of the translation mode of the fd in the Borland RTL (heavy
785          * digging through their runtime sources reveal).  User has to
786          * set the mode explicitly for the stream (though they don't
787          * document this anywhere). GSAR 97-5-24
788          */
789         PerlIO_seek(fp,0L,0);
790         ((FILE*)fp)->flags |= _F_BIN;
791 #endif
792         return 1;
793     }
794     else
795         return 0;
796 #endif
797 #else
798 #if defined(USEMYBINMODE)
799     if (my_binmode(fp,iotype) != NULL)
800         return 1;
801     else
802         return 0;
803 #else
804     return 1;
805 #endif
806 #endif
807 }
808
809 #if !defined(HAS_TRUNCATE) && !defined(HAS_CHSIZE) && defined(F_FREESP)
810         /* code courtesy of William Kucharski */
811 #define HAS_CHSIZE
812
813 I32 my_chsize(fd, length)
814 I32 fd;                 /* file descriptor */
815 Off_t length;           /* length to set file to */
816 {
817     struct flock fl;
818     struct stat filebuf;
819
820     if (PerlLIO_fstat(fd, &filebuf) < 0)
821         return -1;
822
823     if (filebuf.st_size < length) {
824
825         /* extend file length */
826
827         if ((PerlLIO_lseek(fd, (length - 1), 0)) < 0)
828             return -1;
829
830         /* write a "0" byte */
831
832         if ((PerlLIO_write(fd, "", 1)) != 1)
833             return -1;
834     }
835     else {
836         /* truncate length */
837
838         fl.l_whence = 0;
839         fl.l_len = 0;
840         fl.l_start = length;
841         fl.l_type = F_WRLCK;    /* write lock on file space */
842
843         /*
844         * This relies on the UNDOCUMENTED F_FREESP argument to
845         * fcntl(2), which truncates the file so that it ends at the
846         * position indicated by fl.l_start.
847         *
848         * Will minor miracles never cease?
849         */
850
851         if (fcntl(fd, F_FREESP, &fl) < 0)
852             return -1;
853
854     }
855
856     return 0;
857 }
858 #endif /* F_FREESP */
859
860 bool
861 do_print(register SV *sv, PerlIO *fp)
862 {
863     register char *tmps;
864     STRLEN len;
865
866     /* assuming fp is checked earlier */
867     if (!sv)
868         return TRUE;
869     if (PL_ofmt) {
870         if (SvGMAGICAL(sv))
871             mg_get(sv);
872         if (SvIOK(sv) && SvIVX(sv) != 0) {
873             PerlIO_printf(fp, PL_ofmt, (double)SvIVX(sv));
874             return !PerlIO_error(fp);
875         }
876         if (  (SvNOK(sv) && SvNVX(sv) != 0.0)
877            || (looks_like_number(sv) && sv_2nv(sv) != 0.0) ) {
878             PerlIO_printf(fp, PL_ofmt, SvNVX(sv));
879             return !PerlIO_error(fp);
880         }
881     }
882     switch (SvTYPE(sv)) {
883     case SVt_NULL:
884         {
885             dTHR;
886             if (ckWARN(WARN_UNINITIALIZED))
887                 warner(WARN_UNINITIALIZED, warn_uninit);
888         }
889         return TRUE;
890     case SVt_IV:
891         if (SvIOK(sv)) {
892             if (SvGMAGICAL(sv))
893                 mg_get(sv);
894             PerlIO_printf(fp, "%ld", (long)SvIVX(sv));
895             return !PerlIO_error(fp);
896         }
897         /* FALL THROUGH */
898     default:
899         tmps = SvPV(sv, len);
900         break;
901     }
902     if (len && (PerlIO_write(fp,tmps,len) == 0 || PerlIO_error(fp)))
903         return FALSE;
904     return !PerlIO_error(fp);
905 }
906
907 I32
908 my_stat(ARGSproto)
909 {
910     djSP;
911     IO *io;
912     GV* tmpgv;
913
914     if (PL_op->op_flags & OPf_REF) {
915         EXTEND(SP,1);
916         tmpgv = cGVOP->op_gv;
917       do_fstat:
918         io = GvIO(tmpgv);
919         if (io && IoIFP(io)) {
920             PL_statgv = tmpgv;
921             sv_setpv(PL_statname,"");
922             PL_laststype = OP_STAT;
923             return (PL_laststatval = PerlLIO_fstat(PerlIO_fileno(IoIFP(io)), &PL_statcache));
924         }
925         else {
926             if (tmpgv == PL_defgv)
927                 return PL_laststatval;
928             if (ckWARN(WARN_UNOPENED))
929                 warner(WARN_UNOPENED, "Stat on unopened file <%s>",
930                   GvENAME(tmpgv));
931             PL_statgv = Nullgv;
932             sv_setpv(PL_statname,"");
933             return (PL_laststatval = -1);
934         }
935     }
936     else {
937         SV* sv = POPs;
938         char *s;
939         PUTBACK;
940         if (SvTYPE(sv) == SVt_PVGV) {
941             tmpgv = (GV*)sv;
942             goto do_fstat;
943         }
944         else if (SvROK(sv) && SvTYPE(SvRV(sv)) == SVt_PVGV) {
945             tmpgv = (GV*)SvRV(sv);
946             goto do_fstat;
947         }
948
949         s = SvPV(sv, PL_na);
950         PL_statgv = Nullgv;
951         sv_setpv(PL_statname, s);
952         PL_laststype = OP_STAT;
953         PL_laststatval = PerlLIO_stat(s, &PL_statcache);
954         if (PL_laststatval < 0 && ckWARN(WARN_NEWLINE) && strchr(s, '\n'))
955             warner(WARN_NEWLINE, warn_nl, "stat");
956         return PL_laststatval;
957     }
958 }
959
960 I32
961 my_lstat(ARGSproto)
962 {
963     djSP;
964     SV *sv;
965     if (PL_op->op_flags & OPf_REF) {
966         EXTEND(SP,1);
967         if (cGVOP->op_gv == PL_defgv) {
968             if (PL_laststype != OP_LSTAT)
969                 croak("The stat preceding -l _ wasn't an lstat");
970             return PL_laststatval;
971         }
972         croak("You can't use -l on a filehandle");
973     }
974
975     PL_laststype = OP_LSTAT;
976     PL_statgv = Nullgv;
977     sv = POPs;
978     PUTBACK;
979     sv_setpv(PL_statname,SvPV(sv, PL_na));
980 #ifdef HAS_LSTAT
981     PL_laststatval = PerlLIO_lstat(SvPV(sv, PL_na),&PL_statcache);
982 #else
983     PL_laststatval = PerlLIO_stat(SvPV(sv, PL_na),&PL_statcache);
984 #endif
985     if (PL_laststatval < 0 && ckWARN(WARN_NEWLINE) && strchr(SvPV(sv, PL_na), '\n'))
986         warner(WARN_NEWLINE, warn_nl, "lstat");
987     return PL_laststatval;
988 }
989
990 bool
991 do_aexec(SV *really, register SV **mark, register SV **sp)
992 {
993     register char **a;
994     char *tmps;
995
996     if (sp > mark) {
997         dTHR;
998         New(401,PL_Argv, sp - mark + 1, char*);
999         a = PL_Argv;
1000         while (++mark <= sp) {
1001             if (*mark)
1002                 *a++ = SvPVx(*mark, PL_na);
1003             else
1004                 *a++ = "";
1005         }
1006         *a = Nullch;
1007         if (*PL_Argv[0] != '/') /* will execvp use PATH? */
1008             TAINT_ENV();                /* testing IFS here is overkill, probably */
1009         if (really && *(tmps = SvPV(really, PL_na)))
1010             PerlProc_execvp(tmps,PL_Argv);
1011         else
1012             PerlProc_execvp(PL_Argv[0],PL_Argv);
1013         if (ckWARN(WARN_EXEC))
1014             warner(WARN_EXEC, "Can't exec \"%s\": %s", 
1015                 PL_Argv[0], Strerror(errno));
1016     }
1017     do_execfree();
1018     return FALSE;
1019 }
1020
1021 void
1022 do_execfree(void)
1023 {
1024     if (PL_Argv) {
1025         Safefree(PL_Argv);
1026         PL_Argv = Null(char **);
1027     }
1028     if (PL_Cmd) {
1029         Safefree(PL_Cmd);
1030         PL_Cmd = Nullch;
1031     }
1032 }
1033
1034 #if !defined(OS2) && !defined(WIN32) && !defined(DJGPP)
1035
1036 bool
1037 do_exec(char *cmd)
1038 {
1039     register char **a;
1040     register char *s;
1041     char flags[10];
1042
1043     while (*cmd && isSPACE(*cmd))
1044         cmd++;
1045
1046     /* save an extra exec if possible */
1047
1048 #ifdef CSH
1049     if (strnEQ(cmd,PL_cshname,PL_cshlen) && strnEQ(cmd+PL_cshlen," -c",3)) {
1050         strcpy(flags,"-c");
1051         s = cmd+PL_cshlen+3;
1052         if (*s == 'f') {
1053             s++;
1054             strcat(flags,"f");
1055         }
1056         if (*s == ' ')
1057             s++;
1058         if (*s++ == '\'') {
1059             char *ncmd = s;
1060
1061             while (*s)
1062                 s++;
1063             if (s[-1] == '\n')
1064                 *--s = '\0';
1065             if (s[-1] == '\'') {
1066                 *--s = '\0';
1067                 PerlProc_execl(PL_cshname,"csh", flags,ncmd,(char*)0);
1068                 *s = '\'';
1069                 return FALSE;
1070             }
1071         }
1072     }
1073 #endif /* CSH */
1074
1075     /* see if there are shell metacharacters in it */
1076
1077     if (*cmd == '.' && isSPACE(cmd[1]))
1078         goto doshell;
1079
1080     if (strnEQ(cmd,"exec",4) && isSPACE(cmd[4]))
1081         goto doshell;
1082
1083     for (s = cmd; *s && isALPHA(*s); s++) ;     /* catch VAR=val gizmo */
1084     if (*s == '=')
1085         goto doshell;
1086
1087     for (s = cmd; *s; s++) {
1088         if (*s != ' ' && !isALPHA(*s) && strchr("$&*(){}[]'\";\\|?<>~`\n",*s)) {
1089             if (*s == '\n' && !s[1]) {
1090                 *s = '\0';
1091                 break;
1092             }
1093           doshell:
1094             PerlProc_execl(PL_sh_path, "sh", "-c", cmd, (char*)0);
1095             return FALSE;
1096         }
1097     }
1098
1099     New(402,PL_Argv, (s - cmd) / 2 + 2, char*);
1100     PL_Cmd = savepvn(cmd, s-cmd);
1101     a = PL_Argv;
1102     for (s = PL_Cmd; *s;) {
1103         while (*s && isSPACE(*s)) s++;
1104         if (*s)
1105             *(a++) = s;
1106         while (*s && !isSPACE(*s)) s++;
1107         if (*s)
1108             *s++ = '\0';
1109     }
1110     *a = Nullch;
1111     if (PL_Argv[0]) {
1112         PerlProc_execvp(PL_Argv[0],PL_Argv);
1113         if (errno == ENOEXEC) {         /* for system V NIH syndrome */
1114             do_execfree();
1115             goto doshell;
1116         }
1117         {
1118             dTHR;
1119             if (ckWARN(WARN_EXEC))
1120                 warner(WARN_EXEC, "Can't exec \"%s\": %s", 
1121                     PL_Argv[0], Strerror(errno));
1122         }
1123     }
1124     do_execfree();
1125     return FALSE;
1126 }
1127
1128 #endif /* OS2 || WIN32 */
1129
1130 I32
1131 apply(I32 type, register SV **mark, register SV **sp)
1132 {
1133     dTHR;
1134     register I32 val;
1135     register I32 val2;
1136     register I32 tot = 0;
1137     char *what;
1138     char *s;
1139     SV **oldmark = mark;
1140
1141 #define APPLY_TAINT_PROPER() \
1142     STMT_START {                                                        \
1143         if (PL_tainting && PL_tainted) { goto taint_proper_label; }     \
1144     } STMT_END
1145
1146     /* This is a first heuristic; it doesn't catch tainting magic. */
1147     if (PL_tainting) {
1148         while (++mark <= sp) {
1149             if (SvTAINTED(*mark)) {
1150                 TAINT;
1151                 break;
1152             }
1153         }
1154         mark = oldmark;
1155     }
1156     switch (type) {
1157     case OP_CHMOD:
1158         what = "chmod";
1159         APPLY_TAINT_PROPER();
1160         if (++mark <= sp) {
1161             val = SvIVx(*mark);
1162             APPLY_TAINT_PROPER();
1163             tot = sp - mark;
1164             while (++mark <= sp) {
1165                 char *name = SvPVx(*mark, PL_na);
1166                 APPLY_TAINT_PROPER();
1167                 if (PerlLIO_chmod(name, val))
1168                     tot--;
1169             }
1170         }
1171         break;
1172 #ifdef HAS_CHOWN
1173     case OP_CHOWN:
1174         what = "chown";
1175         APPLY_TAINT_PROPER();
1176         if (sp - mark > 2) {
1177             val = SvIVx(*++mark);
1178             val2 = SvIVx(*++mark);
1179             APPLY_TAINT_PROPER();
1180             tot = sp - mark;
1181             while (++mark <= sp) {
1182                 char *name = SvPVx(*mark, PL_na);
1183                 APPLY_TAINT_PROPER();
1184                 if (PerlLIO_chown(name, val, val2))
1185                     tot--;
1186             }
1187         }
1188         break;
1189 #endif
1190 /* 
1191 XXX Should we make lchown() directly available from perl?
1192 For now, we'll let Configure test for HAS_LCHOWN, but do
1193 nothing in the core.
1194     --AD  5/1998
1195 */
1196 #ifdef HAS_KILL
1197     case OP_KILL:
1198         what = "kill";
1199         APPLY_TAINT_PROPER();
1200         if (mark == sp)
1201             break;
1202         s = SvPVx(*++mark, PL_na);
1203         if (isUPPER(*s)) {
1204             if (*s == 'S' && s[1] == 'I' && s[2] == 'G')
1205                 s += 3;
1206             if (!(val = whichsig(s)))
1207                 croak("Unrecognized signal name \"%s\"",s);
1208         }
1209         else
1210             val = SvIVx(*mark);
1211         APPLY_TAINT_PROPER();
1212         tot = sp - mark;
1213 #ifdef VMS
1214         /* kill() doesn't do process groups (job trees?) under VMS */
1215         if (val < 0) val = -val;
1216         if (val == SIGKILL) {
1217 #           include <starlet.h>
1218             /* Use native sys$delprc() to insure that target process is
1219              * deleted; supervisor-mode images don't pay attention to
1220              * CRTL's emulation of Unix-style signals and kill()
1221              */
1222             while (++mark <= sp) {
1223                 I32 proc = SvIVx(*mark);
1224                 register unsigned long int __vmssts;
1225                 APPLY_TAINT_PROPER();
1226                 if (!((__vmssts = sys$delprc(&proc,0)) & 1)) {
1227                     tot--;
1228                     switch (__vmssts) {
1229                         case SS$_NONEXPR:
1230                         case SS$_NOSUCHNODE:
1231                             SETERRNO(ESRCH,__vmssts);
1232                             break;
1233                         case SS$_NOPRIV:
1234                             SETERRNO(EPERM,__vmssts);
1235                             break;
1236                         default:
1237                             SETERRNO(EVMSERR,__vmssts);
1238                     }
1239                 }
1240             }
1241             break;
1242         }
1243 #endif
1244         if (val < 0) {
1245             val = -val;
1246             while (++mark <= sp) {
1247                 I32 proc = SvIVx(*mark);
1248                 APPLY_TAINT_PROPER();
1249 #ifdef HAS_KILLPG
1250                 if (PerlProc_killpg(proc,val))  /* BSD */
1251 #else
1252                 if (PerlProc_kill(-proc,val))   /* SYSV */
1253 #endif
1254                     tot--;
1255             }
1256         }
1257         else {
1258             while (++mark <= sp) {
1259                 I32 proc = SvIVx(*mark);
1260                 APPLY_TAINT_PROPER();
1261                 if (PerlProc_kill(proc, val))
1262                     tot--;
1263             }
1264         }
1265         break;
1266 #endif
1267     case OP_UNLINK:
1268         what = "unlink";
1269         APPLY_TAINT_PROPER();
1270         tot = sp - mark;
1271         while (++mark <= sp) {
1272             s = SvPVx(*mark, PL_na);
1273             APPLY_TAINT_PROPER();
1274             if (PL_euid || PL_unsafe) {
1275                 if (UNLINK(s))
1276                     tot--;
1277             }
1278             else {      /* don't let root wipe out directories without -U */
1279 #ifdef HAS_LSTAT
1280                 if (PerlLIO_lstat(s,&PL_statbuf) < 0 || S_ISDIR(PL_statbuf.st_mode))
1281 #else
1282                 if (PerlLIO_stat(s,&PL_statbuf) < 0 || S_ISDIR(PL_statbuf.st_mode))
1283 #endif
1284                     tot--;
1285                 else {
1286                     if (UNLINK(s))
1287                         tot--;
1288                 }
1289             }
1290         }
1291         break;
1292 #ifdef HAS_UTIME
1293     case OP_UTIME:
1294         what = "utime";
1295         APPLY_TAINT_PROPER();
1296         if (sp - mark > 2) {
1297 #if defined(I_UTIME) || defined(VMS)
1298             struct utimbuf utbuf;
1299 #else
1300             struct {
1301                 long    actime;
1302                 long    modtime;
1303             } utbuf;
1304 #endif
1305
1306             Zero(&utbuf, sizeof utbuf, char);
1307 #ifdef BIG_TIME
1308             utbuf.actime = (Time_t)SvNVx(*++mark);    /* time accessed */
1309             utbuf.modtime = (Time_t)SvNVx(*++mark);    /* time modified */
1310 #else
1311             utbuf.actime = SvIVx(*++mark);    /* time accessed */
1312             utbuf.modtime = SvIVx(*++mark);    /* time modified */
1313 #endif
1314             APPLY_TAINT_PROPER();
1315             tot = sp - mark;
1316             while (++mark <= sp) {
1317                 char *name = SvPVx(*mark, PL_na);
1318                 APPLY_TAINT_PROPER();
1319                 if (PerlLIO_utime(name, &utbuf))
1320                     tot--;
1321             }
1322         }
1323         else
1324             tot = 0;
1325         break;
1326 #endif
1327     }
1328     return tot;
1329
1330   taint_proper_label:
1331     TAINT_PROPER(what);
1332     return 0;   /* this should never happen */
1333
1334 #undef APPLY_TAINT_PROPER
1335 }
1336
1337 /* Do the permissions allow some operation?  Assumes statcache already set. */
1338 #ifndef VMS /* VMS' cando is in vms.c */
1339 I32
1340 cando(I32 bit, I32 effective, register struct stat *statbufp)
1341 {
1342 #ifdef DOSISH
1343     /* [Comments and code from Len Reed]
1344      * MS-DOS "user" is similar to UNIX's "superuser," but can't write
1345      * to write-protected files.  The execute permission bit is set
1346      * by the Miscrosoft C library stat() function for the following:
1347      *          .exe files
1348      *          .com files
1349      *          .bat files
1350      *          directories
1351      * All files and directories are readable.
1352      * Directories and special files, e.g. "CON", cannot be
1353      * write-protected.
1354      * [Comment by Tom Dinger -- a directory can have the write-protect
1355      *          bit set in the file system, but DOS permits changes to
1356      *          the directory anyway.  In addition, all bets are off
1357      *          here for networked software, such as Novell and
1358      *          Sun's PC-NFS.]
1359      */
1360
1361      /* Atari stat() does pretty much the same thing. we set x_bit_set_in_stat
1362       * too so it will actually look into the files for magic numbers
1363       */
1364      return (bit & statbufp->st_mode) ? TRUE : FALSE;
1365
1366 #else /* ! DOSISH */
1367     if ((effective ? PL_euid : PL_uid) == 0) {  /* root is special */
1368         if (bit == S_IXUSR) {
1369             if (statbufp->st_mode & 0111 || S_ISDIR(statbufp->st_mode))
1370                 return TRUE;
1371         }
1372         else
1373             return TRUE;                /* root reads and writes anything */
1374         return FALSE;
1375     }
1376     if (statbufp->st_uid == (effective ? PL_euid : PL_uid) ) {
1377         if (statbufp->st_mode & bit)
1378             return TRUE;        /* ok as "user" */
1379     }
1380     else if (ingroup((I32)statbufp->st_gid,effective)) {
1381         if (statbufp->st_mode & bit >> 3)
1382             return TRUE;        /* ok as "group" */
1383     }
1384     else if (statbufp->st_mode & bit >> 6)
1385         return TRUE;    /* ok as "other" */
1386     return FALSE;
1387 #endif /* ! DOSISH */
1388 }
1389 #endif /* ! VMS */
1390
1391 I32
1392 ingroup(I32 testgid, I32 effective)
1393 {
1394     if (testgid == (effective ? PL_egid : PL_gid))
1395         return TRUE;
1396 #ifdef HAS_GETGROUPS
1397 #ifndef NGROUPS
1398 #define NGROUPS 32
1399 #endif
1400     {
1401         Groups_t gary[NGROUPS];
1402         I32 anum;
1403
1404         anum = getgroups(NGROUPS,gary);
1405         while (--anum >= 0)
1406             if (gary[anum] == testgid)
1407                 return TRUE;
1408     }
1409 #endif
1410     return FALSE;
1411 }
1412
1413 #if defined(HAS_MSG) || defined(HAS_SEM) || defined(HAS_SHM)
1414
1415 I32
1416 do_ipcget(I32 optype, SV **mark, SV **sp)
1417 {
1418     dTHR;
1419     key_t key;
1420     I32 n, flags;
1421
1422     key = (key_t)SvNVx(*++mark);
1423     n = (optype == OP_MSGGET) ? 0 : SvIVx(*++mark);
1424     flags = SvIVx(*++mark);
1425     SETERRNO(0,0);
1426     switch (optype)
1427     {
1428 #ifdef HAS_MSG
1429     case OP_MSGGET:
1430         return msgget(key, flags);
1431 #endif
1432 #ifdef HAS_SEM
1433     case OP_SEMGET:
1434         return semget(key, n, flags);
1435 #endif
1436 #ifdef HAS_SHM
1437     case OP_SHMGET:
1438         return shmget(key, n, flags);
1439 #endif
1440 #if !defined(HAS_MSG) || !defined(HAS_SEM) || !defined(HAS_SHM)
1441     default:
1442         croak("%s not implemented", op_desc[optype]);
1443 #endif
1444     }
1445     return -1;                  /* should never happen */
1446 }
1447
1448 I32
1449 do_ipcctl(I32 optype, SV **mark, SV **sp)
1450 {
1451     dTHR;
1452     SV *astr;
1453     char *a;
1454     I32 id, n, cmd, infosize, getinfo;
1455     I32 ret = -1;
1456
1457     id = SvIVx(*++mark);
1458     n = (optype == OP_SEMCTL) ? SvIVx(*++mark) : 0;
1459     cmd = SvIVx(*++mark);
1460     astr = *++mark;
1461     infosize = 0;
1462     getinfo = (cmd == IPC_STAT);
1463
1464     switch (optype)
1465     {
1466 #ifdef HAS_MSG
1467     case OP_MSGCTL:
1468         if (cmd == IPC_STAT || cmd == IPC_SET)
1469             infosize = sizeof(struct msqid_ds);
1470         break;
1471 #endif
1472 #ifdef HAS_SHM
1473     case OP_SHMCTL:
1474         if (cmd == IPC_STAT || cmd == IPC_SET)
1475             infosize = sizeof(struct shmid_ds);
1476         break;
1477 #endif
1478 #ifdef HAS_SEM
1479     case OP_SEMCTL:
1480         if (cmd == IPC_STAT || cmd == IPC_SET)
1481             infosize = sizeof(struct semid_ds);
1482         else if (cmd == GETALL || cmd == SETALL)
1483         {
1484             struct semid_ds semds;
1485             union semun semun;
1486
1487             semun.buf = &semds;
1488             getinfo = (cmd == GETALL);
1489             if (Semctl(id, 0, IPC_STAT, semun) == -1)
1490                 return -1;
1491             infosize = semds.sem_nsems * sizeof(short);
1492                 /* "short" is technically wrong but much more portable
1493                    than guessing about u_?short(_t)? */
1494         }
1495         break;
1496 #endif
1497 #if !defined(HAS_MSG) || !defined(HAS_SEM) || !defined(HAS_SHM)
1498     default:
1499         croak("%s not implemented", op_desc[optype]);
1500 #endif
1501     }
1502
1503     if (infosize)
1504     {
1505         STRLEN len;
1506         if (getinfo)
1507         {
1508             SvPV_force(astr, len);
1509             a = SvGROW(astr, infosize+1);
1510         }
1511         else
1512         {
1513             a = SvPV(astr, len);
1514             if (len != infosize)
1515                 croak("Bad arg length for %s, is %lu, should be %ld",
1516                         op_desc[optype], (unsigned long)len, (long)infosize);
1517         }
1518     }
1519     else
1520     {
1521         IV i = SvIV(astr);
1522         a = (char *)i;          /* ouch */
1523     }
1524     SETERRNO(0,0);
1525     switch (optype)
1526     {
1527 #ifdef HAS_MSG
1528     case OP_MSGCTL:
1529         ret = msgctl(id, cmd, (struct msqid_ds *)a);
1530         break;
1531 #endif
1532 #ifdef HAS_SEM
1533     case OP_SEMCTL: {
1534             union semun unsemds;
1535
1536             unsemds.buf = (struct semid_ds *)a;
1537             ret = Semctl(id, n, cmd, unsemds);
1538         }
1539         break;
1540 #endif
1541 #ifdef HAS_SHM
1542     case OP_SHMCTL:
1543         ret = shmctl(id, cmd, (struct shmid_ds *)a);
1544         break;
1545 #endif
1546     }
1547     if (getinfo && ret >= 0) {
1548         SvCUR_set(astr, infosize);
1549         *SvEND(astr) = '\0';
1550         SvSETMAGIC(astr);
1551     }
1552     return ret;
1553 }
1554
1555 I32
1556 do_msgsnd(SV **mark, SV **sp)
1557 {
1558 #ifdef HAS_MSG
1559     dTHR;
1560     SV *mstr;
1561     char *mbuf;
1562     I32 id, msize, flags;
1563     STRLEN len;
1564
1565     id = SvIVx(*++mark);
1566     mstr = *++mark;
1567     flags = SvIVx(*++mark);
1568     mbuf = SvPV(mstr, len);
1569     if ((msize = len - sizeof(long)) < 0)
1570         croak("Arg too short for msgsnd");
1571     SETERRNO(0,0);
1572     return msgsnd(id, (struct msgbuf *)mbuf, msize, flags);
1573 #else
1574     croak("msgsnd not implemented");
1575 #endif
1576 }
1577
1578 I32
1579 do_msgrcv(SV **mark, SV **sp)
1580 {
1581 #ifdef HAS_MSG
1582     dTHR;
1583     SV *mstr;
1584     char *mbuf;
1585     long mtype;
1586     I32 id, msize, flags, ret;
1587     STRLEN len;
1588
1589     id = SvIVx(*++mark);
1590     mstr = *++mark;
1591     msize = SvIVx(*++mark);
1592     mtype = (long)SvIVx(*++mark);
1593     flags = SvIVx(*++mark);
1594     if (SvTHINKFIRST(mstr)) {
1595         if (SvREADONLY(mstr))
1596             croak("Can't msgrcv to readonly var");
1597         if (SvROK(mstr))
1598             sv_unref(mstr);
1599     }
1600     SvPV_force(mstr, len);
1601     mbuf = SvGROW(mstr, sizeof(long)+msize+1);
1602     
1603     SETERRNO(0,0);
1604     ret = msgrcv(id, (struct msgbuf *)mbuf, msize, mtype, flags);
1605     if (ret >= 0) {
1606         SvCUR_set(mstr, sizeof(long)+ret);
1607         *SvEND(mstr) = '\0';
1608     }
1609     return ret;
1610 #else
1611     croak("msgrcv not implemented");
1612 #endif
1613 }
1614
1615 I32
1616 do_semop(SV **mark, SV **sp)
1617 {
1618 #ifdef HAS_SEM
1619     dTHR;
1620     SV *opstr;
1621     char *opbuf;
1622     I32 id;
1623     STRLEN opsize;
1624
1625     id = SvIVx(*++mark);
1626     opstr = *++mark;
1627     opbuf = SvPV(opstr, opsize);
1628     if (opsize < sizeof(struct sembuf)
1629         || (opsize % sizeof(struct sembuf)) != 0) {
1630         SETERRNO(EINVAL,LIB$_INVARG);
1631         return -1;
1632     }
1633     SETERRNO(0,0);
1634     return semop(id, (struct sembuf *)opbuf, opsize/sizeof(struct sembuf));
1635 #else
1636     croak("semop not implemented");
1637 #endif
1638 }
1639
1640 I32
1641 do_shmio(I32 optype, SV **mark, SV **sp)
1642 {
1643 #ifdef HAS_SHM
1644     dTHR;
1645     SV *mstr;
1646     char *mbuf, *shm;
1647     I32 id, mpos, msize;
1648     STRLEN len;
1649     struct shmid_ds shmds;
1650
1651     id = SvIVx(*++mark);
1652     mstr = *++mark;
1653     mpos = SvIVx(*++mark);
1654     msize = SvIVx(*++mark);
1655     SETERRNO(0,0);
1656     if (shmctl(id, IPC_STAT, &shmds) == -1)
1657         return -1;
1658     if (mpos < 0 || msize < 0 || mpos + msize > shmds.shm_segsz) {
1659         SETERRNO(EFAULT,SS$_ACCVIO);            /* can't do as caller requested */
1660         return -1;
1661     }
1662     shm = (char *)shmat(id, (char*)NULL, (optype == OP_SHMREAD) ? SHM_RDONLY : 0);
1663     if (shm == (char *)-1)      /* I hate System V IPC, I really do */
1664         return -1;
1665     if (optype == OP_SHMREAD) {
1666         SvPV_force(mstr, len);
1667         mbuf = SvGROW(mstr, msize+1);
1668
1669         Copy(shm + mpos, mbuf, msize, char);
1670         SvCUR_set(mstr, msize);
1671         *SvEND(mstr) = '\0';
1672         SvSETMAGIC(mstr);
1673     }
1674     else {
1675         I32 n;
1676
1677         mbuf = SvPV(mstr, len);
1678         if ((n = len) > msize)
1679             n = msize;
1680         Copy(mbuf, shm + mpos, n, char);
1681         if (n < msize)
1682             memzero(shm + mpos + n, msize - n);
1683     }
1684     return shmdt(shm);
1685 #else
1686     croak("shm I/O not implemented");
1687 #endif
1688 }
1689
1690 #endif /* SYSV IPC */
1691