|
@@ -131,8 +131,15 @@ bool route_init()
|
|
|
#ifdef PROFILE_ROUTING
|
|
|
unsigned long start = printf_with_rtclock("begin precompute evalplans (%u,%hu) (%u,%hu)\n", tot_msg_per_ing, nthreads, max_round2_msgs, nthreads);
|
|
|
#endif
|
|
|
- sort_precompute_evalplan(tot_msg_per_ing, nthreads);
|
|
|
- sort_precompute_evalplan(max_round2_msgs, nthreads);
|
|
|
+ if (my_roles & ROLE_INGESTION) {
|
|
|
+ sort_precompute_evalplan(tot_msg_per_ing, nthreads);
|
|
|
+ }
|
|
|
+ if (my_roles & ROLE_ROUTING) {
|
|
|
+ sort_precompute_evalplan(max_round2_msgs, nthreads);
|
|
|
+ }
|
|
|
+ if (my_roles & ROLE_STORAGE) {
|
|
|
+ sort_precompute_evalplan(max_stg_msgs, nthreads);
|
|
|
+ }
|
|
|
#ifdef PROFILE_ROUTING
|
|
|
printf_with_rtclock_diff(start, "end precompute evalplans\n");
|
|
|
#endif
|