io-mpi.c File Reference

#include <assert.h>
#include "ross.h"

Go to the source code of this file.

Functions
void	io_register_model_version (char *sha1)
tw_event *	io_event_grab (tw_pe *pe)
void	io_event_cancel (tw_event *e)
void	io_init ()
void	io_appending_job ()
void	io_load_checkpoint (char *master_filename, io_load_type load_at)
void	io_read_checkpoint ()
void	io_load_events (tw_pe *me)
void	io_store_checkpoint (char *master_filename, int data_file_number)

Variables
int	g_io_number_of_files = 1
const tw_optdef	io_opts []
io_partition *	g_io_partitions
io_lptype *	g_io_lp_types = NULL
io_load_type	g_io_load_at = NONE
char	g_io_checkpoint_name [1024]
int	g_io_events_buffered_per_rank = 0
tw_eventq	g_io_buffered_events
tw_eventq	g_io_free_events
static unsigned long	l_io_kp_offset = 0
static unsigned long	l_io_lp_offset = 0
static unsigned long	l0_io_total_kp = 0
static unsigned long	l0_io_total_lp = 0
static unsigned long	l_io_min_parts = 0
static int	l_io_init_flag = 0
static int	l_io_append_flag = 0
char	model_version [41]

Function Documentation

void io_appending_job

(

)

Definition at line 101 of file io-mpi.c.

References l_io_append_flag, and l_io_init_flag.

void io_event_cancel

(

tw_event *

e

)

Definition at line 70 of file io-mpi.c.

References tw_eventq_delete_any(), and tw_eventq_push().

Referenced by event_cancel().

Here is the call graph for this function:

Here is the caller graph for this function:

tw_event* io_event_grab

(

tw_pe *

pe

)

Definition at line 42 of file io-mpi.c.

References tw_pe::abort_event, tw_event::cancel_next, tw_event::cause_next, tw_event::caused_by_me, tw_event::event_id, g_io_events_buffered_per_rank, l_io_init_flag, tw_event::next, tw_event::owner, tw_event::prev, tw_event::state, tw_pe::stats, tw_clock_read(), tw_eventq_pop(), and tw_eventq_push().

Referenced by tw_event_new().

Here is the call graph for this function:

Here is the caller graph for this function:

void io_init

(

)

Definition at line 75 of file io-mpi.c.

References g_io_number_of_files, g_tw_mynode, g_tw_nkp, g_tw_nlp, tw_eventq::head, l0_io_total_kp, l0_io_total_lp, l_io_init_flag, l_io_kp_offset, l_io_lp_offset, l_io_min_parts, tw_eventq::size, and tw_eventq::tail.

void io_load_checkpoint	(	char *	master_filename,
		io_load_type	load_at
	)

Definition at line 107 of file io-mpi.c.

References g_io_checkpoint_name, and g_io_load_at.

void io_load_events

(

tw_pe *

me

)

Definition at line 227 of file io-mpi.c.

References tw_pe::abort_event, tw_event::caused_by_me, tw_pe::cev_abort, tw_pe::cur_event, tw_event::cv, tw_event::dest_lp, g_tw_lookahead, g_tw_msg_sz, tw_event::recv_ts, tw_eventq::size, tw_event::src_lp, tw_error(), tw_event_data(), tw_event_new(), tw_event_send(), tw_eventq_pop(), tw_eventq_push(), and TW_LOC.

Referenced by tw_sched_init().

Here is the call graph for this function:

Here is the caller graph for this function:

void io_read_checkpoint

(

)

Definition at line 112 of file io-mpi.c.

References tw_lp::cur_state, g_io_checkpoint_name, g_io_number_of_files, g_tw_lp, g_tw_msg_sz, g_tw_mynode, g_tw_nkp, g_tw_nlp, io_event_deserialize(), io_lp_deserialize(), io_partition_field_count, l_io_kp_offset, l_io_lp_offset, l_io_min_parts, io_partition::lp_count, io_partition::size, tw_eventq::size, tw_event_data(), tw_eventq_pop(), tw_eventq_push(), and tw_nnodes().

Referenced by tw_init_lps().

Here is the call graph for this function:

Here is the caller graph for this function:

void io_register_model_version

(

char *

sha1

)

Definition at line 38 of file io-mpi.c.

References model_version.

void io_store_checkpoint	(	char *	master_filename,
		int	data_file_number
	)

Definition at line 255 of file io-mpi.c.

References tw_lp::cur_state, io_partition::ev_count, io_partition::file, g_io_number_of_files, g_tw_kp, g_tw_lp, g_tw_lp_typemap, g_tw_msg_sz, g_tw_mynode, g_tw_nkp, g_tw_nlp, tw_lp::id, io_event_serialize(), io_lp_serialize(), io_partition_field_count, l0_io_total_kp, l0_io_total_lp, l_io_append_flag, l_io_kp_offset, l_io_lp_offset, l_io_min_parts, io_partition::lp_count, tw_kp::lp_count, model_version, io_partition::offset, io_partition::part, ROSS_VERSION, io_partition::size, tw_eventq::size, tw_event_data(), tw_eventq_pop(), tw_eventq_push(), tw_nnodes(), and tw_opt_settings().

Here is the call graph for this function:

Variable Documentation

tw_eventq g_io_buffered_events

Definition at line 24 of file io-mpi.c.

char g_io_checkpoint_name[1024]

Definition at line 22 of file io-mpi.c.

Referenced by io_load_checkpoint(), and io_read_checkpoint().

int g_io_events_buffered_per_rank = 0

Definition at line 23 of file io-mpi.c.

Referenced by io_event_grab(), and setup_pes().

tw_eventq g_io_free_events

Definition at line 25 of file io-mpi.c.

Referenced by setup_pes().

io_load_type g_io_load_at = NONE

Definition at line 21 of file io-mpi.c.

Referenced by io_load_checkpoint(), and tw_init_lps().

io_lptype* g_io_lp_types = NULL

Definition at line 20 of file io-mpi.c.

int g_io_number_of_files = 1

Definition at line 11 of file io-mpi.c.

Referenced by io_init(), io_read_checkpoint(), and io_store_checkpoint().

io_partition* g_io_partitions

Definition at line 19 of file io-mpi.c.

const tw_optdef io_opts[]

Initial value:

= {
    TWOPT_GROUP("RIO"),
    TWOPT_UINT("io-files", g_io_number_of_files, "io files"),

}

Definition at line 12 of file io-mpi.c.

Referenced by tw_init().

unsigned long l0_io_total_kp = 0

static

Definition at line 30 of file io-mpi.c.

Referenced by io_init(), and io_store_checkpoint().

unsigned long l0_io_total_lp = 0

static

Definition at line 31 of file io-mpi.c.

Referenced by io_init(), and io_store_checkpoint().

int l_io_append_flag = 0

static

Definition at line 34 of file io-mpi.c.

Referenced by io_appending_job(), and io_store_checkpoint().

int l_io_init_flag = 0

static

Definition at line 33 of file io-mpi.c.

Referenced by io_appending_job(), io_event_grab(), and io_init().

unsigned long l_io_kp_offset = 0

static

Definition at line 28 of file io-mpi.c.

Referenced by io_init(), io_read_checkpoint(), and io_store_checkpoint().

unsigned long l_io_lp_offset = 0

static

Definition at line 29 of file io-mpi.c.

Referenced by io_init(), io_read_checkpoint(), and io_store_checkpoint().

unsigned long l_io_min_parts = 0

static

Definition at line 32 of file io-mpi.c.

Referenced by io_init(), io_read_checkpoint(), and io_store_checkpoint().

char model_version[41]

Definition at line 36 of file io-mpi.c.

Referenced by io_register_model_version(), and io_store_checkpoint().