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