Package uk.ac.manchester.spinnaker.front_end.download

Class DataReceiver

java.lang.Object

uk.ac.manchester.spinnaker.front_end.BoardLocalSupport

uk.ac.manchester.spinnaker.front_end.download.DataReceiver

All Implemented Interfaces:

AutoCloseable

public class DataReceiver
extends BoardLocalSupport
implements AutoCloseable

Stripped down version of the BufferManager for early testing.

Author:

Christian-B

See Also:

Python Version

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.BoardLocalSupport

machine, storage

Constructor Summary

Constructors

Constructor	Description
DataReceiver(uk.ac.manchester.spinnaker.machine.Machine machine, BufferManagerStorage storage)	Creates a new mini Buffer Manager.

Method Summary

Modifier and Type	Method	Description
void	close()
void	getDataForPlacements(List<Placement> placements)	Gets the data for a list of placements.
void	getDataForPlacementsParallel(List<Placement> placements, int parallelFactor)	Gets the data for a list of placements in parallel.

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

DataReceiver

@MustBeClosed public DataReceiver(uk.ac.manchester.spinnaker.machine.Machine machine, BufferManagerStorage storage) throws IOException, StorageException, SpinnmanException, InterruptedException

Creates a new mini Buffer Manager.

Parameters:

machine - The SpiNNaker system to get the data from.

storage - How to talk to the database.

Throws:

IOException - If we can't discover the machine details due to I/O problems

InterruptedException - If communications are interrupted.

SpinnmanException - If the there is an error creating a transceiver.

StorageException - If the database access fails.

Method Details

close

public void close() throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

getDataForPlacementsParallel

public void getDataForPlacementsParallel(List<Placement> placements, int parallelFactor) throws IOException, StorageException, ProcessException, InterruptedException

Gets the data for a list of placements in parallel.

Parameters:

placements - List of placements.

parallelFactor - Number of threads to use.

Throws:

IOException - if communications fail

ProcessException - if SpiNNaker rejects a message

StorageException - if database access fails

InterruptedException - If communications are interrupted.

getDataForPlacements

public void getDataForPlacements(List<Placement> placements) throws IOException, StorageException, ProcessException, InterruptedException

Gets the data for a list of placements.

Note: This method is subject to change as best way to pass in placement data is determined.

Parameters:

placements - List of placements.

Throws:

IOException - if communications fail

ProcessException - if SpiNNaker rejects a message

StorageException - if database access fails

InterruptedException - If communications are interrupted.