tw-event.c File Reference

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

Go to the source code of this file.

Macros
#define	INCREASE_ABORTED_COUNT(event)

Functions
static void	link_causality (tw_event *nev, tw_event *cev)
void	tw_event_send (tw_event *event)
static void	local_cancel (tw_pe *d, tw_event *event)
static void	event_cancel (tw_event *event)
void	tw_event_rollback (tw_event *event)

Macro Definition Documentation

INCREASE_ABORTED_COUNT

#define INCREASE_ABORTED_COUNT

(

event

)

Definition at line 7 of file tw-event.c.

Referenced by tw_event_send().

Function Documentation

event_cancel()

void event_cancel ( tw_event * event )

inlinestatic

Definition at line 129 of file tw-event.c.

References tw_event::dest_lp, tw_pe::id, io_event_cancel(), local_cancel(), tw_event::owner, tw_lp::pe, tw_pe::pq, tw_event::recv_ts, tw_statistics::s_net_other, tw_statistics::s_nsend_loc_remote, tw_statistics::s_nsend_net_remote, tw_statistics::s_pq, tw_event::sig, tw_event::state, tw_pe::stats, tw_pe::trans_msg_sig, tw_pe::trans_msg_ts, tw_clock_read(), tw_copy_event_sig(), tw_error(), tw_event_free(), tw_event_sig_compare_ptr(), tw_gvt_inprogress(), TW_kp_pevent_q, TW_LOC, TW_net_asend, tw_net_cancel(), TW_net_outq, TW_pe_event_q, TW_pe_pq, TW_pe_sevent_q, tw_pq_delete_any(), and TW_STIME_CMP.

Referenced by tw_event_rollback().

link_causality()

void link_causality ( tw_event * nev, tw_event * cev )

inlinestatic

Definition at line 10 of file tw-event.c.

References tw_event::cause_next, and tw_event::caused_by_me.

Referenced by tw_event_send().

local_cancel()

void local_cancel ( tw_pe * d, tw_event * event )

inlinestatic

Definition at line 122 of file tw-event.c.

References tw_pe::cancel_q.

Referenced by event_cancel().

tw_event_rollback()

void tw_event_rollback

(

tw_event *

event

)

Definition at line 221 of file tw-event.c.

References tw_event::aborted_total, buddy_free(), tw_event::cause_next, tw_event::caused_by_me, tw_lp::core_rng, tw_lp::critical_path, tw_pe::cur_event, tw_lp::cur_state, tw_event::cv, tw_event::delta_buddy, tw_event::dest_lp, event_cancel(), g_tw_pe, tw_lp::kp, tw_kp::kp_stats, tw_kp::last_sig, tw_kp::last_time, tw_lp::lp_stats, tw_lp::pe, tw_event_sig::priority, tw_event::recv_ts, tw_event_sig::recv_ts, tw_lptype::revent, st_kp_stats::s_e_rbs, st_lp_stats::s_e_rbs, tw_kp::s_e_rbs, tw_event::sig, tw_event::src_lp, tw_lp::suspend_do_orig_event_rc, tw_lp::suspend_error_number, tw_lp::suspend_event, tw_lp::suspend_flag, tw_lp::suspend_sig, tw_lp::suspend_time, tw_event_sig::tie_lineage_length, tw_clock_read(), tw_event_data(), tw_event_sig_compare_ptr(), tw_free_output_messages(), tw_rand_reverse_unif, TW_STIME_CMP, TW_STIME_CRT, tw_lp::type, and USE_RAND_TIEBREAKER.

Referenced by tw_kp_rollback_event(), tw_kp_rollback_to(), tw_sched_batch(), tw_sched_batch_realtime(), and tw_scheduler_sequential_rollback_check().

tw_event_send()

void tw_event_send

(

tw_event *

event

)

Definition at line 15 of file tw-event.c.

References tw_pe::abort_event, tw_pe::cev_abort, CONSERVATIVE, tw_pe::cur_event, tw_event::dest_lp, tw_event::dest_lpid, tw_pe::event_q, g_tw_lookahead, g_tw_mynode, g_tw_synchronization_protocol, g_tw_ts_end, tw_lp::gid, tw_pe::id, INCREASE_ABORTED_COUNT, tw_lp::kp, tw_kp::last_sig, tw_kp::last_time, link_causality(), tw_lptype::map, tw_event::out_msgs, tw_lp::pe, tw_pe::pq, tw_statistics::s_net_other, tw_statistics::s_nsend_loc_remote, tw_statistics::s_nsend_net_remote, tw_statistics::s_pq, tw_pe::seq_num, tw_event::sig, tw_pe::stats, tw_pe::trans_msg_sig, tw_pe::trans_msg_ts, tw_clock_read(), tw_copy_event_sig(), tw_error(), tw_event_sig_compare_ptr(), tw_eventq_push(), tw_getlocal_lp(), tw_gvt_inprogress(), TW_LOC, TW_net_asend, tw_net_send(), tw_now(), TW_pe_event_q, tw_pq_enqueue(), TW_STIME_CMP, TW_STIME_DBL, and tw_lp::type.

Referenced by io_load_events(), phold_event_handler(), phold_init(), phold_pre_run(), and st_create_sample_event().