XrdcpXtremeRead.hh

Go to the documentation of this file.

//////////////////////////////////////////////////////////////////////////
//                                                                      //
// XrdXtremeRead                                                        //
//                                                                      //
// Author: Fabrizio Furano (CERN, 2009)                                 //
//                                                                      //
// Utility classes handling Extreme readers, i.e. coordinated parallel  //
//  reads from multiple XrdClient instances                             //
//                                                                      //
//////////////////////////////////////////////////////////////////////////

//         $Id: XrdcpXtremeRead.hh 30949 2009-11-02 16:37:58Z ganis $

#include "XrdSys/XrdSysPthread.hh"
#include "XrdClient/XrdClient.hh"
#include "XrdClient/XrdClientVector.hh"

class XrdXtRdBlkInfo {
public:
   long long offs;
   int len;
   time_t lastrequested;

   // Nothing more to do, block acquired
   bool done;

   // The seq of the clientidxs which requested this blk
   XrdClientVector<int> requests;

   bool AlreadyRequested(int clientIdx) {
      for (int i = 0; i < requests.GetSize(); i++)
         if (requests[i] == clientIdx) return true;
      return false;
   }

   XrdXtRdBlkInfo() {offs = 0; len = 0; done = false; requests.Clear(); lastrequested = 0; }
};

class XrdXtRdFile {
private:
   int clientidxcnt;         // counter to assign client idxs
   XrdSysRecMutex mtx;       // mutex to protect data structures

   int freeblks;    // Blocks not yet assigned to readers
   int nblks;       // Total number of blocks
   int doneblks;    // Xferred blocks

   XrdXtRdBlkInfo *blocks;

public:

   // Models a file as a sequence of blocks, which can be attrbuted to
   //  different readers
   XrdXtRdFile(int blksize, long long filesize);
   ~XrdXtRdFile();

   bool AllDone() { XrdSysMutexHelper m(mtx); return (doneblks >= nblks); }

   // Gives a unique ID which can identify a reader client in the game
   int GimmeANewClientIdx();

   int GetNBlks() { return nblks; }

   // Finds a block to prefetch and then read
   // Atomically associates it to a client idx
   // Returns the blk index
   int GetBlkToPrefetch(int fromidx, int clientIdx, XrdXtRdBlkInfo *&blkreadonly);
   int GetBlkToRead(int fromidx, int clientidx, XrdXtRdBlkInfo *&blkreadonly);

   void MarkBlkAsRequested(int blkidx);
   int MarkBlkAsRead(int blkidx);

   static int GetListOfSources(XrdClient *ref, XrdOucString xtrememgr, XrdClientVector<XrdClient *> &clients);


};

---