![]() |
XRootD
|
#include <XrdOfsChkPnt.hh>
Public Member Functions | |
XrdOfsChkPnt (XrdOssDF &ossfl, const char *lfn, const char *ckpfn=0) | |
virtual | ~XrdOfsChkPnt () |
int | Create () |
int | Delete () |
void | Finished () |
int | Query (struct iov &range) |
int | Restore (bool *readok=0) |
int | Truncate (struct iov *&range) |
int | Write (struct iov *&range, int rnum) |
![]() | |
XrdOucChkPnt () | |
Constructor and destructor. More... | |
virtual | ~XrdOucChkPnt () |
Definition at line 43 of file XrdOfsChkPnt.hh.
|
inline |
Constructor and destructor.
ossfl | - reference to the Oss File Object for the source file. |
lfn | - pointer to the source file path. |
ckpfn | - pointer to optional prexisting checkpoint file. |
Definition at line 122 of file XrdOfsChkPnt.hh.
|
inlinevirtual |
Definition at line 126 of file XrdOfsChkPnt.hh.
|
virtual |
Create a checkpoint.
Implements XrdOucChkPnt.
Definition at line 81 of file XrdOfsChkPnt.cc.
References XrdOfsCPFile::Create(), XrdSysError::Emsg(), XrdOfsCPFile::FName(), XrdOssDF::Fstat(), XrdOfsCPFile::isActive(), OfsEroute, Stat, and stat().
|
virtual |
Delete a checkpoint.
Implements XrdOucChkPnt.
Definition at line 110 of file XrdOfsChkPnt.cc.
References XrdOfsCPFile::Destroy(), XrdSysError::Emsg(), XrdOfsCPFile::FName(), XrdOfsCPFile::isActive(), and OfsEroute.
Referenced by Restore().
|
inlinevirtual |
Indicate that the checkpointing is finished. Any outstanding checkpoint should be delete and the object should delete itself if necessary.
Implements XrdOucChkPnt.
Definition at line 68 of file XrdOfsChkPnt.hh.
|
virtual |
Query checkpoint limits.
range | - reference to where limits are placed. range.length - holds maximum checkpoint length allowed. |
Implements XrdOucChkPnt.
Definition at line 169 of file XrdOfsChkPnt.cc.
References XrdOfsConfigCP::MaxSZ, XrdOucIOVec::offset, and XrdOucIOVec::size.
|
virtual |
Restore a checkpoint.
readok | - When not nil and an error occurs readok is set true if read access is still allowed; otherwise no access should be allowed. |
Implements XrdOucChkPnt.
Definition at line 180 of file XrdOfsChkPnt.cc.
References XrdOfsCPFile::rInfo::DataLen, XrdOfsCPFile::rInfo::DataNum, XrdOfsCPFile::rInfo::DataVec, Delete(), XrdSysError::Emsg(), eMsg, ENODATA, XrdOssDF::Fctl(), XrdOssDF::Fctl_utimes, XrdOfsCPFile::FName(), XrdOfsCPFile::rInfo::fSize, XrdOssDF::Fsync(), XrdOssDF::Ftruncate(), XrdOfsCPFile::isActive(), XrdOfsCPFile::rInfo::mTime, OfsEroute, XrdOssDF::Open(), XrdOfsCPFile::RestoreInfo(), XrdOfsCPFile::rInfo::srcLFN, and XrdOssDF::WriteV().
|
virtual |
Truncate a file to a specific size.
range | - reference to the file truncate size in offset. |
Implements XrdOucChkPnt.
Definition at line 257 of file XrdOfsChkPnt.cc.
References XrdOfsCPFile::Append(), XrdOfsCPFile::isActive(), XrdOfsConfigCP::MaxSZ, XrdOucIOVec::offset, XrdOssDF::Read(), XrdOfsCPFile::Reserve(), and XrdOfsCPFile::Sync().
|
virtual |
Write data to a checkpointed file.
range | - reference to the file pieces to write. |
rnum | - number of elements in "range". |
Implements XrdOucChkPnt.
Definition at line 307 of file XrdOfsChkPnt.cc.
References XrdOfsCPFile::Append(), XrdOucIOVec::info, XrdOfsCPFile::isActive(), XrdOfsConfigCP::MaxSZ, XrdOucIOVec::offset, XrdOssDF::Read(), XrdOfsCPFile::Reserve(), XrdOucIOVec::size, and XrdOfsCPFile::Sync().