X-Git-Url: https://git.hcoop.net/bpt/guile.git/blobdiff_plain/8588fa1267b759e5a55497d5a18552335effc29c..283a1a0e774770476d51aa47c6ee050f42d03957:/libguile/ioext.c diff --git a/libguile/ioext.c b/libguile/ioext.c dissimilarity index 70% index 37b8bdc34..08229765a 100644 --- a/libguile/ioext.c +++ b/libguile/ioext.c @@ -1,458 +1,528 @@ -/* Copyright (C) 1995 Free Software Foundation, Inc. - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2, or (at your option) - * any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this software; see the file COPYING. If not, write to - * the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. - * - * As a special exception, the Free Software Foundation gives permission - * for additional uses of the text contained in its release of GUILE. - * - * The exception is that, if you link the GUILE library with other files - * to produce an executable, this does not by itself cause the - * resulting executable to be covered by the GNU General Public License. - * Your use of that executable is in no way restricted on account of - * linking the GUILE library code into it. - * - * This exception does not however invalidate any other reasons why - * the executable file might be covered by the GNU General Public License. - * - * This exception applies only to the code released by the - * Free Software Foundation under the name GUILE. If you copy - * code from other Free Software Foundation releases into a copy of - * GUILE, as the General Public License permits, the exception does - * not apply to the code that you add in this way. To avoid misleading - * anyone as to the status of such modified files, you must delete - * this exception notice from them. - * - * If you write modifications of your own for GUILE, it is your choice - * whether to permit this exception to apply to your modifications. - * If you do not wish that, delete this exception notice. - */ - - - -#include -#include "fd.h" -#include "_scm.h" -#include "fports.h" - -#include "ioext.h" - -#ifdef HAVE_STRING_H -#include -#endif -#ifdef HAVE_UNISTD_H -#include -#endif - - -SCM_PROC (s_sys_ftell, "ftell", 1, 0, 0, scm_sys_ftell); - -SCM -scm_sys_ftell (port) - SCM port; -{ - long pos; - SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_sys_ftell); - SCM_SYSCALL (pos = ftell ((FILE *)SCM_STREAM (port))); - if (pos < 0) - scm_syserror (s_sys_ftell); - if (pos > 0 && SCM_CRDYP (port)) - pos--; - return scm_long2num (pos); -} - - - -SCM_PROC (s_sys_fseek, "fseek", 3, 0, 0, scm_sys_fseek); - -SCM -scm_sys_fseek (port, offset, whence) - SCM port; - SCM offset; - SCM whence; -{ - int rv; - long loff; - - SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_sys_fseek); - loff = scm_num2long (offset, (char *)SCM_ARG2, s_sys_fseek); - SCM_ASSERT (SCM_INUMP (whence) && (SCM_INUM (whence) < 3) && (SCM_INUM (whence) >= 0), - whence, SCM_ARG3, s_sys_fseek); - - SCM_CLRDY (port); /* Clear ungetted char */ - /* Values of whence are interned in scm_init_ioext. */ - rv = fseek ((FILE *)SCM_STREAM (port), loff, SCM_INUM (whence)); - if (rv != 0) - scm_syserror (s_sys_fseek); - return SCM_UNSPECIFIED; -} - - - -SCM_PROC (s_sys_freopen, "freopen", 3, 0, 0, scm_sys_freopen); - -SCM -scm_sys_freopen (filename, modes, port) - SCM filename; - SCM modes; - SCM port; -{ - FILE *f; - SCM_ASSERT (SCM_NIMP (filename) && SCM_STRINGP (filename), filename, SCM_ARG1, s_sys_freopen); - SCM_ASSERT (SCM_NIMP (modes) && SCM_STRINGP (modes), modes, SCM_ARG2, s_sys_freopen); - SCM_DEFER_INTS; - SCM_ASSERT (SCM_NIMP (port) && SCM_FPORTP (port), port, SCM_ARG3, s_sys_freopen); - SCM_SYSCALL (f = freopen (SCM_CHARS (filename), SCM_CHARS (modes), (FILE *)SCM_STREAM (port))); - if (!f) - { - SCM p; - p = port; - port = SCM_MAKINUM (errno); - SCM_SETAND_CAR (p, ~SCM_OPN); - scm_remove_from_port_table (p); - } - else - { - SCM_SETCAR (port, scm_tc16_fport | scm_mode_bits (SCM_CHARS (modes))); - SCM_SETSTREAM (port, (SCM)f); - SCM_SETCAR (port, scm_tc16_fport | scm_mode_bits (SCM_CHARS (modes))); - if (SCM_BUF0 & SCM_CAR (port)) - scm_setbuf0 (port); - } - SCM_ALLOW_INTS; - return port; -} - - - -SCM_PROC (s_sys_duplicate_port, "duplicate-port", 2, 0, 0, scm_sys_duplicate_port); - -SCM -scm_sys_duplicate_port (oldpt, modes) - SCM oldpt; - SCM modes; -{ - int oldfd; - int newfd; - FILE *f; - SCM newpt; - SCM_ASSERT (SCM_NIMP (oldpt) && SCM_OPPORTP (oldpt), oldpt, SCM_ARG1, s_sys_duplicate_port); - SCM_ASSERT (SCM_NIMP (modes) && SCM_STRINGP (modes), modes, SCM_ARG2, s_sys_duplicate_port); - SCM_NEWCELL (newpt); - SCM_DEFER_INTS; - oldfd = fileno ((FILE *)SCM_STREAM (oldpt)); - if (oldfd == -1) - scm_syserror (s_sys_duplicate_port); - SCM_SYSCALL (newfd = dup (oldfd)); - if (newfd == -1) - scm_syserror (s_sys_duplicate_port); - f = fdopen (newfd, SCM_CHARS (modes)); - if (!f) - { - SCM_SYSCALL (close (newfd)); - scm_syserror (s_sys_duplicate_port); - } - { - struct scm_port_table * pt; - pt = scm_add_to_port_table (newpt); - SCM_SETPTAB_ENTRY (newpt, pt); - SCM_SETCAR (newpt, scm_tc16_fport | scm_mode_bits (SCM_CHARS (modes))); - if (SCM_BUF0 & SCM_CAR (newpt)) - scm_setbuf0 (newpt); - SCM_SETSTREAM (newpt, (SCM)f); - SCM_PTAB_ENTRY (newpt)->file_name = SCM_PTAB_ENTRY (oldpt)->file_name; - } - SCM_ALLOW_INTS; - return newpt; -} - - - -SCM_PROC (s_sys_redirect_port, "redirect-port", 2, 0, 0, scm_sys_redirect_port); - -SCM -scm_sys_redirect_port (into_pt, from_pt) - SCM into_pt; - SCM from_pt; -{ - int ans, oldfd, newfd; - SCM_DEFER_INTS; - SCM_ASSERT (SCM_NIMP (into_pt) && SCM_OPPORTP (into_pt), into_pt, SCM_ARG1, s_sys_redirect_port); - SCM_ASSERT (SCM_NIMP (from_pt) && SCM_OPPORTP (from_pt), from_pt, SCM_ARG2, s_sys_redirect_port); - oldfd = fileno ((FILE *)SCM_STREAM (into_pt)); - if (oldfd == -1) - scm_syserror (s_sys_redirect_port); - newfd = fileno ((FILE *)SCM_STREAM (from_pt)); - if (newfd == -1) - scm_syserror (s_sys_redirect_port); - SCM_SYSCALL (ans = dup2 (oldfd, newfd)); - if (ans == -1) - scm_syserror (s_sys_redirect_port); - SCM_ALLOW_INTS; - return SCM_UNSPECIFIED; -} - -SCM_PROC (s_sys_fileno, "fileno", 1, 0, 0, scm_sys_fileno); - -SCM -scm_sys_fileno (port) - SCM port; -{ - int fd; - SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_sys_fileno); - fd = fileno ((FILE *)SCM_STREAM (port)); - if (fd == -1) - scm_syserror (s_sys_fileno); - return SCM_MAKINUM (fd); -} - -SCM_PROC (s_sys_isatty, "isatty?", 1, 0, 0, scm_sys_isatty_p); - -SCM -scm_sys_isatty_p (port) - SCM port; -{ - int rv; - SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_sys_isatty); - rv = fileno ((FILE *)SCM_STREAM (port)); - if (rv == -1) - scm_syserror (s_sys_isatty); - rv = isatty (rv); - return rv ? SCM_BOOL_T : SCM_BOOL_F; -} - - - -SCM_PROC (s_sys_fdopen, "fdopen", 2, 0, 0, scm_sys_fdopen); - -SCM -scm_sys_fdopen (fdes, modes) - SCM fdes; - SCM modes; -{ - FILE *f; - SCM port; - struct scm_port_table * pt; - - SCM_ASSERT (SCM_INUMP (fdes), fdes, SCM_ARG1, s_sys_fdopen); - SCM_ASSERT (SCM_NIMP (modes) && SCM_STRINGP (modes), modes, SCM_ARG2, s_sys_fdopen); - SCM_NEWCELL (port); - SCM_DEFER_INTS; - f = fdopen (SCM_INUM (fdes), SCM_CHARS (modes)); - if (f == NULL) - scm_syserror (s_sys_fdopen); - pt = scm_add_to_port_table (port); - SCM_SETPTAB_ENTRY (port, pt); - SCM_SETCAR (port, scm_tc16_fport | scm_mode_bits (SCM_CHARS (modes))); - if (SCM_BUF0 & SCM_CAR (port)) - scm_setbuf0 (port); - SCM_SETSTREAM (port, (SCM)f); - SCM_ALLOW_INTS; - return port; -} - - - -/* Move a port's underlying file descriptor to a given value. - * Returns #f if fdes is already the given value. - * #t if fdes moved. - * MOVE->FDES is implemented in Scheme and calls this primitive. - */ -SCM_PROC (s_sys_primitive_move_to_fdes, "primitive-move->fdes", 2, 0, 0, scm_sys_primitive_move_to_fdes); - -SCM -scm_sys_primitive_move_to_fdes (port, fd) - SCM port; - SCM fd; -{ - FILE *stream; - int old_fd; - int new_fd; - int rv; - - SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_sys_primitive_move_to_fdes); - SCM_ASSERT (SCM_INUMP (fd), fd, SCM_ARG2, s_sys_primitive_move_to_fdes); - SCM_DEFER_INTS; - stream = (FILE *)SCM_STREAM (port); - old_fd = fileno (stream); - new_fd = SCM_INUM (fd); - if (old_fd == new_fd) - { - SCM_ALLOW_INTS; - return SCM_BOOL_F; - } - scm_evict_ports (new_fd); - rv = dup2 (old_fd, new_fd); - if (rv == -1) - scm_syserror (s_sys_primitive_move_to_fdes); - scm_setfileno (stream, new_fd); - SCM_SYSCALL (close (old_fd)); - SCM_ALLOW_INTS; - return SCM_BOOL_T; -} - - -void -scm_setfileno (fs, fd) - FILE *fs; - int fd; -{ -#ifdef SET_FILE_FD_FIELD - SET_FILE_FD_FIELD(fs, fd); -#else - Configure could not guess the name of the correct field in a FILE *. - - This function needs to be ported to your system. - - SET_FILE_FD_FIELD should change the descriptor refered to by a stdio - stream, and nothing else. - - The way to port this file is to add cases to configure.in. Search - that file for "SET_FILE_FD_FIELD" and follow the examples there. -#endif -} - -/* Move ports with the specified file descriptor to new descriptors, - * reseting the revealed count to 0. - * Should be called with SCM_DEFER_INTS active. - */ - -void -scm_evict_ports (fd) - int fd; -{ - int i; - - for (i = 0; i < scm_port_table_size; i++) - { - if (SCM_FPORTP (scm_port_table[i]->port) - && fileno ((FILE *)SCM_STREAM (scm_port_table[i]->port)) == fd) - { - scm_setfileno ((FILE *)SCM_STREAM (scm_port_table[i]->port), dup (fd)); - scm_set_port_revealed_x (scm_port_table[i]->port, SCM_MAKINUM (0)); - } - } -} - -/* Return a list of ports using a given file descriptor. */ -SCM_PROC(s_fdes_to_ports, "fdes->ports", 1, 0, 0, scm_fdes_to_ports); - -SCM -scm_fdes_to_ports (fd) - SCM fd; -{ - SCM result = SCM_EOL; - int int_fd; - int i; - - SCM_ASSERT (SCM_INUMP (fd), fd, SCM_ARG1, s_fdes_to_ports); - int_fd = SCM_INUM (fd); - - SCM_DEFER_INTS; - for (i = 0; i < scm_port_table_size; i++) - { - if (SCM_FPORTP (scm_port_table[i]->port) - && fileno ((FILE *)SCM_STREAM (scm_port_table[i]->port)) == int_fd) - result = scm_cons (scm_port_table[i]->port, result); - } - SCM_ALLOW_INTS; - return result; -} - - -void -scm_init_ioext () -{ - /* fseek() symbols. */ - scm_sysintern ("SEEK_SET", SCM_MAKINUM (SEEK_SET)); - scm_sysintern ("SEEK_CUR", SCM_MAKINUM (SEEK_CUR)); - scm_sysintern ("SEEK_END", SCM_MAKINUM (SEEK_END)); - - /* File type/permission bits. */ -#ifdef S_IRUSR - scm_sysintern ("S_IRUSR", SCM_MAKINUM (S_IRUSR)); -#endif -#ifdef S_IWUSR - scm_sysintern ("S_IWUSR", SCM_MAKINUM (S_IWUSR)); -#endif -#ifdef S_IXUSR - scm_sysintern ("S_IXUSR", SCM_MAKINUM (S_IXUSR)); -#endif -#ifdef S_IRWXU - scm_sysintern ("S_IRWXU", SCM_MAKINUM (S_IRWXU)); -#endif - -#ifdef S_IRGRP - scm_sysintern ("S_IRGRP", SCM_MAKINUM (S_IRGRP)); -#endif -#ifdef S_IWGRP - scm_sysintern ("S_IWGRP", SCM_MAKINUM (S_IWGRP)); -#endif -#ifdef S_IXGRP - scm_sysintern ("S_IXGRP", SCM_MAKINUM (S_IXGRP)); -#endif -#ifdef S_IRWXG - scm_sysintern ("S_IRWXG", SCM_MAKINUM (S_IRWXG)); -#endif - -#ifdef S_IROTH - scm_sysintern ("S_IROTH", SCM_MAKINUM (S_IROTH)); -#endif -#ifdef S_IWOTH - scm_sysintern ("S_IWOTH", SCM_MAKINUM (S_IWOTH)); -#endif -#ifdef S_IXOTH - scm_sysintern ("S_IXOTH", SCM_MAKINUM (S_IXOTH)); -#endif -#ifdef S_IRWXO - scm_sysintern ("S_IRWXO", SCM_MAKINUM (S_IRWXO)); -#endif - -#ifdef S_ISUID - scm_sysintern ("S_ISUID", SCM_MAKINUM (S_ISUID)); -#endif -#ifdef S_ISGID - scm_sysintern ("S_ISGID", SCM_MAKINUM (S_ISGID)); -#endif -#ifdef S_ISVTX - scm_sysintern ("S_ISVTX", SCM_MAKINUM (S_ISVTX)); -#endif - -#ifdef S_IFMT - scm_sysintern ("S_IFMT", SCM_MAKINUM (S_IFMT)); -#endif -#ifdef S_IFDIR - scm_sysintern ("S_IFDIR", SCM_MAKINUM (S_IFDIR)); -#endif -#ifdef S_IFCHR - scm_sysintern ("S_IFCHR", SCM_MAKINUM (S_IFCHR)); -#endif -#ifdef S_IFBLK - scm_sysintern ("S_IFBLK", SCM_MAKINUM (S_IFBLK)); -#endif -#ifdef S_IFREG - scm_sysintern ("S_IFREG", SCM_MAKINUM (S_IFREG)); -#endif -#ifdef S_IFLNK - scm_sysintern ("S_IFLNK", SCM_MAKINUM (S_IFLNK)); -#endif -#ifdef S_IFSOCK - scm_sysintern ("S_IFSOCK", SCM_MAKINUM (S_IFSOCK)); -#endif -#ifdef S_IFIFO - scm_sysintern ("S_IFIFO", SCM_MAKINUM (S_IFIFO)); -#endif -#include "ioext.x" -} - +/* Copyright (C) 1995, 1996, 1997, 1998, 1999 Free Software Foundation, Inc. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2, or (at your option) + * any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this software; see the file COPYING. If not, write to + * the Free Software Foundation, Inc., 59 Temple Place, Suite 330, + * Boston, MA 02111-1307 USA + * + * As a special exception, the Free Software Foundation gives permission + * for additional uses of the text contained in its release of GUILE. + * + * The exception is that, if you link the GUILE library with other files + * to produce an executable, this does not by itself cause the + * resulting executable to be covered by the GNU General Public License. + * Your use of that executable is in no way restricted on account of + * linking the GUILE library code into it. + * + * This exception does not however invalidate any other reasons why + * the executable file might be covered by the GNU General Public License. + * + * This exception applies only to the code released by the + * Free Software Foundation under the name GUILE. If you copy + * code from other Free Software Foundation releases into a copy of + * GUILE, as the General Public License permits, the exception does + * not apply to the code that you add in this way. To avoid misleading + * anyone as to the status of such modified files, you must delete + * this exception notice from them. + * + * If you write modifications of your own for GUILE, it is your choice + * whether to permit this exception to apply to your modifications. + * If you do not wish that, delete this exception notice. */ + + + +#include +#include "_scm.h" +#include "ports.h" +#include "read.h" +#include "fports.h" +#include "unif.h" +#include "chars.h" + +#include "ioext.h" + +#include + +#ifdef HAVE_STRING_H +#include +#endif +#ifdef HAVE_UNISTD_H +#include +#endif + + +SCM_PROC (s_read_delimited_x, "%read-delimited!", 3, 3, 0, scm_read_delimited_x); + +SCM +scm_read_delimited_x (delims, buf, gobble, port, start, end) + SCM delims; + SCM buf; + SCM gobble; + SCM port; + SCM start; + SCM end; +{ + long j; + char *cbuf; + long cstart; + long cend; + int c; + char *cdelims; + int num_delims; + + SCM_ASSERT (SCM_NIMP (delims) && SCM_ROSTRINGP (delims), + delims, SCM_ARG1, s_read_delimited_x); + cdelims = SCM_ROCHARS (delims); + num_delims = SCM_ROLENGTH (delims); + SCM_ASSERT (SCM_NIMP (buf) && SCM_STRINGP (buf), + buf, SCM_ARG2, s_read_delimited_x); + cbuf = SCM_CHARS (buf); + cend = SCM_LENGTH (buf); + if (SCM_UNBNDP (port)) + port = scm_cur_inp; + else + { + SCM_ASSERT (SCM_NIMP (port) && SCM_OPINPORTP (port), + port, SCM_ARG1, s_read_delimited_x); + } + + if (SCM_UNBNDP (start)) + cstart = 0; + else + { + cstart = scm_num2long (start, + (char *) SCM_ARG5, s_read_delimited_x); + if (cstart < 0 || cstart >= cend) + scm_out_of_range (s_read_delimited_x, start); + + if (!SCM_UNBNDP (end)) + { + long tend = scm_num2long (end, (char *) SCM_ARG6, + s_read_delimited_x); + if (tend <= cstart || tend > cend) + scm_out_of_range (s_read_delimited_x, end); + cend = tend; + } + } + + for (j = cstart; j < cend; j++) + { + int k; + + c = scm_getc (port); + for (k = 0; k < num_delims; k++) + { + if (cdelims[k] == c) + { + if (SCM_FALSEP (gobble)) + scm_ungetc (c, port); + + return scm_cons (SCM_MAKICHR (c), + scm_long2num (j - cstart)); + } + } + if (c == EOF) + return scm_cons (SCM_EOF_VAL, + scm_long2num (j - cstart)); + + cbuf[j] = c; + } + return scm_cons (SCM_BOOL_F, scm_long2num (j - cstart)); +} + +static unsigned char * +scm_do_read_line (SCM port, int *len_p) +{ + scm_port *pt = SCM_PTAB_ENTRY (port); + unsigned char *end; + + /* I thought reading lines was simple. Mercy me. */ + + /* The common case: the buffer contains a complete line. + This needs to be fast. */ + if ((end = memchr (pt->read_pos, '\n', (pt->read_end - pt->read_pos))) + != 0) + { + int buf_len = (end + 1) - pt->read_pos; + /* Allocate a buffer of the perfect size. */ + unsigned char *buf = malloc (buf_len + 1); + + memcpy (buf, pt->read_pos, buf_len); + pt->read_pos += buf_len; + + buf[buf_len] = '\0'; + + *len_p = buf_len; + return buf; + } + + /* The buffer contains no newlines. */ + { + /* When live, len is always the number of characters in the + current buffer that are part of the current line. */ + int len = (pt->read_end - pt->read_pos); + int buf_size = (len < 50) ? 60 : len * 2; + /* Invariant: buf always has buf_size + 1 characters allocated; + the `+ 1' is for the final '\0'. */ + unsigned char *buf = malloc (buf_size + 1); + int buf_len = 0; + int c; + + for (;;) + { + if (buf_len + len > buf_size) + { + int new_size = (buf_len + len) * 2; + buf = realloc (buf, new_size + 1); + buf_size = new_size; + } + + /* Copy what we've got out of the port, into our buffer. */ + memcpy (buf + buf_len, pt->read_pos, len); + buf_len += len; + pt->read_pos += len; + + /* If we had seen a newline, we're done now. */ + if (end) + break; + + /* Get more characters. I think having fill_buffer return a + character is not terribly graceful... */ + c = scm_fill_buffer (port); + if (c == EOF) + { + /* If we're missing a final newline in the file, return + what we did get, sans newline. */ + if (buf_len > 0) + break; + + free (buf); + return 0; + } + + /* ... because it makes us duplicate code here... */ + if (buf_len + 1 > buf_size) + { + int new_size = buf_size * 2; + buf = realloc (buf, new_size + 1); + buf_size = new_size; + } + + /* ... and this is really a duplication of the memcpy and + memchr calls, on a single-byte buffer. */ + buf[buf_len++] = c; + if (c == '\n') + break; + + /* Search the buffer for newlines. */ + if ((end = memchr (pt->read_pos, '\n', + (len = (pt->read_end - pt->read_pos)))) + != 0) + len = (end - pt->read_pos) + 1; + } + + /* I wonder how expensive this realloc is. */ + buf = realloc (buf, buf_len + 1); + buf[buf_len] = '\0'; + *len_p = buf_len; + return buf; + } +} + + +/* + * %read-line + * truncates any terminating newline from its input, and returns + * a cons of the string read and its terminating character. Doing + * so makes it easy to implement the hairy `read-line' options + * efficiently in Scheme. + */ + +SCM_PROC (s_read_line, "%read-line", 0, 1, 0, scm_read_line); + +SCM +scm_read_line (port) + SCM port; +{ + scm_port *pt; + char *s; + int slen; + SCM line, term; + + if (SCM_UNBNDP (port)) + port = scm_cur_inp; + else + { + SCM_ASSERT (SCM_NIMP (port) && SCM_OPINPORTP (port), + port, SCM_ARG1, s_read_line); + } + + pt = SCM_PTAB_ENTRY (port); + if (pt->rw_active == SCM_PORT_WRITE) + scm_ptobs[SCM_PTOBNUM (port)].fflush (port); + + s = scm_do_read_line (port, &slen); + + if (s == NULL) + term = line = SCM_EOF_VAL; + else + { + if (s[slen-1] == '\n') + { + term = SCM_MAKICHR ('\n'); + s[slen-1] = '\0'; + line = scm_take_str (s, slen-1); + SCM_INCLINE (port); + } + else + { + /* Fix: we should check for eof on the port before assuming this. */ + term = SCM_EOF_VAL; + line = scm_take_str (s, slen); + SCM_COL (port) += slen; + } + } + + if (pt->rw_random) + pt->rw_active = SCM_PORT_READ; + + return scm_cons (line, term); +} + +SCM_PROC (s_write_line, "write-line", 1, 1, 0, scm_write_line); + +SCM +scm_write_line (obj, port) + SCM obj; + SCM port; +{ + scm_display (obj, port); + return scm_newline (port); +} + +SCM_PROC (s_ftell, "ftell", 1, 0, 0, scm_ftell); + +SCM +scm_ftell (object) + SCM object; +{ + return scm_lseek (object, SCM_INUM0, SCM_MAKINUM (SEEK_CUR)); +} + +SCM_PROC (s_fseek, "fseek", 3, 0, 0, scm_fseek); + +SCM +scm_fseek (object, offset, whence) + SCM object; + SCM offset; + SCM whence; +{ + scm_lseek (object, offset, whence); + + return SCM_UNSPECIFIED; +} + +SCM_PROC (s_redirect_port, "redirect-port", 2, 0, 0, scm_redirect_port); + +SCM +scm_redirect_port (old, new) + SCM old; + SCM new; +{ + int ans, oldfd, newfd; + struct scm_fport *fp; + + old = SCM_COERCE_OUTPORT (old); + new = SCM_COERCE_OUTPORT (new); + + SCM_ASSERT (SCM_NIMP (old) && SCM_OPFPORTP (old), old, SCM_ARG1, s_redirect_port); + SCM_ASSERT (SCM_NIMP (new) && SCM_OPFPORTP (new), new, SCM_ARG2, s_redirect_port); + oldfd = SCM_FPORT_FDES (old); + fp = SCM_FSTREAM (new); + newfd = fp->fdes; + if (oldfd != newfd) + { + scm_port *pt = SCM_PTAB_ENTRY (new); + scm_port *old_pt = SCM_PTAB_ENTRY (old); + scm_ptobfuns *ptob = &scm_ptobs[SCM_PTOBNUM (new)]; + + /* must flush to old fdes. */ + if (pt->rw_active == SCM_PORT_WRITE) + ptob->fflush (new); + else if (pt->rw_active == SCM_PORT_READ) + scm_read_flush (new); + ans = dup2 (oldfd, newfd); + if (ans == -1) + scm_syserror (s_redirect_port); + pt->rw_random = old_pt->rw_random; + /* continue using existing buffers, even if inappropriate. */ + } + return SCM_UNSPECIFIED; +} + +SCM_PROC (s_dup_to_fdes, "dup->fdes", 1, 1, 0, scm_dup_to_fdes); +SCM +scm_dup_to_fdes (SCM fd_or_port, SCM fd) +{ + int oldfd, newfd, rv; + + fd_or_port = SCM_COERCE_OUTPORT (fd_or_port); + + if (SCM_INUMP (fd_or_port)) + oldfd = SCM_INUM (fd_or_port); + else + { + SCM_ASSERT (SCM_NIMP (fd_or_port) && SCM_OPFPORTP (fd_or_port), + fd_or_port, SCM_ARG1, s_dup_to_fdes); + oldfd = SCM_FPORT_FDES (fd_or_port); + } + + if (SCM_UNBNDP (fd)) + { + newfd = dup (oldfd); + if (newfd == -1) + scm_syserror (s_dup_to_fdes); + fd = SCM_MAKINUM (newfd); + } + else + { + SCM_ASSERT (SCM_INUMP (fd), fd, SCM_ARG2, s_dup_to_fdes); + newfd = SCM_INUM (fd); + if (oldfd != newfd) + { + scm_evict_ports (newfd); /* see scsh manual. */ + rv = dup2 (oldfd, newfd); + if (rv == -1) + scm_syserror (s_dup_to_fdes); + } + } + return fd; +} + +SCM_PROC (s_fileno, "fileno", 1, 0, 0, scm_fileno); + +SCM +scm_fileno (port) + SCM port; +{ + port = SCM_COERCE_OUTPORT (port); + SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, + s_fileno); + return SCM_MAKINUM (SCM_FPORT_FDES (port)); +} + +SCM_PROC (s_isatty, "isatty?", 1, 0, 0, scm_isatty_p); + +SCM +scm_isatty_p (port) + SCM port; +{ + int rv; + + port = SCM_COERCE_OUTPORT (port); + + if (!(SCM_NIMP (port) && SCM_OPFPORTP (port))) + return SCM_BOOL_F; + + rv = isatty (SCM_FPORT_FDES (port)); + return rv ? SCM_BOOL_T : SCM_BOOL_F; +} + + + +SCM_PROC (s_fdopen, "fdopen", 2, 0, 0, scm_fdopen); + +SCM +scm_fdopen (fdes, modes) + SCM fdes; + SCM modes; +{ + SCM port; + + SCM_ASSERT (SCM_INUMP (fdes), fdes, SCM_ARG1, s_fdopen); + SCM_ASSERT (SCM_NIMP (modes) && SCM_ROSTRINGP (modes), modes, SCM_ARG2, + s_fdopen); + SCM_COERCE_SUBSTR (modes); + port = scm_fdes_to_port (SCM_INUM (fdes), SCM_ROCHARS (modes), SCM_BOOL_F); + return port; +} + + + +/* Move a port's underlying file descriptor to a given value. + * Returns #f if fdes is already the given value. + * #t if fdes moved. + * MOVE->FDES is implemented in Scheme and calls this primitive. + */ +SCM_PROC (s_primitive_move_to_fdes, "primitive-move->fdes", 2, 0, 0, scm_primitive_move_to_fdes); + +SCM +scm_primitive_move_to_fdes (port, fd) + SCM port; + SCM fd; +{ + struct scm_fport *stream; + int old_fd; + int new_fd; + int rv; + + port = SCM_COERCE_OUTPORT (port); + + SCM_ASSERT (SCM_NIMP (port) && SCM_OPFPORTP (port), port, SCM_ARG1, s_primitive_move_to_fdes); + SCM_ASSERT (SCM_INUMP (fd), fd, SCM_ARG2, s_primitive_move_to_fdes); + stream = SCM_FSTREAM (port); + old_fd = stream->fdes; + new_fd = SCM_INUM (fd); + if (old_fd == new_fd) + { + return SCM_BOOL_F; + } + scm_evict_ports (new_fd); + rv = dup2 (old_fd, new_fd); + if (rv == -1) + scm_syserror (s_primitive_move_to_fdes); + stream->fdes = new_fd; + SCM_SYSCALL (close (old_fd)); + return SCM_BOOL_T; +} + +/* Return a list of ports using a given file descriptor. */ +SCM_PROC(s_fdes_to_ports, "fdes->ports", 1, 0, 0, scm_fdes_to_ports); + +SCM +scm_fdes_to_ports (fd) + SCM fd; +{ + SCM result = SCM_EOL; + int int_fd; + int i; + + SCM_ASSERT (SCM_INUMP (fd), fd, SCM_ARG1, s_fdes_to_ports); + int_fd = SCM_INUM (fd); + + for (i = 0; i < scm_port_table_size; i++) + { + if (SCM_OPFPORTP (scm_port_table[i]->port) + && ((struct scm_fport *) scm_port_table[i]->stream)->fdes == int_fd) + result = scm_cons (scm_port_table[i]->port, result); + } + return result; +} + + +void +scm_init_ioext () +{ +#include "ioext.x" +} +