Go to the documentation of this file.
19 #ifndef __XRD_CL_POST_CHANNEL_HH__
20 #define __XRD_CL_POST_CHANNEL_HH__
41 class VirtualRedirector;
42 class TickGeneratorTask;
65 const URL &prefurl =
URL() );
201 #endif // __XRD_CL_POST_CHANNEL_HH__
Status ForceDisconnect()
Force disconnect of all streams.
Message status handler.
Definition: XrdClPostMasterInterfaces.hh:185
Definition: XrdSysPthread.hh:165
Status Receive(Message *&msg, MessageFilter *filter, time_t expires)
Status Receive(IncomingMsgHandler *handler, time_t expires)
Interface for socket pollers.
Definition: XrdClPoller.hh:87
const URL & GetURL() const
Get the URL.
Definition: XrdClChannel.hh:75
A synchronized queue.
Definition: XrdClJobManager.hh:51
TickGeneratorTask * pTickGenerator
Definition: XrdClChannel.hh:196
Channel(const URL &url, Poller *poller, TransportHandler *transport, TaskManager *taskManager, JobManager *jobManager, const URL &prefurl=URL())
The message representation used throughout the system.
Definition: XrdClMessage.hh:30
Status QueryTransport(uint16_t query, AnyObject &result)
Request status.
Definition: XrdClXRootDResponses.hh:219
TransportHandler * pTransport
Definition: XrdClChannel.hh:190
XrdSysMutex pMutex
Definition: XrdClChannel.hh:193
XRootDStatus Send(Message *msg, bool stateful, time_t expires)
void Tick(time_t now)
Handle a time event.
Definition: XrdClTaskManager.hh:76
A synchronize queue for incoming data.
Definition: XrdClInQueue.hh:36
Message filter.
Definition: XrdClPostMasterInterfaces.hh:50
JobManager * pJobManager
Definition: XrdClChannel.hh:197
Message handler.
Definition: XrdClPostMasterInterfaces.hh:72
void RegisterEventHandler(ChannelEventHandler *handler)
Register channel event handler.
URL pUrl
Definition: XrdClChannel.hh:188
A communication channel between the client and the server.
Definition: XrdClChannel.hh:49
InQueue pIncoming
Definition: XrdClChannel.hh:195
void DecFileInstCnt()
Decrement file object instance count bound to this channel.
uint16_t NbConnectedStrm()
Get the number of connected data streams.
XRootDStatus Send(Message *msg, OutgoingMsgHandler *handler, bool stateful, time_t expires)
Definition: XrdClAnyObject.hh:26
void RemoveEventHandler(ChannelEventHandler *handler)
Remove a channel event handler.
void SetOnDataConnectHandler(std::shared_ptr< Job > &onConnJob)
Set the on-connect handler for data streams.
AnyObject pChannelData
Definition: XrdClChannel.hh:194
Stream * pStream
Definition: XrdClChannel.hh:192
Procedure execution status.
Definition: XrdClStatus.hh:113
URL representation.
Definition: XrdClURL.hh:31
TaskManager * pTaskManager
Definition: XrdClChannel.hh:191
Channel event handler.
Definition: XrdClPostMasterInterfaces.hh:237
Perform the handshake and the authentication for each physical stream.
Definition: XrdClPostMasterInterfaces.hh:317
Definition: XrdClAnyObject.hh:33
Stream.
Definition: XrdClStream.hh:49
Poller * pPoller
Definition: XrdClChannel.hh:189
bool CanCollapse(const URL &url)