8 #ifndef SRC_XRDCL_XRDCLASYNCWRITER_HH_
9 #define SRC_XRDCL_XRDCLASYNCWRITER_HH_
26 const std::string &
streamName ) : socket( socket ),
27 streamName( streamName ),
95 size_t leftToBeWritten =
msg->GetSize()-
msg->GetCursor();
96 while( leftToBeWritten )
106 msg->AdvanceCursor( bytesWritten );
107 leftToBeWritten -= bytesWritten;
115 msg.get(),
msg->GetSize() );
120 std::unique_ptr<Message>
msg;
const uint16_t stOK
Everything went OK.
Definition: XrdClStatus.hh:31
Definition: XrdClAsyncWriter.hh:60
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
virtual Status WriteImpl()=0
Status WriteImpl()
Definition: XrdClAsyncWriter.hh:87
Definition: XrdClAsyncWriter.hh:123
const uint64_t AsyncSockMsg
Definition: XrdClConstants.hh:41
const uint16_t suDone
Definition: XrdClStatus.hh:38
uint16_t code
Error type, or additional hints on what to do.
Definition: XrdClStatus.hh:145
const uint16_t suPartial
Definition: XrdClStatus.hh:41
Socket & socket
Definition: XrdClAsyncWriter.hh:55
void Dump(uint64_t topic, const char *format,...)
Print a dump message.
Procedure execution status.
Definition: XrdClStatus.hh:112
Definition: XrdClAsyncWriter.hh:21
static Log * GetLog()
Get default log.
Status Write()
Definition: XrdClAsyncWriter.hh:36
Definition: XrdClAsyncWriter.hh:128
AsyncWriter(Socket &socket, const std::string &streamName)
Definition: XrdClAsyncWriter.hh:25
const uint16_t suAlreadyDone
Definition: XrdClStatus.hh:42
const uint16_t suNotStarted
Definition: XrdClStatus.hh:43
Request status.
Definition: XrdClXRootDResponses.hh:218
void Replay()
Definition: XrdClAsyncWriter.hh:80
bool HasMsg()
Definition: XrdClAsyncWriter.hh:69
std::unique_ptr< Message > msg
Definition: XrdClAsyncWriter.hh:120
std::string streamName
Definition: XrdClAsyncWriter.hh:56
const uint16_t suContinue
Definition: XrdClStatus.hh:39
Status status
Definition: XrdClAsyncWriter.hh:57
virtual ~AsyncWriter()
Definition: XrdClAsyncWriter.hh:32
MsgWriter(Socket &socket, const std::string &streamName)
Definition: XrdClAsyncWriter.hh:63
void Reset(Message *msg=nullptr)
Definition: XrdClAsyncWriter.hh:74
const uint16_t suRetry
Definition: XrdClStatus.hh:40
bool IsOK() const
We're fine.
Definition: XrdClStatus.hh:122
A network socket.
Definition: XrdClSocket.hh:41
Handle diagnostics.
Definition: XrdClLog.hh:100
XRootDStatus Send(const char *buffer, size_t size, int &bytesWritten)