![]() |
XRootD
|
#include <XrdEcStrmWriter.hh>
Public Member Functions | |
StrmWriter (const ObjCfg &objcfg) | |
Constructor. More... | |
virtual | ~StrmWriter () |
Destructor. More... | |
void | Close (XrdCl::ResponseHandler *handler, uint16_t timeout=0) |
uint64_t | GetSize () |
void | Open (XrdCl::ResponseHandler *handler, uint16_t timeout=0) |
void | Write (uint32_t size, const void *buff, XrdCl::ResponseHandler *handler) |
The Stream Writer objects, responsible for writing erasure coded data into selected placement group.
Definition at line 52 of file XrdEcStrmWriter.hh.
|
inline |
Constructor.
Definition at line 64 of file XrdEcStrmWriter.hh.
|
inlinevirtual |
Destructor.
Definition at line 75 of file XrdEcStrmWriter.hh.
References XrdEc::sync_queue< Element >::interrupt().
void XrdEc::StrmWriter::Close | ( | XrdCl::ResponseHandler * | handler, |
uint16_t | timeout = 0 |
||
) |
Close the data object
handler | : user callback |
Definition at line 108 of file XrdEcStrmWriter.cc.
References XrdCl::Status::IsOK(), and XrdEc::ScheduleHandler().
|
inline |
Definition at line 108 of file XrdEcStrmWriter.hh.
void XrdEc::StrmWriter::Open | ( | XrdCl::ResponseHandler * | handler, |
uint16_t | timeout = 0 |
||
) |
Open the data object for writting
handler | : user callback |
Definition at line 44 of file XrdEcStrmWriter.cc.
References XrdCl::Async(), XrdEc::Config::enable_plugins, XrdEc::ObjCfg::GetDataUrl(), XrdEc::Config::Instance(), XrdEc::ObjCfg::nbchunks, XrdCl::OpenFlags::New, XrdCl::OpenArchive(), XrdCl::Parallel(), XrdEc::ObjCfg::plgr, and XrdCl::OpenFlags::Write.
void XrdEc::StrmWriter::Write | ( | uint32_t | size, |
const void * | buff, | ||
XrdCl::ResponseHandler * | handler | ||
) |
Write data to the data object
size | : number of bytes to be written |
buff | : buffer with data to be written |
handler | : user callback |
Definition at line 73 of file XrdEcStrmWriter.cc.
References XrdCl::Status::IsOK(), and XrdEc::ScheduleHandler().