1 files changed, 403 insertions, 0 deletions
diff --git a/sys/fio/fseti.x b/sys/fio/fseti.x
new file mode 100644
index 00000000..42068096
--- /dev/null
+++ b/sys/fio/fseti.x
@@ -0,0 +1,403 @@
+# Copyright(c) 1986 Association of Universities for Research in Astronomy Inc.
+
+include	<config.h>
+include	<syserr.h>
+include	<error.h>
+include	<mach.h>
+include	<fset.h>
+include	<fio.h>
+
+# FSETI -- Set File I/O options.  FSETI is not intended to be called
+# routinely by user code.  To provide maximum flexibility, any FIO parameter
+# can be changed, and no checking is performed.  Hence, the file buffer size,
+# device, device channel, and so on can be changed during i/o to a file,
+# though doing so is probably an error.  User beware.
+# 
+# The only FIO parameters that should be set in applications programs are
+# F_FLUSHNL (flush output at end of every line of text), and occasionally
+# F_ADVICE (sequential or random).
+
+procedure fseti (fd, param, value)
+
+int	fd			# file in question
+int	param			# parameter to be set
+int	value			# value of parameter
+
+pointer	bp, ffp
+long	file_offset
+int	i, junk, outfd, flags
+bool	blocked_file, setraw, ndelay
+char	set_redraw[LEN_SETREDRAW]
+char	rawcmd[LEN_RAWCMD+1]
+
+int	await(), xisatty()
+include	<fio.com>
+
+begin
+	ffp = fiodes[fd]
+	if (fd <= 0 || ffp == NULL)
+	    iferr (call syserr (SYS_FILENOTOPEN))
+		call erract (EA_FATAL)
+
+	switch (param) {
+
+	case F_ADVICE:
+	    # Set file buffer size, based on expected type of i/o.  By default,
+	    # the device dependent OPTBUFSIZE is used.  If i/o is expected to
+	    # be very random, an integral multiple of the device block size is
+	    # used (beware of 1 char block files).  If highly sequential i/o is
+	    # expected, a large buffer is allocated.
+
+	    if (fd >= FIRST_FD && bufptr[fd] == NULL)
+		switch (value) {
+		case RANDOM:
+		    FBUFSIZE(ffp) = LEN_RANDBUF * max (1, FBLKSIZE(ffp))
+		case SEQUENTIAL:
+		    FBUFSIZE(ffp) = LEN_SEQBUF * FOPTBUFSIZE(ffp)
+		default:
+		    FBUFSIZE(ffp) = FOPTBUFSIZE(ffp)
+		}
+	    
+	case F_ASYNC:
+	    # Enable asynchronous i/o.
+	    ;						# not implemented
+
+	case F_BLKSIZE:
+	    # Set the device block size in chars.
+	    FBLKSIZE(ffp) = value
+
+	case F_BUFPTR, F_BUFSIZE:
+	    # An externally created buffer can be installed by setting F_BUFPTR
+	    # and either F_BUFSIZE or F_BUFTOP (do NOT forget to set both).
+	    # The file buffer size can be changed by a call to F_BUFSIZE,
+	    # even after doing i/o on a file. In both cases, the current file
+	    # offset will be retained.
+
+	    if (param == F_BUFSIZE && FBUFSIZE(ffp) == value)
+		return
+	    else if (bufptr[fd] != NULL) {
+		call flush (fd)
+		call frmbfs (fd)
+	    }
+
+	    if (param == F_BUFSIZE) {
+		FBUFSIZE(ffp) = value
+		if (buftop[fd] == NULL && bufptr[fd] != NULL)
+		    buftop[fd] = bufptr[fd] + value
+	    } else {
+		file_offset = LNOTE (fd)
+		bufptr[fd] = value
+		boffset[fd] = NULL
+		LSEEK (fd, file_offset)
+		if (buftop[fd] == NULL && FBUFSIZE(ffp) != NULL)
+		    buftop[fd] = bufptr[fd] + FBUFSIZE(ffp)
+	    }
+
+	case F_BUFTOP:
+	    # Set a pointer to the top of a buffer (first char after buffer).
+	    buftop[fd] = value
+	    if (FBUFSIZE(ffp) == NULL && bufptr[fd] != NULL)
+		FBUFSIZE(ffp) = buftop[fd] - bufptr[fd]
+
+	case F_FILESIZE:
+	    # Set the file size.  Should not be called by ordinary programs;
+	    # intended for use only in system code which writes to a file at
+	    # the kernel level, preventing FIO from keeping track of the file
+	    # size.
+
+	    FILSIZE(ffp) = value
+
+	case F_FIRSTBUFOFF:
+	    # FIO divides a random access binary file up into a series of
+	    # fixed size buffers, or file "pages".  By default the first buffer
+	    # is at file offset BOF=1, but this does not have to be the case,
+	    # and sometimes it is desirable to align the file buffers starting
+	    # at some format specific offset in the file.  Note that doing so
+	    # renders the file segment to the left of FIRSTBUFOFF inaccessible.
+
+	    call flush (fd)
+	    call frmbfs (fd)
+	    FIRSTBUFOFF(ffp) = value
+
+	case F_BUFTYPE:
+	    # Use file-local buffers or the global pool.
+	    ;						# not implemented
+
+	case F_CANCEL:
+	    # Cancel any buffered data.  For a blocked file, the file offset
+	    # is preserved, hence the only effect is to force the file buffer
+	    # to be refilled.  Any changes made to buffered data are cancelled
+	    # when the buffer is refilled.  For a streaming file, the i/o
+	    # pointers are reset to the beginning of the buffer, to force the
+	    # next read to refill the buffer, or to cause the next write to
+	    # start filling the buffer.
+
+	    call fcanpb (fd)
+	    blocked_file = (FBLKSIZE(ffp) > 0)
+	    if (blocked_file)
+		file_offset = LNOTE(fd)
+
+	    bp = bufptr[fd]
+	    if (FFIOMODE(ffp) != INACTIVE)
+		junk = await (fd)
+
+	    iop[fd] = bp
+	    itop[fd] = bp
+	    otop[fd] = bp
+	    
+	    if (blocked_file) {
+		boffset[fd] = 0		# invalidate buffer
+		LSEEK (fd, file_offset)
+	    } else
+		boffset[fd] = 1		# causes rewind to set iop=bp
+
+	    FILSTAT(ffp) = value
+
+	case F_CHANNEL:
+	    # Kernel i/o channel number.
+	    FCHAN(ffp) = value
+
+	case F_CLOBBER:
+	    # Allow NEW_FILE files to overwrite old files of the same name.
+	    call fset_env ("clobber", value)
+
+	case F_CLOSEFD:
+	    # If this option is set for a file descriptor, the host channel
+	    # is reopened every time an i/o operation takes place (aread or
+	    # awrite), and is closed while the channel is inactive.  This
+	    # is useful to save host system file descriptors, so that a
+	    # program may have a very large number of files "open" at any one
+	    # time (one is still limited by the maximum number of available
+	    # FIO file descriptors).  This option is supported only for binary
+	    # files opened in some mode other than NEW_FILE; special devices
+	    # are supported, but only if the device is randomly accessible and
+	    # does not map file segments in to memory.
+
+	    if (value == YES && FCLOSEFD(ffp) == NO) {
+		if (FTYPE(ffp) == TEXT_FILE)
+		    iferr (call filerr (FNAME(ffp), SYS_FCLFDTX))
+			call erract (EA_FATAL)
+		if (FMODE(ffp) == NEW_FILE)
+		    iferr (call filerr (FNAME(ffp), SYS_FCLFDNF))
+			call erract (EA_FATAL)
+
+		if (FCHAN(ffp) != ERR) {
+		    call zcall2 (ZCLSBF(ffp), FCHAN(ffp), junk)
+		    FCHAN(ffp) = ERR
+		}
+
+		FCLOSEFD(ffp) = YES
+
+	    } else if (value == NO) {
+		# Wait until the next i/o operation occurs to reopen the file.
+		FCLOSEFD(ffp) = NO
+	    }
+
+	case F_DEVICE:
+	    # Set entry point address of the read entry point of the device
+	    # driver for a file.
+
+	    for (i=1;  i < next_dev;  i=i+LEN_DTE)
+		if (value == zdev[i]) {
+		    FDEV(ffp) = i
+		    return
+		}
+	    iferr (call filerr (FNAME(ffp), SYS_FDEVNOTFOUND))
+		call erract (EA_FATAL)
+
+	case F_FILEWAIT:
+	    # Wait for a file to become accessible during open.
+	    call fset_env ("filewait", value)
+
+	case F_FLUSHNL:
+	    # Flush output when newline is seen.
+	    if (value == YES)
+		fflags[fd] = or (FF_FLUSH + FF_FLUSHNL, fflags[fd])
+	    else if (FTYPE(ffp) == TEXT_FILE)
+		fflags[fd] = and (not(FF_FLUSHNL), fflags[fd])
+	    else
+		fflags[fd] = and (not(FF_FLUSH + FF_FLUSHNL), fflags[fd])
+
+	case F_KEEP:
+	    # Keep a file open after program termination.
+	    if (value == YES)
+		fflags[fd] = or (FF_KEEP, fflags[fd])
+	    else
+		fflags[fd] = and (not(FF_KEEP), fflags[fd])
+
+	case F_MODE:
+	    # Set access mode of a file.
+	    switch (value) {
+	    case READ_ONLY:
+		fflags[fd] = and (not(FF_WRITE), fflags[fd])
+	    case READ_WRITE:
+		fflags[fd] = or (FF_READ + FF_WRITE, fflags[fd])
+	    case WRITE_ONLY:			# disable buf read in ffault
+		fflags[fd] = and (not(FF_READ), fflags[fd])
+	    default:
+		iferr (call filerr (FNAME(ffp), SYS_FILLEGMODE))
+		    call erract (EA_FATAL)
+	    }
+	    FMODE(ffp) = value
+
+	case F_NBUFS:
+	    # Set the number of i/o buffers for a file.
+	    ;						# not implemented
+
+	case F_ONEVERSION:
+	    # Keep only one version of each file (in UNIX fashion, as opposed
+	    # to the multiple versions of VMS).
+	    call fset_env ("multversions", value)
+
+	case F_PBBSIZE:
+	    # Set the push-back buffer size for a file.
+	    if (FPBBUF(ffp) == NULL)
+		FPBBUFSIZE(ffp) = value
+
+	case F_TYPE:
+	    # Set the file type (text, binary, etc).
+	    FTYPE(ffp) = value
+
+	    if (value == TEXT_FILE) {
+		fflags[fd] = or (FF_FLUSH, fflags[fd])
+
+	    } else if (value == SPOOL_FILE) {
+		# Reading and writing must be disabled for spool file or
+		# filbuf and flsbuf won't work.  Also set the block size
+		# to zero, since spool files are considered to be streaming
+		# files.
+
+		fflags[fd] = 0
+		FBLKSIZE(ffp) = 0
+	    }
+
+	case F_IOMODE, F_RAW:
+	    # Set the i/o mode for reading from a text device.  In raw mode,
+	    # if the text device is a terminal, each character is returned as
+	    # it is typed and most control characters are passed through on
+	    # reads.  If nonblocking raw mode is selected, each read will
+	    # return immediately whether or not there is any data to be read.
+	    # If no data could be read EOF is returned, but in RAWNB mode
+	    # this indicates merely that no input data was available.
+
+	    setraw = (and (value, IO_RAW) != 0)
+	    ndelay = (and (value, IO_NDELAY) != 0)
+
+	    fflags[fd] = and (not(FF_RAW+FF_NDELAY), fflags[fd])
+	    if (setraw) {
+		flags = FF_RAW
+		if (ndelay)
+		    flags = flags + FF_NDELAY
+		fflags[fd] = or (fflags[fd], flags)
+	    }
+
+	    # Send a special control sequence to the IRAF tty driver to
+	    # physically turn raw mode on or off.  If this were not done then
+	    # raw mode would not be turned off until the next read occurred,
+	    # which is counter intuitive and dangerous, as an abort might
+	    # occur before the read, leaving the terminal in never never
+	    # land.  The funny string must of course agree with what ZPUTTY
+	    # expects.
+
+	    if (fd == STDIN || fd == STDOUT || fd == STDERR)
+		outfd = STDOUT
+	    else
+		outfd = fd
+
+	    if (xisatty (outfd) == YES && and (fflags[outfd], FF_WRITE) != 0) {
+		call flush (outfd)
+
+		if (setraw) {
+		    call strcpy (RAWON, rawcmd, LEN_RAWCMD)
+		    if (ndelay)
+			rawcmd[LEN_RAWCMD+1] = 'N'
+		    else
+			rawcmd[LEN_RAWCMD+1] = 'B'
+		    rawcmd[LEN_RAWCMD+2] = EOS
+		    call putline (outfd, rawcmd)
+		} else
+		    call putline (outfd, RAWOFF)
+
+		call flush (outfd)
+	    }
+
+	case F_SETREDRAW:
+	    # Set the value of, and enable transmission of, the redraw control
+	    # code to be issued following process suspension while in raw mode.
+	    # Following a process suspend/continue while in raw mode, this code
+	    # will be returned to the applications process in the next GETC
+	    # call, as if it had been typed by the user.  The redraw control
+	    # code must be set to some positive nonzero value to enable
+	    # transmission of the code by the terminal driver.  Setting the
+	    # code to zero disables the feature.  The terminal driver (ZFIOTY)
+	    # for host systems which do not support process suspension will
+	    # recognize but ignore this control sequence.  Note that the redraw
+	    # control code to be returned by the driver is limited to a single
+	    # character, e.g., <ctrl/l> or <ctrl/r>, depending upon the
+	    # application.
+
+	    if (fd == STDIN || fd == STDOUT || fd == STDERR)
+		outfd = STDOUT
+	    else
+		outfd = fd
+
+	    if (xisatty (outfd) == YES && and (fflags[outfd], FF_WRITE) != 0) {
+		call strcpy (SETREDRAW, set_redraw, LEN_SETREDRAW)
+		set_redraw[LEN_SETREDRAW] = value
+		call flush (outfd)
+		call write (outfd, set_redraw, LEN_SETREDRAW)
+		call flush (outfd)
+	    }
+
+	case F_REDIR:
+	    # Set redir_fd to a negative value to indicate that the stream
+	    # has been redirected in the parent process.  If redir_fd is
+	    # already set to a nonzero value, indicating that i/o has already
+	    # been redirected either locally or in the parent, do nothing.
+
+	    if (value == YES) {
+		if (redir_fd[fd] == 0)
+		    redir_fd[fd] = -1
+	    } else
+		redir_fd[fd] = 0
+
+	case F_VALIDATE:
+	    # Validate the contents of the FIO buffer, e.g., after an i/o
+	    # error has occurred during AREAD but it is thought that at least
+	    # part of the data in the buffer may be valid.  VALUE is the
+	    # number of chars for which the FIO buffer is to be validated
+	    # in the next call to FILBUF.  This must be the only case for
+	    # which FNCHARS can take on a negative value.
+
+	    FNCHARS(ffp) = -value
+	    FNBYTES(ffp) = value * SZB_CHAR
+	    FILSTAT(ffp) = OK
+
+	default:
+	    # This is a fatal error to prevent error recursion.
+	    iferr (call filerr (FNAME(ffp), SYS_FSETUKNPAR))
+		call erract (EA_FATAL)
+	}
+end
+
+
+# FSET_ENV -- Set the value of a boolean environment variable used for file
+# control.  A set environment call affects all programs in the current process
+# and in all subprocesses, unless overriden by another SET statement or
+# forgotten by ENVFREE.
+
+procedure fset_env (envvar, value)
+
+char	envvar[ARB]		# name of environment variable to be set
+int	value			# YES or NO
+int	junk
+int	envputs()
+
+begin
+	switch (value) {
+	case YES:
+	    junk = envputs (envvar, "yes")
+	case NO:
+	    junk = envputs (envvar, "no")
+	}
+end