WRENCH
1.10
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 | |
FileLocation * | getDestination () |
retrieves the location from which the WorkflowFile is being copied More... | |
SimulationTimestampFileWrite * | getEndpoint () override |
Retrieve the matching endpoint, if any. More... | |
WorkflowFile * | getFile () |
retrieves the WorkflowFile being written More... | |
StorageService * | getService () |
retrieves the Service that ordered file write More... | |
WorkflowTask * | getTask () |
retrieves task associated w/ file write More... | |
Public Member Functions inherited from wrench::SimulationTimestampPair | |
SimulationTimestampPair () | |
Constructor. | |
SimulationTimestampPair (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 | |
SimulationTimestampFileWrite (WorkflowFile *file, FileLocation *dst, StorageService *service, WorkflowTask *task=nullptr) | |
Constructor. More... | |
void | setEndpoints () |
Sets the endpoint of the calling object (SimulationTimestampFileWriteFailure, SimulationTimestampFileWriteTerminated, SimulationTimestampFileWriteStart) with a SimulationTimestampFileWriteStart object. | |
Protected Attributes | |
FileLocation * | destination |
The location where the WorkflowFile was being write from. | |
WorkflowFile * | file |
The WorkflowFile that was being write. | |
StorageService * | service |
Service that initiated the write. | |
WorkflowTask * | task |
Task associated with write. | |
Protected Attributes inherited from wrench::SimulationTimestampPair | |
SimulationTimestampPair * | endpoint = nullptr |
An optional associated "endpoint" simulation timestamp. | |
Static Protected Attributes | |
static std::unordered_multimap< File, std::pair< SimulationTimestampFileWrite *, 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.
file | the WorkflowFile 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) |
FileLocation * wrench::SimulationTimestampFileWrite::getDestination | ( | ) |
retrieves the location from which the WorkflowFile is being copied
|
overridevirtual |
Retrieve the matching endpoint, if any.
retrieves the corresponding SimulationTimestampFileWrite object
Reimplemented from wrench::SimulationTimestampPair.
WorkflowFile * wrench::SimulationTimestampFileWrite::getFile | ( | ) |
retrieves the WorkflowFile being written
StorageService * wrench::SimulationTimestampFileWrite::getService | ( | ) |
retrieves the Service that ordered file write
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;