xrootd
Classes | Namespaces | Macros | Functions | Variables
XrdCpy.cc File Reference
#include "XrdClient/XrdClientUrlInfo.hh"
#include "XrdClient/XrdClientReadCache.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XrdClient/XrdClient.hh"
#include "XrdClient/XrdCpMthrQueue.hh"
#include "XrdClient/XrdClientConn.hh"
#include "XrdClient/XrdClientDebug.hh"
#include "XrdClient/XrdCpWorkLst.hh"
#include "XrdClient/XrdClientEnv.hh"
#include "XrdSys/XrdSysPlatform.hh"
#include "XrdClient/XrdClientAbsMonIntf.hh"
#include "XrdClient/XrdcpXtremeRead.hh"
#include "XrdCks/XrdCks.hh"
#include "XrdCks/XrdCksCalc.hh"
#include "XrdCks/XrdCksData.hh"
#include "XrdApps/XrdCpConfig.hh"
#include "XrdApps/XrdCpFile.hh"
#include "XrdOuc/XrdOucTokenizer.hh"
#include "XrdOuc/XrdOucTPC.hh"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sstream>
#include <sys/time.h>
#include <unistd.h>
#include <dlfcn.h>
#include <stdarg.h>
#include <stdio.h>
Include dependency graph for XrdCpy.cc:

Classes

struct  XrdCpInfo
 
struct  xtreme_threadnfo
 

Namespaces

namespace  XrdCopy
 

Macros

#define EMSG(x)
 
#define COUT(s)
 
#define CERR(s)
 
#define XRDCP_BLOCKSIZE   (8*1024*1024)
 
#define XRDCP_XRDRASIZE   (30*XRDCP_BLOCKSIZE)
 
#define XRDCP_VERSION   "(C) 2004-2011 by the XRootD collaboration. Version: "XrdVSTRING
 
#define LOC_WR_FLAGS_FORCE   ( O_CREAT | O_WRONLY | O_TRUNC | O_BINARY );
 
#define LOC_WR_FLAGS   ( O_CREAT | O_WRONLY | O_EXCL | O_BINARY );
 

Functions

void cout_print (const char *format,...)
 
void cerr_print (const char *format,...)
 
void print_summary (const char *src, const char *dst, unsigned long long bytesread)
 
void print_progbar (unsigned long long bytesread, unsigned long long size)
 
void print_chksum (const char *src, unsigned long long bytesread)
 
void * doProgBar (void *Parm)
 
void undoProgBar (int isOK)
 
int cpFatal (const char *Act, XrdClient *cSrc, XrdClient *cDst)
 
const char * getFName (const char *Url)
 
void * ReaderThread_xrd (void *)
 
void * ReaderThread_xrd_xtreme (void *parm)
 
void * ReaderThread_loc (void *)
 
int CreateDestPath_loc (XrdOucString path, bool isdir)
 
int getCksum (XrdCksData &cksData, const char *Path)
 
int valTPC (XrdClient *cObj, int isDest)
 
char * genDestCgi (XrdClient *xrdsrc, const char *src)
 
int doCp_xrd3xrd (XrdClient *xrddest, const char *src, const char *dst)
 
int doCp_xrd2xrd (XrdClient **xrddest, const char *src, const char *dst)
 
int doCp_xrd2loc (const char *src, const char *dst)
 
int doCp_loc2xrd (XrdClient **xrddest, const char *src, const char *dst)
 
int doCp (XrdOucString &src, XrdOucString &dest, XrdClient *xrddest)
 
int main (int argc, char **argv)
 

Variables

XrdCpConfig XrdCopy::Config ("xrdcp")
 
XrdCksData XrdCopy::srcCksum
 
XrdCksData XrdCopy::dstCksum
 
XrdCksCalcXrdCopy::csObj
 
XrdClientXrdCopy::tpcSrc
 
char XrdCopy::tpcKey [32]
 
long long XrdCopy::tpcFileSize
 
pthread_t XrdCopy::tpcTID
 
int XrdCopy::tpcPB
 
int XrdCopy::isSrv
 
int XrdCopy::isTPC
 
int XrdCopy::getCks
 
int XrdCopy::lenCks
 
int XrdCopy::prtCks
 
int XrdCopy::setCks
 
int XrdCopy::verCks
 
int XrdCopy::xeqCks
 
static const int XrdCopy::rwMode = kXR_ur | kXR_uw | kXR_gw | kXR_gr | kXR_or
 
struct XrdCpInfo cpnfo
 
bool summary =false
 
bool progbar =true
 
bool Verbose =true
 
XrdOucString monlibname = "libXrdCpMonitorClient.so"
 
kXR_unt16 xrd_wr_flags =kXR_async | kXR_mkpath | kXR_open_updt | kXR_new
 
int loc_wr_flags = LOC_WR_FLAGS
 
bool recurse = false
 
bool doXtremeCp = false
 
XrdOucString XtremeCpRdr
 
struct timeval abs_start_time
 
struct timeval abs_stop_time
 
struct timezone tz
 

Macro Definition Documentation

#define CERR (   s)
Value:
do { \
cerr_print s; \
} while (0)

Referenced by print_progbar().

#define COUT (   s)
Value:
do { \
cout_print s; \
} while (0)

Referenced by print_summary().

#define EMSG (   x)
#define LOC_WR_FLAGS   ( O_CREAT | O_WRONLY | O_EXCL | O_BINARY );
#define LOC_WR_FLAGS_FORCE   ( O_CREAT | O_WRONLY | O_TRUNC | O_BINARY );

Referenced by main().

#define XRDCP_BLOCKSIZE   (8*1024*1024)
#define XRDCP_VERSION   "(C) 2004-2011 by the XRootD collaboration. Version: "XrdVSTRING

Referenced by main().

#define XRDCP_XRDRASIZE   (30*XRDCP_BLOCKSIZE)

Referenced by main().

Function Documentation

void cerr_print ( const char *  format,
  ... 
)
void cout_print ( const char *  format,
  ... 
)
int cpFatal ( const char *  Act,
XrdClient cSrc,
XrdClient cDst 
)
int CreateDestPath_loc ( XrdOucString  path,
bool  isdir 
)
int doCp ( XrdOucString src,
XrdOucString dest,
XrdClient xrddest 
)
int doCp_loc2xrd ( XrdClient **  xrddest,
const char *  src,
const char *  dst 
)
int doCp_xrd2loc ( const char *  src,
const char *  dst 
)
int doCp_xrd2xrd ( XrdClient **  xrddest,
const char *  src,
const char *  dst 
)
int doCp_xrd3xrd ( XrdClient xrddest,
const char *  src,
const char *  dst 
)
void* doProgBar ( void *  Parm)
char* genDestCgi ( XrdClient xrdsrc,
const char *  src 
)
int getCksum ( XrdCksData cksData,
const char *  Path 
)
const char* getFName ( const char *  Url)
int main ( int  argc,
char **  argv 
)

References XrdOucString::c_str(), XrdCpConfig::CksData, XrdCopy::Config, XrdCpConfig::Config(), cpFatal(), cpnfo, DebugLevel, DebugSetLevel, XrdClientAbsMonIntf::DeInit(), XrdCpConfig::Dlvl, XrdCpConfig::DoCkprt, XrdCpConfig::DoCksum, XrdCpConfig::DoCoerce, doCp(), XrdCpConfig::DoForce, XrdCpConfig::DoNoPbar, XrdCpConfig::DoPosc, XrdCpConfig::DoProxy, XrdCpConfig::DoRecurse, XrdCpConfig::DoRetry, XrdCpConfig::DoServer, XrdCpConfig::DoSilent, XrdCpConfig::DoSources, XrdCpConfig::DoStreams, XrdCpConfig::DoTpc, doXtremeCp, XrdCpConfig::dstFile, XrdCpConfig::dstOpq, EMSG, EnvGetLong, EnvPutInt, EnvPutString, genDestCgi(), XrdCopy::getCks, XrdCpWorkLst::GetCpJob(), XrdClientAbsMonIntf::GetMonLibInfo(), Info, XrdClientAbsMonIntf::Init(), XrdCpConfig::intDefs, XrdCpConfig::defVar::intVal, XrdCopy::isSrv, XrdCopy::isTPC, XrdClientReadCache::kRmBlk_LeastOffs, XrdClientDebug::kUSERDEBUG, kXR_delete, kXR_force, kXR_new, kXR_posc, XrdCpInfo::len, XrdCksData::Length, loc_wr_flags, LOC_WR_FLAGS_FORCE, XrdCpInfo::mon, monlibname, NAME_CONNECTDOMAINALLOW_RE, NAME_CONNECTDOMAINDENY_RE, NAME_CONNECTTIMEOUT, NAME_DEBUG, NAME_FIRSTCONNECTMAXCNT, NAME_MULTISTREAMCNT, NAME_PURGEWRITTENBLOCKS, NAME_READAHEADSIZE, NAME_READCACHEBLKREMPOLICY, NAME_READCACHESIZE, NAME_REDIRDOMAINALLOW_RE, NAME_REDIRDOMAINDENY_RE, NAME_SOCKS4HOST, NAME_SOCKS4PORT, XrdCpConfig::defVar::Next, XrdCpConfig::nSrcs, XrdCpConfig::nStrm, XrdCpConfig::opt1Src, XrdCpConfig::optNoStdIn, XrdCpConfig::optNoXtnd, XrdCpFile::Path, XrdCpConfig::pHost, XrdCpConfig::pPort, progbar, XrdCopy::prtCks, XrdClientAbsMonIntf::PutProgressInfo(), recurse, XrdCpConfig::Retry, XrdCopy::setCks, XrdCpWorkLst::SetDest(), XrdCpWorkLst::SetSrc(), XrdCpConfig::srcFile, XrdCpConfig::srcOpq, XrdCpConfig::strDefs, XrdCpConfig::defVar::strVal, summary, XrdCopy::tpcPB, XrdCopy::tpcSrc, XrdCpConfig::Verbose, Verbose, XrdCopy::verCks, XrdCpConfig::defVar::vName, XrdCpConfig::Want(), XrdCopy::xeqCks, xrd_wr_flags, XrdCpInfo::XrdCli, XRDCP_VERSION, XRDCP_XRDRASIZE, and XtremeCpRdr.

void print_chksum ( const char *  src,
unsigned long long  bytesread 
)
void print_progbar ( unsigned long long  bytesread,
unsigned long long  size 
)
void print_summary ( const char *  src,
const char *  dst,
unsigned long long  bytesread 
)
void* ReaderThread_loc ( void *  )
void* ReaderThread_xrd ( void *  )
void* ReaderThread_xrd_xtreme ( void *  parm)
void undoProgBar ( int  isOK)
int valTPC ( XrdClient cObj,
int  isDest 
)

Variable Documentation

struct timeval abs_start_time
struct timeval abs_stop_time
struct XrdCpInfo cpnfo
bool doXtremeCp = false

Referenced by doCp_xrd2loc(), doCp_xrd2xrd(), and main().

int loc_wr_flags = LOC_WR_FLAGS

Referenced by doCp_xrd2loc(), and main().

XrdOucString monlibname = "libXrdCpMonitorClient.so"

Referenced by main().

bool progbar =true
bool recurse = false

Referenced by main().

bool summary =false
struct timezone tz
bool Verbose =true

Referenced by doCp_loc2xrd(), doCp_xrd2xrd(), and main().

XrdOucString XtremeCpRdr

Referenced by doCp_xrd2loc(), doCp_xrd2xrd(), and main().