1
Fork 0
mirror of https://git.savannah.gnu.org/git/guile.git synced 2025-05-02 21:10:27 +02:00

Make scm_c_read use caller buffer only for unbuffered ports.

We recently modified scm_c_read so that it temporarily swaps the
caller's buffer with the port's normal read buffer, in order to
improve performance in the case where the port is unbuffered (which
actually means having a single-byte buffer) - but we implemented the
swap in the buffered case too.  The latter turns out to be a bad idea
- because it means that the C code of a custom port implementation
cannot rely on a port's buffer always being the same as when it was
first set up - and so this commit reverts that.  The buffer swapping
trick now applies to unbuffered ports only.

* libguile/ports.c (scm_c_read): Only do swapping of port and caller
  buffer for unbuffered ports.
This commit is contained in:
Neil Jerram 2008-11-23 22:37:23 +00:00
parent c9e44fd755
commit 6d2275560d

View file

@ -1073,14 +1073,20 @@ scm_c_read (SCM port, void *buffer, size_t size)
/* Now we will call scm_fill_input repeatedly until we have read the /* Now we will call scm_fill_input repeatedly until we have read the
requested number of bytes. (Note that a single scm_fill_input requested number of bytes. (Note that a single scm_fill_input
call does not guarantee to fill the whole of the port's read call does not guarantee to fill the whole of the port's read
buffer.) For these calls, since we already have a buffer here to buffer.) */
read into, we bypass the port's own read buffer (if it has one), if (pt->read_buf_size <= 1)
by saving it off and modifying the port structure to point to our {
own buffer. /* The port that we are reading from is unbuffered - i.e. does
not have its own persistent buffer - but we have a buffer,
provided by our caller, that is the right size for the data
that is wanted. For the following scm_fill_input calls,
therefore, we use the buffer in hand as the port's read
buffer.
We need to make sure that the port's normal buffer is reinstated We need to make sure that the port's normal (1 byte) buffer
in case one of the scm_fill_input () calls throws an exception; is reinstated in case one of the scm_fill_input () calls
we use the scm_dynwind_* API to achieve that. */ throws an exception; we use the scm_dynwind_* API to achieve
that. */
psb.pt = pt; psb.pt = pt;
psb.buffer = buffer; psb.buffer = buffer;
psb.size = size; psb.size = size;
@ -1088,8 +1094,8 @@ scm_c_read (SCM port, void *buffer, size_t size)
scm_dynwind_rewind_handler (swap_buffer, &psb, SCM_F_WIND_EXPLICITLY); scm_dynwind_rewind_handler (swap_buffer, &psb, SCM_F_WIND_EXPLICITLY);
scm_dynwind_unwind_handler (swap_buffer, &psb, SCM_F_WIND_EXPLICITLY); scm_dynwind_unwind_handler (swap_buffer, &psb, SCM_F_WIND_EXPLICITLY);
/* Call scm_fill_input until we have all the bytes that we need, or /* Call scm_fill_input until we have all the bytes that we need,
we hit EOF. */ or we hit EOF. */
while (pt->read_buf_size && (scm_fill_input (port) != EOF)) while (pt->read_buf_size && (scm_fill_input (port) != EOF))
{ {
pt->read_buf_size -= (pt->read_end - pt->read_pos); pt->read_buf_size -= (pt->read_end - pt->read_pos);
@ -1099,6 +1105,24 @@ scm_c_read (SCM port, void *buffer, size_t size)
/* Reinstate the port's normal buffer. */ /* Reinstate the port's normal buffer. */
scm_dynwind_end (); scm_dynwind_end ();
}
else
{
/* The port has its own buffer. It is important that we use it,
even if it happens to be smaller than our caller's buffer, so
that a custom port implementation's entry points (in
particular, fill_input) can rely on the buffer always being
the same as they first set up. */
while (size && (scm_fill_input (port) != EOF))
{
n_available = min (size, pt->read_end - pt->read_pos);
memcpy (buffer, pt->read_pos, n_available);
buffer = (char *) buffer + n_available;
pt->read_pos += n_available;
n_read += n_available;
size -= n_available;
}
}
return n_read; return n_read;
} }