XrdCl::PostMasterImpl Struct Reference

Collaboration diagram for XrdCl::PostMasterImpl:

Public Types
typedef std::map< std::string, std::shared_ptr< Channel > >	ChannelMap

Public Member Functions
	PostMasterImpl ()
	~PostMasterImpl ()
void	addFinalize (Channel *ch)
	Used to maintain a non-owning set of live Channels. Used by Finalize. More...
std::shared_ptr< Channel >	GetChannel (const URL &url)
	Get a channel for url, creating one if needed. More...
void	removeFinalize (Channel *ch)
	Used to maintain a non-owning set of live Channels. Used by Finalize. More...

Public Attributes
ChannelMap	pChannelMap
XrdSysMutex	pChannelMapMutex
std::unordered_set< Channel * >	pFinalizeSet
XrdSysMutex	pFinalizeSetMutex
bool	pInitialized
JobManager *	pJobManager
XrdSysMutex	pMtx
std::function< void(const URL &, const XRootDStatus &)>	pOnConnErrCB
std::unique_ptr< Job >	pOnConnJob
Poller *	pPoller
bool	pRunning
TaskManager *	pTaskManager

Detailed Description

Definition at line 60 of file XrdClPostMaster.cc.

Member Typedef Documentation

ChannelMap

typedef std::map<std::string, std::shared_ptr<Channel> > XrdCl::PostMasterImpl::ChannelMap

Definition at line 102 of file XrdClPostMaster.cc.

Constructor & Destructor Documentation

PostMasterImpl()

XrdCl::PostMasterImpl::PostMasterImpl ( )

inline

Definition at line 62 of file XrdClPostMaster.cc.

                     : pPoller( 0 ), pInitialized( false ), pRunning( false )
    {
      Env *env = DefaultEnv::GetEnv();
      int workerThreads = DefaultWorkerThreads;
      env->GetInt( "WorkerThreads", workerThreads );
 
      pTaskManager = new TaskManager();
      pJobManager  = new JobManager(workerThreads);
    }

References XrdCl::DefaultWorkerThreads, XrdCl::DefaultEnv::GetEnv(), XrdCl::Env::GetInt(), pJobManager, and pTaskManager.

Here is the call graph for this function:

~PostMasterImpl()

XrdCl::PostMasterImpl::~PostMasterImpl ( )

inline

Definition at line 72 of file XrdClPostMaster.cc.

    {
      delete pPoller;
      delete pTaskManager;
      delete pJobManager;
    }

References pJobManager, pPoller, and pTaskManager.

Member Function Documentation

addFinalize()

void XrdCl::PostMasterImpl::addFinalize ( Channel *  ch )

inline

Used to maintain a non-owning set of live Channels. Used by Finalize.

Definition at line 82 of file XrdClPostMaster.cc.

    {
      XrdSysMutexHelper lck( pFinalizeSetMutex );
      pFinalizeSet.insert( ch );
    }

References pFinalizeSet, and pFinalizeSetMutex.

Referenced by GetChannel().

Here is the caller graph for this function:

GetChannel()

std::shared_ptr< Channel > XrdCl::PostMasterImpl::GetChannel

(

const URL &

url

)

Get a channel for url, creating one if needed.

Definition at line 566 of file XrdClPostMaster.cc.

  {
    XrdSysMutexHelper scopedLock( pChannelMapMutex );
    std::shared_ptr<Channel> channel;
    PostMasterImpl::ChannelMap::iterator it = pChannelMap.find( url.GetChannelId() );
 
    if( it == pChannelMap.end() )
    {
      TransportManager *trManager = DefaultEnv::GetTransportManager();
      TransportHandler *trHandler = trManager->GetHandler( url.GetProtocol() );
 
      if( !trHandler )
      {
        Log *log = DefaultEnv::GetLog();
        log->Error( PostMasterMsg, "Unable to get transport handler for %s "
                    "protocol", url.GetProtocol().c_str() );
        return 0;
      }
 
      std::shared_ptr<Channel> newchan(new Channel{ url, pPoller,
        trHandler, pTaskManager, pJobManager },
        [this](Channel *ch) { this->removeFinalize( ch ); delete ch; });
      addFinalize( newchan.get() );
      channel = newchan;
      channel->SetSelf( channel );
 
      pChannelMap[url.GetChannelId()] = channel;
    }
    else
      channel = it->second;
    return channel;
  }

References addFinalize(), XrdCl::Log::Error(), XrdCl::URL::GetChannelId(), XrdCl::TransportManager::GetHandler(), XrdCl::DefaultEnv::GetLog(), XrdCl::URL::GetProtocol(), XrdCl::DefaultEnv::GetTransportManager(), pChannelMap, pChannelMapMutex, pJobManager, XrdCl::PostMasterMsg, pPoller, pTaskManager, and removeFinalize().

Here is the call graph for this function:

removeFinalize()

void XrdCl::PostMasterImpl::removeFinalize ( Channel *  ch )

inline

Used to maintain a non-owning set of live Channels. Used by Finalize.

Definition at line 96 of file XrdClPostMaster.cc.

    {
      XrdSysMutexHelper lck( pFinalizeSetMutex );
      pFinalizeSet.erase( ch );
    }

References pFinalizeSet, and pFinalizeSetMutex.

Referenced by GetChannel().

Here is the caller graph for this function:

Member Data Documentation

pChannelMap

ChannelMap XrdCl::PostMasterImpl::pChannelMap

Definition at line 106 of file XrdClPostMaster.cc.

Referenced by GetChannel().

pChannelMapMutex

XrdSysMutex XrdCl::PostMasterImpl::pChannelMapMutex

Definition at line 110 of file XrdClPostMaster.cc.

Referenced by GetChannel().

pFinalizeSet

std::unordered_set<Channel*> XrdCl::PostMasterImpl::pFinalizeSet

Definition at line 107 of file XrdClPostMaster.cc.

Referenced by addFinalize(), and removeFinalize().

pFinalizeSetMutex

XrdSysMutex XrdCl::PostMasterImpl::pFinalizeSetMutex

Definition at line 113 of file XrdClPostMaster.cc.

Referenced by addFinalize(), and removeFinalize().

pInitialized

bool XrdCl::PostMasterImpl::pInitialized

Definition at line 115 of file XrdClPostMaster.cc.

pJobManager

JobManager* XrdCl::PostMasterImpl::pJobManager

Definition at line 117 of file XrdClPostMaster.cc.

Referenced by PostMasterImpl(), ~PostMasterImpl(), and GetChannel().

pMtx

XrdSysMutex XrdCl::PostMasterImpl::pMtx

Definition at line 119 of file XrdClPostMaster.cc.

pOnConnErrCB

std::function<void( const URL&, const XRootDStatus& )> XrdCl::PostMasterImpl::pOnConnErrCB

Definition at line 121 of file XrdClPostMaster.cc.

pOnConnJob

std::unique_ptr<Job> XrdCl::PostMasterImpl::pOnConnJob

Definition at line 120 of file XrdClPostMaster.cc.

pPoller

Poller* XrdCl::PostMasterImpl::pPoller

Definition at line 104 of file XrdClPostMaster.cc.

Referenced by ~PostMasterImpl(), and GetChannel().

pRunning

bool XrdCl::PostMasterImpl::pRunning

Definition at line 116 of file XrdClPostMaster.cc.

pTaskManager

TaskManager* XrdCl::PostMasterImpl::pTaskManager

Definition at line 105 of file XrdClPostMaster.cc.

Referenced by PostMasterImpl(), ~PostMasterImpl(), and GetChannel().

---

The documentation for this struct was generated from the following file:

• XrdClPostMaster.cc