Adding Chris' periodic patch.

ross/models/srw/srw.c

@@ -290,7 +290,8 @@ tw_petype srw_pes[] = {
     (pe_init_f)  0,
     (pe_init_f)  rn_netdmf_init,
     (pe_gvt_f)   0,
-    (pe_final_f) 0
+    (pe_final_f) 0,
+    (pe_periodic_f) 0
   },
   {0},
 };

ross/models/tlm/pm/pm.c

@@ -183,7 +183,8 @@ tw_petype my_pes[] =
                 (pe_init_f) pm_pe_init,
                 (pe_init_f) pm_pe_post_init,
                 (pe_gvt_f) pm_pe_gvt,
-                (pe_final_f) pm_pe_final
+                (pe_final_f) pm_pe_final,
+                (pe_periodic_f) 0
         },
         {0},
 };

ross/models/tlm/rm/rm-interface.c

@@ -13,7 +13,8 @@ tw_petype	rm_pes[] = {
 		(pe_init_f) rm_pe_init,
 		(pe_init_f) rm_pe_post_init,
 		(pe_gvt_f) rm_pe_gvt,
-		(pe_final_f) rm_pe_final
+		(pe_final_f) rm_pe_final,
+                (pe_periodic_f) 0
 	},
 	{0},
 };

ross/ross-extern.h

@@ -52,6 +52,8 @@ extern size_t		g_tw_event_msg_sz;
 extern unsigned int	g_tw_memory_nqueues;
 extern size_t		g_tw_memory_sz;
 
+extern unsigned int     g_tw_periodicity;
+
 extern tw_stime         g_tw_lookahead;
 
 extern tw_peid  g_tw_npe;

ross/ross-global.c

@@ -42,6 +42,13 @@ unsigned int	g_tw_memory_nqueues = 0;
 size_t		g_tw_memory_sz = 0;
 size_t		g_tw_event_msg_sz = 0;
 
+        /*
+         * Number of iterations in scheduler (invoked from tw_run)
+         * before calling application callout.  Default is to call
+         * callout for each iteration.
+         */
+unsigned int    g_tw_periodicity = 1;
+
         /*
          * Minimum lookahead for a model -- model defined when
          * using the Simple Synchronization Protocol (conservative)

ross/ross-types.h

@@ -58,6 +58,7 @@ typedef unsigned long long tw_stat;
 typedef void (*pe_init_f) (tw_pe * pe);
 typedef void (*pe_gvt_f) (tw_pe * pe);
 typedef void (*pe_final_f) (tw_pe * pe);
+typedef void (*pe_periodic_f) (tw_pe * pe);
 
 /** tw_petype @brief Virtual Functions for per PE ops
  *
@@ -70,6 +71,7 @@ struct tw_petype
   pe_init_f post_lp_init;  /**< @brief PE initialization routine, after LP init */
   pe_gvt_f gvt;  /**< @brief PE per GVT routine */
   pe_final_f final;  /**< @brief PE finilization routine */
+  pe_periodic_f periodic; /**< @brief Callout made for K loops of tw scheduler */
 };
 
 /*

ross/tw-pe.c

@@ -17,6 +17,7 @@ tw_pe_settype(tw_pe * pe, const tw_petype * type)
 	copy_pef(post_lp_init, dummy_pe_f);
 	copy_pef(gvt, dummy_pe_f);
 	copy_pef(final, dummy_pe_f);
+        copy_pef(periodic, dummy_pe_f);
 
 #undef copy_pef
 }

ross/tw-sched.c

@@ -302,6 +302,7 @@ tw_scheduler_conservative(tw_pe * me)
 {
   tw_clock start;
   unsigned int msg_i;
+  unsigned int round = 0;
 
   tw_sched_init(me);
   tw_wall_now(&me->start_time);
@@ -369,6 +370,11 @@ tw_scheduler_conservative(tw_pe * me)
 
 	  tw_event_free(me, cev);
 	}
+
+        if(me->type.periodic && (++round % g_tw_periodicity))
+        {
+            (*me->type.periodic)(me);
+        }
     }