XrdPfc::File Class Reference

#include <XrdPfcFile.hh>

Collaboration diagram for XrdPfc::File:

Public Member Functions
void	AddIO (IO *io)
void	BlockRemovedFromWriteQ (Block *)
	Handle removal of a block from Cache's write queue.
void	BlocksRemovedFromWriteQ (std::list< Block * > &)
	Handle removal of a set of blocks from Cache's write queue.
int	dec_ref_cnt ()
bool	FinalizeSyncBeforeExit ()
	Returns true if any of blocks need sync. Called from Cache::dec_ref_cnt on zero ref cnt.
int	Fstat (struct stat &sbuff)
int	get_ref_cnt ()
size_t	GetAccessCnt () const
int	GetBlockSize () const
long long	GetFileSize () const
const Info::AStat *	GetLastAccessStats () const
const std::string &	GetLocalPath () const
XrdSysError *	GetLog ()
int	GetNBlocks () const
int	GetNDownloadedBlocks () const
int	GetPrefetchCountOnIO (IO *io)
long long	GetPrefetchedBytes () const
float	GetPrefetchScore () const
std::string	GetRemoteLocations () const
XrdSysTrace *	GetTrace ()
int	inc_ref_cnt ()
long long	initiate_emergency_shutdown ()
bool	ioActive (IO *io)
	Initiate close. Return true if still IO active. Used in XrdPosixXrootd::Close()
void	ioUpdated (IO *io)
	Notification from IO that it has been updated (remote open).
bool	is_in_emergency_shutdown ()
const char *	lPath () const
	Log path.
void	Prefetch ()
int	Read (IO *io, char *buff, long long offset, int size, ReadReqRH *rh)
	Normal read.
int	ReadV (IO *io, const XrdOucIOVec *readV, int readVnum, ReadReqRH *rh)
	Vector read.
const Stats &	RefStats () const
void	RemoveIO (IO *io)
void	RequestSyncOfDetachStats ()
	Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach.
void	StopPrefetchingOnIO (IO *io)
void	Sync ()
	Sync file cache inf o and output data with disk.
void	WriteBlockToDisk (Block *b)

Static Public Member Functions
static File *	FileOpen (const std::string &path, long long offset, long long fileSize)
	Static constructor that also does Open. Returns null ptr if Open fails.

Friends
class	BlockResponseHandler
class	Cache
class	DirectResponseHandler

Detailed Description

Definition at line 202 of file XrdPfcFile.hh.

Member Function Documentation

AddIO()

void File::AddIO

(

IO *

io

)

Definition at line 346 of file XrdPfcFile.cc.

{
   // Called from Cache::GetFile() when a new IO asks for the file.
 
   TRACEF(Debug, "AddIO() io = " << (void*)io);
 
   time_t      now = time(0);
   std::string loc(io->GetLocation());
 
   m_state_cond.Lock();
 
   IoSet_i mi = m_io_set.find(io);
 
   if (mi == m_io_set.end())
   {
      m_io_set.insert(io);
      io->m_attach_time = now;
      m_delta_stats.IoAttach();
 
      insert_remote_location(loc);
 
      if (m_prefetch_state == kStopped)
      {
         m_prefetch_state = kOn;
         cache()->RegisterPrefetchFile(this);
      }
   }
   else
   {
      TRACEF(Error, "AddIO() io = " << (void*)io << " already registered.");
   }
 
   m_state_cond.UnLock();
}

References Debug, Error, XrdPfc::IO::GetLocation(), XrdPfc::Stats::IoAttach(), XrdSysCondVar::Lock(), TRACEF, and XrdSysCondVar::UnLock().

Referenced by XrdPfc::Cache::GetFile().

Here is the call graph for this function:

Here is the caller graph for this function:

BlockRemovedFromWriteQ()

void File::BlockRemovedFromWriteQ

(

Block *

b

)

Handle removal of a block from Cache's write queue.

Definition at line 208 of file XrdPfcFile.cc.

{
   TRACEF(Dump, "BlockRemovedFromWriteQ() block = " << (void*) b << " idx= " << b->m_offset/m_block_size);
 
   XrdSysCondVarHelper _lck(m_state_cond);
   dec_ref_count(b);
}

References XrdPfc::Block::m_offset, and TRACEF.

BlocksRemovedFromWriteQ()

void File::BlocksRemovedFromWriteQ

(

std::list< Block * > &

blocks

)

Handle removal of a set of blocks from Cache's write queue.

Definition at line 216 of file XrdPfcFile.cc.

{
   TRACEF(Dump, "BlocksRemovedFromWriteQ() n_blocks = " << blocks.size());
 
   XrdSysCondVarHelper _lck(m_state_cond);
 
   for (std::list<Block*>::iterator i = blocks.begin(); i != blocks.end(); ++i)
   {
      dec_ref_count(*i);
   }
}

References TRACEF.

Referenced by XrdPfc::Cache::RemoveWriteQEntriesFor().

Here is the caller graph for this function:

dec_ref_cnt()

int XrdPfc::File::dec_ref_cnt ( )

inline

Definition at line 288 of file XrdPfcFile.hh.

{ return --m_ref_cnt; }

FileOpen()

File * File::FileOpen ( const std::string &  path, long long  offset, long long  fileSize  )

static

Static constructor that also does Open. Returns null ptr if Open fails.

Definition at line 138 of file XrdPfcFile.cc.

{
   File *file = new File(path, offset, fileSize);
   if ( ! file->Open())
   {
      delete file;
      file = 0;
   }
   return file;
}

Referenced by XrdPfc::Cache::GetFile().

Here is the caller graph for this function:

FinalizeSyncBeforeExit()

bool File::FinalizeSyncBeforeExit

(

)

Returns true if any of blocks need sync. Called from Cache::dec_ref_cnt on zero ref cnt.

Definition at line 322 of file XrdPfcFile.cc.

{
   // Returns true if sync is required.
   // This method is called after corresponding IO is detached from PosixCache.
 
   XrdSysCondVarHelper _lck(m_state_cond);
   if ( ! m_in_shutdown)
   {
     if ( ! m_writes_during_sync.empty() || m_non_flushed_cnt > 0 || ! m_detach_time_logged)
     {
       report_and_merge_delta_stats();
       m_cfi.WriteIOStatDetach(m_stats);
       m_detach_time_logged = true;
       m_in_sync            = true;
       TRACEF(Debug, "FinalizeSyncBeforeExit requesting sync to write detach stats");
       return true;
     }
   }
   TRACEF(Debug, "FinalizeSyncBeforeExit sync not required");
   return false;
}

References Debug, TRACEF, and XrdPfc::Info::WriteIOStatDetach().

Here is the call graph for this function:

Fstat()

int File::Fstat

(

struct stat &

sbuff

)

Definition at line 563 of file XrdPfcFile.cc.

{
   // Stat on an open file.
   // Corrects size to actual full size of the file.
   // Sets atime to 0 if the file is only partially downloaded, in accordance
   // with pfc.onlyifcached settings.
   // Called from IO::Fstat() and Cache::Stat() when the file is active.
   // Returns 0 on success, -errno on error.
 
   int res;
 
   if ((res = m_data_file->Fstat(&sbuff))) return res;
 
   sbuff.st_size = m_file_size;
 
   bool is_cached = cache()->DecideIfConsideredCached(m_file_size, sbuff.st_blocks * 512ll);
   if ( ! is_cached)
      sbuff.st_atime = 0;
 
   return 0;
}

References XrdOssDF::Fstat().

Referenced by XrdPfc::Cache::ConsiderCached(), XrdPfc::IOFile::Fstat(), and XrdPfc::Cache::Stat().

Here is the call graph for this function:

Here is the caller graph for this function:

get_ref_cnt()

int XrdPfc::File::get_ref_cnt ( )

inline

Definition at line 286 of file XrdPfcFile.hh.

{ return   m_ref_cnt; }

GetAccessCnt()

size_t XrdPfc::File::GetAccessCnt ( ) const

inline

Definition at line 276 of file XrdPfcFile.hh.

{ return m_cfi.GetAccessCnt(); }

References XrdPfc::Info::GetAccessCnt().

Here is the call graph for this function:

GetBlockSize()

int XrdPfc::File::GetBlockSize ( ) const

inline

Definition at line 277 of file XrdPfcFile.hh.

{ return m_cfi.GetBufferSize(); }

References XrdPfc::Info::GetBufferSize().

Here is the call graph for this function:

GetFileSize()

long long XrdPfc::File::GetFileSize ( ) const

inline

Definition at line 267 of file XrdPfcFile.hh.

{ return m_file_size; }

Referenced by XrdPfc::IOFile::FSize().

Here is the caller graph for this function:

GetLastAccessStats()

const Info::AStat * XrdPfc::File::GetLastAccessStats ( ) const

inline

Definition at line 275 of file XrdPfcFile.hh.

{ return m_cfi.GetLastAccessStats(); }

References XrdPfc::Info::GetLastAccessStats().

Here is the call graph for this function:

GetLocalPath()

const std::string & XrdPfc::File::GetLocalPath ( ) const

inline

Definition at line 262 of file XrdPfcFile.hh.

{ return m_filename; }

Referenced by XrdPfc::Cache::AddWriteTask(), and XrdPfc::Cache::ReleaseFile().

Here is the caller graph for this function:

GetLog()

XrdSysError * File::GetLog

(

)

Definition at line 1627 of file XrdPfcFile.cc.

{
   return Cache::GetInstance().GetLog();
}

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

Here is the call graph for this function:

GetNBlocks()

int XrdPfc::File::GetNBlocks ( ) const

inline

Definition at line 278 of file XrdPfcFile.hh.

{ return m_cfi.GetNBlocks(); }

References XrdPfc::Info::GetNBlocks().

Here is the call graph for this function:

GetNDownloadedBlocks()

int XrdPfc::File::GetNDownloadedBlocks ( ) const

inline

Definition at line 279 of file XrdPfcFile.hh.

{ return m_cfi.GetNDownloadedBlocks(); }

References XrdPfc::Info::GetNDownloadedBlocks().

Here is the call graph for this function:

GetPrefetchCountOnIO()

int XrdPfc::File::GetPrefetchCountOnIO

(

IO *

io

)

GetPrefetchedBytes()

long long XrdPfc::File::GetPrefetchedBytes ( ) const

inline

Definition at line 280 of file XrdPfcFile.hh.

{ return m_prefetch_bytes; }

GetPrefetchScore()

float File::GetPrefetchScore

(

)

const

Definition at line 1622 of file XrdPfcFile.cc.

{
   return m_prefetch_score;
}

GetRemoteLocations()

std::string File::GetRemoteLocations

(

)

const

Definition at line 1646 of file XrdPfcFile.cc.

{
   std::string s;
   if ( ! m_remote_locations.empty())
   {
      size_t      sl = 0;
      int         nl = 0;
      for (std::set<std::string>::iterator i = m_remote_locations.begin(); i != m_remote_locations.end(); ++i, ++nl)
      {
         sl += i->size();
      }
      s.reserve(2 + sl + 2*nl + nl - 1 + 1);
      s = '[';
      int j = 1;
      for (std::set<std::string>::iterator i = m_remote_locations.begin(); i != m_remote_locations.end(); ++i, ++j)
      {
         s += '"'; s += *i; s += '"';
         if (j < nl) s += ',';
      }
      s += ']';
   }
   else
   {
      s = "[]";
   }
   return s;
}

GetTrace()

XrdSysTrace * File::GetTrace

(

)

Definition at line 1632 of file XrdPfcFile.cc.

{
   return Cache::GetInstance().GetTrace();
}

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

Here is the call graph for this function:

inc_ref_cnt()

int XrdPfc::File::inc_ref_cnt ( )

inline

Definition at line 287 of file XrdPfcFile.hh.

{ return ++m_ref_cnt; }

initiate_emergency_shutdown()

long long File::initiate_emergency_shutdown

(

)

Definition at line 151 of file XrdPfcFile.cc.

{
   // Called from Cache::Unlink() when the file is currently open.
   // Cache::Unlink is also called on FSync error and when wrong number of bytes
   // is received from a remote read.
   //
   // From this point onward the file will not be written to, cinfo file will
   // not be updated, and all new read requests will return -ENOENT.
   //
   // File's entry in the Cache's active map is set to nullptr and will be
   // removed from there shortly, in any case, well before this File object
   // shuts down. Cache::Unlink() also reports the appropriate purge event.
 
   XrdSysCondVarHelper _lck(m_state_cond);
 
   m_in_shutdown = true;
 
   if (m_prefetch_state != kStopped && m_prefetch_state != kComplete)
   {
      m_prefetch_state = kStopped;
      cache()->DeRegisterPrefetchFile(this);
   }
 
   report_and_merge_delta_stats();
 
   return m_st_blocks;
}

Referenced by XrdPfc::Cache::UnlinkFile().

Here is the caller graph for this function:

ioActive()

bool File::ioActive

(

IO *

io

)

Initiate close. Return true if still IO active. Used in XrdPosixXrootd::Close()

Definition at line 239 of file XrdPfcFile.cc.

{
   // Returns true if delay is needed.
 
   TRACEF(Debug, "ioActive start for io " << io);
 
   std::string loc(io->GetLocation());
 
   {
      XrdSysCondVarHelper _lck(m_state_cond);
 
      IoSet_i mi = m_io_set.find(io);
 
      if (mi != m_io_set.end())
      {
         unsigned int n_active_reads = io->m_active_read_reqs;
 
         TRACE(Info, "ioActive for io " << io <<
                ", active_reads "       << n_active_reads <<
                ", active_prefetches "  << io->m_active_prefetches <<
                ", allow_prefetching "  << io->m_allow_prefetching <<
                ", ios_in_detach "      << m_ios_in_detach);
         TRACEF(Info,
                "\tio_map.size() "      << m_io_set.size() <<
                ", block_map.size() "   << m_block_map.size() << ", file");
 
         insert_remote_location(loc);
 
         io->m_allow_prefetching = false;
         io->m_in_detach = true;
 
         // Check if any IO is still available for prfetching. If not, stop it.
         if (m_prefetch_state == kOn || m_prefetch_state == kHold)
         {
            if ( ! select_current_io_or_disable_prefetching(false) )
            {
               TRACEF(Debug, "ioActive stopping prefetching after io " << io << " retreat.");
            }
         }
 
         // On last IO, consider write queue blocks. Note, this also contains
         // blocks being prefetched.
 
         bool io_active_result;
 
         if (n_active_reads > 0)
         {
            io_active_result = true;
         }
         else if (m_io_set.size() - m_ios_in_detach == 1)
         {
            io_active_result = ! m_block_map.empty();
         }
         else
         {
            io_active_result = io->m_active_prefetches > 0;
         }
 
         if ( ! io_active_result)
         {
            ++m_ios_in_detach;
         }
 
         TRACEF(Info, "ioActive for io " << io << " returning " << io_active_result << ", file");
 
         return io_active_result;
      }
      else
      {
         TRACEF(Error, "ioActive io " << io <<" not found in IoSet. This should not happen.");
         return false;
      }
   }
}

References Debug, Error, XrdPfc::IO::GetLocation(), XrdPfc::IO::m_active_read_reqs, TRACE, and TRACEF.

Referenced by XrdPfc::IOFile::ioActive().

Here is the call graph for this function:

Here is the caller graph for this function:

ioUpdated()

void File::ioUpdated

(

IO *

io

)

Notification from IO that it has been updated (remote open).

Definition at line 230 of file XrdPfcFile.cc.

{
   std::string loc(io->GetLocation());
   XrdSysCondVarHelper _lck(m_state_cond);
   insert_remote_location(loc);
}

References XrdPfc::IO::GetLocation().

Referenced by XrdPfc::IOFile::Update().

Here is the call graph for this function:

Here is the caller graph for this function:

is_in_emergency_shutdown()

bool XrdPfc::File::is_in_emergency_shutdown ( )

inline

Definition at line 291 of file XrdPfcFile.hh.

{ return m_in_shutdown; }

lPath()

const char * File::lPath

(

)

const

Log path.

Definition at line 1534 of file XrdPfcFile.cc.

{
   return m_filename.c_str();
}

Referenced by XrdPfc::Cache::ProcessWriteTasks(), and XrdPfc::Cache::RemoveWriteQEntriesFor().

Here is the caller graph for this function:

Prefetch()

void File::Prefetch

(

)

Definition at line 1549 of file XrdPfcFile.cc.

{
   // Check that block is not on disk and not in RAM.
   // TODO: Could prefetch several blocks at once!
   //       blks_max could be an argument
 
   BlockList_t blks;
 
   TRACEF(DumpXL, "Prefetch() entering.");
   {
      XrdSysCondVarHelper _lck(m_state_cond);
 
      if (m_prefetch_state != kOn)
      {
         return;
      }
 
      if ( ! select_current_io_or_disable_prefetching(true) )
      {
         TRACEF(Error, "Prefetch no available IO object found, prefetching stopped. This should not happen, i.e., prefetching should be stopped before.");
         return;
      }
 
      // Select block(s) to fetch.
      for (int f = 0; f < m_num_blocks; ++f)
      {
         if ( ! m_cfi.TestBitWritten(f))
         {
            int f_act = f + m_offset / m_block_size;
 
            BlockMap_i bi = m_block_map.find(f_act);
            if (bi == m_block_map.end())
            {
               Block *b = PrepareBlockRequest(f_act, *m_current_io, nullptr, true);
               if (b)
               {
                  TRACEF(Dump, "Prefetch take block " << f_act);
                  blks.push_back(b);
                  // Note: block ref_cnt not increased, it will be when placed into write queue.
 
                  inc_prefetch_read_cnt(1);
               }
               else
               {
                  // This shouldn't happen as prefetching stops when RAM is 70% full.
                  TRACEF(Warning, "Prefetch allocation failed for block " << f_act);
               }
               break;
            }
         }
      }
 
      if (blks.empty())
      {
         TRACEF(Debug, "Prefetch file is complete, stopping prefetch.");
         m_prefetch_state = kComplete;
         cache()->DeRegisterPrefetchFile(this);
      }
      else
      {
         (*m_current_io)->m_active_prefetches += (int) blks.size();
      }
   }
 
   if ( ! blks.empty())
   {
      ProcessBlockRequests(blks);
   }
}

References Debug, Error, XrdPfc::Info::TestBitWritten(), and TRACEF.

Referenced by XrdPfc::Cache::Prefetch().

Here is the call graph for this function:

Here is the caller graph for this function:

Read()

int File::Read	(	IO *	io,
		char *	buff,
		long long	offset,
		int	size,
		ReadReqRH *	rh
	)

Normal read.

Definition at line 748 of file XrdPfcFile.cc.

{
   // rrc_func is ONLY called from async processing.
   // If this function returns anything other than -EWOULDBLOCK, rrc_func needs to be called by the caller.
   // This streamlines implementation of synchronous IO::Read().
 
   TRACEF(Dump, "Read() sid: " << Xrd::hex1 << rh->m_seq_id << " size: " << iUserSize);
 
   m_state_cond.Lock();
 
   if (m_in_shutdown || io->m_in_detach)
   {
      m_state_cond.UnLock();
      return m_in_shutdown ? -ENOENT : -EBADF;
   }
 
   // Shortcut -- file is fully downloaded.
 
   if (m_cfi.IsComplete())
   {
      m_state_cond.UnLock();
      int ret = m_data_file->Read(iUserBuff, iUserOff, iUserSize);
      if (ret > 0) {
         XrdSysCondVarHelper _lck(m_state_cond);
         m_delta_stats.AddBytesHit(ret);
         check_delta_stats();
      }
      return ret;
   }
 
   XrdOucIOVec readV( { iUserOff, iUserSize, 0, iUserBuff } );
 
   return ReadOpusCoalescere(io, &readV, 1, rh, "Read() ");
}

References XrdPfc::Stats::AddBytesHit(), Xrd::hex1, XrdPfc::Info::IsComplete(), XrdSysCondVar::Lock(), XrdPfc::ReadReqRH::m_seq_id, XrdOssDF::Read(), TRACEF, and XrdSysCondVar::UnLock().

Referenced by XrdPfc::IOFileBlock::Read().

Here is the call graph for this function:

Here is the caller graph for this function:

ReadV()

int File::ReadV	(	IO *	io,
		const XrdOucIOVec *	readV,
		int	readVnum,
		ReadReqRH *	rh
	)

Vector read.

Definition at line 785 of file XrdPfcFile.cc.

{
   TRACEF(Dump, "ReadV() for " << readVnum << " chunks.");
 
   m_state_cond.Lock();
 
   if (m_in_shutdown || io->m_in_detach)
   {
      m_state_cond.UnLock();
      return m_in_shutdown ? -ENOENT : -EBADF;
   }
 
   // Shortcut -- file is fully downloaded.
 
   if (m_cfi.IsComplete())
   {
      m_state_cond.UnLock();
      int ret = m_data_file->ReadV(const_cast<XrdOucIOVec*>(readV), readVnum);
      if (ret > 0) {
         XrdSysCondVarHelper _lck(m_state_cond);
         m_delta_stats.AddBytesHit(ret);
         check_delta_stats();
      }
      return ret;
   }
 
   return ReadOpusCoalescere(io, readV, readVnum, rh, "ReadV() ");
}

References XrdPfc::Stats::AddBytesHit(), XrdPfc::Info::IsComplete(), XrdSysCondVar::Lock(), XrdOssDF::ReadV(), TRACEF, and XrdSysCondVar::UnLock().

Here is the call graph for this function:

RefStats()

const Stats & XrdPfc::File::RefStats ( ) const

inline

Definition at line 281 of file XrdPfcFile.hh.

{ return m_stats; }

RemoveIO()

void File::RemoveIO

(

IO *

io

)

Definition at line 383 of file XrdPfcFile.cc.

{
   // Called from Cache::ReleaseFile.
 
   TRACEF(Debug, "RemoveIO() io = " << (void*)io);
 
   time_t now = time(0);
 
   m_state_cond.Lock();
 
   IoSet_i mi = m_io_set.find(io);
 
   if (mi != m_io_set.end())
   {
      if (mi == m_current_io)
      {
         ++m_current_io;
      }
 
      m_delta_stats.IoDetach(now - io->m_attach_time);
      m_io_set.erase(mi);
      --m_ios_in_detach;
 
      if (m_io_set.empty() && m_prefetch_state != kStopped && m_prefetch_state != kComplete)
      {
         TRACEF(Error, "RemoveIO() io = " << (void*)io << " Prefetching is not stopped/complete -- it should be by now.");
         m_prefetch_state = kStopped;
         cache()->DeRegisterPrefetchFile(this);
      }
   }
   else
   {
      TRACEF(Error, "RemoveIO() io = " << (void*)io << " is NOT registered.");
   }
 
   m_state_cond.UnLock();
}

References Debug, Error, XrdPfc::Stats::IoDetach(), XrdSysCondVar::Lock(), TRACEF, and XrdSysCondVar::UnLock().

Referenced by XrdPfc::Cache::ReleaseFile().

Here is the call graph for this function:

Here is the caller graph for this function:

RequestSyncOfDetachStats()

void File::RequestSyncOfDetachStats

(

)

Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach.

Definition at line 316 of file XrdPfcFile.cc.

{
   XrdSysCondVarHelper _lck(m_state_cond);
   m_detach_time_logged = false;
}

Referenced by XrdPfc::IOFile::DetachFinalize().

Here is the caller graph for this function:

StopPrefetchingOnIO()

void XrdPfc::File::StopPrefetchingOnIO

(

IO *

io

)

Sync()

void File::Sync

(

)

Sync file cache inf o and output data with disk.

Definition at line 1148 of file XrdPfcFile.cc.

{
   TRACEF(Dump, "Sync()");
 
   int ret     = m_data_file->Fsync();
   bool errorp = false;
   if (ret == XrdOssOK)
   {
      Stats loc_stats;
      {
         XrdSysCondVarHelper _lck(&m_state_cond);
         report_and_merge_delta_stats();
         loc_stats = m_stats;
      }
      m_cfi.WriteIOStat(loc_stats);
      m_cfi.Write(m_info_file, m_filename.c_str());
      int cret = m_info_file->Fsync();
      if (cret != XrdOssOK)
      {
         TRACEF(Error, "Sync cinfo file sync error " << cret);
         errorp = true;
      }
   }
   else
   {
      TRACEF(Error, "Sync data file sync error " << ret << ", cinfo file has not been updated");
      errorp = true;
   }
 
   if (errorp)
   {
      TRACEF(Error, "Sync failed, unlinking local files and initiating shutdown of File object");
 
      // Unlink will also call this->initiate_emergency_shutdown()
      Cache::GetInstance().UnlinkFile(m_filename, false);
 
      XrdSysCondVarHelper _lck(&m_state_cond);
 
      m_writes_during_sync.clear();
      m_in_sync = false;
 
      return;
   }
 
   int  written_while_in_sync;
   bool resync = false;
   {
      XrdSysCondVarHelper _lck(&m_state_cond);
      for (std::vector<int>::iterator i = m_writes_during_sync.begin(); i != m_writes_during_sync.end(); ++i)
      {
         m_cfi.SetBitSynced(*i);
      }
      written_while_in_sync = m_non_flushed_cnt = (int) m_writes_during_sync.size();
      m_writes_during_sync.clear();
 
      // If there were writes during sync and the file is now complete,
      // let us call Sync again without resetting the m_in_sync flag.
      if (written_while_in_sync > 0 && m_cfi.IsComplete() && ! m_in_shutdown)
         resync = true;
      else
         m_in_sync = false;
   }
   TRACEF(Dump, "Sync "<< written_while_in_sync  << " blocks written during sync." << (resync ? " File is now complete - resyncing." : ""));
 
   if (resync)
      Sync();
}

References Error, XrdOssDF::Fsync(), XrdPfc::Cache::GetInstance(), XrdPfc::Info::IsComplete(), XrdPfc::Info::SetBitSynced(), Sync(), TRACEF, XrdPfc::Cache::UnlinkFile(), XrdPfc::Info::Write(), XrdPfc::Info::WriteIOStat(), and XrdOssOK.

Referenced by Sync().

Here is the call graph for this function:

Here is the caller graph for this function:

WriteBlockToDisk()

void File::WriteBlockToDisk

(

Block *

b

)

Definition at line 1068 of file XrdPfcFile.cc.

{
   // write block buffer into disk file
   long long   offset = b->m_offset - m_offset;
   long long   size   = b->get_size();
   ssize_t     retval;
 
   if (m_cfi.IsCkSumCache())
      if (b->has_cksums())
         retval = m_data_file->pgWrite(b->get_buff(), offset, size, b->ref_cksum_vec().data(), 0);
      else
         retval = m_data_file->pgWrite(b->get_buff(), offset, size, 0, 0);
   else
      retval = m_data_file->Write(b->get_buff(), offset, size);
 
   if (retval < size)
   {
      if (retval < 0) {
         TRACEF(Error, "WriteToDisk() write error " << retval);
      } else {
         TRACEF(Error, "WriteToDisk() incomplete block write ret=" << retval << " (should be " << size << ")");
      }
 
      XrdSysCondVarHelper _lck(m_state_cond);
 
      dec_ref_count(b);
 
      return;
   }
 
   const int blk_idx =  (b->m_offset - m_offset) / m_block_size;
 
   // Set written bit.
   TRACEF(Dump, "WriteToDisk() success set bit for block " <<  b->m_offset << " size=" <<  size);
 
   bool schedule_sync = false;
   {
      XrdSysCondVarHelper _lck(m_state_cond);
 
      m_cfi.SetBitWritten(blk_idx);
 
      if (b->m_prefetch)
      {
         m_cfi.SetBitPrefetch(blk_idx);
      }
      if (b->req_cksum_net() && ! b->has_cksums() && m_cfi.IsCkSumNet())
      {
         m_cfi.ResetCkSumNet();
      }
 
      dec_ref_count(b);
 
      // Set synced bit or stash block index if in actual sync.
      // Synced state is only written out to cinfo file when data file is synced.
      if (m_in_sync)
      {
         m_writes_during_sync.push_back(blk_idx);
      }
      else
      {
         m_cfi.SetBitSynced(blk_idx);
         ++m_non_flushed_cnt;
         if ((m_cfi.IsComplete() || m_non_flushed_cnt >= Cache::GetInstance().RefConfiguration().m_flushCnt) &&
             ! m_in_shutdown)
         {
            schedule_sync     = true;
            m_in_sync         = true;
            m_non_flushed_cnt = 0;
         }
      }
   }
 
   if (schedule_sync)
   {
      cache()->ScheduleFileSync(this);
   }
}

References Error, XrdPfc::Block::get_buff(), XrdPfc::Block::get_size(), XrdPfc::Cache::GetInstance(), XrdPfc::Block::has_cksums(), XrdPfc::Info::IsCkSumCache(), XrdPfc::Info::IsCkSumNet(), XrdPfc::Info::IsComplete(), XrdPfc::Configuration::m_flushCnt, XrdPfc::Block::m_offset, XrdPfc::Block::m_prefetch, XrdOssDF::pgWrite(), XrdPfc::Block::ref_cksum_vec(), XrdPfc::Cache::RefConfiguration(), XrdPfc::Block::req_cksum_net(), XrdPfc::Info::ResetCkSumNet(), XrdPfc::Info::SetBitPrefetch(), XrdPfc::Info::SetBitSynced(), XrdPfc::Info::SetBitWritten(), TRACEF, and XrdOssDF::Write().

Referenced by XrdPfc::Cache::ProcessWriteTasks().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Symbol Documentation

BlockResponseHandler

friend class BlockResponseHandler

friend

Definition at line 205 of file XrdPfcFile.hh.

Cache

friend class Cache

friend

Definition at line 204 of file XrdPfcFile.hh.

DirectResponseHandler

friend class DirectResponseHandler

friend

Definition at line 206 of file XrdPfcFile.hh.

---

The documentation for this class was generated from the following files:

• XrdPfcFile.hh
• XrdPfcFile.cc