pipe.h

Go to the documentation of this file.

// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
 
#include "mos/io/io.h"
#include "mos/tasks/wait.h"
 
#include <mos/lib/structures/ring_buffer.h>
 
typedef struct
{
    u32 magic;
    waitlist_t waitlist; 
    spinlock_t lock;     
    bool other_closed;   
    void *buffers;
    ring_buffer_pos_t buffer_pos;
} pipe_t;
 
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);
 
typedef struct
{
    io_t io_r, io_w;
    pipe_t *pipe;
} pipeio_t;
 
pipeio_t *pipeio_create(pipe_t *pipe);