Skip to content

Commit

Permalink
Whitespace changes.
Browse files Browse the repository at this point in the history
  • Loading branch information
osschar authored and abh3 committed Jun 30, 2016
1 parent 14bc362 commit 17544f1
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 22 deletions.
12 changes: 3 additions & 9 deletions src/XrdFileCache/XrdFileCacheFactory.cc
Expand Up @@ -132,7 +132,6 @@ bool Factory::xdlib(XrdOucStream &Config)
const char* params;
params = (val[0]) ? Config.GetWord() : 0;


XrdOucPinLoader* myLib = new XrdOucPinLoader(&m_log, 0, "decisionlib",
libp.c_str());

Expand All @@ -153,16 +152,16 @@ bool Factory::xdlib(XrdOucStream &Config)
clLog()->Info(XrdCl::AppMsg, "Factory::Config() successfully created decision lib from %s", libp.c_str());
return true;
}
//______________________________________________________________________________

//______________________________________________________________________________

bool Factory::Decide(XrdOucCacheIO* io)
{
if(!m_decisionpoints.empty())
if (!m_decisionpoints.empty())
{
std::string filename = io->Path();
std::vector<Decision*>::const_iterator it;
for ( it = m_decisionpoints.begin(); it != m_decisionpoints.end(); ++it)
for (it = m_decisionpoints.begin(); it != m_decisionpoints.end(); ++it)
{
XrdFileCache::Decision *d = *it;
if (!d) continue;
Expand All @@ -176,11 +175,8 @@ bool Factory::Decide(XrdOucCacheIO* io)
return true;
}



//______________________________________________________________________________


bool Factory::Config(XrdSysLogger *logger, const char *config_filename, const char *parameters)
{
m_log.logger(logger);
Expand Down Expand Up @@ -538,7 +534,6 @@ void FillFileMapRecurse( XrdOssDF* iOssDF, const std::string& path, FPurgeState&
}
}


void Factory::CacheDirCleanup()
{
// check state every sleep seconds
Expand Down Expand Up @@ -615,4 +610,3 @@ void Factory::CacheDirCleanup()
sleep(sleept);
}
}

9 changes: 2 additions & 7 deletions src/XrdFileCache/XrdFileCacheFile.cc
Expand Up @@ -143,7 +143,6 @@ File::~File()
++itr;
}
}


bool blockMapEmpty = m_block_map.empty();
int blocksize = (int)m_block_map.size();
Expand Down Expand Up @@ -196,9 +195,6 @@ File::~File()
}
delete m_syncer;




// print just for curiosity
clLog()->Debug(XrdCl::AppMsg, "File::~File() ended, prefetch score ...%d/%d=%.2f", m_prefetchHitCnt, m_prefetchReadCnt, m_prefetchScore);
}
Expand Down Expand Up @@ -913,9 +909,8 @@ void File::AppendIOStatToFileInfo()
//______________________________________________________________________________
void File::Prefetch()
{

if (m_prefetchState == kOn) {

if (m_prefetchState == kOn)
{
// clLog()->Dump(XrdCl::AppMsg, "File::Prefetch enter to check download status \n");
XrdSysCondVarHelper _lck(m_downloadCond);
// clLog()->Dump(XrdCl::AppMsg, "File::Prefetch enter to check download status BEGIN %s \n", lPath());
Expand Down
8 changes: 4 additions & 4 deletions src/XrdFileCache/XrdFileCacheFile.hh
Expand Up @@ -27,15 +27,16 @@
#include <string>
#include <map>


class XrdJob;
class XrdOucIOVec;

namespace XrdCl
{
class Log;
class Log;
}

namespace XrdFileCache {
namespace XrdFileCache
{
class BlockResponseHandler;
class DirectResponseHandler;

Expand All @@ -46,7 +47,6 @@ namespace XrdFileCache {
}



namespace XrdFileCache
{
class RefCounted
Expand Down
5 changes: 3 additions & 2 deletions src/XrdFileCache/XrdFileCachePrint.cc
Expand Up @@ -71,8 +71,9 @@ void Print::printFile(const std::string& path)
int cntd = 0;
for (int i = 0; i < cfi.GetSizeInBits(); ++i) if (cfi.TestBit(i)) cntd++;


printf("version == %d, bufferSize %lld nBlocks %d nDownlaoded %d %s\n",cfi.GetVersion(), cfi.GetBufferSize(), cfi.GetSizeInBits() , cntd, (cfi.GetSizeInBits() == cntd) ? " complete" :"");
printf("version == %d, bufferSize %lld nBlocks %d nDownloaded %d %s\n",
cfi.GetVersion(), cfi.GetBufferSize(), cfi.GetSizeInBits(), cntd,
(cfi.GetSizeInBits() == cntd) ? "complete" : "");

if (m_verbose) {
printf("printing %d blocks: \n", cfi.GetSizeInBits());
Expand Down

0 comments on commit 17544f1

Please sign in to comment.