+#include <cstdio>
#include <unistd.h>
#include <fcntl.h>
#include <lib/base/rawfile.h>
eRawFile::eRawFile()
{
m_fd = -1;
+ m_file = 0;
m_splitsize = 0;
m_totallength = 0;
m_current_offset = 0;
close();
}
-int eRawFile::open(const char *filename)
+int eRawFile::open(const char *filename, int cached)
{
close();
+ m_cached = cached;
m_basename = filename;
scan();
m_current_offset = 0;
m_last_offset = 0;
- m_fd = ::open(filename, O_RDONLY | O_LARGEFILE);
- return m_fd;
+ if (!m_cached)
+ {
+ m_fd = ::open(filename, O_RDONLY | O_LARGEFILE);
+ return m_fd;
+ } else
+ {
+ m_file = ::fopen64(filename, "rb");
+ if (!m_file)
+ return -1;
+ return 0;
+ }
}
void eRawFile::setfd(int fd)
{
close();
+ m_cached = 0;
m_nrfiles = 1;
m_fd = fd;
}
// eDebug("lseek: %lld, %d", offset, whence);
/* if there is only one file, use the native lseek - the file could be growing! */
if (m_nrfiles < 2)
- return ::lseek(m_fd, offset, whence);
+ {
+ if (!m_cached)
+ return ::lseek(m_fd, offset, whence);
+ else
+ {
+ ::fseeko(m_file, offset, whence);
+ return ::ftello(m_file);
+ }
+ }
switch (whence)
{
case SEEK_SET:
int eRawFile::close()
{
- int ret = ::close(m_fd);
- m_fd = -1;
- return ret;
+ if (m_cached)
+ {
+ if (!m_file)
+ return -1;
+ ::fclose(m_file);
+ m_file = 0;
+ return 0;
+ } else
+ {
+ int ret = ::close(m_fd);
+ m_fd = -1;
+ return ret;
+ }
}
ssize_t eRawFile::read(void *buf, size_t count)
return 0;
}
- int ret = ::read(m_fd, buf, count);
+ int ret;
+
+ if (!m_cached)
+ ret = ::read(m_fd, buf, count);
+ else
+ ret = ::fread(buf, 1, count, m_file);
+
if (ret > 0)
m_current_offset = m_last_offset += ret;
return ret;
int eRawFile::valid()
{
- return m_fd != -1;
+ if (!m_cached)
+ return m_fd != -1;
+ else
+ return !!m_file;
}
void eRawFile::scan()
m_totallength = 0;
while (m_nrfiles < 1000) /* .999 is the last possible */
{
- int f = openFile(m_nrfiles);
- if (f < 0)
- break;
- if (!m_nrfiles)
- m_splitsize = ::lseek(f, 0, SEEK_END);
- m_totallength += ::lseek(f, 0, SEEK_END);
- ::close(f);
+ if (!m_cached)
+ {
+ int f = openFileUncached(m_nrfiles);
+ if (f < 0)
+ break;
+ if (!m_nrfiles)
+ m_splitsize = ::lseek(f, 0, SEEK_END);
+ m_totallength += ::lseek(f, 0, SEEK_END);
+ ::close(f);
+ } else
+ {
+ FILE *f = openFileCached(m_nrfiles);
+ if (!f)
+ break;
+ ::fseeko(f, 0, SEEK_END);
+ if (!m_nrfiles)
+ m_splitsize = ::ftello(f);
+ m_totallength += ::ftello(f);
+ ::fclose(f);
+ }
++m_nrfiles;
}
{
// eDebug("-> %d", filenr);
close();
- m_fd = openFile(filenr);
+ if (!m_cached)
+ m_fd = openFileUncached(filenr);
+ else
+ m_file = openFileCached(filenr);
m_last_offset = m_base_offset = m_splitsize * filenr;
m_current_file = filenr;
}
if (off != m_last_offset)
{
-// eDebug("%llx != %llx", off, m_last_offset);
- m_last_offset = ::lseek(m_fd, off - m_base_offset, SEEK_SET) + m_base_offset;
-// eDebug("offset now %llx", m_last_offset);
+ if (!m_cached)
+ m_last_offset = ::lseek(m_fd, off - m_base_offset, SEEK_SET) + m_base_offset;
+ else
+ {
+ ::fseeko(m_file, off - m_base_offset, SEEK_SET);
+ m_last_offset = ::ftello(m_file) + m_base_offset;
+ }
return m_last_offset;
} else
{
-// eDebug("offset already ok");
return m_last_offset;
}
}
-int eRawFile::openFile(int nr)
+/* m_cached */
+FILE *eRawFile::openFileCached(int nr)
+{
+ std::string filename = m_basename;
+ if (nr)
+ {
+ char suffix[5];
+ snprintf(suffix, 5, ".%03d", nr);
+ filename += suffix;
+ }
+ return ::fopen64(filename.c_str(), "rb");
+}
+
+/* !m_cached */
+int eRawFile::openFileUncached(int nr)
{
std::string filename = m_basename;
if (nr)
snprintf(suffix, 5, ".%03d", nr);
filename += suffix;
}
- return ::open(filename.c_str(), O_RDONLY);
+ return ::open(filename.c_str(), O_RDONLY | O_LARGEFILE);
}