#include <XrdFrmXfrAgent.hh>
Definition at line 38 of file XrdFrmXfrAgent.hh.
◆ XrdFrmXfrAgent()
XrdFrmXfrAgent::XrdFrmXfrAgent |
( |
| ) |
|
|
inline |
◆ ~XrdFrmXfrAgent()
XrdFrmXfrAgent::~XrdFrmXfrAgent |
( |
| ) |
|
|
inline |
◆ Process()
Definition at line 199 of file XrdFrmXfrAgent.cc.
218 {
case '+': Add(Request, tp, StgAgent);
break;
219 case '<': Add(Request, tp, GetAgent);
break;
221 case '>': Add(Request, tp, PutAgent);
break;
223 case '^': Add(Request, tp, MigAgent);
break;
224 case '-': Del(Request, tp+1, StgAgent);
225 Del(Request, tp+1, GetAgent);
227 case '~': Del(Request, tp+1, MigAgent);
228 Del(Request, tp+1, PutAgent);
230 case '?': List(Request, tp+1);
break;
231 case '!': GetAgent.
Ping(tp);
break;
232 default:
Say.
Emsg(
"Agent",
"Invalid request, '", tp,
"'.");
void Ping(const char *Msg=0)
char * GetToken(int lowcase=0)
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)
References XrdSysError::Emsg(), XrdOucStream::GetToken(), XrdCl::List(), and XrdFrc::Say.
Referenced by XrdFrmXfrDaemon::Pong().
◆ Start()
int XrdFrmXfrAgent::Start |
( |
| ) |
|
|
static |
Definition at line 240 of file XrdFrmXfrAgent.cc.
255 Request.
Attach(STDIN_FILENO, 8*1024);
259 while((tp = Request.
GetLine()))
260 {
DEBUG (
"Request: '" <<tp <<
"'");
266 Say.
Emsg(
"Agent",
"Exiting; lost request connection!");
int Start(char *aPath, int aMode)
static void Process(XrdOucStream &Request)
int Attach(int FileDescriptor, int bsz=2047)
References XrdOucStream::Attach(), XrdCms::Config, DEBUG, XrdSysError::Emsg(), EPNAME, XrdOucStream::GetLine(), and XrdFrc::Say.
Referenced by main().
The documentation for this class was generated from the following files: