#include <XrdFrmPstg.hh>
Public Member Functions | |
| int | Agent (char *c2sFN) |
| int | Server (int udpFD) |
| void | Server_Driver (int PushIt) |
| void | Server_Stage () |
| XrdFrmPstg () | |
| ~XrdFrmPstg () | |
Private Member Functions | |
| void | Agent_Add (XrdOucStream &Request, char *Tok) |
| void | Agent_Del (XrdOucStream &Request, char *Tok) |
| void | Agent_Lst (XrdOucStream &Request, char *Tok) |
| XrdFrmPstg::XrdFrmPstg | ( | ) | [inline] |
| XrdFrmPstg::~XrdFrmPstg | ( | ) | [inline] |
| int XrdFrmPstg::Agent | ( | char * | c2sFN | ) |
References Agent_Add(), Agent_Del(), Agent_Lst(), XrdOucStream::Attach(), DEBUG, EPNAME, XrdOucStream::GetLine(), XrdOucStream::GetToken(), Say, XrdNetMsg::Send(), stat(), and STDIN_FILENO.
Referenced by main().
| void XrdFrmPstg::Agent_Add | ( | XrdOucStream & | Request, | |
| char * | Tok | |||
| ) | [private] |
References XrdFrmPstgReq::Add(), XrdFrmPstgReq::Request::addTOD, XrdCms::Config, XrdOucStream::GetToken(), XrdFrmPstgReq::Request::ID, index(), XrdFrmPstgReq::Request::LFN, XrdFrmPstgReq::maxPrty, XrdFrmPstgReq::msgFail, XrdFrmPstgReq::msgSucc, XrdCmsConfig::myProg, XrdFrmPstgReq::Request::Notify, XrdFrmPstgReq::Request::Opaque, XrdFrmPstgReq::Request::Options, XrdFrmPstgReq::Request::Prty, XrdFrm::rQueue, Say, XrdFrmPstgReq::stgRW, strlcpy(), and XrdFrmPstgReq::Request::User.
| void XrdFrmPstg::Agent_Del | ( | XrdOucStream & | Request, | |
| char * | Tok | |||
| ) | [private] |
References XrdOucStream::GetToken(), XrdFrmPstgReq::Request::ID, XrdFrmPstgReq::maxPrty, XrdFrm::rQueue, Say, and strlcpy().
| void XrdFrmPstg::Agent_Lst | ( | XrdOucStream & | Request, | |
| char * | Tok | |||
| ) | [private] |
References XrdFrmPstgReq::getLFN, XrdFrmPstgReq::getLFNCGI, XrdFrmPstgReq::getMODE, XrdFrmPstgReq::getNOTE, XrdFrmPstgReq::getPRTY, XrdFrmPstgReq::getQWT, XrdFrmPstgReq::getRID, XrdFrmPstgReq::getTOD, XrdOucStream::GetToken(), XrdFrmPstgReq::getUSER, XrdFrmPstgReq::maxPrty, and XrdFrm::rQueue.
Referenced by Agent().
| int XrdFrmPstg::Server | ( | int | udpFD | ) |
References Agent_Add(), Agent_Del(), XrdOucStream::Attach(), DEBUG, EPNAME, XrdOucStream::GetLine(), XrdOucStream::GetToken(), Say, and Server_Driver().
Referenced by mainServer().
| void XrdFrmPstg::Server_Driver | ( | int | PushIt | ) |
References XrdSysMutex::Lock(), XrdSysSemaphore::Post(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().
Referenced by main(), Server(), and Server_Stage().
| void XrdFrmPstg::Server_Stage | ( | ) |
References XrdFrmPstgReq::maxPrty, XrdFrmPstgXfr::Queue(), XrdFrm::rQueue, and Server_Driver().
Referenced by mainStage().
1.7.1