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