Go to the documentation of this file.
19 #ifndef __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
20 #define __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
55 virtual time_t
Run( time_t now )
73 uint16_t subStreamNum );
302 #endif // __XRD_CL_ASYNC_SOCKET_HANDLER_HH__
int kXR_int32
Definition: XPtypes.hh:89
std::string pStreamName
Definition: XrdClAsyncSocketHandler.hh:276
XRootDStatus WriteCurrentMessage(Message *toWrite)
A network socket.
Definition: XrdClSocket.hh:42
Message status handler.
Definition: XrdClPostMasterInterfaces.hh:185
HandShakeData * pHandShakeData
Definition: XrdClAsyncSocketHandler.hh:284
Message * pHSIncoming
Definition: XrdClAsyncSocketHandler.hh:279
const XrdNetAddr & GetAddress() const
Get the address that the socket is connected to.
Definition: XrdClAsyncSocketHandler.hh:91
void OnFaultWhileHandshaking(XRootDStatus st)
URL pUrl
Definition: XrdClAsyncSocketHandler.hh:297
void HandShakeNextStep(bool done)
Message * pHSOutgoing
Definition: XrdClAsyncSocketHandler.hh:282
void SetName(const std::string &name)
Set name of the task.
Definition: XrdClTaskManager.hh:60
XrdNetAddr pSockAddr
Definition: XrdClAsyncSocketHandler.hh:283
void OnTimeoutWhileHandshaking()
Interface for socket pollers.
Definition: XrdClPoller.hh:87
WaitTask(XrdCl::AsyncSocketHandler *handler)
Definition: XrdClAsyncSocketHandler.hh:47
time_t pLastActivity
Definition: XrdClAsyncSocketHandler.hh:296
const uint16_t stFatal
Fatal error, it's still an error.
Definition: XrdClStatus.hh:33
kXR_int32 HandleWaitRsp(Message *rsp)
AnyObject * pChannelData
Definition: XrdClAsyncSocketHandler.hh:273
The message representation used throughout the system.
Definition: XrdClMessage.hh:30
void OnWriteWhileHandshaking()
uint16_t pSubStreamNum
Definition: XrdClAsyncSocketHandler.hh:274
Interface.
Definition: XrdClPoller.hh:34
virtual time_t Run(time_t now)
Definition: XrdClAsyncSocketHandler.hh:55
Request status.
Definition: XrdClXRootDResponses.hh:215
bool pHeaderDone
Definition: XrdClAsyncSocketHandler.hh:289
Data structure that carries the handshake information.
Definition: XrdClPostMasterInterfaces.hh:272
time_t pConnectionTimeout
Definition: XrdClAsyncSocketHandler.hh:288
virtual bool EnableWriteNotification(Socket *socket, bool notify, uint16_t timeout=60)=0
void OnFault(XRootDStatus st)
virtual void OnConnectionReturn()
XRootDStatus ReadMessage(Message *&toRead)
uint32_t pIncMsgSize
Definition: XrdClAsyncSocketHandler.hh:294
Stream * pStream
Definition: XrdClAsyncSocketHandler.hh:275
Definition: XrdClAsyncSocketHandler.hh:45
time_t GetLastActivity()
Get timestamp of last registered socket activity.
Definition: XrdClAsyncSocketHandler.hh:147
uint32_t pOutMsgSize
Definition: XrdClAsyncSocketHandler.hh:295
void SetAddress(const XrdNetAddr &address)
Set address.
Definition: XrdClAsyncSocketHandler.hh:83
XRootDStatus EnableUplink()
Enable uplink.
Definition: XrdClAsyncSocketHandler.hh:119
OutgoingMsgHandler * pOutHandler
Definition: XrdClAsyncSocketHandler.hh:293
bool pTlsHandShakeOngoing
Definition: XrdClAsyncSocketHandler.hh:298
Message * pOutgoing
Definition: XrdClAsyncSocketHandler.hh:280
XRootDStatus Close()
Close the connection.
Definition: XrdClAsyncSocketHandler.hh:39
const std::string & GetStreamName()
Get stream name.
Definition: XrdClAsyncSocketHandler.hh:139
TransportHandler * pTransport
Definition: XrdClAsyncSocketHandler.hh:272
Socket * pSocket
Definition: XrdClAsyncSocketHandler.hh:277
std::pair< IncomingMsgHandler *, bool > pIncHandler
Definition: XrdClAsyncSocketHandler.hh:291
Definition: XrdClAnyObject.hh:26
~AsyncSocketHandler()
Destructor.
XRootDStatus Connect(time_t timeout)
Connect to the currently set address.
bool pOutMsgDone
Definition: XrdClAsyncSocketHandler.hh:292
const uint16_t errPollerError
Definition: XrdClStatus.hh:74
bool pHandShakeDone
Definition: XrdClAsyncSocketHandler.hh:285
virtual void Event(uint8_t type, XrdCl::Socket *)
Handle a socket event.
XRootDStatus DisableUplink()
Disable uplink.
Definition: XrdClAsyncSocketHandler.hh:129
void OnReadWhileHandshaking()
Message * pIncoming
Definition: XrdClAsyncSocketHandler.hh:278
URL representation.
Definition: XrdClURL.hh:31
Poller * pPoller
Definition: XrdClAsyncSocketHandler.hh:271
time_t pConnectionStarted
Definition: XrdClAsyncSocketHandler.hh:287
uint16_t pTimeoutResolution
Definition: XrdClAsyncSocketHandler.hh:286
void SetStream(Stream *stream)
Set a stream object to be notified about the status of the operations.
Message * out
Message to be sent out.
Definition: XrdClPostMasterInterfaces.hh:281
Message * pSignature
Definition: XrdClAsyncSocketHandler.hh:281
Interface for a task to be run by the TaskManager.
Definition: XrdClTaskManager.hh:36
void OnHeaderCorruption()
Perform the handshake and the authentication for each physical stream.
Definition: XrdClPostMasterInterfaces.hh:317
Definition: XrdNetAddr.hh:42
Definition: XrdClAnyObject.hh:33
AsyncSocketHandler(const URL &url, Poller *poller, TransportHandler *transport, AnyObject *channelData, uint16_t subStreamNum)
Constructor.
Stream.
Definition: XrdClStream.hh:49
XrdCl::AsyncSocketHandler * pHandler
Definition: XrdClAsyncSocketHandler.hh:62
XRootDStatus WriteMessageAndRaw(Message *toWrite, Message *&sign)
XRootDStatus DoTlsHandShake()