tw-pe.c

Go to the documentation of this file.

#include <ross.h>
 
static void dummy_pe_f (tw_pe *pe)
{
    (void) pe;
}
 
void
tw_pe_settype(const tw_petype * type)
{
        if (!g_tw_pe)
                tw_error(TW_LOC, "Undefined PE!");
 
#define copy_pef(f, d) \
                g_tw_pe->type.f = type->f ? type->f : d
 
        copy_pef(pre_lp_init, dummy_pe_f);
        copy_pef(post_lp_init, dummy_pe_f);
        copy_pef(gvt, dummy_pe_f);
        copy_pef(final, dummy_pe_f);
 
#undef copy_pef
}
 
/**
 * initialize individual PE structs
 *
 * must be called after tw_nnodes / MPI world size is set.
 *
 */
void
tw_pe_init(void)
{
    if (g_tw_pe) tw_error(TW_LOC, "PE %u already initialized", g_tw_mynode);
 
    g_tw_pe = (tw_pe*)tw_calloc(TW_LOC, "PE Struct", sizeof(*g_tw_pe), 1);
 
    g_tw_pe->id = g_tw_mynode;
 
    tw_petype no_type;
    memset(&no_type, 0, sizeof(no_type));
    tw_pe_settype(&no_type);
 
#ifdef USE_RAND_TIEBREAKER
        tw_copy_event_sig(&g_tw_pe->trans_msg_sig, &g_tw_max_sig);
        tw_copy_event_sig(&g_tw_pe->GVT_prev_sig, &g_tw_max_sig);
#else
        g_tw_pe->trans_msg_ts = TW_STIME_MAX;
        g_tw_pe->GVT_prev = TW_STIME_MAX;
#endif
        g_tw_pe->gvt_status = 0;
 
        g_tw_pe->rng = tw_rand_init(31, 41);
        g_tw_pe->core_rng = tw_rand_core_init(31, 41); // Core RNG must have same v & w values as main RNG
 
    //If we're in (some variation of) optimistic mode, we need this hash
    if (g_tw_synchronization_protocol == OPTIMISTIC ||
        g_tw_synchronization_protocol == OPTIMISTIC_DEBUG ||
        g_tw_synchronization_protocol == OPTIMISTIC_REALTIME) {
        g_tw_pe->hash_t = tw_hash_create();
    } else {
        g_tw_pe->hash_t = NULL;
    }
 
}
 
void
tw_pe_fossil_collect(void)
{
        tw_kp      *kp;
 
        unsigned int     i;
 
        g_tw_fossil_attempts++;
 
        for(i = 0; i < g_tw_nkp; i++)
        {
                kp = tw_getkp(i);
                tw_eventq_fossil_collect(&kp->pevent_q, g_tw_pe);
        }
 
}