msg_private.h File Reference

#include "simgrid/msg.h"
#include "src/kernel/activity/SynchroExec.hpp"
#include "src/kernel/activity/SynchroComm.hpp"

Classes
struct	s_msg_host_priv
struct	simdata_task
struct	simdata_file
struct	simdata_process
struct	process_arg
struct	msg_comm
struct	MSG_Global

Typedefs
typedef struct s_msg_host_priv	s_msg_host_priv_t
typedef struct simdata_task	s_simdata_task_t
typedef struct simdata_file	s_simdata_file_t
typedef struct simdata_process	s_simdata_process_t
typedef struct simdata_process *	simdata_process_t
typedef struct process_arg	s_process_arg_t
typedef struct process_arg *	process_arg_t
typedef struct msg_comm	s_msg_comm_t
typedef struct MSG_Global	s_MSG_Global_t
typedef struct MSG_Global *	MSG_Global_t

Functions
int	__MSG_host_get_file_descriptor_id (msg_host_t host)
void	__MSG_host_release_file_descriptor_id (msg_host_t host, int id)
msg_host_t	__MSG_host_create (sg_host_t host)
msg_storage_t	__MSG_storage_create (smx_storage_t storage)
void	__MSG_host_priv_free (msg_host_priv_t priv)
void	__MSG_storage_destroy (msg_storage_priv_t host)
	Destroys a storage (internal call only) More...
void	__MSG_file_destroy (msg_file_priv_t host)
	Destroys a file (internal call only) More...
void	MSG_process_cleanup_from_SIMIX (smx_actor_t smx_proc)
	Cleans the MSG data of a process. More...
smx_actor_t	MSG_process_create_from_SIMIX (const char *name, std::function< void()> code, void *data, sg_host_t host, double kill_time, xbt_dict_t properties, int auto_restart, smx_actor_t parent_process)
void	MSG_comm_copy_data_from_SIMIX (smx_activity_t comm, void *buff, size_t buff_size)
	This function is called by SIMIX in kernel mode to copy the data of a comm. More...
void	MSG_post_create_environment ()
void	MSG_host_add_task (msg_host_t host, msg_task_t task)
	take care of the dirty page tracking, in case we're adding a task to a migrating VM More...
void	MSG_host_del_task (msg_host_t host, msg_task_t task)
void	TRACE_msg_set_task_category (msg_task_t task, const char *category)
void	TRACE_msg_task_create (msg_task_t task)
void	TRACE_msg_task_execute_start (msg_task_t task)
void	TRACE_msg_task_execute_end (msg_task_t task)
void	TRACE_msg_task_destroy (msg_task_t task)
void	TRACE_msg_task_get_end (double start_time, msg_task_t task)
void	TRACE_msg_task_get_start ()
int	TRACE_msg_task_put_start (msg_task_t task)
void	TRACE_msg_task_put_end ()
char *	instr_process_id (msg_process_t proc, char *str, int len)
char *	instr_process_id_2 (const char *process_name, int process_pid, char *str, int len)
void	TRACE_msg_process_change_host (msg_process_t process, msg_host_t old_host, msg_host_t new_host)
void	TRACE_msg_process_create (const char *process_name, int process_pid, msg_host_t host)
void	TRACE_msg_process_destroy (const char *process_name, int process_pid)
void	TRACE_msg_process_kill (smx_process_exit_status_t status, msg_process_t process)
void	TRACE_msg_process_suspend (msg_process_t process)
void	TRACE_msg_process_resume (msg_process_t process)
void	TRACE_msg_process_sleep_in (msg_process_t process)
void	TRACE_msg_process_sleep_out (msg_process_t process)
msg_process_t	MSG_process_create_with_environment (const char *name, std::function< void()> code, void *data, msg_host_t host, xbt_dict_t properties)

Variables
MSG_Global_t	msg_global

Typedef Documentation

s_msg_host_priv_t

typedef struct s_msg_host_priv s_msg_host_priv_t

s_simdata_task_t

typedef struct simdata_task s_simdata_task_t

s_simdata_file_t

typedef struct simdata_file s_simdata_file_t

s_simdata_process_t

typedef struct simdata_process s_simdata_process_t

simdata_process_t

typedef struct simdata_process * simdata_process_t

s_process_arg_t

typedef struct process_arg s_process_arg_t

process_arg_t

typedef struct process_arg * process_arg_t

s_msg_comm_t

typedef struct msg_comm s_msg_comm_t

s_MSG_Global_t

typedef struct MSG_Global s_MSG_Global_t

MSG_Global_t

typedef struct MSG_Global * MSG_Global_t

Function Documentation

__MSG_host_get_file_descriptor_id()

int __MSG_host_get_file_descriptor_id

(

msg_host_t

host

)

__MSG_host_release_file_descriptor_id()

void __MSG_host_release_file_descriptor_id	(	msg_host_t	host,
		int	id
	)

__MSG_host_create()

msg_host_t __MSG_host_create

(

sg_host_t

host

)

__MSG_storage_create()

msg_storage_t __MSG_storage_create

(

smx_storage_t

storage

)

__MSG_host_priv_free()

void __MSG_host_priv_free

(

msg_host_priv_t

priv

)

__MSG_storage_destroy()

void __MSG_storage_destroy

(

msg_storage_priv_t

host

)

Destroys a storage (internal call only)

__MSG_file_destroy()

void __MSG_file_destroy

(

msg_file_priv_t

host

)

Destroys a file (internal call only)

MSG_process_cleanup_from_SIMIX()

void MSG_process_cleanup_from_SIMIX

(

smx_actor_t

smx_proc

)

Cleans the MSG data of a process.

Parameters

smx_proc

a SIMIX process

MSG_process_create_from_SIMIX()

smx_actor_t MSG_process_create_from_SIMIX	(	const char *	name,
		std::function< void()>	code,
		void *	data,
		sg_host_t	host,
		double	kill_time,
		xbt_dict_t	properties,
		int	auto_restart,
		smx_actor_t	parent_process
	)

MSG_comm_copy_data_from_SIMIX()

void MSG_comm_copy_data_from_SIMIX	(	smx_activity_t	synchro,
		void *	buff,
		size_t	buff_size
	)

This function is called by SIMIX in kernel mode to copy the data of a comm.

Parameters

synchro	the comm
buff	the data copied
buff_size	size of the buffer

MSG_post_create_environment()

void MSG_post_create_environment

(

)

MSG_host_add_task()

void MSG_host_add_task	(	msg_host_t	host,
		msg_task_t	task
	)

take care of the dirty page tracking, in case we're adding a task to a migrating VM

MSG_host_del_task()

void MSG_host_del_task	(	msg_host_t	host,
		msg_task_t	task
	)

TRACE_msg_set_task_category()

void TRACE_msg_set_task_category	(	msg_task_t	task,
		const char *	category
	)

TRACE_msg_task_create()

void TRACE_msg_task_create

(

msg_task_t

task

)

TRACE_msg_task_execute_start()

void TRACE_msg_task_execute_start

(

msg_task_t

task

)

TRACE_msg_task_execute_end()

void TRACE_msg_task_execute_end

(

msg_task_t

task

)

TRACE_msg_task_destroy()

void TRACE_msg_task_destroy

(

msg_task_t

task

)

TRACE_msg_task_get_end()

void TRACE_msg_task_get_end	(	double	start_time,
		msg_task_t	task
	)

TRACE_msg_task_get_start()

void TRACE_msg_task_get_start

(

)

TRACE_msg_task_put_start()

int TRACE_msg_task_put_start

(

msg_task_t

task

)

TRACE_msg_task_put_end()

void TRACE_msg_task_put_end

(

)

instr_process_id()

char* instr_process_id	(	msg_process_t	proc,
		char *	str,
		int	len
	)

instr_process_id_2()

char* instr_process_id_2	(	const char *	process_name,
		int	process_pid,
		char *	str,
		int	len
	)

TRACE_msg_process_change_host()

void TRACE_msg_process_change_host	(	msg_process_t	process,
		msg_host_t	old_host,
		msg_host_t	new_host
	)

TRACE_msg_process_create()

void TRACE_msg_process_create	(	const char *	process_name,
		int	process_pid,
		msg_host_t	host
	)

TRACE_msg_process_destroy()

void TRACE_msg_process_destroy	(	const char *	process_name,
		int	process_pid
	)

TRACE_msg_process_kill()

void TRACE_msg_process_kill	(	smx_process_exit_status_t	status,
		msg_process_t	process
	)

TRACE_msg_process_suspend()

void TRACE_msg_process_suspend

(

msg_process_t

process

)

TRACE_msg_process_resume()

void TRACE_msg_process_resume

(

msg_process_t

process

)

TRACE_msg_process_sleep_in()

void TRACE_msg_process_sleep_in

(

msg_process_t

process

)

TRACE_msg_process_sleep_out()

void TRACE_msg_process_sleep_out

(

msg_process_t

process

)

MSG_process_create_with_environment()

msg_process_t MSG_process_create_with_environment	(	const char *	name,
		std::function< void()>	code,
		void *	data,
		msg_host_t	host,
		xbt_dict_t	properties
	)

Variable Documentation

msg_global

MSG_Global_t msg_global