Home Research Papers Posters Manuals Talks Download People Help Internal

libs/ck-libs/pose/pose_config.h

Go to the documentation of this file.

#ifndef POSE_CONFIG_H
#define POSE_CONFIG_H
#include <limits.h>

//#define SEQUENTIAL_POSE 1

#define POSE_STATS_ON 1
//#define POSE_DOP_ON 1
//#define TRACE_DETAIL 1

#define USE_LONG_TIMESTAMPS 1

#define DETERMINISTIC_EVENTS 1

#define MEM_COARSE
#define MAX_USAGE 5   // maximum checkpoints per object for coarse mem. man.

#define MSG_RECYCLING 1

//#define MEM_TEMPORAL

//#define LB_ON 1

#define COMM_TIMEOUT 1
#define COMM_MAXMSG 20

#define MAX_ITERATIONS 100  // maximum forward executions per Step call
#define STORE_RATE 5       // default checkpoint rate: 1 for every n events
#define SPEC_WINDOW 10      // speculative event window size
#define MIN_LEASH 10        // min speculative window for adaptive strategy
#define MAX_LEASH 100        // max speculative window for adaptive strategy
#define LEASH_FLEX 10        // leash increment

#define MAX_LEASH_MULTIPLIER 3     // factor used to calculate the max timeleash
#define MAX_RB_PER_GVT_ITER 2      // max rollbacks allowed per GVT iteration
#define PVT_STRAT_CALC_PERIOD 50   // number of GVT iterations between adapt5 strat calcs50
#define EVQ_SPARSE_CALC_PERIOD 50 // number of commits between evq sparsity calcs100
#define AVG_LEASH_CALC_PERIOD 50    // number of rollbacks between average leash calcs

// Each timestamp "diff" is the difference between the virtual time at
// which the current event is committed and the timestamp of the event
// last committed on a poser.  So if the current event is committed at
// time 40, and the previous event was committed at time 25, the diff
// is 15.  These differences are calculated for each event with
// respect to its previous event.  A set of TS_DIFF_WIN_SIZE diffs
// is examined at one time (basically a "window" of diffs).  The top
// HIGHEST_DIFFS_TO_IGNORE diffs are ignored.  The next highest
// NUM_DIFFS_TO_AVERAGE diffs are then averaged to get the timeleash
// value.  For example, let's say these three values are 16, 3, and 2,
// respectively, and that the size 16 data set is [5, 100, 7, 3, 5, 0, 50, 10, 8,
// 12, 40, 30, 9, 20, 0, 1].  The top three values--100, 50 and
// 40--are ignored.  Then the top two remaining values--30 and 20--are
// averaged to get 25, and that becomes the timeleash value.
#define TS_DIFF_WIN_SIZE 16  // number of timestamp diffs to use in calculating the leash
#define HIGHEST_DIFFS_TO_IGNORE 2  // ignore this many of the highest diffs in the leash calculation
#define NUM_DIFFS_TO_AVERAGE 14  // how many diffs are averaged to get the final leash
#define DIFFS_TO_STORE HIGHEST_DIFFS_TO_IGNORE + NUM_DIFFS_TO_AVERAGE  // for convenience


#define LB_SKIP 51          // LB done 1/LB_SKIP times GVT iterations
#define LB_THRESHOLD 4000   // 20 heavy objects
#define LB_DIFF 2000       // min diff between min and max load PEs

#define POSE_CHECKPOINT_DIRECTORY "__pose_chkpt_files" // directory where checkpoint files are stored

// MISC
#define MAX_POOL_SIZE 40    // maximum size of a memory pool
#define MAX_RECYCLABLE 1000 // maximum size of a recyclable block
#define SEND 0
#define RECV 1
#define OPTIMISTIC 0
#define CONSERVATIVE 1

#define NUM_PVT_DEBUG_BUFFER_LINES 1
#define PVT_DEBUG_BUFFER_LINE_LENGTH 64

#if USE_LONG_TIMESTAMPS 
#include "conv-config.h"
#if CMK_LONG_LONG_DEFINED
typedef long long int POSE_TimeType;
#else
typedef CmiInt8 POSE_TimeType;
#endif
//we'd like to set UnsetTS to a very large negative value with some
//wiggle room for underflow.  But there are many maddeningly hard to
//find things which quietly break if its not -1.

#ifdef LLONG_MAX
const POSE_TimeType POSE_TimeMax=LLONG_MAX;
//const POSE_TimeType POSE_UnsetTS=LLONG_MIN+10LL;
const POSE_TimeType POSE_UnsetTS=-1LL;
#else
const POSE_TimeType POSE_TimeMax=9223372036854775807LL;
//const POSE_TimeType POSE_UnsetTS=(-POSE_TimeMax-1LL)+10LL;
const POSE_TimeType POSE_UnsetTS=-1LL;
#endif
#else
typedef int POSE_TimeType;
const POSE_TimeType POSE_TimeMax=INT_MAX;
const POSE_TimeType POSE_UnsetTS=-1;
#endif



// POSE Command line struct
//glorified struct

class POSE_Config 
{
 public:
  bool stats;
  int start_proj;
  int end_proj;
  bool trace;
  bool dop;
  bool dopSkipCalcs;
  int max_usage;
  bool msg_pool;
  int msg_pool_size;
  int max_pool_msg_size;
  bool lb_on;
  int lb_skip;
  int lb_threshold;
  int lb_diff;
  int store_rate;
  int max_iter;
  int spec_window;
  int min_leash;
  int max_leash;
  int leash_flex;
  bool deterministic;
  int checkpoint_gvt_interval;
  int checkpoint_time_interval;
  int lb_gvt_interval;
  /* one very long initializer line */
  POSE_Config() :
#ifdef POSE_STATS_ON                   //w
    stats(true),
#else
    stats(false), 
#endif
    start_proj(-1),
    end_proj(-1),
#ifdef TRACE_DETAIL                    //w
    trace(true),
#else      
    trace(false),
#endif
#ifdef POSE_DOP_ON
    dop(true),
#else
    dop(false),
#endif
    dopSkipCalcs(false),
    max_usage(MAX_USAGE),
#ifdef MSG_RECYCLING
    msg_pool(true),
#else
    msg_pool(false),
#endif
    msg_pool_size(40),
    max_pool_msg_size(1000),
#ifdef LB_ON
    lb_on(true),                  //w
#else
    lb_on(false),                 //w
#endif
    lb_skip(LB_SKIP),             //w
    lb_threshold(LB_THRESHOLD),   //w
    lb_diff(LB_DIFF),             //w
    store_rate(STORE_RATE),       //w
    max_iter(MAX_ITERATIONS),     //apparently defunct 
    spec_window(SPEC_WINDOW),     //w
    min_leash(MIN_LEASH),         //w
    max_leash(MAX_LEASH),         //w
    leash_flex(LEASH_FLEX),       //w
#ifdef DETERMINISTIC_EVENTS        //w
    deterministic(true),
#else
    deterministic(false),
#endif
    checkpoint_gvt_interval(0),
    checkpoint_time_interval(0),
    lb_gvt_interval(0)
    {// all handled in initializer
    }
};
PUPbytes(POSE_Config)

#endif

---