19 #ifndef __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
20 #define __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
49 uint16_t subStreamNum,
286 #endif // __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
Definition: XrdClAnyObject.hh:32
Interface.
Definition: XrdClPoller.hh:33
AsyncSocketHandler(const URL &url, Poller *poller, TransportHandler *transport, AnyObject *channelData, uint16_t subStreamNum, Stream *strm)
Constructor.
Interface for socket pollers.
Definition: XrdClPoller.hh:86
virtual void Event(uint8_t type, XrdCl::Socket *)
Handle a socket event.
Message * pOutgoing
Definition: XrdClAsyncSocketHandler.hh:262
bool pHandShakeDone
Definition: XrdClAsyncSocketHandler.hh:266
The message representation used throughout the system.
Definition: XrdClMessage.hh:29
time_t GetLastActivity()
Get timestamp of last registered socket activity.
Definition: XrdClAsyncSocketHandler.hh:119
bool pHeaderDone
Definition: XrdClAsyncSocketHandler.hh:270
bool pTlsHandShakeOngoing
Definition: XrdClAsyncSocketHandler.hh:281
XRootDStatus Close()
Close the connection.
std::unique_ptr< MsgWriter > hswriter
Definition: XrdClAsyncSocketHandler.hh:282
AnyObject * pChannelData
Definition: XrdClAsyncSocketHandler.hh:255
Message handler.
Definition: XrdClPostMasterInterfaces.hh:49
virtual void OnConnectionReturn()
uint16_t pSubStreamNum
Definition: XrdClAsyncSocketHandler.hh:256
const XrdNetAddr & GetAddress() const
Get the address that the socket is connected to.
Definition: XrdClAsyncSocketHandler.hh:68
time_t pConnectionStarted
Definition: XrdClAsyncSocketHandler.hh:268
URL pUrl
Definition: XrdClAsyncSocketHandler.hh:280
Definition: XrdNetAddr.hh:41
XRootDStatus DisableUplink()
Disable uplink.
Definition: XrdClAsyncSocketHandler.hh:101
bool pOutMsgDone
Definition: XrdClAsyncSocketHandler.hh:273
void OnFault(XRootDStatus st)
time_t pHSWaitSeconds
Definition: XrdClAsyncSocketHandler.hh:279
void OnFaultWhileHandshaking(XRootDStatus st)
Data structure that carries the handshake information.
Definition: XrdClPostMasterInterfaces.hh:245
uint32_t pOutMsgSize
Definition: XrdClAsyncSocketHandler.hh:276
Perform the handshake and the authentication for each physical stream.
Definition: XrdClPostMasterInterfaces.hh:290
MsgHandler * pOutHandler
Definition: XrdClAsyncSocketHandler.hh:274
const uint16_t stFatal
Fatal error, it's still an error.
Definition: XrdClStatus.hh:33
XRootDStatus WriteCurrentMessage(Message *toWrite)
time_t pHSWaitStarted
Definition: XrdClAsyncSocketHandler.hh:278
Request status.
Definition: XrdClXRootDResponses.hh:218
Socket * pSocket
Definition: XrdClAsyncSocketHandler.hh:259
Poller * pPoller
Definition: XrdClAsyncSocketHandler.hh:253
XRootDStatus ReadMessage(Message *&toRead)
static std::string ToStreamName(Stream *stream, uint16_t strmnb)
Convert Stream object and sub-stream number to stream name.
const std::string & GetStreamName()
Get stream name.
Definition: XrdClAsyncSocketHandler.hh:111
TransportHandler * pTransport
Definition: XrdClAsyncSocketHandler.hh:254
void OnWriteWhileHandshaking()
XrdNetAddr pSockAddr
Definition: XrdClAsyncSocketHandler.hh:264
void OnTimeoutWhileHandshaking()
const uint16_t errPollerError
Definition: XrdClStatus.hh:75
std::pair< MsgHandler *, bool > pIncHandler
Definition: XrdClAsyncSocketHandler.hh:272
void OnHeaderCorruption()
URL representation.
Definition: XrdClURL.hh:30
XRootDStatus DoTlsHandShake()
~AsyncSocketHandler()
Destructor.
time_t pLastActivity
Definition: XrdClAsyncSocketHandler.hh:277
time_t pConnectionTimeout
Definition: XrdClAsyncSocketHandler.hh:269
int kXR_int32
Definition: XPtypes.hh:89
XRootDStatus Connect(time_t timeout)
Connect to the currently set address.
Stream.
Definition: XrdClStream.hh:48
Message * pIncoming
Definition: XrdClAsyncSocketHandler.hh:260
std::string pStreamName
Definition: XrdClAsyncSocketHandler.hh:258
void OnReadWhileHandshaking()
kXR_int32 HandleWaitRsp(Message *rsp)
Message * pHSIncoming
Definition: XrdClAsyncSocketHandler.hh:261
uint32_t pIncMsgSize
Definition: XrdClAsyncSocketHandler.hh:275
void HandShakeNextStep(bool done)
A network socket.
Definition: XrdClSocket.hh:41
XRootDStatus WriteMessageAndRaw(Message *toWrite, Message *&sign)
Definition: XrdClAsyncSocketHandler.hh:39
virtual bool EnableWriteNotification(Socket *socket, bool notify, uint16_t timeout=60)=0
uint16_t pTimeoutResolution
Definition: XrdClAsyncSocketHandler.hh:267
Message * pSignature
Definition: XrdClAsyncSocketHandler.hh:263
void SetAddress(const XrdNetAddr &address)
Set address.
Definition: XrdClAsyncSocketHandler.hh:60
Stream * pStream
Definition: XrdClAsyncSocketHandler.hh:257
HandShakeData * pHandShakeData
Definition: XrdClAsyncSocketHandler.hh:265
XRootDStatus EnableUplink()
Enable uplink.
Definition: XrdClAsyncSocketHandler.hh:91