Merge master in TmfTraceModel

[deliverable/tracecompass.git] / org.eclipse.linuxtools.tmf.core.tests / src / org / eclipse / linuxtools / tmf / core / tests / ctfadaptor / headless / RequestBenchmark.java

/*******************************************************************************
 * Copyright (c) 2009 Ericsson
 *
 * All rights reserved. This program and the accompanying materials are
 * made available under the terms of the Eclipse Public License v1.0 which
 * accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *   William Bourque (wbourque@gmail.com) - Initial API and implementation
 *******************************************************************************/
package org.eclipse.linuxtools.tmf.core.tests.ctfadaptor.headless;

import java.util.Vector;

import org.eclipse.linuxtools.tmf.core.ctfadaptor.CtfTmfEvent;
import org.eclipse.linuxtools.tmf.core.ctfadaptor.CtfTmfTimestamp;
import org.eclipse.linuxtools.tmf.core.ctfadaptor.CtfTmfTrace;
import org.eclipse.linuxtools.tmf.core.event.ITmfEvent;
import org.eclipse.linuxtools.tmf.core.event.TmfTimeRange;
import org.eclipse.linuxtools.tmf.core.experiment.TmfExperiment;
import org.eclipse.linuxtools.tmf.core.request.TmfEventRequest;
import org.eclipse.linuxtools.tmf.core.trace.ITmfTrace;

@SuppressWarnings("nls")
public class RequestBenchmark extends TmfEventRequest<CtfTmfEvent> {

    @SuppressWarnings("unchecked")
    public RequestBenchmark(Class<? extends ITmfEvent> dataType,
            TmfTimeRange range, int nbRequested) {
        super((Class<CtfTmfEvent>) dataType, range, nbRequested, 1);
    }

    // Path of the trace
    public static final String TRACE_PATH = "../org.eclipse.linuxtools.ctf.core.tests/Tests/traces/trace20m1";

    // *** Change this to run several time over the same trace
    public static final int NB_OF_PASS = 100;

    // *** Change this to true to parse all the events in the trace
    // Otherwise, events are just read
    public final boolean PARSE_EVENTS = true;

    // Work variables
    public static int nbEvent = 0;
    public static int nbPassDone = 0;
    public static TmfExperiment<CtfTmfEvent> fExperiment = null;
    public static Vector<Double> benchs = new Vector<Double>();

    public static void main(String[] args) {

        try {
            // OUr experiment will contains ONE trace
            @SuppressWarnings("unchecked")
            ITmfTrace<CtfTmfEvent>[] traces = new ITmfTrace[1];
            traces[0] = new CtfTmfTrace();
            traces[0].initTrace("CtfTrace", TRACE_PATH, CtfTmfEvent.class);
            // Create our new experiment
            fExperiment = new TmfExperiment<CtfTmfEvent>(CtfTmfEvent.class,
                    "Headless", traces);

            // Create a new time range from -infinity to +infinity
            // That way, we will get "everything" in the trace
            CtfTmfTimestamp ts1 = new CtfTmfTimestamp(Long.MIN_VALUE,
                    (CtfTmfTrace) traces[0]);
            CtfTmfTimestamp ts2 = new CtfTmfTimestamp(Long.MAX_VALUE,
                    (CtfTmfTrace) traces[0]);
            TmfTimeRange tmpRange = new TmfTimeRange(ts1, ts2);

            // We will issue a request for each "pass".
            // TMF will then process them synchonously
            RequestBenchmark request = null;
            for (int x = 0; x < NB_OF_PASS; x++) {
                request = new RequestBenchmark(CtfTmfEvent.class, tmpRange,
                        Integer.MAX_VALUE);
                fExperiment.sendRequest(request);
                nbPassDone++;
            }
            prev = System.nanoTime();
        } catch (NullPointerException e) {
            // Silently dismiss Null pointer exception
            // The only way to "finish" the threads in TMF is by crashing them
            // with null
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    @Override
    public void handleData(CtfTmfEvent event) {
        super.handleData(event);
        nbEvent++;

    }

    static long prev;
    static long done = 0;
    @Override
    public void handleCompleted() {
        long next = System.nanoTime();
        double val = next - prev;
        int nbEvent2 = nbEvent;
        val /= nbEvent2;

        nbEvent = 0;
        prev = next;
        benchs.add(val);
        if (benchs.size() == NB_OF_PASS) {
            try {
                System.out.println("Nb events : " + nbEvent2);

                for (double value : benchs) {
                    System.out.print(value + ", ");
                }
                fExperiment.sendRequest(null);

            } catch (Exception e) {
            }
        }
    }

    @Override
    public void handleSuccess() {
    }

    @Override
    public void handleFailure() {
    }

    @Override
    public void handleCancel() {
    }

}