Package uk.ac.manchester.spinnaker.front_end.dse

Class FastExecuteDataSpecification

java.lang.Object

uk.ac.manchester.spinnaker.front_end.BoardLocalSupport

uk.ac.manchester.spinnaker.front_end.dse.ExecuteDataSpecification

uk.ac.manchester.spinnaker.front_end.dse.FastExecuteDataSpecification

All Implemented Interfaces:

AutoCloseable

public class FastExecuteDataSpecification
extends ExecuteDataSpecification

Implementation of the Data Specification Executor that uses the Fast Data In protocol to upload the results to a SpiNNaker machine.

Author:

Donal Fellows, Alan Stokes

Nested Class Summary

Nested classes/interfaces inherited from class uk.ac.manchester.spinnaker.front_end.BoardLocalSupport

BoardLocalSupport.BoardLocal

Field Summary

Fields inherited from class uk.ac.manchester.spinnaker.front_end.dse.ExecuteDataSpecification

db

Fields inherited from class uk.ac.manchester.spinnaker.front_end.BoardLocalSupport

machine, storage

Constructor Summary

Constructors

Constructor	Description
FastExecuteDataSpecification(uk.ac.manchester.spinnaker.machine.Machine machine, List<Gather> gatherers, File reportDir, DSEDatabaseEngine db)	Create an instance of this class.

Method Summary

Modifier and Type	Method	Description
void	close()
void	loadCores(List<Gather> gatherers)	Execute all application data specifications that a particular connection knows about, storing back in the database the information collected about those executions.

Methods inherited from class uk.ac.manchester.spinnaker.front_end.dse.ExecuteDataSpecification

processTasksInParallel

Methods inherited from class uk.ac.manchester.spinnaker.front_end.BoardLocalSupport

getJob, getTransceiver

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FastExecuteDataSpecification

@MustBeClosed
public FastExecuteDataSpecification(uk.ac.manchester.spinnaker.machine.Machine machine,
 List<Gather> gatherers,
 File reportDir,
 DSEDatabaseEngine db)
                             throws IOException,
InterruptedException,
StorageException,
URISyntaxException,
SpinnmanException

Create an instance of this class.

Parameters:

machine - The SpiNNaker machine description.

gatherers - The description of where the gatherers and monitors are.

reportDir - Where to write reports, or null if no reports are to be written.

db - The DSE Database.

Throws:

IOException - If IO goes wrong.

InterruptedException - If communications are interrupted.

URISyntaxException - If the proxy URI is provided but not valid.

StorageException - If there is an error reading the database.

SpinnmanException - If there is an error creating the transceiver.

IllegalStateException - If something really strange occurs with talking to the BMP; this constructor should not be doing that!

Method Details

close

public void close()
           throws IOException

Throws:

IOException

loadCores

public void loadCores(List<Gather> gatherers)
               throws StorageException,
IOException,
ProcessException,
InterruptedException

Execute all application data specifications that a particular connection knows about, storing back in the database the information collected about those executions. Data is transferred using the Fast Data In protocol.

Cannot load data for system cores; those are used by the implementation of this protocol.

Parameters:

gatherers - The receivers of data from the machine.

Throws:

StorageException - If the database can't be talked to.

IOException - If the transceiver can't talk to its sockets.

ProcessException - If SpiNNaker rejects a message.

InterruptedException - If communications are interrupted.

IllegalStateException - If an unexpected exception occurs in any of the parallel tasks.