xrootd
|
Utility class encapsulating writing hand-shake request logic. More...
#include <XrdClAsyncHSWriter.hh>
Public Member Functions | |
AsyncHSWriter (Socket &socket, const std::string &strmname) | |
void | Reset (Message *msg=nullptr) |
Reset the state of the object (makes it ready to read out next msg) | |
void | Replay () |
Replay the message that has been sent. | |
bool | HasMsg () |
Check if writer was assigned with a message. | |
XRootDStatus | Write () |
Write the request into the socket. | |
Private Types | |
enum | Stage { WriteRequest , WriteDone } |
Stages of reading out a response from the socket. More... | |
Private Attributes | |
Stage | writestage |
Socket & | socket |
const std::string & | strmname |
std::unique_ptr< Message > | outmsg |
Utility class encapsulating writing hand-shake request logic.
|
private |
|
inline |
Constructor
socket | : the socket with the message to be read out |
strmname | : stream name |
|
inline |
Check if writer was assigned with a message.
References outmsg.
|
inline |
Replay the message that has been sent.
References outmsg, WriteRequest, and writestage.
|
inline |
Reset the state of the object (makes it ready to read out next msg)
References outmsg, WriteRequest, and writestage.
|
inline |
Write the request into the socket.
References XrdCl::AsyncSockMsg, XrdCl::Status::code, XrdCl::Status::errNo, XrdCl::Log::Error(), XrdCl::Socket::Flash(), XrdCl::DefaultEnv::GetLog(), XrdCl::Status::IsOK(), outmsg, XrdCl::Socket::Send(), socket, strmname, XrdCl::suRetry, WriteDone, WriteRequest, writestage, and XrdSysE2T().
|
private |
|
private |
Referenced by Write().