XrdPfc.cc File Reference

#include <fcntl.h>
#include <sstream>
#include <algorithm>
#include <sys/statvfs.h>
#include "XrdCl/XrdClURL.hh"
#include "XrdOuc/XrdOucEnv.hh"
#include "XrdOuc/XrdOucUtils.hh"
#include "XrdOuc/XrdOucPrivateUtils.hh"
#include "XrdSys/XrdSysTimer.hh"
#include "XrdSys/XrdSysTrace.hh"
#include "XrdSys/XrdSysXAttr.hh"
#include "XrdXrootd/XrdXrootdGStream.hh"
#include "XrdOss/XrdOss.hh"
#include "XrdPfc.hh"
#include "XrdPfcTrace.hh"
#include "XrdPfcFSctl.hh"
#include "XrdPfcInfo.hh"
#include "XrdPfcIOFile.hh"
#include "XrdPfcIOFileBlock.hh"
#include "XrdPfcResourceMonitor.hh"

Include dependency graph for XrdPfc.cc:

Go to the source code of this file.

Functions
void *	PrefetchThread (void *)
void *	ProcessWriteTaskThread (void *)
void *	ResourceMonitorThread (void *)
XrdOucCache *	XrdOucGetCache (XrdSysLogger *logger, const char *config_filename, const char *parameters, XrdOucEnv *env)

Variables
XrdSysXAttr *	XrdSysXAttrActive

Function Documentation

PrefetchThread()

void * PrefetchThread

(

void *

)

Definition at line 66 of file XrdPfc.cc.

{
   Cache::GetInstance().Prefetch();
   return 0;
}

References XrdPfc::Cache::GetInstance(), and XrdPfc::Cache::Prefetch().

Referenced by XrdOucGetCache().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessWriteTaskThread()

void * ProcessWriteTaskThread

(

void *

)

Definition at line 60 of file XrdPfc.cc.

{
   Cache::GetInstance().ProcessWriteTasks();
   return 0;
}

References XrdPfc::Cache::GetInstance(), and XrdPfc::Cache::ProcessWriteTasks().

Referenced by XrdOucGetCache().

Here is the call graph for this function:

Here is the caller graph for this function:

ResourceMonitorThread()

void * ResourceMonitorThread

(

void *

)

Definition at line 54 of file XrdPfc.cc.

{
   Cache::ResMon().main_thread_function();
   return 0;
}

References XrdPfc::ResourceMonitor::main_thread_function(), and XrdPfc::Cache::ResMon().

Referenced by XrdOucGetCache().

Here is the call graph for this function:

Here is the caller graph for this function:

XrdOucGetCache()

XrdOucCache * XrdOucGetCache	(	XrdSysLogger *	logger,
		const char *	config_filename,
		const char *	parameters,
		XrdOucEnv *	env )

Definition at line 76 of file XrdPfc.cc.

{
   XrdSysError err(logger, "");
   err.Say("++++++ Proxy file cache initialization started.");
 
   if ( ! env ||
        ! (XrdPfc::Cache::schedP = (XrdScheduler*) env->GetPtr("XrdScheduler*")))
   {
      XrdPfc::Cache::schedP = new XrdScheduler;
      XrdPfc::Cache::schedP->Start();
   }
 
   Cache &instance = Cache::CreateInstance(logger, env);
 
   if (! instance.Config(config_filename, parameters))
   {
      err.Say("Config Proxy file cache initialization failed.");
      return 0;
   }
   err.Say("++++++ Proxy file cache initialization completed.");
 
   {
      pthread_t tid;
 
      XrdSysThread::Run(&tid, ResourceMonitorThread, 0, 0, "XrdPfc ResourceMonitor");
 
      for (int wti = 0; wti < instance.RefConfiguration().m_wqueue_threads; ++wti)
      {
         XrdSysThread::Run(&tid, ProcessWriteTaskThread, 0, 0, "XrdPfc WriteTasks ");
      }
 
      if (instance.RefConfiguration().m_prefetch_max_blocks > 0)
      {
         XrdSysThread::Run(&tid, PrefetchThread, 0, 0, "XrdPfc Prefetch ");
      }
   }
 
   XrdPfcFSctl* pfcFSctl = new XrdPfcFSctl(instance, logger);
   env->PutPtr("XrdFSCtl_PC*", pfcFSctl);
 
   return &instance;
}

References XrdPfc::Cache::Config(), XrdPfc::Cache::CreateInstance(), XrdOucEnv::GetPtr(), XrdPfc::Configuration::m_prefetch_max_blocks, PrefetchThread(), ProcessWriteTaskThread(), XrdOucEnv::PutPtr(), XrdPfc::Cache::RefConfiguration(), ResourceMonitorThread(), XrdSysThread::Run(), XrdSysError::Say(), and XrdPfc::Cache::schedP.

Referenced by XrdPfc::Cache::Config(), and XrdVERSIONINFO().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

XrdSysXAttrActive

XrdSysXAttr* XrdSysXAttrActive

extern

Definition at line 61 of file XrdSysFAttr.cc.

Referenced by XrdPfc::Cache::DetermineFullFileSize(), XrdOfsConfigPI::Load(), XrdSysFAttr::SetPlugin(), and XrdPfc::Cache::WriteFileSizeXAttr().