replUtil.cpp File Reference

#include <sys/time.h>
#include "rodsPath.h"
#include "rodsErrorTable.h"
#include "rodsLog.h"
#include "miscUtil.h"
#include "replUtil.h"
#include "rcGlobalExtern.h"

Include dependency graph for replUtil.cpp:

Go to the source code of this file.

Functions
int	replUtil (rcComm_t *conn, rodsEnv *myRodsEnv, rodsArguments_t *myRodsArgs, rodsPathInp_t *rodsPathInp)
int	replDataObjUtil (rcComm_t *conn, char *srcPath, rodsLong_t srcSize, rodsArguments_t *rodsArgs, dataObjInp_t *dataObjInp)
int	initCondForRepl (rodsEnv *myRodsEnv, rodsArguments_t *rodsArgs, dataObjInp_t *dataObjInp, rodsRestart_t *rodsRestart)
int	replCollUtil (rcComm_t *conn, char *srcColl, rodsEnv *myRodsEnv, rodsArguments_t *rodsArgs, dataObjInp_t *dataObjInp, rodsRestart_t *rodsRestart)

Function Documentation

initCondForRepl()

int initCondForRepl	(	rodsEnv *	myRodsEnv,
		rodsArguments_t *	rodsArgs,
		dataObjInp_t *	dataObjInp,
		rodsRestart_t *	rodsRestart
	)

Definition at line 139 of file replUtil.cpp.

References addKeyVal(), rodsArguments_t::admin, ADMIN_KW, rodsArguments_t::all, ALL_KW, BACKUP_RESC_NAME_KW, rodsArguments_t::backupMode, DataObjInp::condInput, DEF_RESC_NAME_KW, DEST_RESC_NAME_KW, LOCK_TYPE_KW, LOG_ERROR, NO_THREADING, NULL, rodsArguments_t::number, rodsArguments_t::numberValue, DataObjInp::numThreads, openRestartFile(), PURGE_CACHE_KW, rodsArguments_t::purgeCache, rodsArguments_t::rbudp, RBUDP_PACK_SIZE_KW, RBUDP_SEND_RATE_KW, RBUDP_TRANSFER_KW, READ_LOCK_TYPE, REPL_NUM_KW, rodsArguments_t::replNum, rodsArguments_t::replNumValue, RESC_NAME_KW, rodsArguments_t::resource, rodsArguments_t::resourceString, rodsArguments_t::restart, rodsArguments_t::restartFileString, rodsArguments_t::rlock, rodsEnv::rodsDefResource, rodsLog(), rodsLogError(), rodsArguments_t::srcResc, rodsArguments_t::srcRescString, irods.pypyodbc::status, True, rodsArguments_t::unmount, UPDATE_REPL_KW, USER__NULL_INPUT_ERR, VERY_VERBOSE_KW, rodsArguments_t::veryVerbose, and rodsArguments_t::wlock.

Referenced by replUtil().

Here is the call graph for this function:

replCollUtil()

int replCollUtil	(	rcComm_t *	conn,
		char *	srcColl,
		rodsEnv *	myRodsEnv,
		rodsArguments_t *	rodsArgs,
		dataObjInp_t *	dataObjInp,
		rodsRestart_t *	rodsRestart
	)

Definition at line 256 of file replUtil.cpp.

References CAT_NO_ROWS_FOUND, chkStateForResume(), COLL_OBJ_T, SpecColl::collClass, CollEnt::collName, DataObjInp::condInput, DATA_OBJ_T, CollEnt::dataName, collHandle_t::dataObjInp, CollEnt::dataSize, rodsRestart_t::fd, INCLUDE_CONDINPUT_IN_QUERY, LINKED_COLL, LOG_ERROR, MAX_NAME_LEN, NO_SPEC_COLL, NULL, CollEnt::objType, procAndWriteRestartFile(), rclCloseCollection(), rclOpenCollection(), rclReadCollection(), rodsArguments_t::recursive, replDataObjUtil(), replKeyVal(), rodsLog(), rodsLogError(), collHandle_t::rodsObjStat, DataObjInp::specColl, rodsObjStat::specColl, CollEnt::specColl, irods.pypyodbc::status, SYS_COPY_ALREADY_IN_RESC, True, USER__NULL_INPUT_ERR, USER_INPUT_OPTION_ERR, and rodsArguments_t::verbose.

Referenced by replUtil().

Here is the call graph for this function:

replDataObjUtil()

int replDataObjUtil	(	rcComm_t *	conn,
		char *	srcPath,
		rodsLong_t	srcSize,
		rodsArguments_t *	rodsArgs,
		dataObjInp_t *	dataObjInp
	)

Definition at line 96 of file replUtil.cpp.

References transferStat_t::bytesWritten, OperProgress::curFileName, OperProgress::curFileSize, OperProgress::curFileSizeDone, OperProgress::flag, gGuiProgressCB, LOG_ERROR, MAX_NAME_LEN, NULL, DataObjInp::objPath, rcComm_t::operProgress, printTiming(), rcDataObjRepl(), rodsLog(), rstrcpy(), irods.pypyodbc::status, OperProgress::totalFileSizeDone, OperProgress::totalNumFilesDone, rcComm_t::transStat, True, USER__NULL_INPUT_ERR, and rodsArguments_t::verbose.

Referenced by replCollUtil(), and replUtil().

Here is the call graph for this function:

replUtil()

int replUtil	(	rcComm_t *	conn,
		rodsEnv *	myRodsEnv,
		rodsArguments_t *	myRodsArgs,
		rodsPathInp_t *	rodsPathInp
	)

Definition at line 14 of file replUtil.cpp.

References addKeyVal(), CAT_NO_ROWS_FOUND, COLL_OBJ_T, DataObjInp::condInput, DATA_OBJ_T, rodsRestart_t::fd, getCollSizeForProgStat(), getRodsObjType(), gGuiProgressCB, initCondForRepl(), LOG_ERROR, NOT_EXIST_ST, NULL, RodsPathInp::numSrc, RodsPath::objState, RodsPath::objType, rcComm_t::operProgress, RodsPath::outPath, replCollUtil(), replDataObjUtil(), rmKeyVal(), rodsLog(), rodsLogError(), setStateForRestart(), RodsPath::size, RodsPathInp::srcPath, irods.pypyodbc::status, OperProgress::totalFileSize, OperProgress::totalNumFiles, TRANSLATED_PATH_KW, UNKNOWN_OBJ_T, USER__NULL_INPUT_ERR, and USER_INPUT_PATH_ERR.

Here is the call graph for this function: