23 #include "openPMD/IO/AbstractIOHandler.hpp" 24 #include "openPMD/IO/IOTask.hpp" 25 #include "openPMD/auxiliary/DerefDynamicCast.hpp" 43 std::future<void> flush()
45 using namespace auxiliary;
47 while (!(*m_handler).m_work.empty())
49 IOTask &i = (*m_handler).m_work.front();
67 case O::CREATE_DATASET:
73 case O::EXTEND_DATASET:
103 case O::OPEN_DATASET:
121 case O::DELETE_DATASET:
133 case O::WRITE_DATASET:
145 case O::READ_DATASET:
151 case O::GET_BUFFER_VIEW:
169 case O::LIST_DATASETS:
187 case O::AVAILABLE_CHUNKS:
197 std::cerr <<
"[AbstractIOHandlerImpl] IO Task " 198 << internal::operationAsString(i.operation)
199 <<
" failed with exception. Removing task" 200 <<
" from IO queue and passing on the exception." 202 (*m_handler).m_work.pop();
205 (*m_handler).m_work.pop();
207 return std::future<void>();
454 parameters.out->backendManagedBuffer =
false;
virtual void writeDataset(Writable *, Parameter< Operation::WRITE_DATASET > const &)=0
Write a chunk of data into an existing dataset.
virtual void deleteAttribute(Writable *, Parameter< Operation::DELETE_ATT > const &)=0
Delete an existing attribute.
Definition: IOTask.hpp:562
virtual void writeAttribute(Writable *, Parameter< Operation::WRITE_ATT > const &)=0
Create a single attribute and fill the value, possibly overwriting an existing attribute.
Self-contained description of a single IO operation.
Definition: IOTask.hpp:615
Definition: IOTask.hpp:144
virtual void deleteDataset(Writable *, Parameter< Operation::DELETE_DATASET > const &)=0
Delete an existing dataset.
virtual void createDataset(Writable *, Parameter< Operation::CREATE_DATASET > const &)=0
Create a new dataset of given type, extent and storage properties.
Definition: IOTask.hpp:230
Definition: IOTask.hpp:333
virtual void listPaths(Writable *, Parameter< Operation::LIST_PATHS > &)=0
List all paths/sub-groups inside a group, non-recursively.
virtual void createFile(Writable *, Parameter< Operation::CREATE_FILE > const &)=0
Create a new file in physical storage, possibly overriding an existing file.
virtual void extendDataset(Writable *, Parameter< Operation::EXTEND_DATASET > const &)=0
Increase the extent of an existing dataset.
Definition: IOTask.hpp:120
Definition: IOTask.hpp:159
Definition: IOTask.hpp:471
Interface for communicating between logical and physically persistent data.
Definition: AbstractIOHandler.hpp:122
virtual void deleteFile(Writable *, Parameter< Operation::DELETE_FILE > const &)=0
Delete an existing file from physical storage.
Public definitions of openPMD-api.
Definition: Date.cpp:28
Layer to mirror structure of logical data and persistent data in file.
Definition: Writable.hpp:63
Definition: IOTask.hpp:193
virtual void readDataset(Writable *, Parameter< Operation::READ_DATASET > &)=0
Read a chunk of data from an existing dataset.
virtual void listAttributes(Writable *, Parameter< Operation::LIST_ATTS > &)=0
List all attributes associated with an object.
Definition: IOTask.hpp:384
Typesafe description of all required arguments for a specified Operation.
Definition: IOTask.hpp:93
virtual void openDataset(Writable *, Parameter< Operation::OPEN_DATASET > &)=0
Open an existing dataset and determine its datatype and extent.
virtual void closeFile(Writable *, Parameter< Operation::CLOSE_FILE > const &)=0
Close the file corresponding with the writable and release file handles.
Definition: IOTask.hpp:543
virtual void openFile(Writable *, Parameter< Operation::OPEN_FILE > const &)=0
Open an existing file assuming it conforms to openPMD.
virtual void closePath(Writable *, Parameter< Operation::CLOSE_PATH > const &)
Close an openPMD group.
Definition: AbstractIOHandlerImpl.hpp:247
virtual void getBufferView(Writable *, Parameter< Operation::GET_BUFFER_VIEW > ¶meters)
Get a view into a dataset buffer that can be filled by a user.
Definition: AbstractIOHandlerImpl.hpp:451
virtual void deletePath(Writable *, Parameter< Operation::DELETE_PATH > const &)=0
Delete all objects within an existing path.
Definition: IOTask.hpp:101
Definition: IOTask.hpp:584
Definition: IOTask.hpp:418
virtual void listDatasets(Writable *, Parameter< Operation::LIST_DATASETS > &)=0
List all datasets inside a group, non-recursively.
Definition: IOTask.hpp:313
Definition: IOTask.hpp:176
virtual void availableChunks(Writable *, Parameter< Operation::AVAILABLE_CHUNKS > &)=0
Report chunks that are available for loading from the dataset represented by this writable...
Definition: AbstractIOHandlerImpl.hpp:35
Definition: IOTask.hpp:488
Definition: IOTask.hpp:265
virtual void createPath(Writable *, Parameter< Operation::CREATE_PATH > const &)=0
Create all necessary groups for a path, possibly recursively.
Definition: IOTask.hpp:436
virtual void readAttribute(Writable *, Parameter< Operation::READ_ATT > &)=0
Read the value of an existing attribute.
virtual void advance(Writable *, Parameter< Operation::ADVANCE > &)
Advance the file/stream that this writable belongs to.
Definition: AbstractIOHandlerImpl.hpp:232
Definition: IOTask.hpp:511
Definition: IOTask.hpp:296
Definition: IOTask.hpp:213
Definition: IOTask.hpp:350
virtual void openPath(Writable *, Parameter< Operation::OPEN_PATH > const &)=0
Open all contained groups in a path, possibly recursively.
Definition: IOTask.hpp:247