WRENCH
1.11
Cyberinfrastructure Simulation Workbench
|
Overview | Installation | Getting Started | WRENCH 101 | WRENCH 102 |
A base class for simulation timestamps regarding file writes. More...
#include <SimulationTimestampTypes.h>
Public Member Functions | |
std::shared_ptr< FileLocation > | getDestination () |
retrieves the location from which the DataFile is being copied More... | |
SimulationTimestampFileWrite * | getEndpoint () override |
Retrieve the matching endpoint, if any. More... | |
std::shared_ptr< DataFile > | getFile () |
retrieves the DataFile being written More... | |
std::shared_ptr< StorageService > | getService () |
retrieves the Service that ordered file write More... | |
std::shared_ptr< WorkflowTask > | getTask () |
retrieves task associated w/ file write More... | |
Public Member Functions inherited from wrench::SimulationTimestampType | |
SimulationTimestampType () | |
double | getDate () |
Retrieve the date recorded for this timestamp. More... | |
Protected Member Functions | |
SimulationTimestampFileWrite (double date, std::shared_ptr< DataFile >file, std::shared_ptr< FileLocation > dst, std::shared_ptr< StorageService > service, std::shared_ptr< WorkflowTask >task=nullptr) | |
Constructor. More... | |
void | setEndpoints () |
Sets the endpoint of the calling object (SimulationTimestampFileWriteFailure, SimulationTimestampFileWriteTerminated, SimulationTimestampFileWriteStart) with a SimulationTimestampFileWriteStart object. | |
Protected Attributes | |
std::shared_ptr< FileLocation > | destination |
The location where the DataFile was being write from. | |
std::shared_ptr< DataFile > | file |
The DataFile that was being write. | |
std::shared_ptr< StorageService > | service |
Service that initiated the write. | |
std::shared_ptr< WorkflowTask > | task |
Task associated with write. | |
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< SimulationTimestampFileWrite *, std::shared_ptr< WorkflowTask > > > | pending_file_writes |
the data structure that holds the ongoing file writes. More... | |
A base class for simulation timestamps regarding file writes.
|
protected |
Constructor.
date | the date |
file | the DataFile associated with this file write |
dst_location | the destination location |
service | service requesting file write |
task | a task associated to this file read (or nullptr) |
std::shared_ptr< FileLocation > wrench::SimulationTimestampFileWrite::getDestination | ( | ) |
retrieves the location from which the DataFile is being copied
|
overridevirtual |
Retrieve the matching endpoint, if any.
retrieves the corresponding SimulationTimestampFileWrite object
Reimplemented from wrench::SimulationTimestampPair.
std::shared_ptr< DataFile > wrench::SimulationTimestampFileWrite::getFile | ( | ) |
std::shared_ptr< StorageService > wrench::SimulationTimestampFileWrite::getService | ( | ) |
retrieves the Service that ordered file write
std::shared_ptr< WorkflowTask > wrench::SimulationTimestampFileWrite::getTask | ( | ) |
retrieves task associated w/ file write
|
staticprotected |
the data structure that holds the ongoing file writes.
A static unordered multimap of SimulationTimestampFileWriteStart objects that have yet to be matched with Failure, Terminated or Completion timestamps.
static std::unordered_multimap<File, std::pair<SimulationTimestampFileWrite *, double>, decltype(&file_hash)> pending_file_writes;