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