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