posix_file_handle.h

Go to the documentation of this file.

// Copyright (c) 2018, Smart Projects Holdings Ltd
// All rights reserved.
// See LICENSE file for license details.

#ifndef _UGCS_VSM_POSIX_FILE_HANDLE_H_
#define _UGCS_VSM_POSIX_FILE_HANDLE_H_

#include <ugcs/vsm/poll_io_controller.h>
#include <ugcs/vsm/platform_sockets.h>

namespace ugcs {
namespace vsm {
namespace internal {

class Posix_file_handle:
        public ugcs::vsm::File_processor::Stream::Native_handle {

public:

    Posix_file_handle(int fd, int write_fd = -1);

    Posix_file_handle(
            const std::string& path,
            const File_processor::Stream::Mode& mode,
            mode_t permissions = S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);

    virtual
    ~Posix_file_handle();

protected:

    struct Io_cb: public Poll_io_controller::Io_cb {

        Io_cb(Posix_file_handle &handle):
            handle(handle)
        {}

        Posix_file_handle &handle;
    };

    int fd = -1;
    int write_fd = -1;
    Io_cb read_cb;
    Io_cb write_cb;
    std::shared_ptr<std::vector<uint8_t>> read_buf;
    std::mutex write_mutex,
    read_mutex;
    size_t min_read_size;

    virtual void
    Write() override;

    static void
    Write_complete_cbk_s(Poll_io_controller::Io_cb &io_cb);

    void
    Write_complete_cbk();

    virtual void
    Read() override;

    void
    Read_impl(std::unique_lock<std::mutex>&& read_lock);

    virtual File_processor::Stream::Lock_result
    Try_lock() override;

    virtual bool
    Lock() override;

    virtual bool
    Unlock() override;

    static void
    Read_complete_cbk_s(Poll_io_controller::Io_cb &io_cb);

    void
    Read_complete_cbk();

    virtual bool
    Cancel_write() override;

    virtual bool
    Cancel_read() override;

    virtual void
    Close() override;

    static Io_result
    Map_error(int error);

    Poll_io_controller &
    Get_controller() const
    {
        return reinterpret_cast<Poll_io_controller &>(Get_native_controller());
    }

};

} /* namespace internal */
} /* namespace vsm */
} /* namespace ugcs */

#endif /* _UGCS_VSM_POSIX_FILE_HANDLE_H_ */