irods
4.2.8
About: iRODS (the integrated Rule Oriented Data System) is a distributed data-management system for creating data grids, digital libraries, persistent archives, and real-time data systems.
![]() ![]() |
#include <sys/time.h>
#include "rodsPath.h"
#include "rodsErrorTable.h"
#include "rodsLog.h"
#include "miscUtil.h"
#include "cpUtil.h"
#include "rcGlobalExtern.h"
#include "irods_virtual_path.hpp"
Go to the source code of this file.
Functions | |
int | cpUtil (rcComm_t *conn, rodsEnv *myRodsEnv, rodsArguments_t *myRodsArgs, rodsPathInp_t *rodsPathInp) |
int | cpFileUtil (rcComm_t *conn, char *srcPath, char *targPath, rodsLong_t srcSize, rodsArguments_t *rodsArgs, dataObjCopyInp_t *dataObjCopyInp) |
int | initCondForCp (rodsEnv *myRodsEnv, rodsArguments_t *rodsArgs, dataObjCopyInp_t *dataObjCopyInp, rodsRestart_t *rodsRestart) |
int | cpCollUtil (rcComm_t *conn, char *srcColl, char *targColl, rodsEnv *myRodsEnv, rodsArguments_t *rodsArgs, dataObjCopyInp_t *dataObjCopyInp, rodsRestart_t *rodsRestart) |
int cpCollUtil | ( | rcComm_t * | conn, |
char * | srcColl, | ||
char * | targColl, | ||
rodsEnv * | myRodsEnv, | ||
rodsArguments_t * | rodsArgs, | ||
dataObjCopyInp_t * | dataObjCopyInp, | ||
rodsRestart_t * | rodsRestart | ||
) |
Definition at line 276 of file cpUtil.cpp.
References BAD_FUNCTION_CALL, CAT_NO_ROWS_FOUND, chkStateForResume(), COLL_OBJ_T, SpecColl::collClass, CollEnt::collName, DataObjInp::condInput, cpFileUtil(), DATA_OBJ_T, CollEnt::dataName, CollEnt::dataSize, DataObjCopyInp::destDataObjInp, rodsRestart_t::fd, irods::get_virtual_path_separator(), LOG_ERROR, MAX_NAME_LEN, mkCollR(), NO_SPEC_COLL, NULL, CollEnt::objType, procAndWriteRestartFile(), rclCloseCollection(), rclOpenCollection(), rclReadCollection(), rodsArguments_t::recursive, rodsLog(), rodsLogError(), SAME_SRC_DEST_PATHS_ERR, DataObjInp::specColl, CollEnt::specColl, splitPathByKey(), DataObjCopyInp::srcDataObjInp, irods.pypyodbc::status, SYS_SPEC_COLL_OBJ_NOT_EXIST, True, USER__NULL_INPUT_ERR, USER_INPUT_OPTION_ERR, and rodsArguments_t::verbose.
Referenced by cpUtil().
int cpFileUtil | ( | rcComm_t * | conn, |
char * | srcPath, | ||
char * | targPath, | ||
rodsLong_t | srcSize, | ||
rodsArguments_t * | rodsArgs, | ||
dataObjCopyInp_t * | dataObjCopyInp | ||
) |
Definition at line 112 of file cpUtil.cpp.
References transferStat_t::bytesWritten, OperProgress::curFileName, OperProgress::curFileSize, OperProgress::curFileSizeDone, DataObjInp::dataSize, DataObjCopyInp::destDataObjInp, OperProgress::flag, gGuiProgressCB, LOG_ERROR, MAX_NAME_LEN, NULL, DataObjInp::objPath, rcComm_t::operProgress, printTiming(), rcDataObjCopy(), rodsLog(), rstrcpy(), DataObjCopyInp::srcDataObjInp, irods.pypyodbc::status, OperProgress::totalFileSizeDone, OperProgress::totalNumFilesDone, rcComm_t::transStat, True, USER__NULL_INPUT_ERR, and rodsArguments_t::verbose.
Referenced by cpCollUtil(), and cpUtil().
int cpUtil | ( | rcComm_t * | conn, |
rodsEnv * | myRodsEnv, | ||
rodsArguments_t * | myRodsArgs, | ||
rodsPathInp_t * | rodsPathInp | ||
) |
Definition at line 15 of file cpUtil.cpp.
References addKeyVal(), CAT_NO_ROWS_FOUND, COLL_OBJ_T, SpecColl::collClass, DataObjInp::condInput, cpCollUtil(), cpFileUtil(), DATA_OBJ_T, rodsRestart_t::fd, getCollSizeForProgStat(), gGuiProgressCB, initCondForCp(), LOG_ERROR, NULL, RodsPathInp::numSrc, RodsPath::objType, rcComm_t::operProgress, RodsPath::outPath, PUT_OPR, resolveRodsTarget(), rmKeyVal(), rodsLog(), rodsLogError(), RodsPath::rodsObjStat, setStateForRestart(), RodsPath::size, DataObjInp::specColl, rodsObjStat::specColl, DataObjCopyInp::srcDataObjInp, RodsPathInp::srcPath, irods.pypyodbc::status, STRUCT_FILE_COLL, SYS_SPEC_COLL_OBJ_NOT_EXIST, RodsPathInp::targPath, OperProgress::totalFileSize, OperProgress::totalNumFiles, TRANSLATED_PATH_KW, USER__NULL_INPUT_ERR, and USER_INPUT_PATH_ERR.
int initCondForCp | ( | rodsEnv * | myRodsEnv, |
rodsArguments_t * | rodsArgs, | ||
dataObjCopyInp_t * | dataObjCopyInp, | ||
rodsRestart_t * | rodsRestart | ||
) |
Definition at line 157 of file cpUtil.cpp.
References addKeyVal(), rodsArguments_t::checksum, DataObjInp::condInput, DATA_TYPE_KW, rodsArguments_t::dataType, rodsArguments_t::dataTypeString, DEST_RESC_NAME_KW, DataObjCopyInp::destDataObjInp, FILE_PATH_KW, rodsArguments_t::force, FORCE_FLAG_KW, LOG_ERROR, NO_THREADING, NULL, rodsArguments_t::number, rodsArguments_t::numberValue, DataObjInp::numThreads, DataObjInp::openFlags, openRestartFile(), rodsArguments_t::physicalPath, rodsArguments_t::physicalPathString, rodsArguments_t::rbudp, RBUDP_PACK_SIZE_KW, RBUDP_SEND_RATE_KW, RBUDP_TRANSFER_KW, REG_CHKSUM_KW, rodsArguments_t::resource, rodsArguments_t::resourceString, rodsArguments_t::restart, rodsArguments_t::restartFileString, rodsEnv::rodsDefResource, rodsLog(), rodsLogError(), DataObjCopyInp::srcDataObjInp, irods.pypyodbc::status, True, USER__NULL_INPUT_ERR, VERIFY_CHKSUM_KW, rodsArguments_t::verifyChecksum, VERY_VERBOSE_KW, and rodsArguments_t::veryVerbose.
Referenced by cpUtil().