19#ifndef __XRD_CL_POLLER_BUILT_IN_HH__
20#define __XRD_CL_POLLER_BUILT_IN_HH__
95 uint16_t timeout = 60 );
107 uint16_t timeout = 60);
150 typedef std::map<const AnyObject *, std::pair<XrdSys::IOEvents::Poller *, size_t> >
PollerMap;
A poller implementation using the build-in XRootD poller.
Definition XrdClPollerBuiltIn.hh:41
XrdSys::IOEvents::Poller * RegisterAndGetPoller(const Socket *socket)
Registers given socket as a poller user and returns the poller object.
SocketMap pSocketMap
Definition XrdClPollerBuiltIn.hh:155
~PollerBuiltIn()
Definition XrdClPollerBuiltIn.hh:48
virtual bool IsRegistered(Socket *socket)
Check whether the socket is registered with the poller.
virtual bool RemoveSocket(Socket *socket)
Remove the socket.
XrdSys::IOEvents::Poller * GetNextPoller()
Goes over poller threads in round robin fashion.
virtual bool Stop()
Stop polling.
std::map< Socket *, void * > SocketMap
Definition XrdClPollerBuiltIn.hh:152
XrdSysMutex pMutex
Definition XrdClPollerBuiltIn.hh:160
void UnregisterFromPoller(const Socket *socket)
Unregisters given socket from poller object.
PollerMap pPollerMap
Definition XrdClPollerBuiltIn.hh:156
virtual bool Finalize()
Finalize the poller.
virtual bool Initialize()
Initialize the poller.
const int pNbPoller
Definition XrdClPollerBuiltIn.hh:159
virtual bool EnableReadNotification(Socket *socket, bool notify, uint16_t timeout=60)
virtual bool EnableWriteNotification(Socket *socket, bool notify, uint16_t timeout=60)
PollerBuiltIn()
Constructor.
Definition XrdClPollerBuiltIn.hh:46
XrdSys::IOEvents::Poller * GetPoller(const Socket *socket)
Returns the poller object associated with the given socket.
PollerPool pPollerPool
Definition XrdClPollerBuiltIn.hh:157
std::vector< XrdSys::IOEvents::Poller * > PollerPool
Definition XrdClPollerBuiltIn.hh:153
PollerPool::iterator pNext
Definition XrdClPollerBuiltIn.hh:158
std::map< const AnyObject *, std::pair< XrdSys::IOEvents::Poller *, size_t > > PollerMap
Definition XrdClPollerBuiltIn.hh:150
virtual bool IsRunning() const
Is the event loop running?
Definition XrdClPollerBuiltIn.hh:117
static int GetNbPollerInit()
Gets the initial value for 'pNbPoller'.
virtual bool AddSocket(Socket *socket, SocketHandler *handler)
virtual bool Start()
Start polling.
Interface for socket pollers.
Definition XrdClPoller.hh:87
Interface.
Definition XrdClPoller.hh:34
A network socket.
Definition XrdClSocket.hh:43
Definition XrdSysPthread.hh:165
Definition XrdSysIOEvents.hh:372
Definition XrdClAction.hh:34
Definition XrdClPollerBuiltIn.hh:28