bunUtil.cpp

Go to the documentation of this file.

 
#include "rodsPath.h"
#include "rodsErrorTable.h"
#include "rodsLog.h"
#include "bunUtil.h"
#include "miscUtil.h"
#include "rcGlobalExtern.h"
 
int
bunUtil( rcComm_t *conn, rodsEnv *myRodsEnv, rodsArguments_t *myRodsArgs,
         rodsPathInp_t *rodsPathInp ) {
    rodsPath_t *collPath, *structFilePath;
    structFileExtAndRegInp_t structFileExtAndRegInp;
 
    if ( rodsPathInp == NULL ) {
        return USER__NULL_INPUT_ERR;
    }
 
    int savedStatus = initCondForBunOpr( myRodsEnv, myRodsArgs, &structFileExtAndRegInp );
    if ( savedStatus < 0 ) {
        return savedStatus;
    }
 
    for ( int i = 0; i < rodsPathInp->numSrc; i++ ) {
        collPath = &rodsPathInp->destPath[i];   /* iRODS Collection */
        structFilePath = &rodsPathInp->srcPath[i];  /* iRODS StructFile */
 
        getRodsObjType( conn, collPath );
 
        rstrcpy( structFileExtAndRegInp.collection, collPath->outPath,
                 MAX_NAME_LEN );
        rstrcpy( structFileExtAndRegInp.objPath, structFilePath->outPath,
                 MAX_NAME_LEN );
 
        int status = 0;
        if ( myRodsArgs->extract == True ) {        /* -x */
            if ( myRodsArgs->condition == True ) {
                rodsLog( LOG_ERROR, "bunUtil: cannot use -x and -c at the same time" );
                return -1;
            }
            status = rcStructFileExtAndReg( conn, &structFileExtAndRegInp );
        }
        else if ( myRodsArgs->condition == True ) {  /* -c - create */
            status = rcStructFileBundle( conn, &structFileExtAndRegInp );
        }
        else if ( myRodsArgs->add == True ) {  /* add to tar */ // JMC - backport 4643
            status = rcStructFileBundle( conn, &structFileExtAndRegInp );
        }
        else {
            rodsLog( LOG_ERROR,
                     "bunUtil: -x or -c must be specified" );
            return -1;
        }
 
        /* XXXX may need to return a global status */
        if ( status < 0 &&
                status != CAT_NO_ROWS_FOUND ) {
            if ( status == SYS_CACHE_STRUCT_FILE_RESC_ERR &&
                    myRodsArgs->condition == True ) {
                rodsLogError( LOG_ERROR, status,
                              "bunUtil: A resc must be entered for non-existing structFile" );
            }
            else {
                rodsLogError( LOG_ERROR, status,
                              "bunUtil: opr error for %s, status = %d",
                              collPath->outPath, status );
                savedStatus = status;
            }
        }
    }
    return savedStatus;
}
 
int
initCondForBunOpr( rodsEnv *myRodsEnv, rodsArguments_t *rodsArgs,
                   structFileExtAndRegInp_t *structFileExtAndRegInp ) {
    if ( structFileExtAndRegInp == NULL ) {
        rodsLog( LOG_ERROR,
                 "initCondForBunOpr: NULL structFileExtAndRegInp input" );
        return USER__NULL_INPUT_ERR;
    }
 
    memset( structFileExtAndRegInp, 0, sizeof( structFileExtAndRegInp_t ) );
 
    if ( rodsArgs == NULL ) {
        return 0;
    }
 
    if ( rodsArgs->dataType == True ) {
        if ( rodsArgs->dataTypeString != NULL ) {
            if ( strcmp( rodsArgs->dataTypeString, "t" ) == 0 ||
                    strcmp( rodsArgs->dataTypeString, TAR_DT_STR ) == 0 || // JMC - backport 4640
                    strcmp( rodsArgs->dataTypeString, "tar" ) == 0 ) {
                addKeyVal( &structFileExtAndRegInp->condInput, DATA_TYPE_KW,
                           // =-=-=-=-=-=-=-
                           // JMC - backport 4633
                           TAR_DT_STR );
            }
            else if ( strcmp( rodsArgs->dataTypeString, "g" ) == 0 ||
                      strcmp( rodsArgs->dataTypeString, GZIP_TAR_DT_STR ) == 0 || // JMC - backport 4640
                      strcmp( rodsArgs->dataTypeString, "gzip" ) == 0 ) {
                addKeyVal( &structFileExtAndRegInp->condInput, DATA_TYPE_KW, GZIP_TAR_DT_STR );
            }
            else if ( strcmp( rodsArgs->dataTypeString, "b" ) == 0 ||
                      strcmp( rodsArgs->dataTypeString, BZIP2_TAR_DT_STR ) == 0 || // JMC - backport 4640
                      strcmp( rodsArgs->dataTypeString, "bzip2" ) == 0 ) { // JMC - backport 4648
                addKeyVal( &structFileExtAndRegInp->condInput, DATA_TYPE_KW, BZIP2_TAR_DT_STR );
            }
            else if ( strcmp( rodsArgs->dataTypeString, "z" ) == 0 ||
                      strcmp( rodsArgs->dataTypeString, ZIP_DT_STR ) == 0 || // JMC - backport 4640
                      strcmp( rodsArgs->dataTypeString, "zip" ) == 0 ) {
                addKeyVal( &structFileExtAndRegInp->condInput, DATA_TYPE_KW, ZIP_DT_STR );
                // =-=-=-=-=-=-=-
            }
            else {
                rodsLog( LOG_ERROR, "bunUtil: Unknown dataType %s for ibun", // JMC - backport 4648
                         rodsArgs->dataTypeString );
                return SYS_ZIP_FORMAT_NOT_SUPPORTED;
            }
 
        }
    }
    else if ( rodsArgs->condition == True ) {   /* -c */
        addKeyVal( &structFileExtAndRegInp->condInput, DATA_TYPE_KW,
                   "tar file" );
 
    }
 
    if ( rodsArgs->resource == True ) {
        if ( rodsArgs->resourceString == NULL ) {
            rodsLog( LOG_ERROR,
                     "initCondForBunOpr: NULL resourceString error" );
            return USER__NULL_INPUT_ERR;
        }
        else {
            addKeyVal( &structFileExtAndRegInp->condInput,
                       DEST_RESC_NAME_KW, rodsArgs->resourceString );
            /* RESC_NAME_KW is need for unbundle. DEST_RESC_NAME_KW or
             * DEF_RESC_NAME_KW are neede for bundle */
            addKeyVal( &structFileExtAndRegInp->condInput, RESC_NAME_KW,
                       rodsArgs->resourceString );
        }
    }
    else if ( myRodsEnv != NULL && strlen( myRodsEnv->rodsDefResource ) > 0 ) {
        /* use rodsDefResource but set the DEF_RESC_NAME_KW instead.
         * Used by dataObjCreate. Will only make a new replica only if
         * DEST_RESC_NAME_KW is set */
        addKeyVal( &structFileExtAndRegInp->condInput, DEF_RESC_NAME_KW,
                   myRodsEnv->rodsDefResource );
    }
 
    if ( rodsArgs->force == True ) {
        addKeyVal( &structFileExtAndRegInp->condInput, FORCE_FLAG_KW, "" );
    }
 
    if ( rodsArgs->condition == True ) {  /* -c - create */ // JMC - backport 4644
        structFileExtAndRegInp->oprType = PRESERVE_COLL_PATH;
    }
 
    if ( rodsArgs->add == True ) {  /* add to tar */ // JMC - backport 4643
        structFileExtAndRegInp->oprType = ADD_TO_TAR_OPR | PRESERVE_COLL_PATH; // JMC - backport 4644
        addKeyVal( &structFileExtAndRegInp->condInput, FORCE_FLAG_KW, "" );
    }
 
    if ( rodsArgs->bulk == True ) {
        addKeyVal( &structFileExtAndRegInp->condInput, BULK_OPR_KW, "" );
    }
 
    return 0;
}