open.c

Go to the documentation of this file.

/* ************************************************************************** */
/*      ____    _    _____ ____     _    _   _   _____ _  _   ____  ____      */
/*     / ___|  / \  |  ___|  _ \   / \  | \ | | |_   _| || | |  _ \/ ___|     */
/*     \___ \ / _ \ | |_  | |_) | / _ \ |  \| |   | | | || |_| | | \___ \     */
/*      ___) / ___ \|  _| |  _ < / ___ \| |\  |   | | |__   _| |_| |___) |    */
/*     |____/_/   \_|_|   |_| \_/_/   \_|_| \_|   |_|    |_| |____/|____/     */
/*                                                                            */
/* ************************************************************************** */
 
#include "o2s/file_input_stream.h"
#include "o2s/log.h"
 
#include <fcntl.h> // open
 
#include <errno.h>
#include <stdbool.h>
#include <string.h> // strerror
#include <unistd.h> // close
 
#ifndef FILE_STREAM_BUFFER_SIZE
#   define FILE_STREAM_BUFFER_SIZE 4096
#endif

ifstream_t file_open(const char* file_name, int flags)
{
    int descriptor = open(file_name, flags);
 
    if (descriptor < 0)
    {
        log_error("Unable to open \"%s\": %s", file_name, strerror(errno));
        return (ifstream_t){.descriptor = -1, .opened = false};
    }
    ifstream_t file = file_from_descriptor(descriptor);
    file.stream.accumulate = (bool(*)(istream_t*, size_t))file_accumulate;
    if (file.descriptor == descriptor)
        file.opened = true;
    else
        close(descriptor);
    return file;
}

ifstream_t file_from_descriptor(int descriptor)
{
    ifstream_t file = {.descriptor = descriptor, .opened = false};
 
    file.stream = InputStreamInit(FILE_STREAM_BUFFER_SIZE, file_accumulate_infinite);
    if (file.stream.buffer.capacity == 0)
    {
        log_error("malloc failed: %s", strerror(errno));
        file.descriptor = -1;
    }
    return file;
}