src/inputStream_file.c

   1 /* the Music Player Daemon (MPD)
   2  * Copyright (C) 2003-2007 by Warren Dukes (warren.dukes@gmail.com)
   3  * This project's homepage is: http://www.musicpd.org
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License for more details.
  14  * You should have received a copy of the GNU General Public License
  15  * along with this program; if not, write to the Free Software
  16  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17  */
  18
  19 #include "inputStream_file.h"
  20
  21 #include "log.h"
  22
  23 #include <stdio.h>
  24 #include <string.h>
  25 #include <sys/types.h>
  26 #include <unistd.h>
  27 #include <errno.h>
  28 #define _XOPEN_SOURCE 600
  29 #include <fcntl.h>
  30
  31 void inputStream_initFile(void)
  32 {
  33 }
  34
  35 int inputStream_fileOpen(InputStream * inStream, char *filename)
  36 {
  37         FILE *fp;
  38
  39         fp = fopen(filename, "r");
  40         if (!fp) {
  41                 inStream->error = errno;
  42                 return -1;
  43         }
  44
  45         inStream->seekable = 1;
  46
  47         fseek(fp, 0, SEEK_END);
  48         inStream->size = ftell(fp);
  49         fseek(fp, 0, SEEK_SET);
  50
  51 #ifdef POSIX_FADV_SEQUENTIAL
  52         posix_fadvise(fileno(fp), (off_t)0, inStream->size, POSIX_FADV_SEQUENTIAL);
  53 #endif
  54
  55         inStream->data = fp;
  56         inStream->seekFunc = inputStream_fileSeek;
  57         inStream->closeFunc = inputStream_fileClose;
  58         inStream->readFunc = inputStream_fileRead;
  59         inStream->atEOFFunc = inputStream_fileAtEOF;
  60         inStream->bufferFunc = inputStream_fileBuffer;
  61
  62         return 0;
  63 }
  64
  65 int inputStream_fileSeek(InputStream * inStream, long offset, int whence)
  66 {
  67         if (fseek((FILE *) inStream->data, offset, whence) == 0) {
  68                 inStream->offset = ftell((FILE *) inStream->data);
  69         } else {
  70                 inStream->error = errno;
  71                 return -1;
  72         }
  73
  74         return 0;
  75 }
  76
  77 size_t inputStream_fileRead(InputStream * inStream, void *ptr, size_t size,
  78                             size_t nmemb)
  79 {
  80         size_t readSize;
  81
  82         readSize = fread(ptr, size, nmemb, (FILE *) inStream->data);
  83         if (readSize <= 0 && ferror((FILE *) inStream->data)) {
  84                 inStream->error = errno;
  85                 DEBUG("inputStream_fileRead: error reading: %s\n",
  86                       strerror(inStream->error));
  87         }
  88
  89         inStream->offset = ftell((FILE *) inStream->data);
  90
  91         return readSize;
  92 }
  93
  94 int inputStream_fileClose(InputStream * inStream)
  95 {
  96         if (fclose((FILE *) inStream->data) < 0) {
  97                 inStream->error = errno;
  98                 return -1;
  99         }
 100
 101         return 0;
 102 }
 103
 104 int inputStream_fileAtEOF(InputStream * inStream)
 105 {
 106         if (feof((FILE *) inStream->data))
 107                 return 1;
 108
 109         if (ferror((FILE *) inStream->data) && inStream->error != EINTR) {
 110                 return 1;
 111         }
 112
 113         return 0;
 114 }
 115
 116 int inputStream_fileBuffer(InputStream * inStream)
 117 {
 118         return 0;
 119 }