|
@@ -731,7 +731,7 @@ static void handle_worker_init_end(struct fxt_ev_64 *ev, struct starpu_fxt_optio
|
|
|
if (out_paje_file)
|
|
|
thread_set_state(get_event_time_stamp(ev, options), prefix, ev->param[0], "B");
|
|
|
if (trace_file)
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Blocked");
|
|
|
|
|
|
if (out_paje_file)
|
|
|
worker_set_state(get_event_time_stamp(ev, options), prefix, worker, "I");
|
|
@@ -1112,7 +1112,7 @@ static void handle_end_executing(struct fxt_ev_64 *ev, struct starpu_fxt_options
|
|
|
if (out_paje_file && !find_sync(threadid))
|
|
|
thread_set_state(get_event_time_stamp(ev, options), prefix, threadid, "B");
|
|
|
if (trace_file && !find_sync(threadid))
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), threadid, "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), threadid, "Blocked");
|
|
|
}
|
|
|
|
|
|
static void handle_user_event(struct fxt_ev_64 *ev, struct starpu_fxt_options *options)
|
|
@@ -1174,7 +1174,7 @@ static void handle_end_callback(struct fxt_ev_64 *ev, struct starpu_fxt_options
|
|
|
if (out_paje_file)
|
|
|
thread_set_state(get_event_time_stamp(ev, options), options->file_prefix, ev->param[1], "B");
|
|
|
if (trace_file)
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[1], "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[1], "Blocked");
|
|
|
}
|
|
|
|
|
|
static void handle_hypervisor_begin(struct fxt_ev_64 *ev, struct starpu_fxt_options *options)
|
|
@@ -1200,7 +1200,7 @@ static void handle_hypervisor_end(struct fxt_ev_64 *ev, struct starpu_fxt_option
|
|
|
if (out_paje_file)
|
|
|
thread_set_state(get_event_time_stamp(ev, options), options->file_prefix, ev->param[0], "B");
|
|
|
if (trace_file)
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Blocked");
|
|
|
}
|
|
|
|
|
|
static void handle_worker_status(struct fxt_ev_64 *ev, struct starpu_fxt_options *options, const char *newstatus)
|
|
@@ -1223,7 +1223,7 @@ static void handle_worker_status(struct fxt_ev_64 *ev, struct starpu_fxt_options
|
|
|
else if (!strcmp(newstatus, "U"))
|
|
|
recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[1], "Unpartitioning");
|
|
|
else if (!strcmp(newstatus, "B"))
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[1], "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[1], "Blocked");
|
|
|
else
|
|
|
fprintf(stderr, "WARNING: Unhandled worker status '%s'", newstatus);
|
|
|
}
|
|
@@ -1252,7 +1252,7 @@ static void handle_worker_scheduling_end(struct fxt_ev_64 *ev, struct starpu_fxt
|
|
|
if (out_paje_file)
|
|
|
thread_set_state(get_event_time_stamp(ev, options), options->file_prefix, ev->param[0], "B");
|
|
|
if (trace_file)
|
|
|
- recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Overhead");
|
|
|
+ recfmt_thread_set_state(get_event_time_stamp(ev, options), ev->param[0], "Blocked");
|
|
|
}
|
|
|
|
|
|
static void handle_worker_scheduling_push(struct fxt_ev_64 *ev, struct starpu_fxt_options *options)
|
|
@@ -1305,7 +1305,7 @@ static void handle_worker_sleep_end(struct fxt_ev_64 *ev, struct starpu_fxt_opti
|
|
|
if (out_paje_file)
|
|
|
thread_set_state(end_sleep_timestamp, options->file_prefix, ev->param[0], "B");
|
|
|
if (trace_file)
|
|
|
- recfmt_thread_set_state(end_sleep_timestamp, ev->param[0], "Overhead");
|
|
|
+ recfmt_thread_set_state(end_sleep_timestamp, ev->param[0], "Blocked");
|
|
|
|
|
|
double sleep_length = end_sleep_timestamp - last_sleep_start[worker];
|
|
|
|