pipe.hpp

Go to the documentation of this file.

// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
 
#include "mos/io/io.hpp"
#include "mos/tasks/wait.hpp"
 
#include <mos/allocator.hpp>
#include <mos/lib/structures/ring_buffer.hpp>
 
struct pipe_t : mos::NamedType<"Pipe">
{
    u32 magic;
    waitlist_t waitlist; 
    spinlock_t lock;     
    bool other_closed;   
    void *buffers;
    ring_buffer_pos_t buffer_pos;
};
 
PtrResult<pipe_t> pipe_create(size_t bufsize);
size_t pipe_read(pipe_t *pipe, void *buf, size_t size);
size_t pipe_write(pipe_t *pipe, const void *buf, size_t size);

__nodiscard bool pipe_close_one_end(pipe_t *pipe);
 
struct pipeio_t : mos::NamedType<"PipeIO">
{
    io_t io_r, io_w;
    pipe_t *pipe;
};
 
pipeio_t *pipeio_create(pipe_t *pipe);