aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2008-10-28 20:41:24 +0100
committerMax Kellermann <max@duempel.org>2008-10-28 20:41:24 +0100
commit25f98a41c4b67a52e051c449ebaea815754a8134 (patch)
tree673a3da2d3d65526bd83967aeeedad90d5e493d2 /src
parent0a61877702965dc375b3ad2b2d1cf0315703c22e (diff)
downloadmpd-25f98a41c4b67a52e051c449ebaea815754a8134.tar.gz
mpd-25f98a41c4b67a52e051c449ebaea815754a8134.tar.xz
mpd-25f98a41c4b67a52e051c449ebaea815754a8134.zip
input_file: don't use buffered I/O
Yet another superfluous buffering layer. input_file was using FILE*, but we're better off with unbuffered I/O using open(), read(), ...
Diffstat (limited to '')
-rw-r--r--src/input_file.c59
1 files changed, 31 insertions, 28 deletions
diff --git a/src/input_file.c b/src/input_file.c
index dfb9a815d..467719c60 100644
--- a/src/input_file.c
+++ b/src/input_file.c
@@ -17,35 +17,40 @@
*/
#include "input_file.h"
-
#include "log.h"
-#include "os_compat.h"
+
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <errno.h>
+#include <string.h>
+#include <glib.h>
static bool
input_file_open(struct input_stream *is, const char *filename)
{
- FILE *fp;
+ int fd, ret;
+ struct stat st;
if (filename[0] != '/')
return false;
- fp = fopen(filename, "r");
- if (!fp) {
+ fd = open(filename, O_RDONLY);
+ if (fd < 0) {
is->error = errno;
return false;
}
is->seekable = true;
- fseek(fp, 0, SEEK_END);
- is->size = ftell(fp);
- fseek(fp, 0, SEEK_SET);
+ ret = fstat(fd, &st);
+ is->size = st.st_size;
#ifdef POSIX_FADV_SEQUENTIAL
- posix_fadvise(fileno(fp), (off_t)0, is->size, POSIX_FADV_SEQUENTIAL);
+ posix_fadvise(fd, (off_t)0, is->size, POSIX_FADV_SEQUENTIAL);
#endif
- is->data = fp;
+ is->data = GINT_TO_POINTER(fd);
is->ready = true;
return true;
@@ -54,50 +59,48 @@ input_file_open(struct input_stream *is, const char *filename)
static bool
input_file_seek(struct input_stream *is, off_t offset, int whence)
{
- if (fseek((FILE *) is->data, offset, whence) == 0) {
- is->offset = ftell((FILE *) is->data);
- } else {
+ int fd = GPOINTER_TO_INT(is->data);
+
+ offset = lseek(fd, offset, whence);
+ if (offset < 0) {
is->error = errno;
return false;
}
+ is->offset = offset;
return true;
}
static size_t
input_file_read(struct input_stream *is, void *ptr, size_t size)
{
- size_t readSize;
+ int fd = GPOINTER_TO_INT(is->data);
+ ssize_t nbytes;
- readSize = fread(ptr, 1, size, (FILE *) is->data);
- if (readSize <= 0 && ferror((FILE *) is->data)) {
+ nbytes = read(fd, ptr, size);
+ if (nbytes < 0) {
is->error = errno;
DEBUG("input_file_read: error reading: %s\n",
strerror(is->error));
+ return 0;
}
- is->offset = ftell((FILE *) is->data);
-
- return readSize;
+ is->offset += nbytes;
+ return (size_t)nbytes;
}
static void
input_file_close(struct input_stream *is)
{
- fclose((FILE *) is->data);
+ int fd = GPOINTER_TO_INT(is->data);
+
+ close(fd);
}
static bool
input_file_eof(struct input_stream *is)
{
- if (feof((FILE *) is->data))
- return 1;
-
- if (ferror((FILE *) is->data) && is->error != EINTR) {
- return 1;
- }
-
- return 0;
+ return is->offset >= is->size;
}
static int