xrootd
Classes | Defines | Functions | Variables
Xrdcp.cc File Reference
#include "XrdClient/XrdClientUrlInfo.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XrdClient/XrdClient.hh"
#include "XrdClient/XrdCpMthrQueue.hh"
#include "XrdClient/XrdClientDebug.hh"
#include "XrdClient/XrdCpWorkLst.hh"
#include "XrdClient/XrdClientEnv.hh"
#include "XrdSys/XrdSysPlatform.hh"
#include <XrdCrypto/XrdCryptoFactory.hh>
#include <XrdCrypto/XrdCryptoMsgDigest.hh>
#include "XrdClient/XrdClientAbsMonIntf.hh"
#include "XrdClient/XrdcpXtremeRead.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 Xrdcp.cc:

Classes

struct  XrdCpInfo
struct  xtreme_threadnfo

Defines

#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, unsigned int adler)
void print_progbar (unsigned long long bytesread, unsigned long long size)
void print_chksum (const char *src, unsigned long long bytesread, unsigned adler)
XrdOucString AddSizeHint (const char *dst, off_t size)
void * ReaderThread_xrd (void *)
void * ReaderThread_xrd_xtreme (void *parm)
void * ReaderThread_loc (void *)
int CreateDestPath_loc (XrdOucString path, bool isdir)
void BuildFullDestFilename (XrdOucString &src, XrdOucString &dest, bool destisdir)
int CreateDestPath_xrd (XrdOucString url, bool isdir)
int doCp_xrd2xrd (XrdClient **xrddest, const char *src, const char *dst)
XrdClientBWMToken_Init (const char *bwmhost, const char *srcurl, const char *dsturl)
bool BWMToken_WaitFor (XrdClient *cli)
int doCp_xrd2loc (const char *src, const char *dst)
int doCp_loc2xrd (XrdClient **xrddest, const char *src, const char *dst)
void PrintUsage ()
int main (int argc, char **argv)

Variables

const char * XrdcpCVSID = "$Id$"
struct XrdCpInfo cpnfo
bool summary = false
bool progbar = true
bool md5 = false
bool adlerchk = false
XrdOucString monlibname = "libXrdCpMonitorClient.so"
char * srcopaque = 0
char * dstopaque = 0
kXR_unt16 xrd_wr_flags = kXR_async | kXR_mkpath | kXR_open_updt | kXR_new
int loc_wr_flags = LOC_WR_FLAGS
bool recurse = false
char BWMHost [1024]
bool doXtremeCp = false
XrdOucString XtremeCpRdr
struct timeval abs_start_time
struct timeval abs_stop_time
struct timezone tz
unsigned int adler = 0

Define 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 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

XrdOucString AddSizeHint ( const char *  dst,
off_t  size 
)
void BuildFullDestFilename ( XrdOucString src,
XrdOucString dest,
bool  destisdir 
)
XrdClient* BWMToken_Init ( const char *  bwmhost,
const char *  srcurl,
const char *  dsturl 
)
bool BWMToken_WaitFor ( XrdClient cli)
void cerr_print ( const char *  format,
  ... 
)
void cout_print ( const char *  format,
  ... 
)
int CreateDestPath_loc ( XrdOucString  path,
bool  isdir 
)
int CreateDestPath_xrd ( XrdOucString  url,
bool  isdir 
)
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 main ( int  argc,
char **  argv 
)
void print_chksum ( const char *  src,
unsigned long long  bytesread,
unsigned  adler 
)
void print_progbar ( unsigned long long  bytesread,
unsigned long long  size 
)
void print_summary ( const char *  src,
const char *  dst,
unsigned long long  bytesread,
unsigned int  adler 
)
void PrintUsage ( )
void* ReaderThread_loc ( void *  )
void* ReaderThread_xrd ( void *  )
void* ReaderThread_xrd_xtreme ( void *  parm)

Variable Documentation

struct timeval abs_start_time
struct timeval abs_stop_time
unsigned int adler = 0

Referenced by main().

bool adlerchk = false
char BWMHost[1024]

Referenced by doCp_xrd2loc(), and main().

struct XrdCpInfo cpnfo
bool doXtremeCp = false

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

char * dstopaque = 0

Referenced by main().

int loc_wr_flags = LOC_WR_FLAGS

Referenced by doCp_xrd2loc(), and main().

bool md5 = false
XrdOucString monlibname = "libXrdCpMonitorClient.so"
bool progbar = true
bool recurse = false

Referenced by main().

char* srcopaque = 0

Referenced by main().

bool summary = false
struct timezone tz
kXR_unt16 xrd_wr_flags = kXR_async | kXR_mkpath | kXR_open_updt | kXR_new
const char* XrdcpCVSID = "$Id$"