svg_trace.c File Reference

#include "svg_trace.h"

Include dependency graph for svg_trace.c:

Go to the source code of this file.

Functions
void	svg_trace_init (int num_cores)
	Initialize tracing. More...
void	svg_trace_start (int thread_rank)
	Start tracing an event. More...
void	svg_trace_stop (int thread_rank, int color)
	Stop tracing an event. More...
void	svg_trace_finish ()
	Finish tracing. Collect traces from all nodes. Write the combined trace to an SVG file. More...

Function Documentation

void svg_trace_finish

(

)

Finish tracing. Collect traces from all nodes. Write the combined trace to an SVG file.

Definition at line 78 of file svg_trace.c.

References SVG_TRACE_FILE_NAME_SIZE, SVG_TRACE_MAX_CORES, and SVG_TRACE_MAX_EVENTS.

{
    int mpi_rank;
    int mpi_size;
    MPI_Comm_rank(MPI_COMM_WORLD, &mpi_rank);
    MPI_Comm_size(MPI_COMM_WORLD, &mpi_size);

    int proc;
    int core;
    int event;
    double max_time = 0.0;
    for (core = 0; core < SVG_TRACE_MAX_CORES; core++) {
        double time =
            eventStopCore [core][eventNumCore[core]-1] -
            eventStopCore[0][0];
        if (time > max_time)
            max_time = time;
    }
    double max_time_out;
    MPI_Reduce(
        &max_time, &max_time_out, 1, MPI_DOUBLE, MPI_MAX, 0, MPI_COMM_WORLD);
    double hscale = 2000.0 / max_time_out;

    int max_core_in = 0;
    for (core = 0; core < SVG_TRACE_MAX_CORES; core++)
        if (eventNumCore[core] > 1)
            max_core_in = core;
    int max_core;
    MPI_Reduce(
        &max_core_in, &max_core, 1, MPI_INT, MPI_MAX, 0, MPI_COMM_WORLD);
    double vscale = 1000.0 / ((max_core+1)*mpi_size);

    if (mpi_rank == 0) {
        char trace_file_name[SVG_TRACE_FILE_NAME_SIZE];
        sprintf(trace_file_name, "trace_%d.svg", (int)(time(NULL)));
        FILE *trace_file = fopen(trace_file_name, "w");
        assert(trace_file != NULL);
        fprintf(trace_file,
            "<svg width=\"200mm\" height=\"100mm\" viewBox=\"0 0 2000 1000\">\n"
            "  <g>\n");

        for (proc = 0; proc < mpi_size; proc++) {
            if (proc > 0) {
                MPI_Recv(
                    &eventNumCore[0],
                    SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS, MPI_INT,
                    proc, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
                MPI_Recv(
                    &eventStartCore[0][0],
                    SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS, MPI_DOUBLE,
                    proc, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
                MPI_Recv(
                    &eventStopCore[0][0],
                    SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS, MPI_DOUBLE,
                    proc, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
                MPI_Recv(
                    &eventColorCore[0][0],
                    SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS, MPI_INT,
                    proc, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
            }
            for (core = 0; core < SVG_TRACE_MAX_CORES; core++) {
                for (event = 0; event < eventNumCore[core]; event++) {
                    double start = eventStartCore[core][event] - eventStopCore[0][0];
                    double stop =  eventStopCore [core][event] - eventStopCore[0][0];
                    double width = (stop-start) * hscale;
                    int color = eventColorCore[core][event];
                    int thread = proc*(max_core+1)+core;
                    fprintf(trace_file,
                        "    "
                        "<rect x=\"%.2lf\" y=\"%.0lf\" width=\"%.2lf\" height=\"%.0lf\" "
                        "fill=\"#%06x\" stroke=\"#%06x\" stroke-width=\"1\"/>\n",
                        start * hscale,
                        thread * vscale,
                        width < 2.0 ? 2.0 : width,
                        vscale * 0.9,
                        abs(color),
                        color < 0 ? color : 0);
                }
            }
        }
        fprintf(trace_file,
            "  </g>\n"
            "</svg>\n");
        fclose(trace_file);
    }
    else {
        MPI_Send(
            &eventNumCore[0],
            SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS,
            MPI_INT, 0, 0, MPI_COMM_WORLD);
        MPI_Send(
            &eventStartCore[0][0],
            SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS,
            MPI_DOUBLE, 0, 0, MPI_COMM_WORLD);
        MPI_Send(
            &eventStopCore[0][0],
            SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS,
            MPI_DOUBLE, 0, 0, MPI_COMM_WORLD);
        MPI_Send(
            &eventColorCore[0][0],
            SVG_TRACE_MAX_CORES*SVG_TRACE_MAX_EVENTS,
            MPI_INT, 0, 0, MPI_COMM_WORLD);
    }
}

Here is the caller graph for this function:

void svg_trace_init

(

int

num_cores

)

Initialize tracing.

Parameters

num_cores

Definition at line 38 of file svg_trace.c.

References SVG_TRACE_MAX_CORES, and SVG_TRACE_MAX_EVENTS.

{
    assert(num_cores <= SVG_TRACE_MAX_CORES);
    assert(__builtin_popcount(SVG_TRACE_MAX_EVENTS) == 0x01);
}

Here is the caller graph for this function:

void svg_trace_start

(

int

thread_rank

)

Start tracing an event.

Parameters

rank	thread rank

Definition at line 50 of file svg_trace.c.

References SVG_TRACE_MAX_CORES.

{
    assert(thread_rank < SVG_TRACE_MAX_CORES);
    eventStartCore[thread_rank][eventNumCore[thread_rank]] = get_time_of_day();
}

Here is the caller graph for this function:

void svg_trace_stop	(	int	thread_rank,
		int	color
	)

Stop tracing an event.

Parameters

rank	thread rank
color	RGB color

Definition at line 63 of file svg_trace.c.

References SVG_TRACE_MAX_CORES, and SVG_TRACE_MAX_EVENTS.

{
    assert(thread_rank < SVG_TRACE_MAX_CORES);
    eventStopCore [thread_rank][eventNumCore[thread_rank]] = get_time_of_day();
    eventColorCore[thread_rank][eventNumCore[thread_rank]] = color;
    eventNumCore[thread_rank]++;
    eventNumCore[thread_rank] &= (SVG_TRACE_MAX_EVENTS-1);
}

Here is the caller graph for this function: