spinn_front_end_common.interface.buffer_management package

Subpackages

• spinn_front_end_common.interface.buffer_management.buffer_models package
  • Module contents
    • AbstractReceiveBuffersToHost
      • AbstractReceiveBuffersToHost.get_recorded_region_ids()
      • AbstractReceiveBuffersToHost.get_recording_region_base_address()
    • AbstractReceiveRegionsToHost
      • AbstractReceiveRegionsToHost.get_download_regions()
    • AbstractSendsBuffersFromHost
      • AbstractSendsBuffersFromHost.buffering_input()
      • AbstractSendsBuffersFromHost.get_next_key()
      • AbstractSendsBuffersFromHost.get_next_timestamp()
      • AbstractSendsBuffersFromHost.get_region_buffer_size()
      • AbstractSendsBuffersFromHost.get_regions()
      • AbstractSendsBuffersFromHost.is_empty()
      • AbstractSendsBuffersFromHost.is_next_key()
      • AbstractSendsBuffersFromHost.is_next_timestamp()
      • AbstractSendsBuffersFromHost.rewind()
• spinn_front_end_common.interface.buffer_management.storage_objects package
  • Module contents
    • BufferDatabase
      • BufferDatabase.clear_recording_region()
      • BufferDatabase.get_core_name()
      • BufferDatabase.get_download_by_extraction_id()
      • BufferDatabase.get_last_extraction_id()
      • BufferDatabase.get_power_monitor_core()
      • BufferDatabase.get_recording()
      • BufferDatabase.get_recording_by_extraction_id()
      • BufferDatabase.start_new_extraction()
      • BufferDatabase.store_download()
      • BufferDatabase.store_recording()
      • BufferDatabase.store_setup_data()
      • BufferDatabase.store_vertex_labels()
      • BufferDatabase.write_session_credentials_to_db()
    • BufferedSendingRegion
      • BufferedSendingRegion.add_key()
      • BufferedSendingRegion.add_keys()
      • BufferedSendingRegion.clear()
      • BufferedSendingRegion.current_timestamp
      • BufferedSendingRegion.get_n_keys()
      • BufferedSendingRegion.is_next_key()
      • BufferedSendingRegion.is_next_timestamp
      • BufferedSendingRegion.n_timestamps
      • BufferedSendingRegion.next_key()
      • BufferedSendingRegion.next_timestamp
      • BufferedSendingRegion.rewind()
      • BufferedSendingRegion.timestamps
    • BuffersSentDeque
      • BuffersSentDeque.add_message_to_send()
      • BuffersSentDeque.is_empty()
      • BuffersSentDeque.is_full
      • BuffersSentDeque.messages
      • BuffersSentDeque.send_stop_message()
      • BuffersSentDeque.update_last_received_sequence_number()

Submodules

spinn_front_end_common.interface.buffer_management.recording_utilities module

spinn_front_end_common.interface.buffer_management.recording_utilities.get_recording_data_constant_size(n_recording_regions: int) → int

Get the size of the headers that are stored in the SDRAM spaces allocated during recording_initialise, and so do not need to be reserved with DSG (but need to be accounted for in SDRAM calculations).

Parameters:

n_recording_regions – The number of regions that can be recorded

Returns:

size of the recoding headers stored in the SDRAM space

spinn_front_end_common.interface.buffer_management.recording_utilities.get_recording_header_array(recorded_region_sizes: Sequence[int]) → List[int]

Get data to be written for the recording header.

Parameters:

recorded_region_sizes – A list of sizes of each region to be recorded. A size of 0 is acceptable.

Returns:

List of int being the number of regions and then for each region its size then two zeros

spinn_front_end_common.interface.buffer_management.recording_utilities.get_recording_header_size(n_recording_regions: int) → int

Get the size of the data to be written for the recording header.

This is the data that sets up how recording will be done, and indicates the sizes of the regions to be stored.

Parameters:

n_recording_regions – The number of regions that can be recorded

Returns:

size of the list returned by get_recording_header_array

Module contents

class spinn_front_end_common.interface.buffer_management.BufferManager

Bases: object

Manager of send buffers.

clear_recorded_data(x: int, y: int, p: int, recording_region_id: int) → None

Removes the recorded data stored in memory.

Parameters:

• x – placement X coordinate

• y – placement Y coordinate

• p – placement processor ID

• recording_region_id – the recording region ID

extract_data() → None

Retrieve the data from placed vertices.

get_data_by_placement(placement: Placement, recording_region_id: int) → Tuple[memoryview, bool]

Deprecated use get_recording or get_download

Parameters:

• placement

• recording_region_id

Returns:

get_download(placement: Placement, recording_region_id: int) → Tuple[memoryview, bool]

Get the data container for the data retrieved during the simulation from a specific region area of a core.

Only the last data extracted is returned.

Parameters:

• placement – the placement to get the data from

• recording_region_id – desired recording data region

Returns:

an array contained all the data received during the simulation, and a flag indicating if any data was missing

Raises:

• BufferedRegionNotPresent – If no data is available nor marked missing.

• NotImplementedError – If the placement’s vertex is not a type that records data

get_recording(placement: Placement, recording_region_id: int) → Tuple[memoryview, bool]

Get the data container for the data retrieved during the simulation from a specific region area of a core.

Data for all extractions is combined.

Parameters:

• placement – The placement to get the data from

• recording_region_id – desired recording data region

Returns:

an array contained all the data received during the simulation, and a flag indicating if any data was missing

Raises:

• BufferedRegionNotPresent – If no data is available nor marked missing.

• NotImplementedError – If the placement’s vertex is not a type that records data

load_initial_buffers() → None

Load the initial buffers for the senders using memory writes.

reset() → None

Resets the buffered regions to start transmitting from the beginning of its expected regions and clears the buffered out data files.

resume() → None

Resets any data structures needed before starting running again.

property sender_vertices: Iterable[AbstractSendsBuffersFromHost]

The vertices which are buffered.