pipe.hpp File Reference

#include "mos/io/io.hpp"
#include "mos/tasks/wait.hpp"
#include <mos/allocator.hpp>
#include <mos/lib/structures/ring_buffer.hpp>

Include dependency graph for pipe.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	pipe_t
struct	PipeIOImpl
struct	pipeio_t

Functions
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)
	Close one end of the pipe, so that the other end will get EOF.
pipeio_t *	pipeio_create (pipe_t *pipe)

Function Documentation

pipe_create()

PtrResult< pipe_t > pipe_create

(

size_t

bufsize

)

Definition at line 165 of file pipe.cpp.

Referenced by ipc_server_accept(), and MOS_STATIC_ASSERT().

Here is the call graph for this function:

pipe_read()

size_t pipe_read	(	pipe_t *	pipe,
		void *	buf,
		size_t	size )

Definition at line 80 of file pipe.cpp.

Referenced by ipc_client_read(), ipc_server_read(), and PipeIOImpl::on_read().

Here is the call graph for this function:

pipe_write()

size_t pipe_write	(	pipe_t *	pipe,
		const void *	buf,
		size_t	size )

Definition at line 20 of file pipe.cpp.

Referenced by ipc_client_write(), ipc_server_write(), and PipeIOImpl::on_write().

Here is the call graph for this function:

pipe_close_one_end()

__nodiscard bool pipe_close_one_end

(

pipe_t *

pipe

)

Close one end of the pipe, so that the other end will get EOF.

Note

The other end should also call this function to get the pipe correctly freed.

Parameters

pipe	The pipe to close one end of.

Returns

true if the pipe was fully closed, false if the other end is still open.

Definition at line 134 of file pipe.cpp.

Referenced by ipc_client_close_channel(), ipc_server_close_channel(), and PipeIOImpl::on_closed().

Here is the call graph for this function:

pipeio_create()

pipeio_t * pipeio_create

(

pipe_t *

pipe

)

Definition at line 213 of file pipe.cpp.

Referenced by MOS_STATIC_ASSERT().

Here is the call graph for this function: