tw-kp.c File Reference

#include <ross.h>

Go to the source code of this file.

Macros
#define	NUM_OUT_MESG   2000

Functions
void	tw_kp_onpe (tw_kpid id, tw_pe *pe)
void	tw_kp_rollback_to (tw_kp *kp, tw_stime to)
void	tw_kp_rollback_event (tw_event *event)
static tw_out *	init_output_messages (tw_kp *kp)
void	tw_init_kps (tw_pe *me)
tw_out *	tw_kp_grab_output_buffer (tw_kp *kp)
void	tw_kp_put_back_output_buffer (tw_out *out)

Macro Definition Documentation

NUM_OUT_MESG

#define NUM_OUT_MESG   2000

Definition at line 159 of file tw-kp.c.

Referenced by init_output_messages().

Function Documentation

init_output_messages()

tw_out * init_output_messages ( tw_kp * kp )

static

Definition at line 162 of file tw-kp.c.

References tw_out::next, NUM_OUT_MESG, tw_out::owner, tw_calloc(), and TW_LOC.

Referenced by tw_init_kps().

tw_init_kps()

void tw_init_kps

(

tw_pe *

me

)

Definition at line 179 of file tw-kp.c.

References g_tw_nkp, g_tw_synchronization_protocol, tw_kp::id, init_output_messages(), tw_kp::kp_stats, tw_kp::last_stats, OPTIMISTIC, OPTIMISTIC_DEBUG, OPTIMISTIC_REALTIME, tw_kp::output, tw_kp::pe, tw_kp::s_e_rbs, tw_kp::s_nevent_processed, tw_kp::s_rb_secondary, tw_kp::s_rb_total, tw_calloc(), tw_getkp(), and TW_LOC.

Referenced by tw_sched_init().

tw_kp_grab_output_buffer()

tw_out * tw_kp_grab_output_buffer

(

tw_kp *

kp

)

Definition at line 210 of file tw-kp.c.

References tw_out::next, and tw_kp::output.

Referenced by tw_output().

tw_kp_onpe()

void tw_kp_onpe	(	tw_kpid	id,
		tw_pe *	pe )

Definition at line 4 of file tw-kp.c.

References g_tw_kp, g_tw_nkp, pe, tw_calloc(), tw_error(), and TW_LOC.

Referenced by map_linear(), and map_round_robin().

tw_kp_put_back_output_buffer()

void tw_kp_put_back_output_buffer

(

tw_out *

out

)

Definition at line 223 of file tw-kp.c.

References tw_out::next, tw_kp::output, and tw_out::owner.

Referenced by tw_free_output_messages().

tw_kp_rollback_event()

void tw_kp_rollback_event

(

tw_event *

event

)

Definition at line 104 of file tw-kp.c.

References tw_pe::GVT, tw_pe::GVT_sig, tw_eventq::head, tw_kp::id, tw_kp::kp_stats, tw_kp::last_sig, tw_kp::last_time, pe, tw_kp::pe, tw_kp::pevent_q, tw_event::recv_ts, st_kp_stats::s_rb_secondary, tw_kp::s_rb_secondary, st_kp_stats::s_rb_total, tw_kp::s_rb_total, tw_event::sig, tw_eventq::size, tw_clock_read(), tw_error(), tw_event_rollback(), tw_eventq_shift(), TW_LOC, and tw_pq_enqueue().

Referenced by tw_sched_cancel_q().

tw_kp_rollback_to()

void tw_kp_rollback_to	(	tw_kp *	kp,
		tw_stime	to )

Definition at line 59 of file tw-kp.c.

References tw_pe::GVT, tw_eventq::head, tw_kp::id, tw_pe::id, tw_kp::kp_stats, tw_kp::last_time, tw_kp::pe, tw_kp::pevent_q, tw_pe::pq, tw_event::recv_ts, tw_statistics::s_pq, st_kp_stats::s_rb_total, tw_kp::s_rb_total, tw_eventq::size, tw_pe::stats, tw_clock_read(), tw_event_rollback(), tw_eventq_shift(), tw_pq_enqueue(), TW_STIME_CMP, and TW_STIME_DBL.

Referenced by tw_scheduler_optimistic_debug(), and tw_scheduler_rollback_and_cancel_events_pe().