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)  
Functions
objDesc.cpp File Reference
#include "rcMisc.h"
#include "rodsDef.h"
#include "objDesc.hpp"
#include "dataObjOpr.hpp"
#include "rsGlobalExtern.hpp"
#include "fileChksum.h"
#include "modDataObjMeta.h"
#include "objMetaOpr.hpp"
#include "collection.hpp"
#include "resource.hpp"
#include "dataObjClose.h"
#include "rcGlobalExtern.h"
#include "genQuery.h"
#include "rsGenQuery.hpp"
#include "rsGetHierFromLeafId.hpp"
#include "rsQuerySpecColl.hpp"
#include "rsDataObjClose.hpp"
#include "irods_resource_backport.hpp"
#include "irods_hierarchy_parser.hpp"
#include "irods_stacktrace.hpp"
#include "irods_re_structs.hpp"
#include "get_hier_from_leaf_id.h"
Include dependency graph for objDesc.cpp:

Go to the source code of this file.

Functions

int initL1desc ()
 
int allocL1desc ()
 
int isL1descInuse ()
 
int initSpecCollDesc ()
 
int allocSpecCollDesc ()
 
int freeSpecCollDesc (int specCollInx)
 
int closeAllL1desc (rsComm_t *rsComm)
 
int freeL1desc (int l1descInx)
 
int fillL1desc (int l1descInx, dataObjInp_t *dataObjInp, dataObjInfo_t *dataObjInfo, int replStatus, rodsLong_t dataSize)
 
int initDataObjInfoWithInp (dataObjInfo_t *dataObjInfo, dataObjInp_t *dataObjInp)
 
int getL1descIndexByDataObjInfo (const dataObjInfo_t *dataObjInfo)
 
int getNumThreads (rsComm_t *rsComm, rodsLong_t dataSize, int inpNumThr, keyValPair_t *condInput, char *destRescHier, char *srcRescHier, int oprType)
 
int initDataOprInp (dataOprInp_t *dataOprInp, int l1descInx, int oprType)
 
int initDataObjInfoForRepl (dataObjInfo_t *destDataObjInfo, dataObjInfo_t *srcDataObjInfo, const char *_resc_name)
 
int convL3descInx (int l3descInx)
 
int allocCollHandle ()
 
int freeCollHandle (int handleInx)
 
int rsInitQueryHandle (queryHandle_t *queryHandle, rsComm_t *rsComm)
 
int allocAndSetL1descForZoneOpr (int remoteL1descInx, dataObjInp_t *dataObjInp, rodsServerHost_t *remoteZoneHost, openStat_t *openStat)
 

Function Documentation

◆ allocAndSetL1descForZoneOpr()

int allocAndSetL1descForZoneOpr ( int  remoteL1descInx,
dataObjInp_t *  dataObjInp,
rodsServerHost_t *  remoteZoneHost,
openStat_t *  openStat 
)

Definition at line 638 of file objDesc.cpp.

References allocL1desc(), OpenStat::dataMode, DataObjInfo::dataMode, l1desc::dataObjInfo, l1desc::dataObjInp, l1desc::dataObjInpReplFlag, OpenStat::dataSize, DataObjInfo::dataSize, OpenStat::dataType, DataObjInfo::dataType, L1desc, OpenStat::l3descInx, l1desc::l3descInx, MAX_NAME_LEN, NAME_LEN, NULL, DataObjInfo::objPath, l1desc::oprType, REMOTE_ZONE_OPR, l1desc::remoteL1descInx, l1desc::remoteZoneHost, replDataObjInp(), OpenStat::replStatus, l1desc::replStatus, rstrcpy(), and SHORT_STR_LEN.

Referenced by rsDataObjCreate(), rsDataObjGet(), rsDataObjOpen(), and rsDataObjPut().

Here is the call graph for this function:

◆ allocCollHandle()

int allocCollHandle ( )

Definition at line 585 of file objDesc.cpp.

References CollHandle, FD_FREE, FD_INUSE, and collHandle_t::inuseFlag.

Referenced by rsOpenCollection().

◆ allocL1desc()

int allocL1desc ( )

Definition at line 39 of file objDesc.cpp.

References FD_FREE, FD_INUSE, l1desc::inuseFlag, L1desc, LOG_NOTICE, NUM_L1_DESC, rodsLog(), and SYS_OUT_OF_FILE_DESC.

Referenced by _rsDataObjCreateWithResc(), _rsDataObjOpenWithObjInfo(), allocAndSetL1descForZoneOpr(), dataObjOpenForRepl(), and specCollSubCreate().

Here is the call graph for this function:

◆ allocSpecCollDesc()

int allocSpecCollDesc ( )

Definition at line 74 of file objDesc.cpp.

References FD_FREE, FD_INUSE, specCollDesc::inuseFlag, LOG_NOTICE, NUM_SPEC_COLL_DESC, rodsLog(), SpecCollDesc, and SYS_OUT_OF_FILE_DESC.

Referenced by openSpecColl().

Here is the call graph for this function:

◆ closeAllL1desc()

int closeAllL1desc ( rsComm_t *  rsComm)

Definition at line 108 of file objDesc.cpp.

References FD_INUSE, L1desc, l3Close(), NULL, and NUM_L1_DESC.

Referenced by cleanup(), and execCmd().

Here is the call graph for this function:

◆ convL3descInx()

int convL3descInx ( int  l3descInx)

Definition at line 571 of file objDesc.cpp.

References fileDesc_t::fd, FileDesc, LOCAL_HOST, rodsServerHost::localFlag, and NULL.

Referenced by remoteDataCopy(), remoteDataGet(), remoteDataPut(), remoteFileClose(), remoteFileLseek(), remoteFileRead(), remoteFileReaddir(), and remoteFileWrite().

◆ fillL1desc()

int fillL1desc ( int  l1descInx,
dataObjInp_t *  dataObjInp,
dataObjInfo_t *  dataObjInfo,
int  replStatus,
rodsLong_t  dataSize 
)

Definition at line 154 of file objDesc.cpp.

References l1desc::bytesWritten, l1desc::chksumFlag, DataObjInp::condInput, l1desc::dataObjInfo, l1desc::dataObjInp, l1desc::dataObjInpReplFlag, l1desc::dataSize, getValByKey(), IN_PDMO_KW, L1desc, KeyValPair::len, MAX_NAME_LEN, NAME_LEN, NULL, OPEN_TYPE_KW, l1desc::openType, DataObjInp::oprType, l1desc::oprType, REG_CHKSUM, REG_CHKSUM_KW, replDataObjInp(), l1desc::replStatus, RESC_HIER_STR_KW, DataObjInfo::rescHier, rstrcpy(), VERIFY_CHKSUM, and VERIFY_CHKSUM_KW.

Referenced by _rsDataObjCreateWithResc(), _rsDataObjOpenWithObjInfo(), dataObjOpenForRepl(), and specCollSubCreate().

Here is the call graph for this function:

◆ freeCollHandle()

int freeCollHandle ( int  handleInx)

Definition at line 608 of file objDesc.cpp.

References clearCollHandle(), CollHandle, LOG_NOTICE, rodsLog(), and SYS_FILE_DESC_OUT_OF_RANGE.

Referenced by rsCloseCollection().

Here is the call graph for this function:

◆ freeL1desc()

int freeL1desc ( int  l1descInx)

Definition at line 124 of file objDesc.cpp.

References clearDataObjInp(), freeAllDataObjInfo(), freeDataObjInfo(), L1desc, LOG_NOTICE, NULL, NUM_L1_DESC, rodsLog(), and SYS_FILE_DESC_OUT_OF_RANGE.

Referenced by _rsDataObjClose(), _rsDataObjCreateWithResc(), _rsDataObjOpenWithObjInfo(), dataObjOpenForRepl(), irsDataObjClose(), rsOprComplete(), and specCollSubCreate().

Here is the call graph for this function:

◆ freeSpecCollDesc()

int freeSpecCollDesc ( int  specCollInx)

Definition at line 91 of file objDesc.cpp.

References freeDataObjInfo(), LOG_NOTICE, NULL, NUM_SPEC_COLL_DESC, rodsLog(), SpecCollDesc, and SYS_FILE_DESC_OUT_OF_RANGE.

Referenced by _rsQuerySpecColl().

Here is the call graph for this function:

◆ getL1descIndexByDataObjInfo()

int getL1descIndexByDataObjInfo ( const dataObjInfo_t *  dataObjInfo)

Definition at line 262 of file objDesc.cpp.

References L1desc, and NUM_L1_DESC.

Referenced by irods::file_object::file_object().

◆ getNumThreads()

int getNumThreads ( rsComm_t *  rsComm,
rodsLong_t  dataSize,
int  inpNumThr,
keyValPair_t *  condInput,
char *  destRescHier,
char *  srcRescHier,
int  oprType 
)

Definition at line 279 of file objDesc.cpp.

References applyRule(), clearKeyVal(), RuleExecInfo::condInputData, DataObjInp::dataSize, irods::get_loc_for_hier_string(), irods::get_resc_properties_as_kvp(), getValByKey(), initReiWithDataObjInp(), irods::is_hier_live(), isLocalHost(), irods::log(), LOG_ERROR, MIN_SZ_FOR_PARA_TRAN, NO_PARA_OP_KW, NO_SAVE_REI, NO_THREADING, NULL, DataObjInp::numThreads, irods::error::ok(), DataObjInp::oprType, PASSMSG, RBUDP_TRANSFER_KW, rodsLog(), irods.pypyodbc::status, and RuleExecInfo::status.

Referenced by dataObjOpenForRepl(), and setupSrvPortalForParaOpr().

Here is the call graph for this function:

◆ initDataObjInfoForRepl()

int initDataObjInfoForRepl ( dataObjInfo_t *  destDataObjInfo,
dataObjInfo_t *  srcDataObjInfo,
const char *  _resc_name 
)

Definition at line 544 of file objDesc.cpp.

References DataObjInfo::condInput, DataObjInfo::dataId, DataObjInfo::filePath, irods::resource_manager::hier_to_leaf_id(), irods::log(), MAX_NAME_LEN, NAME_LEN, irods::error::ok(), PASS, replKeyVal(), DataObjInfo::replNum, resc_mgr, DataObjInfo::rescHier, DataObjInfo::rescId, DataObjInfo::rescName, and rstrcpy().

Referenced by dataObjOpenForRepl().

Here is the call graph for this function:

◆ initDataObjInfoWithInp()

int initDataObjInfoWithInp ( dataObjInfo_t *  dataObjInfo,
dataObjInp_t *  dataObjInp 
)

Definition at line 217 of file objDesc.cpp.

References DataObjInp::condInput, DataObjInp::createMode, DATA_TYPE_KW, DataObjInfo::dataMode, DataObjInfo::dataType, FILE_PATH_KW, DataObjInfo::filePath, getValByKey(), irods::resource_manager::hier_to_leaf_id(), irods::log(), MAX_NAME_LEN, NAME_LEN, NULL, DataObjInp::objPath, DataObjInfo::objPath, irods::error::ok(), PASS, RESC_HIER_STR_KW, resc_mgr, RESC_NAME_KW, DataObjInfo::rescHier, DataObjInfo::rescId, DataObjInfo::rescName, rstrcpy(), and SHORT_STR_LEN.

Referenced by _rsDataObjCreateWithResc(), and filePathReg().

Here is the call graph for this function:

◆ initDataOprInp()

int initDataOprInp ( dataOprInp_t *  dataOprInp,
int  l1descInx,
int  oprType 
)

Definition at line 453 of file objDesc.cpp.

References addKeyVal(), DataObjInp::condInput, DataOprInp::condInput, COPY_TO_LOCAL_OPR, COPY_TO_REM_OPR, l1desc::dataObjInfo, l1desc::dataObjInp, DataObjInp::dataSize, DataOprInp::dataSize, DataObjInfo::dataSize, DataOprInp::destL3descInx, GET_OPR, irods::get_resc_type_for_hier_string(), getValByKey(), L1desc, l1desc::l3descInx, irods::log(), NO_PARA_OP_KW, NULL, DataObjInp::numThreads, DataOprInp::numThreads, DataObjInp::offset, DataOprInp::offset, irods::error::ok(), DataOprInp::oprType, PASS, PUT_OPR, RBUDP_PACK_SIZE_KW, RBUDP_SEND_RATE_KW, RBUDP_TRANSFER_KW, DataObjInfo::rescHier, irods::RESOURCE_TYPE_NATIVE(), SAME_HOST_COPY_OPR, l1desc::srcL1descInx, DataOprInp::srcL3descInx, STREAMING_KW, type, and VERY_VERBOSE_KW.

Referenced by dataObjCopy(), preProcParaGet(), and preProcParaPut().

Here is the call graph for this function:

◆ initL1desc()

int initL1desc ( )

Definition at line 33 of file objDesc.cpp.

References L1desc.

Referenced by initAgent().

◆ initSpecCollDesc()

int initSpecCollDesc ( )

Definition at line 68 of file objDesc.cpp.

References SpecCollDesc.

Referenced by initAgent().

◆ isL1descInuse()

int isL1descInuse ( )

Definition at line 56 of file objDesc.cpp.

References FD_INUSE, L1desc, and NUM_L1_DESC.

Referenced by readAndProcClientMsg(), and readTimeoutHandler().

◆ rsInitQueryHandle()

int rsInitQueryHandle ( queryHandle_t *  queryHandle,
rsComm_t *  rsComm 
)

Definition at line 623 of file objDesc.cpp.

References QueryHandle::conn, QueryHandle::connType, QueryHandle::genQuery, QueryHandle::getHierForId, NULL, QueryHandle::querySpecColl, RS_COMM, rsGenQuery(), rsGetHierFromLeafId(), rsQuerySpecColl(), and USER__NULL_INPUT_ERR.

Referenced by rsOpenCollection().

Here is the call graph for this function: