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