in Prefetch wait 5ms if ram limit has been reached.

xrootd · Jun 30, 2016 · 21a5ee5 · 21a5ee5
1 parent dd8ab68
commit 21a5ee5
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/XrdFileCache/XrdFileCache.cc b/src/XrdFileCache/XrdFileCache.cc
@@ -104,12 +104,12 @@ void Cache::Detach(XrdOucCacheIO* io)
 bool
 Cache::HaveFreeWritingSlots()
 {
-   const static size_t maxWriteWaits=500;
+   const static size_t maxWriteWaits=100000;
    if ( s_writeQ.size < maxWriteWaits) {
       return true;
    }
    else {
-       XrdCl::DefaultEnv::GetLog()->Debug(XrdCl::AppMsg, "Cache::HaveFreeWritingSlots() negative", s_writeQ.size);
+       XrdCl::DefaultEnv::GetLog()->Info(XrdCl::AppMsg, "Cache::HaveFreeWritingSlots() negative", s_writeQ.size);
        return false;
    }
 }
@@ -272,16 +272,16 @@ Cache::Prefetch()
    XrdCl::DefaultEnv::GetLog()->Dump(XrdCl::AppMsg, "Cache::Prefetch thread start");
 
    while (true) {
-      bool doPrefetch = false;
       m_RAMblock_mutex.Lock();
-      if (m_RAMblocks_used < limitRAM && HaveFreeWritingSlots())
-         doPrefetch = true;
+      bool doPrefetch = (m_RAMblocks_used < limitRAM && HaveFreeWritingSlots());
       m_RAMblock_mutex.UnLock();
 
       if (doPrefetch) {
          File* f = GetNextFileToPrefetch();
          f->Prefetch();
-         XrdSysTimer::Wait(5); // ??? what is here a reasonable value
+      }
+      else {
+         XrdSysTimer::Wait(5);
       }
    }  
 }