aboutsummaryrefslogtreecommitdiff
path: root/lib/mlibc/options/posix/generic/posix-file-io.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/mlibc/options/posix/generic/posix-file-io.cpp')
-rw-r--r--lib/mlibc/options/posix/generic/posix-file-io.cpp275
1 files changed, 0 insertions, 275 deletions
diff --git a/lib/mlibc/options/posix/generic/posix-file-io.cpp b/lib/mlibc/options/posix/generic/posix-file-io.cpp
deleted file mode 100644
index 1a4f38b..0000000
--- a/lib/mlibc/options/posix/generic/posix-file-io.cpp
+++ /dev/null
@@ -1,275 +0,0 @@
-#include <mlibc/posix-file-io.hpp>
-#include <mlibc/debug.hpp>
-#include <mlibc/posix-sysdeps.hpp>
-
-#include <errno.h>
-
-namespace mlibc {
-
-int mem_file::reopen(const char *, const char *) {
- mlibc::panicLogger() << "mlibc: freopen() on a mem_file stream is unimplemented!" << frg::endlog;
- return -1;
-}
-
-int mem_file::determine_type(stream_type *type) {
- *type = stream_type::file_like;
- return 0;
-}
-
-int mem_file::determine_bufmode(buffer_mode *mode) {
- *mode = buffer_mode::no_buffer;
- return 0;
-}
-
-memstream_mem_file::memstream_mem_file(char **ptr, size_t *sizeloc, int flags, void (*do_dispose)(abstract_file *))
-: mem_file{flags, do_dispose}, _bufloc{ptr}, _sizeloc{sizeloc} { }
-
-
-int memstream_mem_file::close() {
- _update_ptrs();
- _buf.detach();
-
- return 0;
-}
-
-int memstream_mem_file::io_read(char *buffer, size_t max_size, size_t *actual_size) {
- if ((_pos >= 0 && _pos >= _max_size) || !max_size) {
- *actual_size = 0;
- return 0;
- }
-
- size_t bytes_read = std::min(size_t(_max_size - _pos), max_size);
- memcpy(buffer, _buffer().data() + _pos, bytes_read);
- _pos += bytes_read;
- *actual_size = bytes_read;
- return 0;
-}
-
-int memstream_mem_file::io_write(const char *buffer, size_t max_size, size_t *actual_size) {
- if (_pos + max_size >= _buffer_size()) {
- _buf.resize(_pos + max_size + 1, '\0');
- _update_ptrs();
- }
-
- size_t bytes_write = std::min(static_cast<size_t>(_buffer_size() - _pos), max_size);
- memcpy(_buffer().data() + _pos, buffer, bytes_write);
- _pos += max_size;
- *actual_size = max_size;
-
- return 0;
-}
-
-int memstream_mem_file::io_seek(off_t offset, int whence, off_t *new_offset) {
- switch (whence) {
- case SEEK_SET:
- _pos = offset;
- if (_pos >= 0 && size_t(_pos) >= _buffer_size()) {
- _buf.resize(_pos + 1, '\0');
- _update_ptrs();
- }
- *new_offset = _pos;
- break;
- case SEEK_CUR:
- _pos += offset;
- if (_pos >= 0 && size_t(_pos) >= _buffer_size()) {
- _buf.resize(_pos + 1, '\0');
- _update_ptrs();
- }
- *new_offset = _pos;
- break;
- case SEEK_END:
- _pos = _buffer_size() ? _buffer_size() - 1 + offset : _buffer_size() + offset;
- _buf.resize(_pos + 1, '\0');
- _update_ptrs();
- *new_offset = _pos;
- break;
- default:
- return EINVAL;
- }
- return 0;
-}
-
-void memstream_mem_file::_update_ptrs() {
- *_bufloc = _buf.data();
- *_sizeloc = _buf.size() - 1;
-}
-
-fmemopen_mem_file::fmemopen_mem_file(void *in_buf, size_t size, int flags, void (*do_dispose)(abstract_file *))
-: mem_file{flags, do_dispose}, _inBuffer{in_buf}, _inBufferSize{size} {
- if(!_inBuffer) {
- _inBuffer = getAllocator().allocate(size);
- _needsDeallocation = true;
- }
-
- if(_flags & O_APPEND) {
- // the initial seek-size for append is zero if buf was NULL, or the first '\0' found, or the size
- _max_size = (_needsDeallocation) ? 0 : strnlen(reinterpret_cast<char *>(_inBuffer), _inBufferSize);
- _pos = _max_size;
- } else if((_flags & O_WRONLY || _flags & O_RDWR) && _flags & O_CREAT && _flags & O_TRUNC) {
- // modes: "w", "w+"
- _max_size = 0;
- } else {
- _max_size = size;
- }
-}
-
-int fmemopen_mem_file::close() {
- if(_needsDeallocation) {
- getAllocator().free(_inBuffer);
- }
-
- return 0;
-}
-
-int fmemopen_mem_file::io_read(char *buffer, size_t max_size, size_t *actual_size) {
- if ((_pos >= 0 && _pos >= _max_size) || !max_size) {
- *actual_size = 0;
- return 0;
- }
-
- size_t bytes_read = std::min(size_t(_max_size - _pos), max_size);
- memcpy(buffer, _buffer().data() + _pos, bytes_read);
- _pos += bytes_read;
- *actual_size = bytes_read;
- return 0;
-}
-
-int fmemopen_mem_file::io_write(const char *buffer, size_t max_size, size_t *actual_size) {
- off_t bytes_write = std::min(static_cast<size_t>(_buffer_size() - _pos), max_size);
- memcpy(_buffer().data() + _pos, buffer, bytes_write);
- _pos += bytes_write;
- *actual_size = bytes_write;
-
- if(_pos > _max_size) {
- _max_size = _pos;
- }
-
- // upon flushing, we need to put a null byte at the current position or at the end of the buffer
- size_t null = _pos;
- // a special case is if the mode is set to updating ('+'), then it always goes at the end
- if(null >= _buffer_size() || _flags & O_RDWR) {
- null = _buffer_size() - 1;
- }
-
- if(_buffer_size()) {
- _buffer()[null] = '\0';
- }
-
- return 0;
-}
-
-int fmemopen_mem_file::io_seek(off_t offset, int whence, off_t *new_offset) {
- switch (whence) {
- case SEEK_SET:
- if(offset < 0 || size_t(offset) > _buffer_size()) {
- return EINVAL;
- }
- _pos = offset;
- *new_offset = _pos;
- break;
- case SEEK_CUR:
- // seeking to negative positions or positions larger than the buffer is disallowed in fmemopen(3)
- if((_pos + offset) < 0 || size_t(_pos + offset) > _buffer_size()) {
- return EINVAL;
- }
- _pos += offset;
- *new_offset = _pos;
- break;
- case SEEK_END:
- if((_max_size + offset) < 0 || size_t(_max_size + offset) > _buffer_size()) {
- return EINVAL;
- }
- _pos = _max_size + offset;
- *new_offset = _pos;
- break;
- default:
- return EINVAL;
- }
- return 0;
-}
-
-int cookie_file::close() {
- if(!_funcs.close) {
- return 0;
- }
-
- return _funcs.close(_cookie);
-}
-
-int cookie_file::reopen(const char *, const char *) {
- mlibc::panicLogger() << "mlibc: freopen() on a cookie_file stream is unimplemented!" << frg::endlog;
- return -1;
-}
-
-int cookie_file::determine_type(stream_type *type) {
- *type = stream_type::file_like;
- return 0;
-}
-
-int cookie_file::determine_bufmode(buffer_mode *mode) {
- *mode = buffer_mode::no_buffer;
- return 0;
-}
-
-int cookie_file::io_read(char *buffer, size_t max_size, size_t *actual_size) {
- if(!_funcs.read) {
- return EOF;
- }
-
- *actual_size = _funcs.read(_cookie, buffer, max_size);
-
- return 0;
-}
-
-int cookie_file::io_write(const char *buffer, size_t max_size, size_t *actual_size) {
- if(!_funcs.write) {
- return 0;
- }
-
- *actual_size = _funcs.write(_cookie, buffer, max_size);
-
- return 0;
-}
-
-int cookie_file::io_seek(off_t offset, int whence, off_t *new_offset) {
- if(!_funcs.seek) {
- return ENOTSUP;
- }
-
- *new_offset = offset;
-
- return _funcs.seek(_cookie, new_offset, whence);
-}
-
-} // namespace mlibc
-
-FILE *fdopen(int fd, const char *mode) {
- int flags = mlibc::fd_file::parse_modestring(mode);
-
- flags &= ~O_TRUNC; // 'w' should not truncate the file
-
- if (flags & O_APPEND) {
- int cur_flags = fcntl(fd, F_GETFL, 0);
- if (cur_flags < 0) {
- errno = EINVAL;
- return nullptr;
- } else if (!(cur_flags & O_APPEND)) {
- if (fcntl(fd, F_SETFL, cur_flags | O_APPEND)) {
- errno = EINVAL;
- return nullptr;
- }
- }
- }
-
- if (flags & O_CLOEXEC) {
- if (fcntl(fd, F_SETFD, FD_CLOEXEC)) {
- errno = EINVAL;
- return nullptr;
- }
- }
-
- // TODO: We may need to activate line buffered mode for terminals.
-
- return frg::construct<mlibc::fd_file>(getAllocator(), fd,
- mlibc::file_dispose_cb<mlibc::fd_file>);
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-02 01:18:23 +0000