ipc.cpp File Reference

#include "mos/ipc/ipc.hpp"
#include "mos/filesystem/dentry.hpp"
#include "mos/filesystem/sysfs/sysfs.hpp"
#include "mos/filesystem/sysfs/sysfs_autoinit.hpp"
#include "mos/filesystem/vfs_types.hpp"
#include "mos/ipc/pipe.hpp"
#include "mos/lib/sync/spinlock.hpp"
#include "mos/platform/platform.hpp"
#include "mos/syslog/printk.hpp"
#include "mos/tasks/schedule.hpp"
#include "mos/tasks/signal.hpp"
#include "mos/tasks/wait.hpp"
#include <mos/allocator.hpp>
#include <mos/filesystem/fs_types.h>
#include <mos/lib/structures/hashmap_common.hpp>
#include <mos/lib/structures/list.hpp>
#include <mos/mos_global.h>
#include <mos_stdlib.hpp>
#include <mos_string.hpp>

Include dependency graph for ipc.cpp:

Go to the source code of this file.

Classes
struct	IPCDescriptor
struct	IPCServer

Macros
#define	pr_fmt(fmt)
#define	IPC_SERVER_MAGIC   MOS_FOURCC('I', 'P', 'C', 'S')

Functions
void	ipc_server_close (IPCServer *server)
size_t	ipc_client_read (IPCDescriptor *ipc, void *buf, size_t size)
size_t	ipc_client_write (IPCDescriptor *ipc, const void *buf, size_t size)
size_t	ipc_server_read (IPCDescriptor *ipc, void *buf, size_t size)
size_t	ipc_server_write (IPCDescriptor *ipc, const void *buf, size_t size)
void	ipc_client_close_channel (IPCDescriptor *ipc)
void	ipc_server_close_channel (IPCDescriptor *ipc)
void	ipc_init (void)
static inode_t *	ipc_sysfs_create_ino (IPCServer *ipc_server)
PtrResult< IPCServer >	ipc_server_create (mos::string_view name, size_t max_pending)
PtrResult< IPCServer >	ipc_get_server (mos::string_view name)
PtrResult< IPCDescriptor >	ipc_server_accept (IPCServer *ipc_server)
PtrResult< IPCDescriptor >	ipc_connect_to_server (mos::string_view name, size_t buffer_size)
static bool	ipc_sysfs_servers (sysfs_file_t *f)
static void	ipc_sysfs_list_ipcs (sysfs_item_t *item, dentry_t *d, vfs_listdir_state_t *state, dentry_iterator_op add_record)
static bool	ipc_sysfs_lookup_ipc (inode_t *parent_dir, dentry_t *dentry)
static bool	ipc_sysfs_create_server (inode_t *dir, dentry_t *dentry, file_type_t type, file_perm_t perm)
static bool	ipc_dump_name_waitlist (uintn key, void *value, void *data)
static bool	ipc_sysfs_dump_name_waitlist (sysfs_file_t *f)
	SYSFS_AUTOREGISTER (ipc, ipc_sysfs_items)

Variables
static list_head	ipc_servers
static hashmap_t	name_waitlist
	waitlist for an IPC server, key = name, value = waitlist_t *
static spinlock_t	ipc_lock
	protects ipc_servers and name_waitlist
static sysfs_item_t	ipc_sysfs_items []

Macro Definition Documentation

pr_fmt

#define pr_fmt

(

fmt

)

Value:

"ipc: " fmt

Definition at line 3 of file ipc.cpp.

IPC_SERVER_MAGIC

#define IPC_SERVER_MAGIC   MOS_FOURCC('I', 'P', 'C', 'S')

Definition at line 27 of file ipc.cpp.

Function Documentation

ipc_server_close()

void ipc_server_close

(

IPCServer *

server

)

Definition at line 88 of file ipc.cpp.

Referenced by ipc_control_io_close(), ipc_create(), and vfs_ipc_file_release().

Here is the call graph for this function:

ipc_client_read()

size_t ipc_client_read	(	IPCDescriptor *	ipc,
		void *	buf,
		size_t	size )

Definition at line 133 of file ipc.cpp.

Referenced by ipc_client_io_read(), and vfs_ipc_file_read().

Here is the call graph for this function:

ipc_client_write()

size_t ipc_client_write	(	IPCDescriptor *	ipc,
		const void *	buf,
		size_t	size )

Definition at line 138 of file ipc.cpp.

Referenced by ipc_client_io_write(), and vfs_ipc_file_write().

Here is the call graph for this function:

ipc_server_read()

size_t ipc_server_read	(	IPCDescriptor *	ipc,
		void *	buf,
		size_t	size )

Definition at line 143 of file ipc.cpp.

Referenced by ipc_server_io_read().

Here is the call graph for this function:

ipc_server_write()

size_t ipc_server_write	(	IPCDescriptor *	ipc,
		const void *	buf,
		size_t	size )

Definition at line 148 of file ipc.cpp.

Referenced by ipc_server_io_write().

Here is the call graph for this function:

ipc_client_close_channel()

void ipc_client_close_channel

(

IPCDescriptor *

ipc

)

Definition at line 153 of file ipc.cpp.

Referenced by ipc_client_io_close(), and vfs_ipc_file_release().

Here is the call graph for this function:

ipc_server_close_channel()

void ipc_server_close_channel

(

IPCDescriptor *

ipc

)

Definition at line 167 of file ipc.cpp.

Referenced by ipc_server_io_close().

Here is the call graph for this function:

ipc_init()

void ipc_init

(

void

)

Definition at line 181 of file ipc.cpp.

Referenced by mos_start_kernel().

Here is the call graph for this function:

ipc_sysfs_create_ino()

static inode_t * ipc_sysfs_create_ino ( IPCServer * ipc_server )

static

Definition at line 422 of file ipc.cpp.

Referenced by ipc_server_create().

Here is the call graph for this function:

ipc_server_create()

PtrResult< IPCServer > ipc_server_create	(	mos::string_view	name,
		size_t	max_pending )

Definition at line 188 of file ipc.cpp.

Referenced by ipc_create(), and ipc_sysfs_create_server().

Here is the call graph for this function:

ipc_get_server()

PtrResult< IPCServer > ipc_get_server

(

mos::string_view

name

)

Definition at line 224 of file ipc.cpp.

Referenced by vfs_open_ipc().

ipc_server_accept()

PtrResult< IPCDescriptor > ipc_server_accept

(

IPCServer *

ipc_server

)

Definition at line 236 of file ipc.cpp.

Referenced by ipc_accept(), and vfs_ipc_file_read().

Here is the call graph for this function:

ipc_connect_to_server()

PtrResult< IPCDescriptor > ipc_connect_to_server	(	mos::string_view	name,
		size_t	buffer_size )

Definition at line 305 of file ipc.cpp.

Referenced by ipc_connect(), and vfs_open_ipc().

Here is the call graph for this function:

ipc_sysfs_servers()

static bool ipc_sysfs_servers ( sysfs_file_t * f )

static

Definition at line 411 of file ipc.cpp.

Here is the call graph for this function:

ipc_sysfs_list_ipcs()

static void ipc_sysfs_list_ipcs ( sysfs_item_t * item, dentry_t * d, vfs_listdir_state_t * state, dentry_iterator_op add_record )

static

Definition at line 430 of file ipc.cpp.

ipc_sysfs_lookup_ipc()

static bool ipc_sysfs_lookup_ipc ( inode_t * parent_dir, dentry_t * dentry )

static

Definition at line 442 of file ipc.cpp.

Here is the call graph for this function:

ipc_sysfs_create_server()

static bool ipc_sysfs_create_server ( inode_t * dir, dentry_t * dentry, file_type_t type, file_perm_t perm )

static

Definition at line 464 of file ipc.cpp.

Here is the call graph for this function:

ipc_dump_name_waitlist()

static bool ipc_dump_name_waitlist ( uintn key, void * value, void * data )

static

Definition at line 480 of file ipc.cpp.

Referenced by ipc_sysfs_dump_name_waitlist().

Here is the call graph for this function:

ipc_sysfs_dump_name_waitlist()

static bool ipc_sysfs_dump_name_waitlist ( sysfs_file_t * f )

static

Definition at line 496 of file ipc.cpp.

Here is the call graph for this function:

SYSFS_AUTOREGISTER()

SYSFS_AUTOREGISTER	(	ipc	,
		ipc_sysfs_items	)

Variable Documentation

ipc_servers

list_head ipc_servers

static

Definition at line 84 of file ipc.cpp.

Referenced by ipc_connect_to_server(), ipc_get_server(), ipc_server_create(), ipc_sysfs_list_ipcs(), ipc_sysfs_lookup_ipc(), and ipc_sysfs_servers().

name_waitlist

hashmap_t name_waitlist

static

waitlist for an IPC server, key = name, value = waitlist_t *

Definition at line 85 of file ipc.cpp.

Referenced by ipc_connect_to_server(), ipc_init(), ipc_server_close(), ipc_server_create(), and ipc_sysfs_dump_name_waitlist().

ipc_lock

spinlock_t ipc_lock

static

protects ipc_servers and name_waitlist

Definition at line 86 of file ipc.cpp.

Referenced by ipc_connect_to_server(), ipc_get_server(), ipc_server_close(), ipc_server_create(), and ipc_sysfs_dump_name_waitlist().

ipc_sysfs_items

sysfs_item_t ipc_sysfs_items[]

static

Initial value:

= {
    SYSFS_RO_ITEM("servers", ipc_sysfs_servers),
    SYSFS_DYN_DIR("ipcs", ipc_sysfs_list_ipcs, ipc_sysfs_lookup_ipc, ipc_sysfs_create_server),
    SYSFS_RO_ITEM("name_waitlist", ipc_sysfs_dump_name_waitlist),
}

Definition at line 504 of file ipc.cpp.

Referenced by SYSFS_AUTOREGISTER().