class
#include <eckit/io/AsyncHandle.h>
AsyncHandle
Base classes
- class DataHandle
- class HandleHolder
Public static functions
Constructors, destructors, conversion operators
- AsyncHandle(DataHandle*, size_t = 1024*1024, size_t rounding = 64*1024)
- Contructor, taking ownership.
- AsyncHandle(DataHandle&, size_t = 1024*1024, size_t rounding = 64*1024)
- Contructor, not taking ownership.
- ~AsyncHandle() override
- Destructor.
Public functions
- auto openForRead() -> Length override
- void openForWrite(const Length&) override
- void openForAppend(const Length&) override
- auto read(void*, long) -> long override
- auto write(const void*, long) -> long override
- void close() override
- void flush() override
- void rewind() override
-
void print(std::
ostream&) const override - void skip(const Length&) override
- auto seek(const Offset&) -> Offset override
- auto estimate() -> Length override
- auto position() -> Offset override
- auto clone() const -> DataHandle* override
- auto size() -> Length virtual
- auto canSeek() const -> bool virtual
- void restartReadFrom(const Offset&) virtual
- void restartWriteFrom(const Offset&) virtual
- auto saveInto(DataHandle&, TransferWatcher& = TransferWatcher::dummy()) -> Length virtual
- Save into an other datahandle.
- auto saveInto(const PathName&, TransferWatcher& = TransferWatcher::dummy()) -> Length virtual
- Save into a file.
- auto copyTo(DataHandle&, long bufsize = -1, Length maxsize = -1, TransferWatcher& = TransferWatcher::dummy()) -> Length virtual
-
auto name() const -> std::
string virtual - auto openf(const char* mode, bool delete_on_close = false) -> FILE*
- Create a FILE* from this handle.
- auto openf(bool delete_on_close = false) -> FILE*
- auto compare(DataHandle&) -> bool
- Compare bytes.
- auto compress(bool = false) -> bool virtual
- auto merge(DataHandle*) -> bool virtual
- auto isEmpty() const -> bool virtual
- auto moveable() const -> bool virtual
- void toLocal(Stream& s) const virtual
- auto toLocal() -> DataHandle* virtual
- void toRemote(Stream& s) const virtual
- void selectMover(MoverTransferSelection&, bool read) const virtual
-
auto metricsTag() const -> std::
string virtual - void hash(MD5& md5) const virtual
- auto doubleBufferOK() const -> bool virtual
- void encode(Stream&) const override
- auto reanimator() const -> const ReanimatorBase& override
-
auto className() const -> std::
string virtual
Private functions
-
auto title() const -> std::
string override -
void collectMetrics(const std::
string& what) const override
Function documentation
static const ClassSpec& eckit:: AsyncHandle:: classSpec()
#include <eckit/io/DataHandle.h>
Length eckit:: AsyncHandle:: size() virtual
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: canSeek() const virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: restartReadFrom(const Offset&) virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: restartWriteFrom(const Offset&) virtual
#include <eckit/io/DataHandle.h>
Length eckit:: AsyncHandle:: saveInto(DataHandle&,
TransferWatcher& = TransferWatcher::dummy()) virtual
#include <eckit/io/DataHandle.h>
Save into an other datahandle.
Length eckit:: AsyncHandle:: saveInto(const PathName&,
TransferWatcher& = TransferWatcher::dummy()) virtual
#include <eckit/io/DataHandle.h>
Save into a file.
Length eckit:: AsyncHandle:: copyTo(DataHandle&,
long bufsize = -1,
Length maxsize = -1,
TransferWatcher& = TransferWatcher::dummy()) virtual
#include <eckit/io/DataHandle.h>
Quiet version of saveInto Does not support progess, restart and double buffering
std:: string eckit:: AsyncHandle:: name() const virtual
#include <eckit/io/DataHandle.h>
FILE* eckit:: AsyncHandle:: openf(const char* mode,
bool delete_on_close = false)
#include <eckit/io/DataHandle.h>
Create a FILE* from this handle.
FILE* eckit:: AsyncHandle:: openf(bool delete_on_close = false)
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: compare(DataHandle&)
#include <eckit/io/DataHandle.h>
Compare bytes.
bool eckit:: AsyncHandle:: compress(bool = false) virtual
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: merge(DataHandle*) virtual
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: isEmpty() const virtual
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: moveable() const virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: toLocal(Stream& s) const virtual
#include <eckit/io/DataHandle.h>
DataHandle* eckit:: AsyncHandle:: toLocal() virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: toRemote(Stream& s) const virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: selectMover(MoverTransferSelection&,
bool read) const virtual
#include <eckit/io/DataHandle.h>
std:: string eckit:: AsyncHandle:: metricsTag() const virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: hash(MD5& md5) const virtual
#include <eckit/io/DataHandle.h>
bool eckit:: AsyncHandle:: doubleBufferOK() const virtual
#include <eckit/io/DataHandle.h>
void eckit:: AsyncHandle:: encode(Stream&) const override
#include <eckit/io/DataHandle.h>
const ReanimatorBase& eckit:: AsyncHandle:: reanimator() const override
#include <eckit/io/DataHandle.h>
std:: string eckit:: AsyncHandle:: className() const virtual
#include <eckit/serialisation/Streamable.h>