** New module (ice-9 history)
[bpt/guile.git] / libguile / ports.c
CommitLineData
6fe692e9 1/* Copyright (C) 1995,1996,1997,1998,1999, 2000, 2001 Free Software Foundation, Inc.
0f2d19dd
JB
2 *
3 * This program is free software; you can redistribute it and/or modify
4 * it under the terms of the GNU General Public License as published by
5 * the Free Software Foundation; either version 2, or (at your option)
6 * any later version.
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License
14 * along with this software; see the file COPYING. If not, write to
82892bed
JB
15 * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
16 * Boston, MA 02111-1307 USA
0f2d19dd
JB
17 *
18 * As a special exception, the Free Software Foundation gives permission
19 * for additional uses of the text contained in its release of GUILE.
20 *
21 * The exception is that, if you link the GUILE library with other files
22 * to produce an executable, this does not by itself cause the
23 * resulting executable to be covered by the GNU General Public License.
24 * Your use of that executable is in no way restricted on account of
25 * linking the GUILE library code into it.
26 *
27 * This exception does not however invalidate any other reasons why
28 * the executable file might be covered by the GNU General Public License.
29 *
30 * This exception applies only to the code released by the
31 * Free Software Foundation under the name GUILE. If you copy
32 * code from other Free Software Foundation releases into a copy of
33 * GUILE, as the General Public License permits, the exception does
34 * not apply to the code that you add in this way. To avoid misleading
35 * anyone as to the status of such modified files, you must delete
36 * this exception notice from them.
37 *
38 * If you write modifications of your own for GUILE, it is your choice
39 * whether to permit this exception to apply to your modifications.
82892bed 40 * If you do not wish that, delete this exception notice. */
1bbd0b84
GB
41
42/* Software engineering face-lift by Greg J. Badros, 11-Dec-1999,
43 gjb@cs.washington.edu, http://www.cs.washington.edu/homes/gjb */
44
0f2d19dd 45\f
d68fee48
JB
46/* Headers. */
47
0f2d19dd 48#include <stdio.h>
e6e2e95a
MD
49#include <errno.h>
50
a0599745 51#include "libguile/_scm.h"
f0942910 52#include "libguile/eval.h"
a0599745
MD
53#include "libguile/objects.h"
54#include "libguile/smob.h"
55#include "libguile/chars.h"
0f2d19dd 56
a0599745
MD
57#include "libguile/keywords.h"
58#include "libguile/root.h"
59#include "libguile/strings.h"
20e6290e 60
a0599745
MD
61#include "libguile/validate.h"
62#include "libguile/ports.h"
0f2d19dd 63
bd9e24b3
GH
64#ifdef HAVE_STRING_H
65#include <string.h>
66#endif
67
0f2d19dd 68#ifdef HAVE_MALLOC_H
95b88819 69#include <malloc.h>
0f2d19dd
JB
70#endif
71
72#ifdef HAVE_UNISTD_H
73#include <unistd.h>
74#endif
75
95b88819
GH
76#ifdef HAVE_SYS_IOCTL_H
77#include <sys/ioctl.h>
78#endif
d68fee48 79
0f2d19dd 80\f
d68fee48 81/* The port kind table --- a dynamically resized array of port types. */
0f2d19dd
JB
82
83
84/* scm_ptobs scm_numptob
85 * implement a dynamicly resized array of ptob records.
86 * Indexes into this table are used when generating type
87 * tags for smobjects (if you know a tag you can get an index and conversely).
88 */
f12733c9 89scm_ptob_descriptor *scm_ptobs;
a1c95c45 90int scm_numptob;
0f2d19dd 91
ee149d03 92/* GC marker for a port with stream of SCM type. */
0f2d19dd 93SCM
a284e297 94scm_markstream (SCM ptr)
0f2d19dd
JB
95{
96 int openp;
f9a64404 97 openp = SCM_CELL_WORD_0 (ptr) & SCM_OPN;
0f2d19dd 98 if (openp)
74a16888 99 return SCM_PACK (SCM_STREAM (ptr));
0f2d19dd
JB
100 else
101 return SCM_BOOL_F;
102}
103
f12733c9 104/*
f12733c9 105 * We choose to use an interface similar to the smob interface with
affc96b5 106 * fill_input and write as standard fields, passed to the port
f12733c9
MD
107 * type constructor, and optional fields set by setters.
108 */
109
70df8af6
GH
110static void
111flush_port_default (SCM port)
112{
113}
114
115static void
116end_input_default (SCM port, int offset)
117{
118}
0f2d19dd 119
a98bddfd 120scm_bits_t
f12733c9 121scm_make_port_type (char *name,
affc96b5 122 int (*fill_input) (SCM port),
8aa011a1 123 void (*write) (SCM port, const void *data, size_t size))
0f2d19dd
JB
124{
125 char *tmp;
126 if (255 <= scm_numptob)
127 goto ptoberr;
f12733c9
MD
128 SCM_DEFER_INTS;
129 SCM_SYSCALL (tmp = (char *) realloc ((char *) scm_ptobs,
130 (1 + scm_numptob)
131 * sizeof (scm_ptob_descriptor)));
0f2d19dd
JB
132 if (tmp)
133 {
f12733c9 134 scm_ptobs = (scm_ptob_descriptor *) tmp;
affc96b5 135
f12733c9
MD
136 scm_ptobs[scm_numptob].name = name;
137 scm_ptobs[scm_numptob].mark = 0;
138 scm_ptobs[scm_numptob].free = scm_free0;
139 scm_ptobs[scm_numptob].print = scm_port_print;
140 scm_ptobs[scm_numptob].equalp = 0;
affc96b5
GH
141 scm_ptobs[scm_numptob].close = 0;
142
143 scm_ptobs[scm_numptob].write = write;
70df8af6 144 scm_ptobs[scm_numptob].flush = flush_port_default;
affc96b5 145
70df8af6 146 scm_ptobs[scm_numptob].end_input = end_input_default;
affc96b5
GH
147 scm_ptobs[scm_numptob].fill_input = fill_input;
148 scm_ptobs[scm_numptob].input_waiting = 0;
149
f12733c9 150 scm_ptobs[scm_numptob].seek = 0;
affc96b5
GH
151 scm_ptobs[scm_numptob].truncate = 0;
152
0f2d19dd
JB
153 scm_numptob++;
154 }
f12733c9 155 SCM_ALLOW_INTS;
0f2d19dd 156 if (!tmp)
2500356c
DH
157 {
158 ptoberr:
159 scm_memory_error ("scm_make_port_type");
160 }
f12733c9
MD
161 /* Make a class object if Goops is present */
162 if (scm_port_class)
163 scm_make_port_classes (scm_numptob - 1, SCM_PTOBNAME (scm_numptob - 1));
0f2d19dd
JB
164 return scm_tc7_port + (scm_numptob - 1) * 256;
165}
166
f12733c9 167void
6c747373 168scm_set_port_mark (long tc, SCM (*mark) (SCM))
f12733c9
MD
169{
170 scm_ptobs[SCM_TC2PTOBNUM (tc)].mark = mark;
171}
172
173void
6c747373 174scm_set_port_free (long tc, scm_sizet (*free) (SCM))
f12733c9
MD
175{
176 scm_ptobs[SCM_TC2PTOBNUM (tc)].free = free;
177}
178
179void
6c747373 180scm_set_port_print (long tc, int (*print) (SCM exp, SCM port,
f12733c9
MD
181 scm_print_state *pstate))
182{
183 scm_ptobs[SCM_TC2PTOBNUM (tc)].print = print;
184}
185
186void
6c747373 187scm_set_port_equalp (long tc, SCM (*equalp) (SCM, SCM))
f12733c9
MD
188{
189 scm_ptobs[SCM_TC2PTOBNUM (tc)].equalp = equalp;
190}
191
31703ab8 192void
affc96b5 193scm_set_port_flush (long tc, void (*flush) (SCM port))
31703ab8 194{
affc96b5 195 scm_ptobs[SCM_TC2PTOBNUM (tc)].flush = flush;
31703ab8
GH
196}
197
f12733c9 198void
affc96b5 199scm_set_port_end_input (long tc, void (*end_input) (SCM port, int offset))
f12733c9 200{
affc96b5 201 scm_ptobs[SCM_TC2PTOBNUM (tc)].end_input = end_input;
f12733c9
MD
202}
203
204void
6c747373 205scm_set_port_close (long tc, int (*close) (SCM))
f12733c9 206{
affc96b5 207 scm_ptobs[SCM_TC2PTOBNUM (tc)].close = close;
f12733c9
MD
208}
209
210void
6c747373 211scm_set_port_seek (long tc, off_t (*seek) (SCM port,
f12733c9
MD
212 off_t OFFSET,
213 int WHENCE))
214{
215 scm_ptobs[SCM_TC2PTOBNUM (tc)].seek = seek;
216}
217
218void
6c747373 219scm_set_port_truncate (long tc, void (*truncate) (SCM port, off_t length))
f12733c9 220{
affc96b5 221 scm_ptobs[SCM_TC2PTOBNUM (tc)].truncate = truncate;
f12733c9
MD
222}
223
224void
affc96b5 225scm_set_port_input_waiting (long tc, int (*input_waiting) (SCM))
f12733c9 226{
affc96b5 227 scm_ptobs[SCM_TC2PTOBNUM (tc)].input_waiting = input_waiting;
f12733c9
MD
228}
229
0f2d19dd 230\f
0f2d19dd 231
3b3b36dd 232SCM_DEFINE (scm_char_ready_p, "char-ready?", 0, 1, 0,
1bbd0b84 233 (SCM port),
bfc46627
GB
234 "Returns @code{#t} if a character is ready on input @var{port} and\n"
235 "returns @code{#f} otherwise. If @code{char-ready?} returns @code{#t}\n"
236 "then the next @code{read-char} operation on @var{port} is\n"
237 "guaranteed not to hang. If @var{port} is a file port at end of\n"
238 "file then @code{char-ready?} returns @code{#t}.\n"
239 "@footnote{@code{char-ready?} exists to make it possible for a\n"
240 "program to accept characters from interactive ports without getting\n"
241 "stuck waiting for input. Any input editors associated with such ports\n"
242 "must make sure that characters whose existence has been asserted by\n"
243 "@code{char-ready?} cannot be rubbed out. If @code{char-ready?} were to\n"
244 "return @code{#f} at end of file, a port at end of file would be\n"
245 "indistinguishable from an interactive port that has no ready\n"
246 "characters.}")
1bbd0b84 247#define FUNC_NAME s_scm_char_ready_p
0f2d19dd 248{
ae4c4016 249 scm_port *pt;
6c951427 250
0f2d19dd
JB
251 if (SCM_UNBNDP (port))
252 port = scm_cur_inp;
253 else
3b3b36dd 254 SCM_VALIDATE_OPINPORT (1,port);
d68fee48 255
ae4c4016
JB
256 pt = SCM_PTAB_ENTRY (port);
257
6c951427
GH
258 /* if the current read buffer is filled, or the
259 last pushed-back char has been read and the saved buffer is
260 filled, result is true. */
261 if (pt->read_pos < pt->read_end
262 || (pt->read_buf == pt->putback_buf
263 && pt->saved_read_pos < pt->saved_read_end))
0f2d19dd 264 return SCM_BOOL_T;
ee149d03
JB
265 else
266 {
f12733c9 267 scm_ptob_descriptor *ptob = &scm_ptobs[SCM_PTOBNUM (port)];
ee149d03 268
affc96b5 269 if (ptob->input_waiting)
1bbd0b84 270 return SCM_BOOL(ptob->input_waiting (port));
ee149d03 271 else
6c951427 272 return SCM_BOOL_T;
ee149d03 273 }
0f2d19dd 274}
1bbd0b84 275#undef FUNC_NAME
0f2d19dd 276
c2da2648
GH
277/* move up to read_len chars from port's putback and/or read buffers
278 into memory starting at dest. returns the number of chars moved. */
279size_t scm_take_from_input_buffers (SCM port, char *dest, size_t read_len)
280{
281 scm_port *pt = SCM_PTAB_ENTRY (port);
282 size_t chars_read = 0;
283 size_t from_buf = min (pt->read_end - pt->read_pos, read_len);
284
285 if (from_buf > 0)
286 {
287 memcpy (dest, pt->read_pos, from_buf);
288 pt->read_pos += from_buf;
289 chars_read += from_buf;
290 read_len -= from_buf;
291 dest += from_buf;
292 }
293
294 /* if putback was active, try the real input buffer too. */
295 if (pt->read_buf == pt->putback_buf)
296 {
297 from_buf = min (pt->saved_read_end - pt->saved_read_pos, read_len);
298 if (from_buf > 0)
299 {
300 memcpy (dest, pt->saved_read_pos, from_buf);
301 pt->saved_read_pos += from_buf;
302 chars_read += from_buf;
303 }
304 }
305 return chars_read;
306}
307
6c951427 308/* Clear a port's read buffers, returning the contents. */
a1ec6916 309SCM_DEFINE (scm_drain_input, "drain-input", 1, 0, 0,
1bbd0b84 310 (SCM port),
e1546b65
MG
311 "Drain @var{port}'s read buffers (including any pushed-back\n"
312 "characters) and returns the content as a single string.")
1bbd0b84 313#define FUNC_NAME s_scm_drain_input
ee149d03 314{
840ae05d
JB
315 SCM result;
316 scm_port *pt = SCM_PTAB_ENTRY (port);
6c951427 317 int count;
ee149d03 318
3b3b36dd 319 SCM_VALIDATE_OPINPORT (1,port);
840ae05d 320
6c951427
GH
321 count = pt->read_end - pt->read_pos;
322 if (pt->read_buf == pt->putback_buf)
323 count += pt->saved_read_end - pt->saved_read_pos;
840ae05d 324
6c951427 325 result = scm_makstr (count, 0);
c2da2648 326 scm_take_from_input_buffers (port, SCM_STRING_CHARS (result), count);
6c951427 327
840ae05d 328 return result;
ee149d03 329}
1bbd0b84 330#undef FUNC_NAME
0f2d19dd
JB
331
332\f
d68fee48 333/* Standard ports --- current input, output, error, and more(!). */
0f2d19dd 334
3b3b36dd 335SCM_DEFINE (scm_current_input_port, "current-input-port", 0, 0, 0,
e1546b65
MG
336 (),
337 "Return the current input port. This is the default port used\n"
338 "by many input procedures. Initially, @code{current-input-port}\n"
339 "returns the @dfn{standard input} in Unix and C terminology.")
1bbd0b84 340#define FUNC_NAME s_scm_current_input_port
0f2d19dd
JB
341{
342 return scm_cur_inp;
343}
1bbd0b84 344#undef FUNC_NAME
0f2d19dd 345
3b3b36dd 346SCM_DEFINE (scm_current_output_port, "current-output-port", 0, 0, 0,
e1546b65
MG
347 (),
348 "Return the current output port. This is the default port used\n"
349 "by many output procedures. Initially, \n"
350 "@code{current-output-port} returns the @dfn{standard output} in\n"
351 "Unix and C terminology.")
1bbd0b84 352#define FUNC_NAME s_scm_current_output_port
0f2d19dd
JB
353{
354 return scm_cur_outp;
355}
1bbd0b84 356#undef FUNC_NAME
0f2d19dd 357
3b3b36dd 358SCM_DEFINE (scm_current_error_port, "current-error-port", 0, 0, 0,
1bbd0b84 359 (),
b380b885
MD
360 "Return the port to which errors and warnings should be sent (the\n"
361 "@dfn{standard error} in Unix and C terminology).")
1bbd0b84 362#define FUNC_NAME s_scm_current_error_port
0f2d19dd
JB
363{
364 return scm_cur_errp;
365}
1bbd0b84 366#undef FUNC_NAME
0f2d19dd 367
3b3b36dd 368SCM_DEFINE (scm_current_load_port, "current-load-port", 0, 0, 0,
e1546b65 369 (),
b450f070 370 "Return the current-load-port.\n"
e1546b65 371 "The load port is used internally by @code{primitive-load}.")
1bbd0b84 372#define FUNC_NAME s_scm_current_load_port
31614d8e
MD
373{
374 return scm_cur_loadp;
375}
1bbd0b84 376#undef FUNC_NAME
31614d8e 377
3b3b36dd 378SCM_DEFINE (scm_set_current_input_port, "set-current-input-port", 1, 0, 0,
1bbd0b84 379 (SCM port),
b380b885
MD
380 "@deffnx primitive set-current-output-port port\n"
381 "@deffnx primitive set-current-error-port port\n"
382 "Change the ports returned by @code{current-input-port},\n"
383 "@code{current-output-port} and @code{current-error-port}, respectively,\n"
384 "so that they use the supplied @var{port} for input or output.")
1bbd0b84 385#define FUNC_NAME s_scm_set_current_input_port
0f2d19dd
JB
386{
387 SCM oinp = scm_cur_inp;
3b3b36dd 388 SCM_VALIDATE_OPINPORT (1,port);
0f2d19dd
JB
389 scm_cur_inp = port;
390 return oinp;
391}
1bbd0b84 392#undef FUNC_NAME
0f2d19dd
JB
393
394
3b3b36dd 395SCM_DEFINE (scm_set_current_output_port, "set-current-output-port", 1, 0, 0,
e1546b65
MG
396 (SCM port),
397 "Set the current default output port to @var{port}.")
1bbd0b84 398#define FUNC_NAME s_scm_set_current_output_port
0f2d19dd
JB
399{
400 SCM ooutp = scm_cur_outp;
78446828 401 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 402 SCM_VALIDATE_OPOUTPORT (1,port);
0f2d19dd
JB
403 scm_cur_outp = port;
404 return ooutp;
405}
1bbd0b84 406#undef FUNC_NAME
0f2d19dd
JB
407
408
3b3b36dd 409SCM_DEFINE (scm_set_current_error_port, "set-current-error-port", 1, 0, 0,
e1546b65
MG
410 (SCM port),
411 "Set the current default error port to @var{port}.")
1bbd0b84 412#define FUNC_NAME s_scm_set_current_error_port
0f2d19dd
JB
413{
414 SCM oerrp = scm_cur_errp;
78446828 415 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 416 SCM_VALIDATE_OPOUTPORT (1,port);
0f2d19dd
JB
417 scm_cur_errp = port;
418 return oerrp;
419}
1bbd0b84 420#undef FUNC_NAME
0f2d19dd
JB
421
422\f
840ae05d 423/* The port table --- an array of pointers to ports. */
0f2d19dd 424
840ae05d 425scm_port **scm_port_table;
0f2d19dd
JB
426
427int scm_port_table_size = 0; /* Number of ports in scm_port_table. */
428int scm_port_table_room = 20; /* Size of the array. */
429
ee149d03 430/* Add a port to the table. */
1cc91f1b 431
840ae05d 432scm_port *
a284e297 433scm_add_to_port_table (SCM port)
0f2d19dd 434{
840ae05d
JB
435 scm_port *entry;
436
0f2d19dd
JB
437 if (scm_port_table_size == scm_port_table_room)
438 {
ee149d03 439 void *newt = realloc ((char *) scm_port_table,
840ae05d 440 (scm_sizet) (sizeof (scm_port *)
ee149d03
JB
441 * scm_port_table_room * 2));
442 if (newt == NULL)
840ae05d
JB
443 scm_memory_error ("scm_add_to_port_table");
444 scm_port_table = (scm_port **) newt;
0f2d19dd
JB
445 scm_port_table_room *= 2;
446 }
840ae05d
JB
447 entry = (scm_port *) malloc (sizeof (scm_port));
448 if (entry == NULL)
449 scm_memory_error ("scm_add_to_port_table");
450
451 entry->port = port;
452 entry->entry = scm_port_table_size;
453 entry->revealed = 0;
454 entry->stream = 0;
455 entry->file_name = SCM_BOOL_F;
456 entry->line_number = 0;
457 entry->column_number = 0;
6c951427
GH
458 entry->putback_buf = 0;
459 entry->putback_buf_size = 0;
61e452ba 460 entry->rw_active = SCM_PORT_NEITHER;
0de97b83 461 entry->rw_random = 0;
840ae05d
JB
462
463 scm_port_table[scm_port_table_size] = entry;
464 scm_port_table_size++;
465
466 return entry;
0f2d19dd
JB
467}
468
6c951427 469/* Remove a port from the table and destroy it. */
1cc91f1b 470
0f2d19dd 471void
a284e297 472scm_remove_from_port_table (SCM port)
db4b4ca6 473#define FUNC_NAME "scm_remove_from_port_table"
0f2d19dd 474{
840ae05d 475 scm_port *p = SCM_PTAB_ENTRY (port);
ee1e7e13 476 int i = p->entry;
6c951427 477
ee1e7e13 478 if (i >= scm_port_table_size)
db4b4ca6 479 SCM_MISC_ERROR ("Port not in table: ~S", SCM_LIST1 (port));
6c951427
GH
480 if (p->putback_buf)
481 free (p->putback_buf);
840ae05d 482 free (p);
ee1e7e13
MD
483 /* Since we have just freed slot i we can shrink the table by moving
484 the last entry to that slot... */
485 if (i < scm_port_table_size - 1)
0f2d19dd 486 {
ee1e7e13
MD
487 scm_port_table[i] = scm_port_table[scm_port_table_size - 1];
488 scm_port_table[i]->entry = i;
0f2d19dd 489 }
0f2d19dd
JB
490 SCM_SETPTAB_ENTRY (port, 0);
491 scm_port_table_size--;
492}
db4b4ca6
DH
493#undef FUNC_NAME
494
0f2d19dd 495
fea6b4ea 496#ifdef GUILE_DEBUG
b450f070 497/* Functions for debugging. */
1cc91f1b 498
3b3b36dd 499SCM_DEFINE (scm_pt_size, "pt-size", 0, 0, 0,
b450f070 500 (),
5352393c
MG
501 "Returns the number of ports in the port table. @code{pt-size}\n"
502 "is only included in @code{--enable-guile-debug} builds.")
1bbd0b84 503#define FUNC_NAME s_scm_pt_size
0f2d19dd
JB
504{
505 return SCM_MAKINUM (scm_port_table_size);
506}
1bbd0b84 507#undef FUNC_NAME
0f2d19dd 508
3b3b36dd 509SCM_DEFINE (scm_pt_member, "pt-member", 1, 0, 0,
b450f070 510 (SCM index),
5352393c
MG
511 "Returns the port at @var{index} in the port table.\n"
512 "@code{pt-member} is only included in\n"
513 "@code{--enable-guile-debug} builds.")
1bbd0b84 514#define FUNC_NAME s_scm_pt_member
0f2d19dd
JB
515{
516 int i;
b450f070 517 SCM_VALIDATE_INUM_COPY (1,index,i);
0f2d19dd
JB
518 if (i < 0 || i >= scm_port_table_size)
519 return SCM_BOOL_F;
520 else
521 return scm_port_table[i]->port;
522}
1bbd0b84 523#undef FUNC_NAME
0f2d19dd
JB
524#endif
525
70df8af6
GH
526void
527scm_port_non_buffer (scm_port *pt)
528{
529 pt->read_pos = pt->read_buf = pt->read_end = &pt->shortbuf;
530 pt->write_buf = pt->write_pos = &pt->shortbuf;
531 pt->read_buf_size = pt->write_buf_size = 1;
532 pt->write_end = pt->write_buf + pt->write_buf_size;
533}
0f2d19dd 534
d68fee48
JB
535\f
536/* Revealed counts --- an oddity inherited from SCSH. */
537
8b13c6b3
GH
538/* Find a port in the table and return its revealed count.
539 Also used by the garbage collector.
0f2d19dd 540 */
1cc91f1b 541
0f2d19dd 542int
a284e297 543scm_revealed_count (SCM port)
0f2d19dd
JB
544{
545 return SCM_REVEALED(port);
546}
547
548
549
550/* Return the revealed count for a port. */
551
3b3b36dd 552SCM_DEFINE (scm_port_revealed, "port-revealed", 1, 0, 0,
1bbd0b84 553 (SCM port),
b380b885 554 "Returns the revealed count for @var{port}.")
1bbd0b84 555#define FUNC_NAME s_scm_port_revealed
0f2d19dd 556{
78446828 557 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 558 SCM_VALIDATE_PORT (1,port);
8b13c6b3 559 return SCM_MAKINUM (scm_revealed_count (port));
0f2d19dd 560}
1bbd0b84 561#undef FUNC_NAME
0f2d19dd
JB
562
563/* Set the revealed count for a port. */
3b3b36dd 564SCM_DEFINE (scm_set_port_revealed_x, "set-port-revealed!", 2, 0, 0,
1bbd0b84 565 (SCM port, SCM rcount),
b450f070 566 "Sets the revealed count for a port to a given value.\n"
b380b885 567 "The return value is unspecified.")
1bbd0b84 568#define FUNC_NAME s_scm_set_port_revealed_x
0f2d19dd 569{
78446828 570 port = SCM_COERCE_OUTPORT (port);
3b3b36dd
GB
571 SCM_VALIDATE_PORT (1,port);
572 SCM_VALIDATE_INUM (2,rcount);
0f2d19dd 573 SCM_REVEALED (port) = SCM_INUM (rcount);
8b13c6b3 574 return SCM_UNSPECIFIED;
0f2d19dd 575}
1bbd0b84 576#undef FUNC_NAME
0f2d19dd 577
d68fee48
JB
578
579\f
580/* Retrieving a port's mode. */
581
eadd48de
GH
582/* Return the flags that characterize a port based on the mode
583 * string used to open a file for that port.
584 *
585 * See PORT FLAGS in scm.h
586 */
587
588long
a284e297 589scm_mode_bits (char *modes)
eadd48de
GH
590{
591 return (SCM_OPN
592 | (strchr (modes, 'r') || strchr (modes, '+') ? SCM_RDNG : 0)
593 | ( strchr (modes, 'w')
594 || strchr (modes, 'a')
595 || strchr (modes, '+') ? SCM_WRTNG : 0)
ee149d03
JB
596 | (strchr (modes, '0') ? SCM_BUF0 : 0)
597 | (strchr (modes, 'l') ? SCM_BUFLINE : 0));
eadd48de
GH
598}
599
600
601/* Return the mode flags from an open port.
602 * Some modes such as "append" are only used when opening
603 * a file and are not returned here. */
604
3b3b36dd 605SCM_DEFINE (scm_port_mode, "port-mode", 1, 0, 0,
1bbd0b84 606 (SCM port),
b380b885
MD
607 "Returns the port modes associated with the open port @var{port}. These\n"
608 "will not necessarily be identical to the modes used when the port was\n"
609 "opened, since modes such as \"append\" which are used only during\n"
610 "port creation are not retained.")
1bbd0b84 611#define FUNC_NAME s_scm_port_mode
eadd48de 612{
26a3038d 613 char modes[4];
eadd48de 614 modes[0] = '\0';
78446828
MV
615
616 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 617 SCM_VALIDATE_OPPORT (1,port);
f9a64404
DH
618 if (SCM_CELL_WORD_0 (port) & SCM_RDNG) {
619 if (SCM_CELL_WORD_0 (port) & SCM_WRTNG)
eadd48de
GH
620 strcpy (modes, "r+");
621 else
622 strcpy (modes, "r");
623 }
f9a64404 624 else if (SCM_CELL_WORD_0 (port) & SCM_WRTNG)
eadd48de 625 strcpy (modes, "w");
f9a64404 626 if (SCM_CELL_WORD_0 (port) & SCM_BUF0)
eadd48de
GH
627 strcat (modes, "0");
628 return scm_makfromstr (modes, strlen (modes), 0);
629}
1bbd0b84 630#undef FUNC_NAME
eadd48de
GH
631
632
d68fee48
JB
633\f
634/* Closing ports. */
635
0f2d19dd
JB
636/* scm_close_port
637 * Call the close operation on a port object.
eadd48de 638 * see also scm_close.
0f2d19dd 639 */
3b3b36dd 640SCM_DEFINE (scm_close_port, "close-port", 1, 0, 0,
1bbd0b84 641 (SCM port),
b380b885
MD
642 "Close the specified port object. Returns @code{#t} if it successfully\n"
643 "closes a port or @code{#f} if it was already\n"
644 "closed. An exception may be raised if an error occurs, for example\n"
645 "when flushing buffered output.\n"
646 "See also @ref{Ports and File Descriptors, close}, for a procedure\n"
647 "which can close file descriptors.")
1bbd0b84 648#define FUNC_NAME s_scm_close_port
0f2d19dd
JB
649{
650 scm_sizet i;
eadd48de
GH
651 int rv;
652
78446828
MV
653 port = SCM_COERCE_OUTPORT (port);
654
7a754ca6 655 SCM_VALIDATE_PORT (1, port);
0f2d19dd 656 if (SCM_CLOSEDP (port))
eadd48de 657 return SCM_BOOL_F;
0f2d19dd 658 i = SCM_PTOBNUM (port);
affc96b5
GH
659 if (scm_ptobs[i].close)
660 rv = (scm_ptobs[i].close) (port);
eadd48de
GH
661 else
662 rv = 0;
0f2d19dd 663 scm_remove_from_port_table (port);
898a256f 664 SCM_SETAND_CAR (port, ~SCM_OPN);
7a754ca6
MD
665 return SCM_NEGATE_BOOL (rv < 0);
666}
667#undef FUNC_NAME
668
669SCM_DEFINE (scm_close_input_port, "close-input-port", 1, 0, 0,
670 (SCM port),
671 "Close the specified input port object. The routine has no effect if\n"
672 "the file has already been closed. An exception may be raised if an\n"
673 "error occurs. The value returned is unspecified.\n\n"
674 "See also @ref{Ports and File Descriptors, close}, for a procedure\n"
675 "which can close file descriptors.")
676#define FUNC_NAME s_scm_close_input_port
677{
678 SCM_VALIDATE_INPUT_PORT (1, port);
679 scm_close_port (port);
680 return SCM_UNSPECIFIED;
681}
682#undef FUNC_NAME
683
684SCM_DEFINE (scm_close_output_port, "close-output-port", 1, 0, 0,
685 (SCM port),
686 "Close the specified output port object. The routine has no effect if\n"
687 "the file has already been closed. An exception may be raised if an\n"
688 "error occurs. The value returned is unspecified.\n\n"
689 "See also @ref{Ports and File Descriptors, close}, for a procedure\n"
690 "which can close file descriptors.")
691#define FUNC_NAME s_scm_close_output_port
692{
693 port = SCM_COERCE_OUTPORT (port);
694 SCM_VALIDATE_OUTPUT_PORT (1, port);
695 scm_close_port (port);
696 return SCM_UNSPECIFIED;
0f2d19dd 697}
1bbd0b84 698#undef FUNC_NAME
0f2d19dd 699
c2ca4493
GH
700SCM_DEFINE (scm_port_for_each, "port-for-each", 1, 0, 0,
701 (SCM proc),
702 "Apply @var{proc} to each port in the Guile port table\n"
2f1bbcfd
MV
703 "in turn. The return value is unspecified. More specifically,\n"
704 "@var{proc} is applied exactly once to every port that exists\n"
705 "in the system at the time @var{port-for-each} is invoked.\n"
706 "Changes to the port table while @var{port-for-each} is running\n"
707 "have no effect as far as @var{port-for-each} is concerned.\n")
c2ca4493
GH
708#define FUNC_NAME s_scm_port_for_each
709{
710 int i;
fdfe6305
MV
711 SCM ports;
712
c2ca4493
GH
713 SCM_VALIDATE_PROC (1, proc);
714
715 /* when pre-emptive multithreading is supported, access to the port
716 table will need to be controlled by a mutex. */
fdfe6305
MV
717
718 /* Even without pre-emptive multithreading, running arbitrary code
719 while scanning the port table is unsafe because the port table
720 can change arbitrarily (from a GC, for example). So we build a
721 list in advance while blocking the GC. -mvo */
722
c2ca4493 723 SCM_DEFER_INTS;
fdfe6305
MV
724 scm_block_gc++;
725 ports = SCM_EOL;
c2ca4493 726 for (i = 0; i < scm_port_table_size; i++)
fdfe6305
MV
727 ports = scm_cons (scm_port_table[i]->port, ports);
728 scm_block_gc--;
729 SCM_ALLOW_INTS;
730
731 while (ports != SCM_EOL)
c2ca4493 732 {
fdfe6305
MV
733 scm_apply (proc, scm_cons (SCM_CAR (ports), SCM_EOL), SCM_EOL);
734 ports = SCM_CDR (ports);
c2ca4493 735 }
fdfe6305 736
c2ca4493
GH
737 return SCM_UNSPECIFIED;
738}
739#undef FUNC_NAME
740
b875c468
GH
741#if (SCM_DEBUG_DEPRECATED == 0)
742
3b3b36dd 743SCM_DEFINE (scm_close_all_ports_except, "close-all-ports-except", 0, 0, 1,
1bbd0b84 744 (SCM ports),
b875c468 745 "[DEPRECATED] Close all open file ports used by the interpreter\n"
b380b885 746 "except for those supplied as arguments. This procedure\n"
b875c468
GH
747 "was intended to be used before an exec call to close file descriptors\n"
748 "which are not needed in the new process. However it has the\n"
749 "undesirable side-effect of flushing buffes, so it's deprecated.\n"
750 "Use port-for-each instead.")
1bbd0b84 751#define FUNC_NAME s_scm_close_all_ports_except
0f2d19dd
JB
752{
753 int i = 0;
af45e3b0 754 SCM_VALIDATE_REST_ARGUMENT (ports);
0f2d19dd
JB
755 while (i < scm_port_table_size)
756 {
757 SCM thisport = scm_port_table[i]->port;
758 int found = 0;
759 SCM ports_ptr = ports;
760
761 while (SCM_NNULLP (ports_ptr))
762 {
78446828 763 SCM port = SCM_COERCE_OUTPORT (SCM_CAR (ports_ptr));
0f2d19dd 764 if (i == 0)
3b3b36dd 765 SCM_VALIDATE_OPPORT (SCM_ARG1,port);
54778cd3 766 if (SCM_EQ_P (port, thisport))
0f2d19dd
JB
767 found = 1;
768 ports_ptr = SCM_CDR (ports_ptr);
769 }
770 if (found)
771 i++;
772 else
773 /* i is not to be incremented here. */
774 scm_close_port (thisport);
775 }
0f2d19dd
JB
776 return SCM_UNSPECIFIED;
777}
1bbd0b84 778#undef FUNC_NAME
0f2d19dd 779
b875c468 780#endif
d68fee48
JB
781
782\f
783/* Utter miscellany. Gosh, we should clean this up some time. */
784
3b3b36dd 785SCM_DEFINE (scm_input_port_p, "input-port?", 1, 0, 0,
1bbd0b84 786 (SCM x),
bfc46627
GB
787 "Returns @code{#t} if @var{x} is an input port, otherwise returns\n"
788 "@code{#f}. Any object satisfying this predicate also satisfies\n"
789 "@code{port?}.")
1bbd0b84 790#define FUNC_NAME s_scm_input_port_p
0f2d19dd
JB
791{
792 if (SCM_IMP (x))
4a94d8ca 793 return SCM_BOOL_F;
f5f2dcff 794 return SCM_BOOL(SCM_INPUT_PORT_P (x));
0f2d19dd 795}
1bbd0b84 796#undef FUNC_NAME
0f2d19dd 797
3b3b36dd 798SCM_DEFINE (scm_output_port_p, "output-port?", 1, 0, 0,
1bbd0b84 799 (SCM x),
bfc46627
GB
800 "Returns @code{#t} if @var{x} is an output port, otherwise returns\n"
801 "@code{#f}. Any object satisfying this predicate also satisfies\n"
802 "@code{port?}.")
1bbd0b84 803#define FUNC_NAME s_scm_output_port_p
0f2d19dd
JB
804{
805 if (SCM_IMP (x))
4a94d8ca
MD
806 return SCM_BOOL_F;
807 if (SCM_PORT_WITH_PS_P (x))
808 x = SCM_PORT_WITH_PS_PORT (x);
f5f2dcff 809 return SCM_BOOL(SCM_OUTPUT_PORT_P (x));
0f2d19dd 810}
1bbd0b84 811#undef FUNC_NAME
0f2d19dd 812
eb5c0a2a
GH
813SCM_DEFINE (scm_port_p, "port?", 1, 0, 0,
814 (SCM x),
5352393c
MG
815 "Returns a boolean indicating whether @var{x} is a port.\n"
816 "Equivalent to @code{(or (input-port? @var{x}) (output-port?\n"
817 "@var{x}))}.")
eb5c0a2a
GH
818#define FUNC_NAME s_scm_port_p
819{
820 return SCM_BOOL (SCM_PORTP (x));
821}
822#undef FUNC_NAME
823
3b3b36dd 824SCM_DEFINE (scm_port_closed_p, "port-closed?", 1, 0, 0,
1bbd0b84 825 (SCM port),
b380b885 826 "Returns @code{#t} if @var{port} is closed or @code{#f} if it is open.")
1bbd0b84 827#define FUNC_NAME s_scm_port_closed_p
60d0643d 828{
c1bfcf60 829 SCM_VALIDATE_PORT (1,port);
1bbd0b84 830 return SCM_NEGATE_BOOL(SCM_OPPORTP (port));
60d0643d 831}
1bbd0b84 832#undef FUNC_NAME
0f2d19dd 833
3b3b36dd 834SCM_DEFINE (scm_eof_object_p, "eof-object?", 1, 0, 0,
1bbd0b84 835 (SCM x),
bfc46627
GB
836 "Returns @code{#t} if @var{x} is an end-of-file object; otherwise\n"
837 "returns @code{#f}.")
1bbd0b84 838#define FUNC_NAME s_scm_eof_object_p
0f2d19dd 839{
1bbd0b84 840 return SCM_BOOL(SCM_EOF_OBJECT_P (x));
0f2d19dd 841}
1bbd0b84 842#undef FUNC_NAME
0f2d19dd 843
3b3b36dd 844SCM_DEFINE (scm_force_output, "force-output", 0, 1, 0,
1bbd0b84 845 (SCM port),
b380b885
MD
846 "Flush the specified output port, or the current output port if @var{port}\n"
847 "is omitted. The current output buffer contents are passed to the \n"
848 "underlying port implementation (e.g., in the case of fports, the\n"
849 "data will be written to the file and the output buffer will be cleared.)\n"
850 "It has no effect on an unbuffered port.\n\n"
851 "The return value is unspecified.")
1bbd0b84 852#define FUNC_NAME s_scm_force_output
0f2d19dd
JB
853{
854 if (SCM_UNBNDP (port))
3e877d15 855 port = scm_cur_outp;
0f2d19dd 856 else
78446828
MV
857 {
858 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 859 SCM_VALIDATE_OPOUTPORT (1,port);
78446828 860 }
affc96b5 861 scm_flush (port);
ee149d03 862 return SCM_UNSPECIFIED;
0f2d19dd 863}
1bbd0b84 864#undef FUNC_NAME
0f2d19dd 865
a1ec6916 866SCM_DEFINE (scm_flush_all_ports, "flush-all-ports", 0, 0, 0,
1bbd0b84 867 (),
b380b885
MD
868 "Equivalent to calling @code{force-output} on\n"
869 "all open output ports. The return value is unspecified.")
1bbd0b84 870#define FUNC_NAME s_scm_flush_all_ports
89ea5b7c
GH
871{
872 int i;
873
874 for (i = 0; i < scm_port_table_size; i++)
875 {
ee149d03 876 if (SCM_OPOUTPORTP (scm_port_table[i]->port))
affc96b5 877 scm_flush (scm_port_table[i]->port);
89ea5b7c
GH
878 }
879 return SCM_UNSPECIFIED;
880}
1bbd0b84 881#undef FUNC_NAME
0f2d19dd 882
3b3b36dd 883SCM_DEFINE (scm_read_char, "read-char", 0, 1, 0,
1bbd0b84 884 (SCM port),
bfc46627
GB
885 "Returns the next character available from @var{port}, updating\n"
886 "@var{port} to point to the following character. If no more\n"
887 "characters are available, an end-of-file object is returned.")
1bbd0b84 888#define FUNC_NAME s_scm_read_char
0f2d19dd
JB
889{
890 int c;
891 if (SCM_UNBNDP (port))
334341aa 892 port = scm_cur_inp;
3b3b36dd 893 SCM_VALIDATE_OPINPORT (1,port);
b7f3516f 894 c = scm_getc (port);
0f2d19dd
JB
895 if (EOF == c)
896 return SCM_EOF_VAL;
7866a09b 897 return SCM_MAKE_CHAR (c);
0f2d19dd 898}
1bbd0b84 899#undef FUNC_NAME
0f2d19dd 900
5c070ca7 901/* this should only be called when the read buffer is empty. it
affc96b5 902 tries to refill the read buffer. it returns the first char from
5c070ca7 903 the port, which is either EOF or *(pt->read_pos). */
6c951427 904int
affc96b5 905scm_fill_input (SCM port)
6c951427 906{
283a1a0e
GH
907 scm_port *pt = SCM_PTAB_ENTRY (port);
908
6c951427
GH
909 if (pt->read_buf == pt->putback_buf)
910 {
911 /* finished reading put-back chars. */
912 pt->read_buf = pt->saved_read_buf;
913 pt->read_pos = pt->saved_read_pos;
914 pt->read_end = pt->saved_read_end;
915 pt->read_buf_size = pt->saved_read_buf_size;
916 if (pt->read_pos < pt->read_end)
5c070ca7 917 return *(pt->read_pos);
6c951427 918 }
affc96b5 919 return scm_ptobs[SCM_PTOBNUM (port)].fill_input (port);
6c951427
GH
920}
921
ee149d03 922int
a284e297 923scm_getc (SCM port)
0f2d19dd
JB
924{
925 int c;
840ae05d 926 scm_port *pt = SCM_PTAB_ENTRY (port);
ee149d03 927
840ae05d
JB
928 if (pt->rw_active == SCM_PORT_WRITE)
929 {
affc96b5
GH
930 /* may be marginally faster than calling scm_flush. */
931 scm_ptobs[SCM_PTOBNUM (port)].flush (port);
840ae05d 932 }
6c951427 933
5c070ca7
GH
934 if (pt->rw_random)
935 pt->rw_active = SCM_PORT_READ;
936
937 if (pt->read_pos >= pt->read_end)
ee149d03 938 {
affc96b5 939 if (scm_fill_input (port) == EOF)
5c070ca7 940 return EOF;
ee149d03
JB
941 }
942
5c070ca7 943 c = *(pt->read_pos++);
840ae05d 944
ee149d03
JB
945 if (c == '\n')
946 {
947 SCM_INCLINE (port);
948 }
949 else if (c == '\t')
950 {
951 SCM_TABCOL (port);
952 }
953 else
954 {
955 SCM_INCCOL (port);
956 }
957
958 return c;
0f2d19dd
JB
959}
960
ee149d03 961void
a284e297 962scm_putc (char c, SCM port)
ee149d03 963{
265e6a4d 964 scm_lfwrite (&c, 1, port);
ee149d03 965}
3cb988bd 966
ee149d03 967void
70d63753 968scm_puts (const char *s, SCM port)
3cb988bd 969{
265e6a4d 970 scm_lfwrite (s, strlen (s), port);
ee149d03 971}
3cb988bd 972
6fe692e9
MD
973/* scm_lfwrite
974 *
975 * Currently, this function has an identical implementation to
976 * scm_c_write. We could have turned it into a macro expanding into a
977 * call to scm_c_write. However, the implementation is small and
978 * might differ in the future.
979 */
980
ee149d03 981void
70d63753 982scm_lfwrite (const char *ptr, scm_sizet size, SCM port)
ee149d03 983{
840ae05d 984 scm_port *pt = SCM_PTAB_ENTRY (port);
f12733c9 985 scm_ptob_descriptor *ptob = &scm_ptobs[SCM_PTOBNUM (port)];
3e2043c4 986
840ae05d 987 if (pt->rw_active == SCM_PORT_READ)
affc96b5 988 scm_end_input (port);
283a1a0e 989
31703ab8 990 ptob->write (port, ptr, size);
840ae05d
JB
991
992 if (pt->rw_random)
993 pt->rw_active = SCM_PORT_WRITE;
ee149d03 994}
3cb988bd 995
6fe692e9
MD
996/* scm_c_read
997 *
998 * Used by an application to read arbitrary number of bytes from an
999 * SCM port. Same semantics as libc read, except that scm_c_read only
1000 * returns less than SIZE bytes if at end-of-file.
1001 *
1002 * Warning: Doesn't update port line and column counts! */
1003
1004scm_sizet
1005scm_c_read (SCM port, void *buffer, scm_sizet size)
1006{
1007 scm_port *pt = SCM_PTAB_ENTRY (port);
1008 scm_sizet n_read = 0, n_available;
1009
1010 if (pt->rw_active == SCM_PORT_WRITE)
1011 scm_ptobs[SCM_PTOBNUM (port)].flush (port);
1012
1013 if (pt->rw_random)
1014 pt->rw_active = SCM_PORT_READ;
1015
1016 if (SCM_READ_BUFFER_EMPTY_P (pt))
1017 {
1018 if (scm_fill_input (port) == EOF)
1019 return 0;
1020 }
1021
1022 n_available = pt->read_end - pt->read_pos;
1023
1024 while (n_available < size)
1025 {
1026 memcpy (buffer, pt->read_pos, n_available);
1027 buffer += n_available;
1028 pt->read_pos += n_available;
1029 n_read += n_available;
1030
1031 if (SCM_READ_BUFFER_EMPTY_P (pt))
1032 {
1033 if (scm_fill_input (port) == EOF)
1034 return n_read;
1035 }
1036
1037 size -= n_available;
1038 n_available = pt->read_end - pt->read_pos;
1039 }
1040
1041 memcpy (buffer, pt->read_pos, size);
1042 pt->read_pos += size;
1043
1044 return n_read + size;
1045}
1046
1047/* scm_c_write
1048 *
1049 * Used by an application to write arbitrary number of bytes to an SCM
1050 * port. Similar semantics as libc write. However, unlike libc
1051 * write, scm_c_write writes the requested number of bytes and has no
1052 * return value.
1053 *
1054 * Warning: Doesn't update port line and column counts!
1055 */
1056
1057void
1058scm_c_write (SCM port, const void *ptr, scm_sizet size)
1059{
1060 scm_port *pt = SCM_PTAB_ENTRY (port);
1061 scm_ptob_descriptor *ptob = &scm_ptobs[SCM_PTOBNUM (port)];
1062
1063 if (pt->rw_active == SCM_PORT_READ)
1064 scm_end_input (port);
1065
1066 ptob->write (port, ptr, size);
1067
1068 if (pt->rw_random)
1069 pt->rw_active = SCM_PORT_WRITE;
1070}
3cb988bd 1071
ee149d03 1072void
a284e297 1073scm_flush (SCM port)
ee149d03
JB
1074{
1075 scm_sizet i = SCM_PTOBNUM (port);
affc96b5 1076 (scm_ptobs[i].flush) (port);
ee149d03
JB
1077}
1078
283a1a0e 1079void
a284e297 1080scm_end_input (SCM port)
283a1a0e
GH
1081{
1082 int offset;
1083 scm_port *pt = SCM_PTAB_ENTRY (port);
1084
1085 if (pt->read_buf == pt->putback_buf)
1086 {
1087 offset = pt->read_end - pt->read_pos;
1088 pt->read_buf = pt->saved_read_buf;
1089 pt->read_pos = pt->saved_read_pos;
1090 pt->read_end = pt->saved_read_end;
1091 pt->read_buf_size = pt->saved_read_buf_size;
1092 }
1093 else
1094 offset = 0;
1095
affc96b5 1096 scm_ptobs[SCM_PTOBNUM (port)].end_input (port, offset);
283a1a0e
GH
1097}
1098
ee149d03
JB
1099\f
1100
1101
1102void
a284e297 1103scm_ungetc (int c, SCM port)
ee149d03 1104{
840ae05d
JB
1105 scm_port *pt = SCM_PTAB_ENTRY (port);
1106
6c951427
GH
1107 if (pt->read_buf == pt->putback_buf)
1108 /* already using the put-back buffer. */
1109 {
1110 /* enlarge putback_buf if necessary. */
1111 if (pt->read_end == pt->read_buf + pt->read_buf_size
1112 && pt->read_buf == pt->read_pos)
1113 {
1114 int new_size = pt->read_buf_size * 2;
1115 unsigned char *tmp =
1116 (unsigned char *) realloc (pt->putback_buf, new_size);
1117
1118 if (tmp == NULL)
1119 scm_memory_error ("scm_ungetc");
1120 pt->read_pos = pt->read_buf = pt->putback_buf = tmp;
1121 pt->read_end = pt->read_buf + pt->read_buf_size;
1122 pt->read_buf_size = pt->putback_buf_size = new_size;
1123 }
1124
1125 /* shift any existing bytes to buffer + 1. */
1126 if (pt->read_pos == pt->read_end)
1127 pt->read_end = pt->read_buf + 1;
1128 else if (pt->read_pos != pt->read_buf + 1)
1129 {
1130 int count = pt->read_end - pt->read_pos;
1131
1132 memmove (pt->read_buf + 1, pt->read_pos, count);
1133 pt->read_end = pt->read_buf + 1 + count;
1134 }
1135
1136 pt->read_pos = pt->read_buf;
1137 }
1138 else
1139 /* switch to the put-back buffer. */
1140 {
1141 if (pt->putback_buf == NULL)
1142 {
c357d546
MD
1143 pt->putback_buf
1144 = (unsigned char *) malloc (SCM_INITIAL_PUTBACK_BUF_SIZE);
6c951427
GH
1145 if (pt->putback_buf == NULL)
1146 scm_memory_error ("scm_ungetc");
1147 pt->putback_buf_size = SCM_INITIAL_PUTBACK_BUF_SIZE;
1148 }
1149
1150 pt->saved_read_buf = pt->read_buf;
1151 pt->saved_read_pos = pt->read_pos;
1152 pt->saved_read_end = pt->read_end;
1153 pt->saved_read_buf_size = pt->read_buf_size;
1154
1155 pt->read_pos = pt->read_buf = pt->putback_buf;
1156 pt->read_end = pt->read_buf + 1;
1157 pt->read_buf_size = pt->putback_buf_size;
1158 }
1159
1160 *pt->read_buf = c;
ee149d03 1161
840ae05d
JB
1162 if (pt->rw_random)
1163 pt->rw_active = SCM_PORT_READ;
1164
ee149d03
JB
1165 if (c == '\n')
1166 {
1167 /* What should col be in this case?
1168 * We'll leave it at -1.
1169 */
1170 SCM_LINUM (port) -= 1;
1171 }
1172 else
1173 SCM_COL(port) -= 1;
1174}
1175
1176
1177void
70d63753 1178scm_ungets (const char *s, int n, SCM port)
ee149d03
JB
1179{
1180 /* This is simple minded and inefficient, but unreading strings is
1181 * probably not a common operation, and remember that line and
1182 * column numbers have to be handled...
1183 *
1184 * Please feel free to write an optimized version!
1185 */
1186 while (n--)
1187 scm_ungetc (s[n], port);
1188}
1189
1190
3b3b36dd 1191SCM_DEFINE (scm_peek_char, "peek-char", 0, 1, 0,
1bbd0b84 1192 (SCM port),
bfc46627
GB
1193 "Returns the next character available from @var{port},\n"
1194 "@emph{without} updating @var{port} to point to the following\n"
1195 "character. If no more characters are available, an end-of-file object\n"
1196 "is returned.@footnote{The value returned by a call to @code{peek-char}\n"
1197 "is the same as the value that would have been returned by a call to\n"
1198 "@code{read-char} on the same port. The only difference is that the very\n"
1199 "next call to @code{read-char} or @code{peek-char} on that\n"
1200 "@var{port} will return the value returned by the preceding call to\n"
1201 "@code{peek-char}. In particular, a call to @code{peek-char} on an\n"
1202 "interactive port will hang waiting for input whenever a call to\n"
1203 "@code{read-char} would have hung.}")
1bbd0b84 1204#define FUNC_NAME s_scm_peek_char
ee149d03
JB
1205{
1206 int c;
1207 if (SCM_UNBNDP (port))
1208 port = scm_cur_inp;
1209 else
3b3b36dd 1210 SCM_VALIDATE_OPINPORT (1,port);
ee149d03
JB
1211 c = scm_getc (port);
1212 if (EOF == c)
1213 return SCM_EOF_VAL;
1214 scm_ungetc (c, port);
7866a09b 1215 return SCM_MAKE_CHAR (c);
3cb988bd 1216}
1bbd0b84 1217#undef FUNC_NAME
3cb988bd 1218
1be4270a 1219SCM_DEFINE (scm_unread_char, "unread-char", 1, 1, 0,
1bbd0b84 1220 (SCM cobj, SCM port),
b380b885
MD
1221 "Place @var{char} in @var{port} so that it will be read by the\n"
1222 "next read operation. If called multiple times, the unread characters\n"
1223 "will be read again in last-in first-out order. If @var{port} is\n"
1224 "not supplied, the current input port is used.")
1bbd0b84 1225#define FUNC_NAME s_scm_unread_char
0f2d19dd
JB
1226{
1227 int c;
1228
7866a09b 1229 SCM_VALIDATE_CHAR (1,cobj);
0f2d19dd
JB
1230 if (SCM_UNBNDP (port))
1231 port = scm_cur_inp;
1232 else
3b3b36dd 1233 SCM_VALIDATE_OPINPORT (2,port);
0f2d19dd 1234
7866a09b 1235 c = SCM_CHAR (cobj);
0f2d19dd 1236
b7f3516f 1237 scm_ungetc (c, port);
0f2d19dd
JB
1238 return cobj;
1239}
1bbd0b84 1240#undef FUNC_NAME
0f2d19dd 1241
a1ec6916 1242SCM_DEFINE (scm_unread_string, "unread-string", 2, 0, 0,
1bbd0b84 1243 (SCM str, SCM port),
b380b885
MD
1244 "Place the string @var{str} in @var{port} so that its characters will be\n"
1245 "read in subsequent read operations. If called multiple times, the\n"
1246 "unread characters will be read again in last-in first-out order. If\n"
1247 "@var{port} is not supplied, the current-input-port is used.")
1bbd0b84 1248#define FUNC_NAME s_scm_unread_string
ee1e7e13 1249{
3b3b36dd 1250 SCM_VALIDATE_STRING (1,str);
ee1e7e13
MD
1251 if (SCM_UNBNDP (port))
1252 port = scm_cur_inp;
1253 else
3b3b36dd 1254 SCM_VALIDATE_OPINPORT (2,port);
ee1e7e13 1255
34f0f2b8 1256 scm_ungets (SCM_STRING_CHARS (str), SCM_STRING_LENGTH (str), port);
ee1e7e13
MD
1257
1258 return str;
1259}
1bbd0b84 1260#undef FUNC_NAME
ee1e7e13 1261
a1ec6916 1262SCM_DEFINE (scm_seek, "seek", 3, 0, 0,
1bbd0b84 1263 (SCM object, SCM offset, SCM whence),
b380b885
MD
1264 "Sets the current position of @var{fd/port} to the integer @var{offset},\n"
1265 "which is interpreted according to the value of @var{whence}.\n\n"
1266 "One of the following variables should be supplied\n"
1267 "for @var{whence}:\n"
1268 "@defvar SEEK_SET\n"
1269 "Seek from the beginning of the file.\n"
1270 "@end defvar\n"
1271 "@defvar SEEK_CUR\n"
1272 "Seek from the current position.\n"
1273 "@end defvar\n"
1274 "@defvar SEEK_END\n"
1275 "Seek from the end of the file.\n"
1276 "@end defvar\n\n"
1277 "If @var{fd/port} is a file descriptor, the underlying system call is\n"
1278 "@code{lseek}. @var{port} may be a string port.\n\n"
1279 "The value returned is the new position in the file. This means that\n"
1280 "the current position of a port can be obtained using:\n"
1281 "@smalllisp\n"
1282 "(seek port 0 SEEK_CUR)\n"
1283 "@end smalllisp")
1bbd0b84 1284#define FUNC_NAME s_scm_seek
840ae05d
JB
1285{
1286 off_t off;
1287 off_t rv;
1288 int how;
1289
1290 object = SCM_COERCE_OUTPORT (object);
1291
6fe692e9
MD
1292 off = SCM_NUM2LONG (2, offset);
1293 SCM_VALIDATE_INUM_COPY (3, whence, how);
840ae05d 1294 if (how != SEEK_SET && how != SEEK_CUR && how != SEEK_END)
1bbd0b84 1295 SCM_OUT_OF_RANGE (3, whence);
0c95b57d 1296 if (SCM_OPPORTP (object))
840ae05d 1297 {
f12733c9 1298 scm_ptob_descriptor *ptob = scm_ptobs + SCM_PTOBNUM (object);
840ae05d
JB
1299
1300 if (!ptob->seek)
1bbd0b84
GB
1301 SCM_MISC_ERROR ("port is not seekable",
1302 scm_cons (object, SCM_EOL));
840ae05d 1303 else
7dcb364d 1304 rv = ptob->seek (object, off, how);
840ae05d
JB
1305 }
1306 else /* file descriptor?. */
1307 {
3b3b36dd 1308 SCM_VALIDATE_INUM (1,object);
840ae05d
JB
1309 rv = lseek (SCM_INUM (object), off, how);
1310 if (rv == -1)
1bbd0b84 1311 SCM_SYSERROR;
840ae05d
JB
1312 }
1313 return scm_long2num (rv);
1314}
1bbd0b84 1315#undef FUNC_NAME
840ae05d 1316
a1ec6916 1317SCM_DEFINE (scm_truncate_file, "truncate-file", 1, 1, 0,
1bbd0b84 1318 (SCM object, SCM length),
b380b885
MD
1319 "Truncates the object referred to by @var{obj} to at most @var{size} bytes.\n"
1320 "@var{obj} can be a string containing a file name or an integer file\n"
1321 "descriptor or a port. @var{size} may be omitted if @var{obj} is not\n"
1322 "a file name, in which case the truncation occurs at the current port.\n"
1323 "position.\n\n"
1324 "The return value is unspecified.")
1bbd0b84 1325#define FUNC_NAME s_scm_truncate_file
840ae05d 1326{
69bc9ff3
GH
1327 int rv;
1328 off_t c_length;
1329
1330 /* object can be a port, fdes or filename. */
840ae05d 1331
840ae05d
JB
1332 if (SCM_UNBNDP (length))
1333 {
69bc9ff3 1334 /* must supply length if object is a filename. */
a6d9e5ab 1335 if (SCM_STRINGP (object))
c1bfcf60 1336 SCM_MISC_ERROR("must supply length if OBJECT is a filename",SCM_EOL);
69bc9ff3 1337
c94577b4 1338 length = scm_seek (object, SCM_INUM0, SCM_MAKINUM (SEEK_CUR));
840ae05d 1339 }
1bbd0b84 1340 c_length = SCM_NUM2LONG (2,length);
69bc9ff3 1341 if (c_length < 0)
1bbd0b84 1342 SCM_MISC_ERROR ("negative offset", SCM_EOL);
3fe6190f 1343
69bc9ff3
GH
1344 object = SCM_COERCE_OUTPORT (object);
1345 if (SCM_INUMP (object))
1346 {
1347 SCM_SYSCALL (rv = ftruncate (SCM_INUM (object), c_length));
1348 }
0c95b57d 1349 else if (SCM_OPOUTPORTP (object))
69bc9ff3
GH
1350 {
1351 scm_port *pt = SCM_PTAB_ENTRY (object);
f12733c9 1352 scm_ptob_descriptor *ptob = scm_ptobs + SCM_PTOBNUM (object);
69bc9ff3 1353
affc96b5 1354 if (!ptob->truncate)
1bbd0b84 1355 SCM_MISC_ERROR ("port is not truncatable", SCM_EOL);
69bc9ff3 1356 if (pt->rw_active == SCM_PORT_READ)
affc96b5 1357 scm_end_input (object);
69bc9ff3 1358 else if (pt->rw_active == SCM_PORT_WRITE)
affc96b5 1359 ptob->flush (object);
69bc9ff3 1360
affc96b5 1361 ptob->truncate (object, c_length);
69bc9ff3
GH
1362 rv = 0;
1363 }
1364 else
1365 {
a6d9e5ab
DH
1366 SCM_VALIDATE_STRING (1, object);
1367 SCM_STRING_COERCE_0TERMINATION_X (object);
1368 SCM_SYSCALL (rv = truncate (SCM_STRING_CHARS (object), c_length));
69bc9ff3
GH
1369 }
1370 if (rv == -1)
1bbd0b84 1371 SCM_SYSERROR;
840ae05d
JB
1372 return SCM_UNSPECIFIED;
1373}
1bbd0b84 1374#undef FUNC_NAME
840ae05d 1375
a1ec6916 1376SCM_DEFINE (scm_port_line, "port-line", 1, 0, 0,
1bbd0b84 1377 (SCM port),
e1546b65 1378 "Return the current line number for @var{port}.")
1bbd0b84 1379#define FUNC_NAME s_scm_port_line
0f2d19dd 1380{
78446828 1381 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 1382 SCM_VALIDATE_OPENPORT (1,port);
360fc44c 1383 return SCM_MAKINUM (SCM_LINUM (port));
0f2d19dd 1384}
1bbd0b84 1385#undef FUNC_NAME
0f2d19dd 1386
a1ec6916 1387SCM_DEFINE (scm_set_port_line_x, "set-port-line!", 2, 0, 0,
1bbd0b84 1388 (SCM port, SCM line),
e1546b65 1389 "Set the current line number for @var{port} to @var{line}.")
1bbd0b84 1390#define FUNC_NAME s_scm_set_port_line_x
d043d8c2 1391{
360fc44c 1392 port = SCM_COERCE_OUTPORT (port);
3b3b36dd
GB
1393 SCM_VALIDATE_OPENPORT (1,port);
1394 SCM_VALIDATE_INUM (2,line);
564478fd
GB
1395 SCM_PTAB_ENTRY (port)->line_number = SCM_INUM (line);
1396 return SCM_UNSPECIFIED;
d043d8c2 1397}
1bbd0b84 1398#undef FUNC_NAME
d043d8c2 1399
a1ec6916 1400SCM_DEFINE (scm_port_column, "port-column", 1, 0, 0,
1bbd0b84 1401 (SCM port),
650a1cf9
NJ
1402 "@deffnx primitive port-line port\n"
1403 "Return the current column number or line number of @var{port},\n"
b380b885
MD
1404 "using the current input port if none is specified. If the number is\n"
1405 "unknown, the result is #f. Otherwise, the result is a 0-origin integer\n"
1406 "- i.e. the first character of the first line is line 0, column 0.\n"
1407 "(However, when you display a file position, for example in an error\n"
650a1cf9 1408 "message, we recommend you add 1 to get 1-origin integers. This is\n"
b380b885
MD
1409 "because lines and column numbers traditionally start with 1, and that is\n"
1410 "what non-programmers will find most natural.)")
1bbd0b84 1411#define FUNC_NAME s_scm_port_column
0f2d19dd 1412{
78446828 1413 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 1414 SCM_VALIDATE_OPENPORT (1,port);
360fc44c 1415 return SCM_MAKINUM (SCM_COL (port));
0f2d19dd 1416}
1bbd0b84 1417#undef FUNC_NAME
0f2d19dd 1418
a1ec6916 1419SCM_DEFINE (scm_set_port_column_x, "set-port-column!", 2, 0, 0,
1bbd0b84 1420 (SCM port, SCM column),
92ccc1f1
NJ
1421 "@deffnx primitive set-port-line! port line\n"
1422 "Set the current column or line number of @var{port}, using the\n"
b380b885 1423 "current input port if none is specified.")
1bbd0b84 1424#define FUNC_NAME s_scm_set_port_column_x
d043d8c2 1425{
360fc44c 1426 port = SCM_COERCE_OUTPORT (port);
3b3b36dd
GB
1427 SCM_VALIDATE_OPENPORT (1,port);
1428 SCM_VALIDATE_INUM (2,column);
564478fd
GB
1429 SCM_PTAB_ENTRY (port)->column_number = SCM_INUM (column);
1430 return SCM_UNSPECIFIED;
d043d8c2 1431}
1bbd0b84 1432#undef FUNC_NAME
d043d8c2 1433
a1ec6916 1434SCM_DEFINE (scm_port_filename, "port-filename", 1, 0, 0,
1bbd0b84 1435 (SCM port),
b380b885 1436 "Return the filename associated with @var{port}. This function returns\n"
2a2a730b 1437 "the strings \"standard input\", \"standard output\" and \"standard error\"\n"
a3c8b9fc 1438 "when called on the current input, output and error ports respectively.")
1bbd0b84 1439#define FUNC_NAME s_scm_port_filename
0f2d19dd 1440{
78446828 1441 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 1442 SCM_VALIDATE_OPENPORT (1,port);
b24b5e13 1443 return SCM_FILENAME (port);
0f2d19dd 1444}
1bbd0b84 1445#undef FUNC_NAME
0f2d19dd 1446
a1ec6916 1447SCM_DEFINE (scm_set_port_filename_x, "set-port-filename!", 2, 0, 0,
1bbd0b84 1448 (SCM port, SCM filename),
b380b885
MD
1449 "Change the filename associated with @var{port}, using the current input\n"
1450 "port if none is specified. Note that this does not change the port's\n"
1451 "source of data, but only the value that is returned by\n"
1452 "@code{port-filename} and reported in diagnostic output.")
1bbd0b84 1453#define FUNC_NAME s_scm_set_port_filename_x
d14af9f2 1454{
360fc44c 1455 port = SCM_COERCE_OUTPORT (port);
3b3b36dd 1456 SCM_VALIDATE_OPENPORT (1,port);
360fc44c 1457 /* We allow the user to set the filename to whatever he likes. */
b24b5e13
DH
1458 SCM_SET_FILENAME (port, filename);
1459 return SCM_UNSPECIFIED;
d14af9f2 1460}
1bbd0b84 1461#undef FUNC_NAME
d14af9f2 1462
0f2d19dd
JB
1463#ifndef ttyname
1464extern char * ttyname();
1465#endif
1466
f12733c9
MD
1467void
1468scm_print_port_mode (SCM exp, SCM port)
1469{
1470 scm_puts (SCM_CLOSEDP (exp)
1471 ? "closed: "
f9a64404
DH
1472 : (SCM_RDNG & SCM_CELL_WORD_0 (exp)
1473 ? (SCM_WRTNG & SCM_CELL_WORD_0 (exp)
f12733c9
MD
1474 ? "input-output: "
1475 : "input: ")
f9a64404 1476 : (SCM_WRTNG & SCM_CELL_WORD_0 (exp)
f12733c9
MD
1477 ? "output: "
1478 : "bogus: ")),
1479 port);
1480}
1cc91f1b 1481
f12733c9
MD
1482int
1483scm_port_print (SCM exp, SCM port, scm_print_state *pstate)
0f2d19dd 1484{
f12733c9
MD
1485 char *type = SCM_PTOBNAME (SCM_PTOBNUM (exp));
1486 if (!type)
1487 type = "port";
b7f3516f 1488 scm_puts ("#<", port);
f12733c9 1489 scm_print_port_mode (exp, port);
b7f3516f
TT
1490 scm_puts (type, port);
1491 scm_putc (' ', port);
12a8b769 1492 scm_intprint (SCM_CELL_WORD_1 (exp), 16, port);
b7f3516f 1493 scm_putc ('>', port);
f12733c9 1494 return 1;
0f2d19dd
JB
1495}
1496
0f2d19dd
JB
1497void
1498scm_ports_prehistory ()
0f2d19dd
JB
1499{
1500 scm_numptob = 0;
f12733c9 1501 scm_ptobs = (scm_ptob_descriptor *) malloc (sizeof (scm_ptob_descriptor));
0f2d19dd 1502}
0f2d19dd
JB
1503
1504\f
ee149d03 1505
d68fee48 1506/* Void ports. */
0f2d19dd 1507
e841c3e0 1508scm_bits_t scm_tc16_void_port = 0;
0f2d19dd 1509
70df8af6 1510static int fill_input_void_port (SCM port)
283a1a0e 1511{
70df8af6 1512 return EOF;
283a1a0e
GH
1513}
1514
31703ab8 1515static void
8aa011a1 1516write_void_port (SCM port, const void *data, size_t size)
31703ab8
GH
1517{
1518}
1519
0f2d19dd 1520SCM
a284e297 1521scm_void_port (char *mode_str)
0f2d19dd
JB
1522{
1523 int mode_bits;
1524 SCM answer;
840ae05d 1525 scm_port * pt;
0f2d19dd
JB
1526
1527 SCM_NEWCELL (answer);
1528 SCM_DEFER_INTS;
1529 mode_bits = scm_mode_bits (mode_str);
1530 pt = scm_add_to_port_table (answer);
70df8af6 1531 scm_port_non_buffer (pt);
0f2d19dd 1532 SCM_SETPTAB_ENTRY (answer, pt);
ee149d03 1533 SCM_SETSTREAM (answer, 0);
54778cd3 1534 SCM_SET_CELL_TYPE (answer, scm_tc16_void_port | mode_bits);
0f2d19dd
JB
1535 SCM_ALLOW_INTS;
1536 return answer;
1537}
1538
a1ec6916 1539SCM_DEFINE (scm_sys_make_void_port, "%make-void-port", 1, 0, 0,
1bbd0b84 1540 (SCM mode),
70df8af6
GH
1541 "Create and return a new void port. A void port acts like\n"
1542 "/dev/null. The @var{mode} argument\n"
1543 "specifies the input/output modes for this port: see the\n"
b380b885 1544 "documentation for @code{open-file} in @ref{File Ports}.")
1bbd0b84 1545#define FUNC_NAME s_scm_sys_make_void_port
0f2d19dd 1546{
a6d9e5ab
DH
1547 SCM_VALIDATE_STRING (1, mode);
1548 SCM_STRING_COERCE_0TERMINATION_X (mode);
1549 return scm_void_port (SCM_STRING_CHARS (mode));
0f2d19dd 1550}
1bbd0b84 1551#undef FUNC_NAME
0f2d19dd 1552
0f2d19dd 1553\f
89545eba 1554/* Initialization. */
1cc91f1b 1555
0f2d19dd
JB
1556void
1557scm_init_ports ()
0f2d19dd 1558{
840ae05d
JB
1559 /* lseek() symbols. */
1560 scm_sysintern ("SEEK_SET", SCM_MAKINUM (SEEK_SET));
1561 scm_sysintern ("SEEK_CUR", SCM_MAKINUM (SEEK_CUR));
1562 scm_sysintern ("SEEK_END", SCM_MAKINUM (SEEK_END));
1563
70df8af6
GH
1564 scm_tc16_void_port = scm_make_port_type ("void", fill_input_void_port,
1565 write_void_port);
8dc9439f 1566#ifndef SCM_MAGIC_SNARFER
a0599745 1567#include "libguile/ports.x"
8dc9439f 1568#endif
0f2d19dd 1569}
89e00824
ML
1570
1571/*
1572 Local Variables:
1573 c-file-style: "gnu"
1574 End:
1575*/