Commit c556c444 authored by Jonathan Jenkins's avatar Jonathan Jenkins
Browse files

adopting 'pre_run' lp interface change

parent 000052ab
...@@ -806,12 +806,13 @@ const tw_optdef app_opt [] = ...@@ -806,12 +806,13 @@ const tw_optdef app_opt [] =
}; };
tw_lptype nw_lp = { tw_lptype nw_lp = {
(init_f) nw_test_init, (init_f) nw_test_init,
(event_f) nw_test_event_handler, (pre_run_f) NULL,
(revent_f) nw_test_event_handler_rc, (event_f) nw_test_event_handler,
(final_f) nw_test_finalize, (revent_f) nw_test_event_handler_rc,
(map_f) codes_mapping, (final_f) nw_test_finalize,
sizeof(nw_state) (map_f) codes_mapping,
sizeof(nw_state)
}; };
const tw_lptype* nw_get_lp_type() const tw_lptype* nw_get_lp_type()
......
...@@ -1783,6 +1783,7 @@ tw_lptype dragonfly_lps[] = ...@@ -1783,6 +1783,7 @@ tw_lptype dragonfly_lps[] =
// Terminal handling functions // Terminal handling functions
{ {
(init_f)terminal_init, (init_f)terminal_init,
(pre_run_f) NULL,
(event_f) terminal_event, (event_f) terminal_event,
(revent_f) terminal_rc_event_handler, (revent_f) terminal_rc_event_handler,
(final_f) dragonfly_terminal_final, (final_f) dragonfly_terminal_final,
...@@ -1791,6 +1792,7 @@ tw_lptype dragonfly_lps[] = ...@@ -1791,6 +1792,7 @@ tw_lptype dragonfly_lps[] =
}, },
{ {
(init_f) router_setup, (init_f) router_setup,
(pre_run_f) NULL,
(event_f) router_event, (event_f) router_event,
(revent_f) router_rc_event_handler, (revent_f) router_rc_event_handler,
(final_f) dragonfly_router_final, (final_f) dragonfly_router_final,
......
...@@ -185,12 +185,13 @@ static void loggp_finalize( ...@@ -185,12 +185,13 @@ static void loggp_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype loggp_lp = { tw_lptype loggp_lp = {
(init_f) loggp_init, (init_f) loggp_init,
(event_f) loggp_event, (pre_run_f) NULL,
(revent_f) loggp_rev_event, (event_f) loggp_event,
(final_f) loggp_finalize, (revent_f) loggp_rev_event,
(map_f) codes_mapping, (final_f) loggp_finalize,
sizeof(loggp_state), (map_f) codes_mapping,
sizeof(loggp_state),
}; };
static void handle_msg_ready_rev_event( static void handle_msg_ready_rev_event(
......
...@@ -96,12 +96,13 @@ static void handle_sched_next_rc( ...@@ -96,12 +96,13 @@ static void handle_sched_next_rc(
/* ROSS function pointer table for this LP */ /* ROSS function pointer table for this LP */
tw_lptype model_net_base_lp = { tw_lptype model_net_base_lp = {
(init_f) model_net_base_lp_init, (init_f) model_net_base_lp_init,
(event_f) model_net_base_event, (pre_run_f) NULL,
(revent_f) model_net_base_event_rc, (event_f) model_net_base_event,
(final_f) model_net_base_finalize, (revent_f) model_net_base_event_rc,
(map_f) codes_mapping, (final_f) model_net_base_finalize,
sizeof(model_net_base_state), (map_f) codes_mapping,
sizeof(model_net_base_state),
}; };
/**** END LP, EVENT PROCESSING FUNCTION DECLS ****/ /**** END LP, EVENT PROCESSING FUNCTION DECLS ****/
......
...@@ -151,12 +151,13 @@ static void sn_finalize( ...@@ -151,12 +151,13 @@ static void sn_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype sn_lp = { tw_lptype sn_lp = {
(init_f) sn_init, (init_f) sn_init,
(event_f) sn_event, (pre_run_f) NULL,
(revent_f) sn_rev_event, (event_f) sn_event,
(final_f) sn_finalize, (revent_f) sn_rev_event,
(map_f) codes_mapping, (final_f) sn_finalize,
sizeof(sn_state), (map_f) codes_mapping,
sizeof(sn_state),
}; };
static tw_stime rate_to_ns(uint64_t bytes, double MB_p_s); static tw_stime rate_to_ns(uint64_t bytes, double MB_p_s);
......
...@@ -181,12 +181,13 @@ static void sw_finalize( ...@@ -181,12 +181,13 @@ static void sw_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype sw_lp = { tw_lptype sw_lp = {
(init_f) sw_init, (init_f) sw_init,
(event_f) sw_event, (pre_run_f) NULL,
(revent_f) sw_rev_event, (event_f) sw_event,
(final_f) sw_finalize, (revent_f) sw_rev_event,
(map_f) codes_mapping, (final_f) sw_finalize,
sizeof(sw_state), (map_f) codes_mapping,
sizeof(sw_state),
}; };
static tw_stime rate_to_ns(uint64_t bytes, double MB_p_s); static tw_stime rate_to_ns(uint64_t bytes, double MB_p_s);
......
...@@ -1307,12 +1307,13 @@ static void event_handler(nodes_state * s, tw_bf * bf, nodes_message * msg, tw_l ...@@ -1307,12 +1307,13 @@ static void event_handler(nodes_state * s, tw_bf * bf, nodes_message * msg, tw_l
/* event types */ /* event types */
tw_lptype torus_lp = tw_lptype torus_lp =
{ {
(init_f) torus_init, (init_f) torus_init,
(event_f) event_handler, (pre_run_f) NULL,
(revent_f) node_rc_handler, (event_f) event_handler,
(final_f) final, (revent_f) node_rc_handler,
(map_f) codes_mapping, (final_f) final,
sizeof(nodes_state), (map_f) codes_mapping,
sizeof(nodes_state),
}; };
/* returns the torus lp type for lp registration */ /* returns the torus lp type for lp registration */
......
...@@ -120,12 +120,13 @@ static void handle_testsvr_local_rev( ...@@ -120,12 +120,13 @@ static void handle_testsvr_local_rev(
/* ROSS function pointer table for this LP */ /* ROSS function pointer table for this LP */
tw_lptype testsvr_lp = { tw_lptype testsvr_lp = {
(init_f) testsvr_lp_init, (init_f) testsvr_lp_init,
(event_f) testsvr_event_handler, (pre_run_f) NULL,
(revent_f) testsvr_rev_handler, (event_f) testsvr_event_handler,
(final_f) testsvr_finalize, (revent_f) testsvr_rev_handler,
(map_f) codes_mapping, (final_f) testsvr_finalize,
sizeof(testsvr_state), (map_f) codes_mapping,
sizeof(testsvr_state),
}; };
/* for debugging: print messages */ /* for debugging: print messages */
......
...@@ -85,12 +85,13 @@ static void svr_finalize( ...@@ -85,12 +85,13 @@ static void svr_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype svr_lp = { tw_lptype svr_lp = {
(init_f) svr_init, (init_f) svr_init,
(event_f) svr_event, (pre_run_f) NULL,
(revent_f) svr_rev_event, (event_f) svr_event,
(final_f) svr_finalize, (revent_f) svr_rev_event,
(map_f) codes_mapping, (final_f) svr_finalize,
sizeof(svr_state), (map_f) codes_mapping,
sizeof(svr_state),
}; };
extern const tw_lptype* svr_get_lp_type(); extern const tw_lptype* svr_get_lp_type();
......
...@@ -71,12 +71,13 @@ static void svr_finalize( ...@@ -71,12 +71,13 @@ static void svr_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype svr_lp = { tw_lptype svr_lp = {
(init_f) svr_init, (init_f) svr_init,
(event_f) svr_event, (pre_run_f) NULL,
(revent_f) svr_rev_event, (event_f) svr_event,
(final_f) svr_finalize, (revent_f) svr_rev_event,
(map_f) codes_mapping, (final_f) svr_finalize,
sizeof(svr_state), (map_f) codes_mapping,
sizeof(svr_state),
}; };
static void svr_add_lp_type(); static void svr_add_lp_type();
......
...@@ -77,12 +77,13 @@ static void svr_finalize( ...@@ -77,12 +77,13 @@ static void svr_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype svr_lp = { tw_lptype svr_lp = {
(init_f) svr_init, (init_f) svr_init,
(event_f) svr_event, (pre_run_f) NULL,
(revent_f) svr_rev_event, (event_f) svr_event,
(final_f) svr_finalize, (revent_f) svr_rev_event,
(map_f) codes_mapping, (final_f) svr_finalize,
sizeof(svr_state), (map_f) codes_mapping,
sizeof(svr_state),
}; };
extern const tw_lptype* svr_get_lp_type(); extern const tw_lptype* svr_get_lp_type();
......
...@@ -87,12 +87,13 @@ static void svr_finalize( ...@@ -87,12 +87,13 @@ static void svr_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype svr_lp = { tw_lptype svr_lp = {
(init_f) svr_init, (init_f) svr_init,
(event_f) svr_event, (pre_run_f) NULL,
(revent_f) svr_rev_event, (event_f) svr_event,
(final_f) svr_finalize, (revent_f) svr_rev_event,
(map_f) codes_mapping, (final_f) svr_finalize,
sizeof(svr_state), (map_f) codes_mapping,
sizeof(svr_state),
}; };
extern const tw_lptype* svr_get_lp_type(); extern const tw_lptype* svr_get_lp_type();
......
...@@ -87,12 +87,13 @@ static void svr_finalize( ...@@ -87,12 +87,13 @@ static void svr_finalize(
tw_lp * lp); tw_lp * lp);
tw_lptype svr_lp = { tw_lptype svr_lp = {
(init_f) svr_init, (init_f) svr_init,
(event_f) svr_event, (pre_run_f) NULL,
(revent_f) svr_rev_event, (event_f) svr_event,
(final_f) svr_finalize, (revent_f) svr_rev_event,
(map_f) codes_mapping, (final_f) svr_finalize,
sizeof(svr_state), (map_f) codes_mapping,
sizeof(svr_state),
}; };
extern const tw_lptype* svr_get_lp_type(); extern const tw_lptype* svr_get_lp_type();
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment