#include <XrdFrmAdmin.hh>

Collaboration diagram for XrdFrmAdmin:

Public Member Functions
	XrdFrmAdmin ()

	~XrdFrmAdmin ()

int	Audit ()

int	Chksum ()

int	Copy ()

int	Create ()

int	Find ()

int	Help ()

int	MakeLF ()

int	Mark ()

int	Mmap ()

int	Mv ()

int	Pin ()

int	Query ()

int	Quit ()

int	Reloc ()

int	Remove ()

int	Rename ()

void	setArgs (char *argv)

void	setArgs (int argc, char **argv)

int	xeqArgs (char *Cmd)

Detailed Description

Definition at line 44 of file XrdFrmAdmin.hh.

Constructor & Destructor Documentation

◆ XrdFrmAdmin()

XrdFrmAdmin::XrdFrmAdmin ( )

inline

Definition at line 86 of file XrdFrmAdmin.hh.

86: frmProxy(0), frmProxz(0), finalRC(0) {}

Referenced by Query(), and xeqArgs().

Here is the caller graph for this function:

◆ ~XrdFrmAdmin()

XrdFrmAdmin::~XrdFrmAdmin ( )

inline

Definition at line 87 of file XrdFrmAdmin.hh.

87{}

Member Function Documentation

◆ Audit()

int XrdFrmAdmin::Audit ( )

Definition at line 71 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "fix",         3, "f",
                                "force",       1, "F",
                                "migratable",  1, "m",
                                "purgeable",   1, "p",
                                "recursive",   1, "r",
                                (const char *)0);
 
   static const char *Reqs[] = {"type", 0};
 
// Parse the request
//
   if (!Parse("audit ", Spec, Reqs)) return 1;
   Opt.Args[1] = Spec.getarg();
 
// Fan out based on the function
//
           if (!strcmp(Opt.Args[0], "usage")) return AuditUsage();
   if (!Opt.Args[1])  Emsg("audit target not specified.");
      else if (!strcmp(Opt.Args[0], "names")) return AuditNames();
      else if (!strcmp(Opt.Args[0], "space")) return AuditSpace();
      else    Emsg("Unknown audit type - ", Opt.Args[0]);
 
// Nothing we understand
//
   return 4;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Chksum()

int XrdFrmAdmin::Chksum ( )

Definition at line 111 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "force",       1, "f",
                                "pfn",         3, "p",
                                "type",        1, "t:",
                                "verbose",     1, "v", (const char *)0);
 
   static const char *Reqs[] = {"function", "target", 0};
   const char *csName;
   char pfnbuf[MAXPATHLEN], *Pfn, *Lfn, *csFunc;
   int rc = 0;
 
// Check if this is even supported
//
   CksData.Reset();
   if (!Config.CksMan || !(CksData.Length = Config.CksMan->Size()))
      {Emsg("Checksum support has not been configured!"); return 8;}
 
// Parse the request
//
   if (!Parse("chksum ", Spec, Reqs)) return 1;
   csFunc = Opt.Args[0];
   csName = CksData.Name;
   if (!*CksData.Name) {Opt.All = 1; CksData.Set(Config.CksMan->Name());}
 
// Check first for set or verify
//
   if (!strcmp (csFunc, "set") || Abbrev(csFunc, "verify", 3))
      {int n = strlen(Opt.Args[1]);
       if (n != CksData.Length*2 || !CksData.Set(Opt.Args[1], n))
          {Emsg("Invalid ", csName, " checksum value - ", Opt.Args[1]);
           return 4;
          }
       if (!(Opt.Args[1] = Spec.getarg()))
          {Emsg("chksum target not specified."); return 4;}
      }
 
// Convert the lfn to a pfn if it has not been converted already
//
   Pfn = Lfn = Opt.Args[1];
   if (Opt.MPType != 'p')
      {if (!Config.LocalPath(Opt.Args[1], pfnbuf, sizeof(pfnbuf))) return 4;
       Pfn = pfnbuf;
      }
 
// Process the request
//
        if (!strcmp(csFunc, "calc"))
           {if (Opt.Force || Config.CksMan->Get(Pfn, CksData) <= 0)
               rc = Config.CksMan->Calc(Pfn, CksData, 1);
            if (rc >= 0) {ChksumPrint(Lfn, rc); return 0;}
           }
 
   else if (!strcmp("ls", csFunc))
           {if (!(rc = ChksumList(Lfn, Pfn))) return 0;}
 
   else if (!strcmp(csFunc, "set"))
           {if (!(rc = Config.CksMan->Set(Pfn, CksData))) return 0;}
 
   else if (!strcmp(csFunc, "unset"))
           {if (!(rc = Config.CksMan->Del(Pfn, CksData))) return 0;}
 
   else if (Abbrev(csFunc, "verify", 3))
           {if ((rc = Config.CksMan->Ver(Pfn, CksData)) > 0)
               {Say.Say(CksData.Name, " checksums match for ", Lfn); return 0;}
            if (!rc)
               {Say.Say(CksData.Name, " checksums differ for ",Lfn); return 1;}
           }
 
   else {Emsg("Unknown chksum function - ", csFunc); return 4;}
 
// Determine name of the problem
//
        if (rc == -EDOM)    Emsg("Invalid ", csName, " checksum length.");
   else if (rc == -ENOTSUP) Emsg(csName, " checksums are not supported.");
   else if (rc == -ESRCH)   Emsg(csName, " checksum not set for ", Lfn);
   else if (rc == -ESTALE)  Emsg(csName, " checksum no longer valid for ", Lfn);
   else                     Emsg(-rc, csFunc, " ", csName, " checksum");
 
// Return failure
//
   return 4;
}

References XrdFrm::Config, XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Copy()

int XrdFrmAdmin::Copy ( )

◆ Create()

int XrdFrmAdmin::Create ( )

◆ Find()

int XrdFrmAdmin::Find ( )

Definition at line 270 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "recursive",   1, "r", (const char *)0);
 
   static const char *Reqs[] = {"type", "target", 0};
 
// Parse the request
//
   if (!Parse("find ", Spec, Reqs)) return 1;
 
// Process the correct find
//
        if (Abbrev(Opt.Args[0], "failfiles", 4)) return FindFail(Spec);
   else if (Abbrev(Opt.Args[0], "mmapped",   4)) return FindMmap(Spec);
   else if (Abbrev(Opt.Args[0], "nocs",      4)) return FindNocs(Spec);
   else if (Abbrev(Opt.Args[0], "nochksum",  8)) return FindNocs(Spec);
   else if (Abbrev(Opt.Args[0], "pinned",    3)) return FindPins(Spec);
   else if (Abbrev(Opt.Args[0], "unmigrated",4)) return FindUnmi(Spec);
 
// Nothing we understand
//
   Emsg("Unknown find type - ", Opt.Args[0]);
   return 4;
}

References Say.

Referenced by xeqArgs().

Here is the caller graph for this function:

◆ Help()

int XrdFrmAdmin::Help ( )

Definition at line 304 of file XrdFrmAdmin.cc.

{
   static struct CmdInfo {const char *Name;
                                int   minL;
                                int   maxL;
                          const char *Help;
                         }
                 CmdTab[] = {{"audit",  5, 5, AuditHelp },
                             {"chksum", 6, 6, ChksumHelp },
                             {"find",   1, 4, FindHelp  },
                             {"makelf", 6, 6, MakeLFHelp},
                             {"mark",   4, 4, MarkHelp  },
                             {"mmap",   4, 4, MmapHelp  },
                             {"mv",     2, 2, MvHelp    },
                             {"pin",    3, 3, PinHelp   },
                             {"query",  1, 5, QueryHelp },
                             {"reloc",  5, 5, RelocHelp },
                             {"rm",     2, 2, RemoveHelp}
                            };
   static int CmdNum = sizeof(CmdTab)/sizeof(struct CmdInfo);
   const char *theHelp = HelpHelp;
   char *Cmd;
   int   i, n;
 
// Get the next argument (array or string)
//
   if (!ArgS) Cmd = ArgV[0];
      else {XrdOucTokenizer Tokens(ArgS);
            if ((Cmd = Tokens.GetLine())) Cmd = Tokens.GetToken();
           }
 
// Try to give the correct help
//
   if (Cmd)
      {n = strlen(Cmd);
       for (i = 0; i < CmdNum; i++)
           if (n <= CmdTab[i].maxL && n >= CmdTab[i].minL
           && !strncmp(CmdTab[i].Name, Cmd, n)) break;
       if (i < CmdNum) {Msg("Usage: ", CmdTab[i].Help); return 0;}
      }
   Emsg(0, "Usage: ", theHelp);
   return 0;
}

References XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), and Help().

Referenced by Help(), and xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ MakeLF()

int XrdFrmAdmin::MakeLF ( )

Definition at line 359 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "migratable",  1, "m",
                                "owner",       1, "o:",
                                "purgeable",   1, "p",
                                "recursive",   1, "r",
                                (const char *)0);
 
   static const char *Reqs[] = {"lfn", 0};
 
   char *lfn, buff[80], Resp;
   int ok = 1;
 
// Parse the request
//
   if (!Parse("makelf ", Spec, Reqs)) return 1;
 
// Process all of the files
//
   numFiles = 0;
   lfn = Opt.Args[0];
   if (!Opt.MPType) Opt.MPType = 'm';
   do {Opt.All = VerifyAll(lfn);
       if ((Resp = VerifyMP("makelf", lfn)) == 'y') ok = mkLock(lfn);
      } while(Resp != 'a' && ok && (lfn = Spec.getarg()));
 
// All done
//
   if (Resp == 'a' || !ok) Msg("makelf aborted!");
   sprintf(buff, "%d lock file%s made.", numFiles, (numFiles == 1 ? "" : "s"));
   Msg(buff);
   return 0;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Mark()

int XrdFrmAdmin::Mark ( )

Definition at line 404 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "force",       1, "F",
                                "migratable",  1, "m",
                                "purgeable",   1, "p",
                                "recursive",   1, "r",
                                (const char *)0);
 
   static const char *Reqs[] = {"lfn", 0};
 
   char *lfn, buff[80], Resp;
   int ok = 1;
 
// Parse the request
//
   if (!Parse("mark ", Spec, Reqs)) return 1;
 
// Process all of the files
//
   numFiles = 0;
   lfn = Opt.Args[0];
   if (!Opt.MPType) Opt.MPType = 'm';
   do {Opt.All = VerifyAll(lfn);
       if ((Resp = VerifyMP("mark", lfn)) == 'y') ok = mkMark(lfn);
      } while(Resp != 'a' && ok && (lfn = Spec.getarg()));
 
// All done
//
   if (Resp == 'a' || !ok) Msg("mark aborted!");
   sprintf(buff, "%d file%s marked %s.", numFiles, (numFiles == 1 ? "" : "s"),
                 (Opt.MPType == 'm' ? "migratable" : "purgeable"));
   Msg(buff);
   return 0;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Mmap()

int XrdFrmAdmin::Mmap ( )

Definition at line 450 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "keep",        1, "K",
                                "lock",        1, "f",
                                "off",         1, "l",
                                "recursive",   1, "r",
                                (const char *)0);
 
   static const char *Reqs[] = {"lfn", 0};
 
   char *lfn, itbuff[80], Resp;
   int ok = 1;
 
// Parse the request
//
   if (!Parse("pin ", Spec, Reqs)) return 1;
 
// Process all of the files
//
   numFiles = 0;
   lfn = Opt.Args[0];
   Opt.MPType = 'p';
   do {Opt.All = VerifyAll(lfn);
       if ((Resp = VerifyMP("mmap", lfn)) == 'y') ok = mkMmap(lfn);
      } while(Resp != 'a' && ok && (lfn = Spec.getarg()));
 
// All done
//
   if (Resp == 'a' || !ok) Msg("mmap aborted!");
   sprintf(itbuff,"%d mmap%s processed.",numFiles,(numFiles==1?"":"s"));
   Msg(itbuff);
   return 0;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Mv()

int XrdFrmAdmin::Mv ( )

Definition at line 491 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ", "", (const char *)0);
 
   static const char *Reqs[] = {"oldlfn", "newlfn", 0};
 
   int rc;
 
// Parse the request and do it
//
   if (!Parse("mv ", Spec, Reqs)) return 1;
 
// Simply invoke the reloc function in the underlying FS
//
   if ((rc = Config.ossFS->Rename(Opt.Args[0], Opt.Args[1])))
      Emsg(-rc, "rename ", Opt.Args[0]);
      else Msg(Opt.Args[0], " renamed to ", Opt.Args[1]);
   return rc != 0;
}

References XrdFrm::Config, and Say.

Referenced by xeqArgs().

Here is the caller graph for this function:

◆ Pin()

int XrdFrmAdmin::Pin ( )

Definition at line 523 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "keep",        1, "k:",
                                "recursive",   1, "r",
                                (const char *)0);
 
   static const char *Reqs[] = {"lfn", 0};
 
   const char *Act;
   char *lfn, itbuff[80], Resp;
   int ok = 1;
 
// Parse the request
//
   if (!Parse("pin ", Spec, Reqs)) return 1;
 
// Process all of the files
//
   numFiles = 0;
   lfn = Opt.Args[0];
   Opt.MPType = 'p';
   do {Opt.All = VerifyAll(lfn);
       if ((Resp = VerifyMP("pin", lfn)) == 'y') ok = mkPin(lfn);
      } while(Resp != 'a' && ok && (lfn = Spec.getarg()));
 
// All done
//
   Act = (Opt.KeepTime || Opt.ktAlways ? "" : "un");
   if (Resp == 'a' || !ok) Msg("pin aborted!");
   sprintf(itbuff,"%d %spin%s processed.",numFiles,Act,(numFiles==1?"":"s"));
   Msg(itbuff);
   return 0;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Query()

int XrdFrmAdmin::Query ( )

Definition at line 571 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ", "", (const char *)0);
 
   static const char *Reqs[] = {"type", 0};
   static struct CmdInfo {const char *Name;
                          int (XrdFrmAdmin::*Method)(XrdOucArgs &Spec);
                         }
                 CmdTab[] = {{"pfn",    &XrdFrmAdmin::QueryPfn},
                             {"rfn",    &XrdFrmAdmin::QueryRfn},
                             {"space",  &XrdFrmAdmin::QuerySpace},
                             {"usage",  &XrdFrmAdmin::QueryUsage},
                             {"xfrq",   &XrdFrmAdmin::QueryXfrQ}
                            };
   static int CmdNum = sizeof(CmdTab)/sizeof(struct CmdInfo);
 
   int i;
 
// Parse the request
//
   if (!Parse("query ", Spec, Reqs)) return 1;
 
// Find the command
//
   for (i = 0; i < CmdNum; i++)
       if (!strcmp(CmdTab[i].Name, Opt.Args[0])) break;
 
// See if we found the command
//
   if (i >= CmdNum)
      {Emsg("Invalid query type - ", Opt.Args[0]);
       return 1;
      }
 
// Perform required function
//
   return (*this.*CmdTab[i].Method)(Spec);
}

References XrdFrmAdmin(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Quit()

int XrdFrmAdmin::Quit ( )

inline

Definition at line 72 of file XrdFrmAdmin.hh.

72{exit(finalRC); return 0;}

Referenced by xeqArgs().

Here is the caller graph for this function:

◆ Reloc()

int XrdFrmAdmin::Reloc ( )

Definition at line 616 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ", "", (const char *)0);
 
   static const char *Reqs[] = {"lfn", "target", 0};
 
   int rc;
 
// Parse the request and do it
//
   if (!Parse("reloc ", Spec, Reqs)) return 1;
 
// Simply invoke the reloc function in the underlying FS
//
   if ((rc = Config.ossFS->Reloc("admin", Opt.Args[0], Opt.Args[1])))
      Emsg(-rc, "reloc ", Opt.Args[0]);
      else Msg(Opt.Args[0], " relocated to space ", Opt.Args[1]);
   return rc != 0;
}

References XrdFrm::Config, and Say.

Referenced by xeqArgs().

Here is the caller graph for this function:

◆ Remove()

int XrdFrmAdmin::Remove ( )

Definition at line 646 of file XrdFrmAdmin.cc.

{
   static XrdOucArgs Spec(&Say, "frm_admin: ",    "",
                                "echo",        1, "E",
                                "force",       1, "F",
                                "recursive",   1, "r",
                          (const char *)0);
 
   static const char *Reqs[] = {"lfn", 0};
 
   const char *Txt = "";
   char buff[80];
   int rc = 0, aOK = 1;
 
// Parse the request
//
   if (!Parse("rm ", Spec, Reqs)) return 1;
 
// Do some initialization
//
   numDirs = numFiles = numProb = 0;
 
// Preform action
//
   do {Opt.All = VerifyAll(Opt.Args[0]);
       if ((rc = Unlink(Opt.Args[0])) < 0) aOK = 0;
      } while(rc && (Opt.Args[0] = Spec.getarg()));
 
   if (!rc) {Txt = "rm aborted; only "; finalRC = 4;}
      else if (numProb || !aOK) {Txt = "rm incomplete; only "; finalRC = 4;}
 
// Compose message
//
   sprintf(buff, "%s%d %s and %d %s deleted.", Txt,
          numFiles, (numFiles != 1 ? "files"       : "file"),
          numDirs,  (numDirs  != 1 ? "directories" : "directory"));
   Msg(buff);
   return 0;
}

References XrdOucArgs::getarg(), and Say.

Referenced by xeqArgs().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Rename()

int XrdFrmAdmin::Rename ( )

◆ setArgs() [1/2]

void XrdFrmAdmin::setArgs ( char * argv )

Definition at line 696 of file XrdFrmAdmin.cc.

{
   ArgC = 0;    ArgV = 0;    ArgS = args;
}

◆ setArgs() [2/2]

void XrdFrmAdmin::setArgs	(	int	argc,
		char **	argv )

Definition at line 690 of file XrdFrmAdmin.cc.

{
   ArgC = argc; ArgV = argv; ArgS = 0;
}

◆ xeqArgs()

int XrdFrmAdmin::xeqArgs ( char * Cmd )

Definition at line 705 of file XrdFrmAdmin.cc.

{
   static struct CmdInfo {const char *Name;
                          int         minLen;
                          int         maxLen;
                          int        (XrdFrmAdmin::*Method)();
                         }
                 CmdTab[] = {{"audit",  5, 5, &XrdFrmAdmin::Audit},
                             {"chksum", 6, 6, &XrdFrmAdmin::Chksum},
                             {"exit",   4, 4, &XrdFrmAdmin::Quit},
                             {"find",   1, 4, &XrdFrmAdmin::Find},
                             {"help",   1, 4, &XrdFrmAdmin::Help},
                             {"makelf", 6, 6, &XrdFrmAdmin::MakeLF},
                             {"mark",   1, 4, &XrdFrmAdmin::Mark},
                             {"mmap",   1, 4, &XrdFrmAdmin::Mmap},
                             {"mv",     2, 2, &XrdFrmAdmin::Mv},
                             {"pin",    3, 3, &XrdFrmAdmin::Pin},
                             {"query",  1, 5, &XrdFrmAdmin::Query},
                             {"quit",   4, 4, &XrdFrmAdmin::Quit},
                             {"reloc",  5, 5, &XrdFrmAdmin::Reloc},
                             {"rm",     2, 2, &XrdFrmAdmin::Remove}
                            };
   static int CmdNum = sizeof(CmdTab)/sizeof(struct CmdInfo);
 
   int i, n = strlen(Cmd);
 
// Find the command
//
   for (i = 0; i < CmdNum; i++)
       if (n >= CmdTab[i].minLen && n <= CmdTab[i].maxLen
       &&  !strncmp(CmdTab[i].Name, Cmd, n)) break;
 
// See if we found the command
//
   if (i >= CmdNum)
      {Emsg("Invalid command - ", Cmd);
       return 1;
      }
 
// Perform required function
//
   return (*this.*CmdTab[i].Method)();
}

References XrdFrmAdmin(), Audit(), Chksum(), Find(), Help(), MakeLF(), Mark(), Mmap(), Mv(), Pin(), Query(), Quit(), Reloc(), and Remove().

Here is the call graph for this function:

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

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ XrdFrmAdmin()

◆ ~XrdFrmAdmin()

Member Function Documentation

◆ Audit()

◆ Chksum()

◆ Copy()

◆ Create()

◆ Find()

◆ Help()

◆ MakeLF()

◆ Mark()

◆ Mmap()

◆ Mv()

◆ Pin()

◆ Query()

◆ Quit()

◆ Reloc()

◆ Remove()

◆ Rename()

◆ setArgs() [1/2]

◆ setArgs() [2/2]

◆ xeqArgs()