/*
* (c) The GRASP/AQUA Project, Glasgow University, 1994-1998
*
- * $Id: readFile.c,v 1.10 2000/01/18 12:42:12 simonmar Exp $
+ * $Id: readFile.c,v 1.13 2000/03/21 17:41:02 simonmar Exp $
*
* hGetContents Runtime Support
*/
}
/* Filling up a (block-buffered) buffer of length len */
+
+/* readChunk(FileObjet *, void *, int)
+ * returns:
+ * -1 error
+ * -2 object closed
+ * FILEOBJ_BLOCKED_CONN_WRITE blocking while flushing
+ * buffer of connected handle.
+ * FILEOBJ_BLOCKED_READ didn't read anything; would block
+ * n, where n > 0 read n bytes into buffer.
+ */
+
StgInt
-readChunk(StgForeignPtr ptr, StgAddr buf, StgInt len)
+readChunk(StgForeignPtr ptr, StgAddr buf, StgInt off, StgInt len)
{
IOFileObject* fo = (IOFileObject*)ptr;
- int count=0,rc=0, total_count;
+ int count, rc=0, total_count=0;
int fd;
char* p;
}
fo->flags = (fo->flags & ~FILEOBJ_RW_WRITE) | FILEOBJ_RW_READ;
+ p = buf+off;
+
/* copy the unread parts of the file buffer..*/
if ( FILEOBJ_READABLE(fo) &&
fo->bufRPtr > 0 &&
fo->bufWPtr >= fo->bufRPtr ) {
- count = ( len < (fo->bufWPtr - fo->bufRPtr)) ? len : (fo->bufWPtr - fo->bufRPtr);
- memcpy(buf,fo->buf, count);
- fo->bufWPtr=0;
- fo->bufRPtr=0;
-
- }
-
- if (len - count <= 0)
- return count;
- len -= count;
- p = buf;
- p += count;
- total_count = count;
+ if (fo->bufWPtr - fo->bufRPtr >= len) {
+ /* buffer has enough data to fulfill the request */
+ memcpy(buf, fo->buf + fo->bufRPtr, len);
+ fo->bufRPtr += len;
+ return len;
+ } else {
+ /* can only partially fulfill the request from the buffer */
+ count = fo->bufWPtr - fo->bufRPtr;
+ memcpy(buf, fo->buf + fo->bufRPtr, count);
+ fo->bufWPtr=0;
+ fo->bufRPtr=0;
+ len -= count;
+ p += count;
+ total_count = count;
+ }
+ }
while ((count =
(
#else
read(fd, p, len))) <= 0 ) {
#endif
- if ( count == 0 ) { /* EOF */
- break;
+ /* EOF */
+ if ( count == 0 ) {
+ FILEOBJ_SET_EOF(fo);
+ return total_count;
+
+ /* Blocking */
} else if ( count == -1 && errno == EAGAIN) {
- /* ToDo: partial/blocked reads?????? Looks like we don't recover
- * from this properly.
- */
errno = 0;
- return FILEOBJ_BLOCKED_READ;
+ if (total_count > 0)
+ return total_count; /* partial read */
+ else
+ return FILEOBJ_BLOCKED_READ;
+
+ /* Error */
} else if ( count == -1 && errno != EINTR) {
cvtErrno();
stdErrno();
return -1;
- }
- total_count += count;
- len -= count;
- p += count;
+ }
}
total_count += count;
- /* ToDo: might point beyond the end of the buffer??? */
- fo->bufWPtr = total_count;
- fo->bufRPtr = 0;
return total_count;
}