xrootd
|
#include <XrdCmsAdmin.hh>
Public Member Functions | |
void | Login (int socknum) |
void * | Notes (XrdNetSocket *AdminSock) |
void | Send (const char *Req, XrdCmsRRData &Data) |
void * | Start (XrdNetSocket *AdminSock) |
XrdCmsAdmin () | |
~XrdCmsAdmin () | |
Static Public Member Functions | |
static void | setSync (XrdSysSemaphore *sync) |
static void | Relay (int setSock, int newSock) |
Private Member Functions | |
int | do_Login () |
void | do_RmDid (int dotrim=0) |
void | do_RmDud (int dotrim=0) |
Private Attributes | |
XrdOucStream | Stream |
const char * | Stype |
char * | Sname |
int | Primary |
Static Private Attributes | |
static XrdSysMutex | myMutex |
static XrdSysSemaphore * | SyncUp = 0 |
static int | POnline = 0 |
XrdCmsAdmin::~XrdCmsAdmin | ( | ) | [inline] |
References Sname.
int XrdCmsAdmin::do_Login | ( | ) | [private] |
void XrdCmsAdmin::do_RmDid | ( | int | dotrim = 0 | ) | [private] |
References XrdCms::Config, DEBUG, XrdSysError::Emsg(), XrdCmsPrepare::Gone(), XrdCmsManager::Inform(), XrdCmsPrepare::isOK(), XrdCms::kYR_gone, XrdCms::kYR_raw, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), XrdCms::Manager, XrdOucName2Name::pfn2lfn(), XrdCms::PrepQ, XrdCms::Say, and XrdCmsMAX_PATH_LEN.
void XrdCmsAdmin::do_RmDud | ( | int | dotrim = 0 | ) | [private] |
void XrdCmsAdmin::Login | ( | int | socknum | ) |
References XrdCmsState::Active, XrdCms::CmsState, DEBUG, XrdSysError::Emsg(), XrdCmsState::FrontEnd, XrdCms::Say, and XrdCmsState::Update().
Referenced by XrdCmsAdminLogin().
void * XrdCmsAdmin::Notes | ( | XrdNetSocket * | AdminSock | ) |
References XrdCms::CmsState, DEBUG, XrdNetSocket::Detach(), XrdSysError::Emsg(), XrdCms::Say, XrdCmsState::Stage, and XrdCmsState::Update().
Referenced by XrdCmsStartAnote().
void XrdCmsAdmin::Relay | ( | int | setSock, |
int | newSock | ||
) | [static] |
References close, XrdCms::AdminReq::Data, DEBUG, XrdCms::AdminReq::Dlen, XrdSysError::Emsg(), XrdCms::AdminReq::getReq(), XrdCms::AdminReq::Hdr, XrdSysMutex::Lock(), XrdCms::AdminReq::Path, XrdSysSemaphore::Post(), XrdCms::AdminReq::Req, XrdCms::AdminReq::Requeue(), XrdCms::Say, XrdNetSocket::setOpts(), XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), and write().
Referenced by XrdCmsAdminSend().
void XrdCmsAdmin::Send | ( | const char * | Req, |
XrdCmsRRData & | Data | ||
) |
References XrdSysError::Emsg(), XrdCms::AdminReq::maxinQ, XrdCms::AdminReq::numinQ, XrdCmsRRData::Path, and XrdCms::Say.
static void XrdCmsAdmin::setSync | ( | XrdSysSemaphore * | sync | ) | [inline, static] |
References SyncUp.
Referenced by XrdCmsConfig::DoIt().
void * XrdCmsAdmin::Start | ( | XrdNetSocket * | AdminSock | ) |
References XrdNetSocket::Accept(), close, XrdCms::Config, XrdCmsConfig::doWait, XrdSysError::Emsg(), XrdSysThread::Run(), XrdCms::Say, XrdNetSocket::setOpts(), XrdCmsAdminLogin(), and XrdCmsAdminSend().
Referenced by XrdCmsStartAdmin().
XrdSysMutex XrdCmsAdmin::myMutex [static, private] |
int XrdCmsAdmin::POnline = 0 [static, private] |
int XrdCmsAdmin::Primary [private] |
Referenced by XrdCmsAdmin().
char* XrdCmsAdmin::Sname [private] |
Referenced by XrdCmsAdmin(), and ~XrdCmsAdmin().
XrdOucStream XrdCmsAdmin::Stream [private] |
const char* XrdCmsAdmin::Stype [private] |
Referenced by XrdCmsAdmin().
XrdSysSemaphore * XrdCmsAdmin::SyncUp = 0 [static, private] |
Referenced by setSync().