00001 #ifndef __CMS_CACHE__H
00002 #define __CMS_CACHE__H
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033 #include <string.h>
00034
00035 #include "Xrd/XrdJob.hh"
00036 #include "Xrd/XrdScheduler.hh"
00037 #include "XrdCms/XrdCmsKey.hh"
00038 #include "XrdCms/XrdCmsNash.hh"
00039 #include "XrdCms/XrdCmsPList.hh"
00040 #include "XrdSys/XrdSysPthread.hh"
00041 #include "XrdCms/XrdCmsSelect.hh"
00042 #include "XrdCms/XrdCmsTypes.hh"
00043
00044 class XrdCmsCache
00045 {
00046 public:
00047 friend class XrdCmsCacheJob;
00048
00049 XrdCmsPList_Anchor Paths;
00050
00051
00052
00053
00054 int AddFile(XrdCmsSelect &Sel, SMask_t mask);
00055
00056
00057
00058 int DelFile(XrdCmsSelect &Sel, SMask_t mask);
00059
00060
00061
00062 int GetFile(XrdCmsSelect &Sel, SMask_t mask);
00063
00064
00065
00066 int UnkFile(XrdCmsSelect &Sel, SMask_t mask);
00067
00068
00069
00070
00071 int WT4File(XrdCmsSelect &Sel, SMask_t mask);
00072
00073 void Bounce(SMask_t smask, int SNum);
00074
00075 void Drop(SMask_t mask, int SNum, int xHi);
00076
00077 int Init(int fxHold, int fxDelay, int fxQuery, int seFS, int nxHold);
00078
00079 void *TickTock();
00080
00081 static const int min_nxTime = 60;
00082
00083 XrdCmsCache() : okVec(0), Tick(8*60*60), Tock(0), BClock(0),
00084 nilTMO(0),
00085 DLTime(5), QDelay(5), Bhits(0), Bmiss(0), vecHi(-1),
00086 isDFS(0)
00087 {memset(Bounced, 0, sizeof(Bounced));
00088 memset(Bhistory, 0, sizeof(Bhistory));
00089 }
00090 ~XrdCmsCache() {}
00091
00092 private:
00093
00094 void Add2Q(XrdCmsRRQInfo *Info, XrdCmsKeyItem *cp, int selOpts);
00095 void Dispatch(XrdCmsSelect &Sel, XrdCmsKeyItem *cinfo,
00096 short roQ, short rwQ);
00097 SMask_t getBVec(unsigned int todA, unsigned int &todB);
00098 void Recycle(XrdCmsKeyItem *theList);
00099
00100 struct {SMask_t Vec;
00101 unsigned int Start;
00102 unsigned int End;
00103 } Bhistory[XrdCmsKeyItem::TickRate];
00104
00105 XrdSysMutex myMutex;
00106 XrdCmsNash CTable;
00107 unsigned int Bounced[STMax];
00108 SMask_t okVec;
00109 unsigned int Tick;
00110 unsigned int Tock;
00111 unsigned int BClock;
00112 int nilTMO;
00113 int DLTime;
00114 int QDelay;
00115 int Bhits;
00116 int Bmiss;
00117 int vecHi;
00118 int isDFS;
00119 };
00120
00121 namespace XrdCms
00122 {
00123 extern XrdCmsCache Cache;
00124 }
00125 #endif