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.
  Fossies Dox: irods-4.2.8.tar.gz  ("unofficial" and yet experimental doxygen-generated source code documentation)  

rsDataObjRepl.hpp File Reference
#include "rcConnect.h"
#include "dataObjInpOut.h"
#include "objInfo.h"
Include dependency graph for rsDataObjRepl.hpp:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

int rsDataObjRepl (rsComm_t *rsComm, dataObjInp_t *dataObjInp, transferStat_t **transferStat)
 
int _rsDataObjRepl (rsComm_t *rsComm, dataObjInp_t *dataObjInp, transferStat_t *transStat, dataObjInfo_t *outDataObjInfo)
 
int _rsDataObjReplUpdate (rsComm_t *rsComm, dataObjInp_t *dataObjInp, dataObjInfo_t *srcDataObjInfoHead, dataObjInfo_t *destDataObjInfoHead, transferStat_t *transStat)
 
int _rsDataObjReplNewCopy (rsComm_t *rsComm, dataObjInp_t *dataObjInp, dataObjInfo_t *srcDataObjInfoHead, const char *_resc_name, transferStat_t *transStat, dataObjInfo_t *outDataObjInfo)
 
int _rsDataObjReplS (rsComm_t *rsComm, dataObjInp_t *dataObjInp, dataObjInfo_t *srcDataObjInfo, const char *rescName, dataObjInfo_t *destDataObjInfo, int updateFlag)
 
int dataObjOpenForRepl (rsComm_t *rsComm, dataObjInp_t *dataObjInp, dataObjInfo_t *srcDataObjInfo, const char *_resc_name, dataObjInfo_t *destDataObjInfo, int updateFlag)
 
int dataObjCopy (rsComm_t *rsComm, int l1descInx)
 
int l3DataCopySingleBuf (rsComm_t *rsComm, int l1descInx)
 
int l3DataStageSync (rsComm_t *rsComm, int l1descInx)
 
int l3FileSync (rsComm_t *rsComm, int srcL1descInx, int destL1descInx)
 
int l3FileStage (rsComm_t *rsComm, int srcL1descInx, int destL1descInx)
 
int _l3FileStage (rsComm_t *rsComm, dataObjInfo_t *srcDataObjInfo, dataObjInfo_t *destDataObjInfo, int mode)
 
int rsReplAndRequeDataObjInfo (rsComm_t *rsComm, dataObjInfo_t **srcDataObjInfoHead, char *destRescName, char *flagStr)
 
int replToCacheRescOfCompObj (rsComm_t *rsComm, dataObjInp_t *dataObjInp, dataObjInfo_t *srcDataObjInfoHead, dataObjInfo_t *compObjInfo, dataObjInfo_t *oldDataObjInfo, dataObjInfo_t **outDestDataObjInfo)
 
int stageBundledData (rsComm_t *rsComm, dataObjInfo_t **subfileObjInfoHead)
 
int unbunAndStageBunfileObj (rsComm_t *rsComm, char *bunfileObjPath, char **outCacheRescName)
 
int _unbunAndStageBunfileObj (rsComm_t *rsComm, dataObjInfo_t **bunfileObjInfoHead, keyValPair_t *condInput, char **outCacheRescName, int rmBunCopyFlag)
 
int stageDataFromCompToCache (rsComm_t *rsComm, dataObjInfo_t *compObjInfo, dataObjInfo_t *outCacheObjInfo)
 
int stageAndRequeDataToCache (rsComm_t *rsComm, dataObjInfo_t **compObjInfoHead)
 

Function Documentation

◆ _l3FileStage()

◆ _rsDataObjRepl()

◆ _rsDataObjReplNewCopy()

int _rsDataObjReplNewCopy ( rsComm_t rsComm,
dataObjInp_t dataObjInp,
dataObjInfo_t srcDataObjInfoHead,
const char *  _resc_name,
transferStat_t transStat,
dataObjInfo_t outDataObjInfo 
)

Definition at line 589 of file rsDataObjRepl.cpp.

References _rsDataObjReplS(), ALL_KW, transferStat_t::bytesWritten, DataObjInp::condInput, DataObjInfo::dataSize, getValByKey(), DataObjInfo::next, NULL, DataObjInp::numThreads, transferStat_t::numThreads, and irods.pypyodbc::status.

Referenced by _rsDataObjRepl().

Here is the call graph for this function:

◆ _rsDataObjReplS()

◆ _rsDataObjReplUpdate()

int _rsDataObjReplUpdate ( rsComm_t rsComm,
dataObjInp_t dataObjInp,
dataObjInfo_t srcDataObjInfoHead,
dataObjInfo_t destDataObjInfoHead,
transferStat_t transStat 
)

Definition at line 490 of file rsDataObjRepl.cpp.

References _rsDataObjReplS(), addKeyVal(), ALL_KW, transferStat_t::bytesWritten, DataObjInp::condInput, DataObjInfo::dataId, DataObjInfo::dataSize, DEST_RESC_HIER_STR_KW, getValByKey(), DataObjInfo::next, NULL, DataObjInp::numThreads, transferStat_t::numThreads, DataObjInfo::rescHier, and irods.pypyodbc::status.

Referenced by _rsDataObjRepl().

Here is the call graph for this function:

◆ _unbunAndStageBunfileObj()

int _unbunAndStageBunfileObj ( rsComm_t rsComm,
dataObjInfo_t **  bunfileObjInfoHead,
keyValPair_t condInput,
char **  outCacheRescName,
int  rmBunCopyFlag 
)

Definition at line 1527 of file rsDataObjRepl.cpp.

References _rsUnbunAndRegPhyBunfile(), addKeyVal(), BUN_FILE_PATH_KW, DataObjInp::condInput, DATA_TYPE_KW, MAX_NAME_LEN, NULL, DataObjInp::objPath, RESC_HIER_STR_KW, RM_BUN_COPY_KW, rstrcpy(), sortObjInfoForOpen(), and irods.pypyodbc::status.

Referenced by _rsDataObjUnlink(), and unbunAndStageBunfileObj().

Here is the call graph for this function:

◆ dataObjCopy()

◆ dataObjOpenForRepl()

int dataObjOpenForRepl ( rsComm_t rsComm,
dataObjInp_t dataObjInp,
dataObjInfo_t srcDataObjInfo,
const char *  _resc_name,
dataObjInfo_t destDataObjInfo,
int  updateFlag 
)

Definition at line 737 of file rsDataObjRepl.cpp.

References addKeyVal(), allocL1desc(), irods::CFG_MAX_SIZE_FOR_SINGLE_BUFFER(), clearKeyVal(), irods::error::code(), DataObjInp::condInput, DataObjInfo::condInput, irods::CREATE_OPERATION(), CREATE_TYPE, dataCreate(), DataObjInfo::dataId, l1desc::dataObjInp, dataOpen(), DataObjInp::dataSize, DataObjInfo::dataSize, DEST_RESC_HIER_STR_KW, terminate_irods_processes::e, fileNotify(), fillL1desc(), FORCE_FLAG_KW, freeDataObjInfo(), freeL1desc(), getFilePathName(), getNumThreads(), getValByKey(), irods::resource_manager::hier_to_leaf_id(), IN_REPL_KW, initDataObjInfoForRepl(), irods::is_hier_live(), L1desc, OpenedDataObjInp::l1descInx, irods::log(), LOG_ERROR, MAX_NAME_LEN, NAME_LEN, DataObjInfo::next, NO_STAGING, NULL, DataObjInp::numThreads, DataObjInp::objPath, DataObjInfo::objPath, irods::error::ok(), OPEN_EXISTING_COPY, OPEN_FOR_WRITE_TYPE, DataObjInp::openFlags, l1desc::openType, DataObjInp::oprType, l1desc::oprType, deploy_schemas_locally::parser, PASS, PASSMSG, PHYMV_DEST, PHYMV_OPR, PHYMV_SRC, PURGE_CACHE_KW, l1desc::purgeCacheFlag, REPLICATE_DEST, REPLICATE_SRC, replKeyVal(), DataObjInfo::replNum, DataObjInfo::replStatus, resc_mgr, RESC_NAME_KW, DataObjInfo::rescHier, DataObjInfo::rescId, DataObjInfo::rescName, irods::resolve_resource_hierarchy(), rodsLog(), rsDataObjClose(), rstrcpy(), l1desc::srcL1descInx, STAGE_OBJ_KW, STAGE_SRC, l1desc::stageFlag, irods.pypyodbc::status, SYNC_DEST, SYNC_OBJ_KW, SYS_UPDATE_REPL_INFO_ERR, and irods::WRITE_OPERATION().

Referenced by _rsDataObjReplS().

Here is the call graph for this function:

◆ l3DataCopySingleBuf()

int l3DataCopySingleBuf ( rsComm_t rsComm,
int  l1descInx 
)

Definition at line 1185 of file rsDataObjRepl.cpp.

References BytesBuf::buf, l1desc::bytesWritten, l1desc::dataObjInp, DataObjInp::dataSize, l1desc::dataSize, getValByKey(), L1desc, LOG_ERROR, LOG_NOTICE, NO_CHK_COPY_LEN_KW, NULL, rodsLog(), rsL3FileGetSingleBuf(), rsL3FilePutSingleBuf(), l1desc::srcL1descInx, and SYS_COPY_LEN_ERR.

Referenced by _rsDataObjReplS().

Here is the call graph for this function:

◆ l3DataStageSync()

int l3DataStageSync ( rsComm_t rsComm,
int  l1descInx 
)

Definition at line 1245 of file rsDataObjRepl.cpp.

References l1desc::bytesWritten, l1desc::dataSize, L1desc, l3FileStage(), l3FileSync(), LOG_ERROR, rodsLog(), l1desc::srcL1descInx, irods.pypyodbc::status, SYNC_DEST, SYS_COPY_LEN_ERR, and UNKNOWN_FILE_SZ.

Referenced by _rsDataObjReplS().

Here is the call graph for this function:

◆ l3FileStage()

int l3FileStage ( rsComm_t rsComm,
int  srcL1descInx,
int  destL1descInx 
)

Definition at line 1361 of file rsDataObjRepl.cpp.

References _l3FileStage(), l1desc::dataObjInfo, getFileMode(), L1desc, mode, and irods.pypyodbc::status.

Referenced by l3DataStageSync().

Here is the call graph for this function:

◆ l3FileSync()

◆ replToCacheRescOfCompObj()

int replToCacheRescOfCompObj ( rsComm_t rsComm,
dataObjInp_t dataObjInp,
dataObjInfo_t srcDataObjInfoHead,
dataObjInfo_t compObjInfo,
dataObjInfo_t oldDataObjInfo,
dataObjInfo_t **  outDestDataObjInfo 
)

◆ rsDataObjRepl()

◆ rsReplAndRequeDataObjInfo()

int rsReplAndRequeDataObjInfo ( rsComm_t rsComm,
dataObjInfo_t **  srcDataObjInfoHead,
char *  destRescName,
char *  flagStr 
)

Definition at line 1416 of file rsDataObjRepl.cpp.

References _rsDataObjRepl(), addKeyVal(), ALL_KW, clearKeyVal(), DataObjInp::condInput, DEST_RESC_NAME_KW, freeAllDataObjInfo(), MAX_NAME_LEN, NAME_LEN, NULL, DataObjInp::objPath, DataObjInfo::objPath, queDataObjInfo(), RBUDP_TRANSFER_KW, REPL_NUM_KW, DataObjInfo::replNum, rstrcpy(), irods.pypyodbc::status, SU_CLIENT_USER_KW, and UPDATE_REPL_KW.

Referenced by msiSysReplDataObj().

Here is the call graph for this function:

◆ stageAndRequeDataToCache()

int stageAndRequeDataToCache ( rsComm_t rsComm,
dataObjInfo_t **  compObjInfoHead 
)

◆ stageBundledData()

int stageBundledData ( rsComm_t rsComm,
dataObjInfo_t **  subfileObjInfoHead 
)

Definition at line 1468 of file rsDataObjRepl.cpp.

References addKeyVal(), clearKeyVal(), DataObjInp::condInput, DataObjInfo::filePath, getDataObjInfo(), LOG_ERROR, MAX_NAME_LEN, NULL, DataObjInp::objPath, DataObjInfo::objPath, queDataObjInfo(), RESC_NAME_KW, rodsLog(), rstrcpy(), irods.pypyodbc::status, and unbunAndStageBunfileObj().

Referenced by _rsDataObjOpen().

Here is the call graph for this function:

◆ stageDataFromCompToCache()

int stageDataFromCompToCache ( rsComm_t rsComm,
dataObjInfo_t compObjInfo,
dataObjInfo_t outCacheObjInfo 
)

◆ unbunAndStageBunfileObj()

int unbunAndStageBunfileObj ( rsComm_t rsComm,
char *  bunfileObjPath,
char **  outCacheRescName 
)

Definition at line 1502 of file rsDataObjRepl.cpp.

References _unbunAndStageBunfileObj(), DataObjInp::condInput, freeAllDataObjInfo(), getDataObjInfo(), LOG_ERROR, MAX_NAME_LEN, NULL, DataObjInp::objPath, rodsLog(), rstrcpy(), and irods.pypyodbc::status.

Referenced by stageBundledData().

Here is the call graph for this function: