mpw/toolbox/os_internal.cpp

152 lines
2.5 KiB
C++
Raw Normal View History

2013-02-25 22:47:58 +00:00
#include "os_internal.h"
2013-02-26 01:16:55 +00:00
#include <stdexcept>
#include <cerrno>
#include <unistd.h>
#include <fcntl.h>
2013-02-25 22:47:58 +00:00
namespace OS { namespace Internal {
2013-02-26 01:16:55 +00:00
//std::deque<FDEntry> FDTable;
std::deque<FDEntry> FDEntry::FDTable;
FDEntry& FDEntry::allocate(int fd)
{
std::string noname;
return allocate(fd, noname);
}
FDEntry& FDEntry::allocate(int fd, std::string &&filename)
{
if (fd < 0) throw std::out_of_range("Invalid FD");
if (FDTable.size() <= fd)
FDTable.resize(fd + 1);
auto &e = FDTable[fd];
e.refcount = 1;
e.text = false;
e.resource = false;
e.filename = std::move(filename);
return e;
}
FDEntry& FDEntry::allocate(int fd, const std::string &filename)
{
if (fd < 0) throw std::out_of_range("Invalid FD");
if (FDTable.size() <= fd)
FDTable.resize(fd + 1);
auto &e = FDTable[fd];
e.refcount = 1;
e.text = false;
e.resource = false;
e.filename = filename;
return e;
}
2013-02-26 01:40:28 +00:00
int FDEntry::close(int fd, bool force)
{
if (fd < 0 || fd >= FDTable.size())
{
errno = EBADF;
return -1;
}
auto &e = FDTable[fd];
if (!e.refcount)
{
errno = EBADF;
return -1;
}
if (--e.refcount == 0 || force)
{
e.refcount = 0;
return ::close(fd);
}
return 0;
}
2013-02-26 01:16:55 +00:00
ssize_t FDEntry::read(int fd, void *buffer, size_t count)
{
if (fd < 0 || fd >= FDTable.size())
{
errno = EBADF;
return -1;
}
auto const &e = FDTable[fd];
if (!e.refcount)
{
errno = EBADF;
return -1;
}
// hmm... keep a current seek position?
ssize_t size;
if (e.text)
{
std::unique_ptr<uint8_t[]> trbuffer(new uint8_t[count]);
size = ::read(fd, trbuffer.get(), count);
if (size > 0)
{
std::transform(trbuffer.get(), trbuffer.get() + size, (uint8_t *)buffer,
[](uint8_t c) { return c == '\n' ? '\r' : c; }
);
}
}
else
{
size = ::read(fd, buffer, count);
}
return size;
}
ssize_t FDEntry::write(int fd, const void *buffer, size_t count)
{
if (fd < 0 || fd >= FDTable.size())
{
errno = EBADF;
return -1;
}
auto const &e = FDTable[fd];
if (!e.refcount)
{
errno = EBADF;
return -1;
}
// hmm... keep a current seek position?
ssize_t size;
if (e.text)
{
std::unique_ptr<uint8_t[]> trbuffer(new uint8_t[count]);
if (count > 0)
{
std::transform((const uint8_t *)buffer, (const uint8_t *)buffer + count, trbuffer.get(),
[](uint8_t c) { return c == '\r' ? '\n' : c; }
);
}
size = ::write(fd, trbuffer.get(), count);
}
else
{
size = ::write(fd, buffer, count);
}
return size;
}
2013-02-25 22:47:58 +00:00
} }