WRENCH
1.11
Cyberinfrastructure Simulation Workbench
|
Overview | Installation | Getting Started | WRENCH 101 | WRENCH 102 |
A base class for simulation timestamps regarding file reads. More...
#include <SimulationTimestampTypes.h>
Public Member Functions | |
SimulationTimestampFileRead * | getEndpoint () override |
Retrieve the matching endpoint, if any. More... | |
std::shared_ptr< DataFile > | getFile () |
retrieves the DataFile being read More... | |
std::shared_ptr< StorageService > | getService () |
retrieves the storage service for file read More... | |
std::shared_ptr< FileLocation > | getSource () |
retrieves the location from which the DataFile is being copied More... | |
std::shared_ptr< WorkflowTask > | getTask () |
retrieves task associated w/ file read More... | |
Public Member Functions inherited from wrench::SimulationTimestampPair | |
SimulationTimestampPair () | |
Constructor. | |
SimulationTimestampPair (double date, SimulationTimestampPair *endpoint) | |
Constructor. More... | |
Public Member Functions inherited from wrench::SimulationTimestampType | |
SimulationTimestampType () | |
double | getDate () |
Retrieve the date recorded for this timestamp. More... | |
Protected Member Functions | |
SimulationTimestampFileRead (double date, std::shared_ptr< DataFile >file, std::shared_ptr< FileLocation > src, std::shared_ptr< StorageService > service, std::shared_ptr< WorkflowTask >task=nullptr) | |
Constructor. More... | |
void | setEndpoints () |
Sets the endpoint of the calling object (SimulationTimestampFileReadFailure, SimulationTimestampFileReadTerminated, SimulationTimestampFileReadStart) with a SimulationTimestampFileReadStart object. | |
Protected Attributes | |
std::shared_ptr< DataFile > | file |
The DataFile that was being read. | |
std::shared_ptr< StorageService > | service |
Service that initiated the read. | |
std::shared_ptr< FileLocation > | source |
The location where the DataFile was being read from. | |
std::shared_ptr< WorkflowTask > | task |
Task tied to read. | |
Protected Attributes inherited from wrench::SimulationTimestampPair | |
SimulationTimestampPair * | endpoint = nullptr |
An optional associated "endpoint" simulation timestamp. | |
Protected Attributes inherited from wrench::SimulationTimestampType | |
double | date = -0.1 |
Date. | |
Static Protected Attributes | |
static std::unordered_multimap< FileReadWrite, std::pair< SimulationTimestampFileRead *, std::shared_ptr< WorkflowTask > > > | pending_file_reads |
the data structure that holds the ongoing file reads. More... | |
A base class for simulation timestamps regarding file reads.
|
protected |
Constructor.
date | the date |
file | the DataFile associated with this file read |
src_location | the source location |
service | service requesting file read |
task | a task associated to this file read (or nullptr) |
|
overridevirtual |
Retrieve the matching endpoint, if any.
retrieves the corresponding SimulationTimestampFileRead object
Reimplemented from wrench::SimulationTimestampPair.
std::shared_ptr< DataFile > wrench::SimulationTimestampFileRead::getFile | ( | ) |
std::shared_ptr< StorageService > wrench::SimulationTimestampFileRead::getService | ( | ) |
retrieves the storage service for file read
std::shared_ptr< FileLocation > wrench::SimulationTimestampFileRead::getSource | ( | ) |
retrieves the location from which the DataFile is being copied
std::shared_ptr< WorkflowTask > wrench::SimulationTimestampFileRead::getTask | ( | ) |
retrieves task associated w/ file read
|
staticprotected |
the data structure that holds the ongoing file reads.
A static unordered multimap of SimulationTimestampFileReadStart objects that have yet to be matched with Failure, Terminated or Completion timestamps.
static std::unordered_multimap<File, std::pair<SimulationTimestampFileRead *, double>, decltype(&file_hash)> pending_file_reads;