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, txrx

Constructor Summary

Constructors

Constructor	Description
FastExecuteDataSpecification(TransceiverInterface txrx, 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
protected void	buildMaps(List<Gather> gatherers)	Construct the internal mappings for gatherers and monitors.
void	loadCores()	Execute all application data specifications that a particular connection knows about, storing back in the database the information collected about those executions.
void	writeReport(uk.ac.manchester.spinnaker.machine.HasChipLocation chip, long timeDiff, int size, uk.ac.manchester.spinnaker.machine.MemoryLocation baseAddress, Object missingNumbers)	Writes (part of) the report describing what data transfer rates were achieved.

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

close, processTasksInParallel

Methods inherited from class java.lang.Object

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

Constructor Details

FastExecuteDataSpecification

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

Create an instance of this class.

Parameters:

txrx - The transceiver for talking to the SpiNNaker machine.

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.

ProcessException - If SpiNNaker rejects a message.

InterruptedException - If communications are interrupted.

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

StorageException - If there is an error reading the database.

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

Method Details

buildMaps

protected void buildMaps(List<Gather> gatherers) throws IOException, ProcessException, InterruptedException

Construct the internal mappings for gatherers and monitors.

Parameters:

gatherers - The descriptions of whether the gatherers are located.

Throws:

IOException - If IDs can't be read from the machine for network reasons.

ProcessException - If IDs can't be read from the machine for machine reasons.

InterruptedException - If we are interrupted.

loadCores

public void loadCores() 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.

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.

writeReport

public void writeReport(uk.ac.manchester.spinnaker.machine.HasChipLocation chip, long timeDiff, int size, uk.ac.manchester.spinnaker.machine.MemoryLocation baseAddress, Object missingNumbers) throws IOException

Writes (part of) the report describing what data transfer rates were achieved.

Parameters:

chip - Which chip was the data bound for?

timeDiff - How long did the transfer take, in nanoseconds.

size - How many bytes were transferred?

baseAddress - Where were the bytes written to?

missingNumbers - What were the missing sequence numbers at each stage.

Throws:

IOException - If IO fails.