|
xrootd
|
#include <XrdXrootdAdmin.hh>

Classes | |
| struct | JobTable |
| struct | usr |
Public Member Functions | |
| void | Login (int socknum) |
| void * | Start (XrdNetSocket *AdminSock) |
| XrdXrootdAdmin () | |
| ~XrdXrootdAdmin () | |
Static Public Member Functions | |
| static void | addJob (const char *jname, XrdXrootdJob *jp) |
| static int | Init (XrdSysError *erp, XrdNetSocket *asock) |
Private Member Functions | |
| int | do_Abort () |
| int | do_Cj () |
| int | do_Cont () |
| int | do_Disc () |
| int | do_Login () |
| int | do_Lsc () |
| int | do_Lsj () |
| int | do_Lsj_Xeq (XrdXrootdJob *jp) |
| int | do_Lsd () |
| int | do_Msg () |
| int | do_Pause () |
| int | do_Red () |
| char * | getMsg (char *msg, int &mlen) |
| int | getreqID () |
| int | getTarget (const char *act, char **rest=0) |
| int | sendErr (int rc, const char *act, const char *msg) |
| int | sendOK (int sent) |
| int | sendResp (const char *act, XActionCode anum) |
| int | sendResp (const char *act, XActionCode anum, const char *msg, int mlen) |
| void | Xeq () |
Private Attributes | |
| XrdOucStream | Stream |
| XrdLinkMatch | Target |
| struct XrdXrootdAdmin::usr | usResp |
| char | TraceID [24] |
| char | reqID [16] |
Static Private Attributes | |
| static JobTable * | JobList = 0 |
| static XrdSysError * | eDest |
| XrdXrootdAdmin::XrdXrootdAdmin | ( | ) | [inline] |
| XrdXrootdAdmin::~XrdXrootdAdmin | ( | ) | [inline] |
| void XrdXrootdAdmin::addJob | ( | const char * | jname, |
| XrdXrootdJob * | jp | ||
| ) | [static] |
References XrdXrootdAdmin::JobTable::Jname, XrdXrootdAdmin::JobTable::Job, XrdXrootdAdmin::JobTable::Next, and JobList.
Referenced by XrdXrootdProtocol::Configure().
| int XrdXrootdAdmin::do_Abort | ( | ) | [private] |
References getTarget(), getMsg(), sendResp(), and kXR_asyncab.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Cj | ( | ) | [private] |
References Stream, XrdOucStream::GetToken(), sendErr(), JobList, XrdXrootdAdmin::JobTable::Jname, XrdXrootdAdmin::JobTable::Next, XrdXrootdAdmin::JobTable::Job, reqID, XrdOucStream::Put(), and XrdXrootdJob::Cancel().
Referenced by Xeq().
| int XrdXrootdAdmin::do_Cont | ( | ) | [private] |
References getTarget(), sendResp(), and kXR_asyncgo.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Disc | ( | ) | [private] |
References getTarget(), Stream, XrdOucStream::GetToken(), sendErr(), sendResp(), and kXR_asyncdi.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Login | ( | ) | [private] |
References kXR_PROTOCOLVSTRING, Stream, XrdOucStream::GetToken(), eDest, XrdSysError::Emsg(), strlcpy(), TraceID, snprintf, reqID, and XrdOucStream::Put().
Referenced by Login().
| int XrdXrootdAdmin::do_Lsc | ( | ) | [private] |
References getTarget(), reqID, Stream, XrdOucStream::Put(), XrdLink::getName(), and Target.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Lsd | ( | ) | [private] |
References XrdSecPROTOIDSIZE, getTarget(), reqID, Stream, XrdOucStream::Put(), XrdLink::Find(), Target, XrdLink::getProtocol(), XrdXrootdProtocol::CapVer, XrdXrootdProtocol::Status, XRD_ADMINUSER, XrdLink::timeCon(), XrdXrootdProtocol::monFILE, XrdXrootdProtocol::monIO, XrdLink::getIOStats(), XrdLink::Client(), XrdXrootdProtocol::numFiles, XrdXrootdProtocol::totReadP, XrdXrootdProtocol::cumReadP, XrdXrootdProtocol::numReadP, XrdXrootdProtocol::cumWrites, XrdXrootdProtocol::numWrites, XrdXrootdProtocol::cumReads, XrdXrootdProtocol::numReads, XrdXrootdProtocol::Client, XrdXrootdProtocol::Entity, XrdSecEntity::prot, XrdSecEntity::name, XrdSecEntity::host, XrdSecEntity::vorg, XrdSecEntity::role, and XrdLink::setRef().
Referenced by Xeq().
| int XrdXrootdAdmin::do_Lsj | ( | ) | [private] |
References Stream, XrdOucStream::GetToken(), sendErr(), JobList, XrdXrootdAdmin::JobTable::Jname, XrdXrootdAdmin::JobTable::Next, XrdXrootdAdmin::JobTable::Job, reqID, XrdOucStream::Put(), and do_Lsj_Xeq().
Referenced by Xeq().
| int XrdXrootdAdmin::do_Lsj_Xeq | ( | XrdXrootdJob * | jp | ) | [private] |
References XrdXrootdJob::List(), Stream, XrdOucStream::Put(), XrdOucTList::text, XrdOucTList::val, and XrdOucTList::next.
Referenced by do_Lsj().
| int XrdXrootdAdmin::do_Msg | ( | ) | [private] |
References getTarget(), getMsg(), sendResp(), and kXR_asyncms.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Pause | ( | ) | [private] |
References getTarget(), Stream, XrdOucStream::GetToken(), sendErr(), sendResp(), and kXR_asyncwt.
Referenced by Xeq().
| int XrdXrootdAdmin::do_Red | ( | ) | [private] |
References XrdMonCtrCollector::port, getTarget(), Stream, XrdOucStream::GetToken(), sendErr(), index(), strlcpy(), sendResp(), and kXR_asyncrd.
Referenced by Xeq().
| char * XrdXrootdAdmin::getMsg | ( | char * | msg, |
| int & | mlen | ||
| ) | [private] |
Referenced by do_Abort(), and do_Msg().
| int XrdXrootdAdmin::getreqID | ( | ) | [private] |
| int XrdXrootdAdmin::getTarget | ( | const char * | act, |
| char ** | rest = 0 |
||
| ) | [private] |
References Stream, XrdOucStream::GetToken(), sendErr(), Target, and XrdLinkMatch::Set().
Referenced by do_Abort(), do_Cont(), do_Disc(), do_Lsc(), do_Lsd(), do_Msg(), do_Pause(), and do_Red().
| int XrdXrootdAdmin::Init | ( | XrdSysError * | erp, |
| XrdNetSocket * | asock | ||
| ) | [static] |
References eDest, XrdSysThread::Run(), XrdXrootdInitAdmin(), and XrdSysError::Emsg().
Referenced by XrdXrootdProtocol::Configure().
| void XrdXrootdAdmin::Login | ( | int | socknum | ) |
References Stream, XrdOucStream::SetEroute(), eDest, XrdOucStream::AttachIO(), XrdOucStream::GetLine(), XrdSysError::Emsg(), getreqID(), XrdOucStream::GetToken(), do_Login(), TraceID, and Xeq().
Referenced by XrdXrootdLoginAdmin().
| int XrdXrootdAdmin::sendErr | ( | int | rc, |
| const char * | act, | ||
| const char * | msg | ||
| ) | [private] |
References snprintf, reqID, Stream, and XrdOucStream::Put().
Referenced by do_Cj(), do_Disc(), do_Lsj(), do_Pause(), do_Red(), getreqID(), getTarget(), and Xeq().
| int XrdXrootdAdmin::sendOK | ( | int | sent | ) | [private] |
References snprintf, reqID, Stream, and XrdOucStream::Put().
Referenced by sendResp().
| int XrdXrootdAdmin::sendResp | ( | const char * | act, |
| XActionCode | anum | ||
| ) | [private] |
References usResp, XrdXrootdAdmin::usr::act, XrdXrootdAdmin::usr::len, XrdLink::Find(), Target, TRACE, XrdLink::ID, XrdLink::Send(), and sendOK().
Referenced by do_Abort(), do_Cont(), do_Disc(), do_Msg(), do_Pause(), and do_Red().
| int XrdXrootdAdmin::sendResp | ( | const char * | act, |
| XActionCode | anum, | ||
| const char * | msg, | ||
| int | mlen | ||
| ) | [private] |
References usResp, XrdXrootdAdmin::usr::act, XrdXrootdAdmin::usr::len, iovec::iov_base, iovec::iov_len, XrdLink::Find(), Target, TRACE, and sendOK().
| void * XrdXrootdAdmin::Start | ( | XrdNetSocket * | AdminSock | ) |
References XrdNetSocket::Accept(), XrdSysThread::Run(), XrdXrootdLoginAdmin(), eDest, XrdSysError::Emsg(), and close.
Referenced by XrdXrootdInitAdmin().
| void XrdXrootdAdmin::Xeq | ( | ) | [private] |
References Stream, XrdOucStream::GetLine(), TRACE, DEBUG, getreqID(), XrdOucStream::GetToken(), do_Abort(), do_Cj(), do_Cont(), do_Disc(), do_Lsc(), do_Lsd(), do_Lsj(), do_Msg(), do_Pause(), do_Red(), eDest, XrdSysError::Emsg(), sendErr(), and TraceID.
Referenced by Login().
XrdSysError * XrdXrootdAdmin::eDest [static, private] |
Referenced by Init(), Login(), Start(), do_Login(), and Xeq().
XrdXrootdAdmin::JobTable * XrdXrootdAdmin::JobList = 0 [static, private] |
char XrdXrootdAdmin::reqID[16] [private] |
Referenced by do_Cj(), do_Login(), do_Lsc(), do_Lsd(), do_Lsj(), getreqID(), sendErr(), and sendOK().
XrdOucStream XrdXrootdAdmin::Stream [private] |
Referenced by Login(), do_Cj(), do_Disc(), do_Login(), do_Lsc(), do_Lsd(), do_Lsj(), do_Lsj_Xeq(), do_Pause(), do_Red(), getreqID(), getTarget(), sendErr(), sendOK(), and Xeq().
XrdLinkMatch XrdXrootdAdmin::Target [private] |
Referenced by do_Lsc(), do_Lsd(), getTarget(), and sendResp().
char XrdXrootdAdmin::TraceID[24] [private] |
Referenced by Login(), do_Login(), and Xeq().
struct XrdXrootdAdmin::usr XrdXrootdAdmin::usResp [private] |
Referenced by sendResp().
1.7.5