package candis.example.mini;

import candis.distributed.DistributedJobParameter;

/**
 * Serializable initial parameter for "global" settings.
 */
public class MiniInitParameter implements DistributedJobParameter {

	/// Some example Value
	public final int offset;

	/**
	 * Initializes the Initial Parameters for MiniTask
	 *
	 * @param offset some integer value
	 */
	public MiniInitParameter(final int offset) {
		this.offset = offset;
	}
}

package candis.example.mini;

import candis.distributed.DistributedJobParameter;

/**
 * Serializable task parameter for MiniTask.
 */
public class MiniJobParameter implements DistributedJobParameter {

	/// Some value
	public final int foo;
	/// Another value
	public final float bar;

	/**
	 * Initializes the Task Parameters for MiniTask
	 *
	 * @param foo some integer value
	 * @param bar some float value
	 */
	public MiniJobParameter(final int foo, final float bar) {
		this.foo = foo;
		this.bar = bar;
	}
}

package candis.example.mini;

import candis.distributed.DistributedJobResult;

/**
 * Serializable result for MiniTask.
 */
public class MiniJobResult implements DistributedJobResult {

	/// Some value
	public final float foobar;

	/**
	 * Initializes the result data.
	 *
	 * @param foobar
	 */
	public MiniJobResult(final float foobar) {
		this.foobar = foobar;
	}
}

package candis.example.mini;

import candis.distributed.DistributedJobParameter;
import candis.distributed.DistributedJobResult;
import candis.distributed.DistributedRunnable;

/**
 * Example Task.
 * Multiplies MiniParameter.foo with MiniParamter.bar
 */
public class MiniRunnable implements DistributedRunnable {

	private MiniInitParameter initial;

	/**
	 * Gets called when the Task should be aborted.
	 */
	@Override
	public void stopJob() {
		// Nothing to do here
	}

	/**
	 * Gets called to start the Task with given parameter.
	 * Contains main code for this Task.
	 *
	 * @param parameter Parameter (MiniParameter) specifying the current Task
	 * @return The generated MiniResult, when the task is finished
	 */
	@Override
	public DistributedJobResult runJob(DistributedJobParameter parameter) {
		// Cast incomming Parameter
		MiniJobParameter p = (MiniJobParameter) parameter;
		System.out.println(String.format("HEY, I AM THE RUNNABLE, MY PARAMETERS ARE: %s and %s", p.bar, p.foo));
		return new MiniJobResult(p.foo * p.bar + initial.offset);
	}

	/**
	 * Gets called to set the initial parameter.
	 *
	 * @param parameter Transfered initial parameter
	 */
	@Override
	public void setInitialParameter(DistributedJobParameter parameter) {
		initial = (MiniInitParameter) parameter;
	}
}

package candis.example.mini;

import candis.distributed.DistributedControl;
import candis.distributed.DistributedJobParameter;
import candis.distributed.DistributedJobResult;
import candis.distributed.ResultReceiver;
import candis.distributed.Scheduler;
import candis.distributed.SimpleScheduler;

/**
 * Minimalistic example how to initialize a set of tasks and receive its
 * results.
 */
public class MiniControl implements DistributedControl, ResultReceiver {

	MiniInitParameter init;
	Scheduler scheduler;

	@Override
	public Scheduler initScheduler() {
		scheduler = new SimpleScheduler();

		// Register ResultReceiver
		scheduler.addResultReceiver(this);

		// Set initial Parameters
		init = new MiniInitParameter(23);
		scheduler.setInitialParameter(init);

		// Create some tasks
		for (int i = 0; i < 10; i++) {
			scheduler.addParameter(new MiniJobParameter(i, 3.5f));
		}

		return scheduler;
	}

	@Override
	public void onSchedulerDone() {
		// Now all tasks are completed successfully
		System.out.println("done!");
	}

	@Override
	public void onReceiveResult(DistributedJobParameter param, DistributedJobResult result) {
		/// One result is finished and we can use it, somehow ...
		MiniJobResult miniResult = (MiniJobResult) result;
		System.out.println(String.format("Got Result: %.3f", miniResult.foobar));

	}
}