XrdFrmXfrAgent Class Reference

#include <XrdFrmXfrAgent.hh>

Collaboration diagram for XrdFrmXfrAgent:

Public Member Functions
	XrdFrmXfrAgent ()
	~XrdFrmXfrAgent ()

Static Public Member Functions
static void	Process (XrdOucStream &Request)
static int	Start ()

Detailed Description

Definition at line 38 of file XrdFrmXfrAgent.hh.

Constructor & Destructor Documentation

XrdFrmXfrAgent()

XrdFrmXfrAgent::XrdFrmXfrAgent ( )

inline

Definition at line 46 of file XrdFrmXfrAgent.hh.

{}

~XrdFrmXfrAgent()

XrdFrmXfrAgent::~XrdFrmXfrAgent ( )

inline

Definition at line 47 of file XrdFrmXfrAgent.hh.

{}

Member Function Documentation

Process()

void XrdFrmXfrAgent::Process ( XrdOucStream &  Request )

static

Definition at line 199 of file XrdFrmXfrAgent.cc.

{
   char *tp;
 
// Each frm request comes in as:
//
// Copy in:    <[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Copy purge: =[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Copy out:   >[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Migrate:    &[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Migr+Purge: ^[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Stage:      +[<traceid>] <reqid> <npath> <prty> <mode> <path> [. . .]
// Cancel in:  - <requestid>
// Cancel out: ~ <requestid>
// List:       ?[<][+][&][>]
// Wakeup:     ![<][+][&][>]
//
   if ((tp = Request.GetToken()))
      switch(*tp)
            {case '+':  Add(Request, tp,   StgAgent); break;
             case '<':  Add(Request, tp,   GetAgent); break;
             case '=':
             case '>':  Add(Request, tp,   PutAgent); break;
             case '&':
             case '^':  Add(Request, tp,   MigAgent); break;
             case '-':  Del(Request, tp+1, StgAgent);
                        Del(Request, tp+1, GetAgent);
                        break;
             case '~':  Del(Request, tp+1, MigAgent);
                        Del(Request, tp+1, PutAgent);
                        break;
             case '?': List(Request, tp+1);           break;
             case '!': GetAgent.Ping(tp);             break;
             default: Say.Emsg("Agent", "Invalid request, '", tp, "'.");
            }
}

References XrdSysError::Emsg(), XrdOucStream::GetToken(), XrdCl::List(), and XrdFrc::Say.

Referenced by XrdFrmXfrDaemon::Pong().

Here is the call graph for this function:

Here is the caller graph for this function:

Start()

int XrdFrmXfrAgent::Start ( )

static

Definition at line 240 of file XrdFrmXfrAgent.cc.

{
   EPNAME("Agent");
   XrdOucStream Request;
   char *tp;
 
// Prepare our agents
//
   if (!StgAgent.Start(Config.QPath, Config.AdminMode)
   ||  !MigAgent.Start(Config.QPath, Config.AdminMode)
   ||  !GetAgent.Start(Config.QPath, Config.AdminMode)
   ||  !PutAgent.Start(Config.QPath, Config.AdminMode)) return 2;
 
// Attach stdin to the Request stream
//
   Request.Attach(STDIN_FILENO, 8*1024);
 
// Process all input
//
   while((tp = Request.GetLine()))
        {DEBUG ("Request: '" <<tp <<"'");
         Process(Request);
        }
 
// If we exit then we lost the connection
//
   Say.Emsg("Agent", "Exiting; lost request connection!");
   return 8;
}

References XrdOucStream::Attach(), XrdCms::Config, DEBUG, XrdSysError::Emsg(), EPNAME, XrdOucStream::GetLine(), and XrdFrc::Say.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• XrdFrmXfrAgent.hh
• XrdFrmXfrAgent.cc