00001 #ifndef __FRMREQAGENT_H__ 00002 #define __FRMREQAGENT_H__ 00003 /******************************************************************************/ 00004 /* */ 00005 /* X r d F r m R e q A g e n t . h h */ 00006 /* */ 00007 /* (c) 2010 by the Board of Trustees of the Leland Stanford, Jr., University */ 00008 /* All Rights Reserved */ 00009 /* Produced by Andrew Hanushevsky for Stanford University under contract */ 00010 /* DE-AC02-76-SFO0515 with the Department of Energy */ 00011 /******************************************************************************/ 00012 00013 // $Id: XrdFrmReqAgent.hh 35287 2010-09-14 21:19:35Z ganis $ 00014 00015 #include "XrdFrm/XrdFrmReqFile.hh" 00016 #include "XrdFrm/XrdFrmRequest.hh" 00017 00018 class XrdFrmReqAgent 00019 { 00020 public: 00021 00022 void Add(XrdFrmRequest &Request); 00023 00024 void Del(XrdFrmRequest &Request); 00025 00026 int List(XrdFrmRequest::Item *Items, int Num); 00027 int List(XrdFrmRequest::Item *Items, int Num, int Prty); 00028 00029 int NextLFN(char *Buff, int Bsz, int Prty, int &Offs); 00030 00031 void Ping(const char *Msg=0); 00032 00033 int Start(char *aPath, int aMode); 00034 00035 XrdFrmReqAgent(const char *Me, int qVal); 00036 ~XrdFrmReqAgent() {} 00037 00038 private: 00039 00040 static char *c2sFN; 00041 00042 XrdFrmReqFile *rQueue[XrdFrmRequest::maxPQE]; 00043 const char *Persona; 00044 const char *pingMsg; 00045 const char *myName; 00046 int theQ; 00047 }; 00048 #endif