rsGeneralRowInsert.cpp

Go to the documentation of this file.

 
/* This is script-generated code (for the most part).  */
/* See generalRowInsert.h for a description of this API call.*/
 
#include "generalRowInsert.h"
#include "rsGeneralRowInsert.hpp"
#include "icatHighLevelRoutines.hpp"
#include "miscServerFunct.hpp"
#include "irods_configuration_keywords.hpp"
 
int
rsGeneralRowInsert( rsComm_t *rsComm, generalRowInsertInp_t *generalRowInsertInp ) {
    rodsServerHost_t *rodsServerHost;
    int status;
 
    rodsLog( LOG_DEBUG, "generalRowInsert" );
 
    status = getAndConnRcatHost( rsComm, MASTER_RCAT, ( const char* )NULL, &rodsServerHost );
    if ( status < 0 ) {
        return status;
    }
 
    if ( rodsServerHost->localFlag == LOCAL_HOST ) {
        std::string svc_role;
        irods::error ret = get_catalog_service_role(svc_role);
        if(!ret.ok()) {
            irods::log(PASS(ret));
            return ret.code();
        }
        if( irods::CFG_SERVICE_ROLE_PROVIDER == svc_role ) {
            status = _rsGeneralRowInsert( rsComm, generalRowInsertInp );
        } else if( irods::CFG_SERVICE_ROLE_CONSUMER == svc_role ) {
            status = SYS_NO_RCAT_SERVER_ERR;
        } else {
            rodsLog(
                LOG_ERROR,
                "role not supported [%s]",
                svc_role.c_str() );
            status = SYS_SERVICE_ROLE_NOT_SUPPORTED;
        }
    }
    else {
        status = rcGeneralRowInsert( rodsServerHost->conn,
                                     generalRowInsertInp );
    }
 
    if ( status < 0 ) {
        rodsLog( LOG_NOTICE,
                 "rsGeneralRowInsert: rcGeneralRowInsert failed" );
    }
    return status;
}
 
int
_rsGeneralRowInsert( rsComm_t *rsComm, generalRowInsertInp_t *generalRowInsertInp ) {
    int status;
 
    rodsLog( LOG_DEBUG,
             "_rsGeneralRowInsert tableName=%s",
             generalRowInsertInp->tableName );
 
    if ( strcmp( generalRowInsertInp->tableName, "serverload" ) == 0 ) {
        status = chlRegServerLoad( rsComm,
                                   generalRowInsertInp->arg1,
                                   generalRowInsertInp->arg2,
                                   generalRowInsertInp->arg3,
                                   generalRowInsertInp->arg4,
                                   generalRowInsertInp->arg5,
                                   generalRowInsertInp->arg6,
                                   generalRowInsertInp->arg7,
                                   generalRowInsertInp->arg8,
                                   generalRowInsertInp->arg9 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "serverloaddigest" ) == 0 ) {
        status = chlRegServerLoadDigest( rsComm,
                                         generalRowInsertInp->arg1,
                                         generalRowInsertInp->arg2 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "ruleTable" ) == 0 ) {
        status = chlInsRuleTable( rsComm,
                                  generalRowInsertInp->arg1,
                                  generalRowInsertInp->arg2,
                                  generalRowInsertInp->arg3,
                                  generalRowInsertInp->arg4,
                                  generalRowInsertInp->arg5,
                                  generalRowInsertInp->arg6,
                                  generalRowInsertInp->arg7,
                                  generalRowInsertInp->arg8,
                                  generalRowInsertInp->arg9 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "versionRuleBase" ) == 0 ) {
        status = chlVersionRuleBase( rsComm,
                                     generalRowInsertInp->arg1,
                                     generalRowInsertInp->arg2 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "dvmTable" ) == 0 ) {
        status = chlInsDvmTable( rsComm,
                                 generalRowInsertInp->arg1,
                                 generalRowInsertInp->arg2,
                                 generalRowInsertInp->arg3,
                                 generalRowInsertInp->arg4,
                                 generalRowInsertInp->arg5 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "versionDVMBase" ) == 0 ) {
        status = chlVersionDvmBase( rsComm,
                                    generalRowInsertInp->arg1,
                                    generalRowInsertInp->arg2 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "fnmTable" ) == 0 ) {
        status = chlInsFnmTable( rsComm,
                                 generalRowInsertInp->arg1,
                                 generalRowInsertInp->arg2,
                                 generalRowInsertInp->arg3,
                                 generalRowInsertInp->arg4 );
        return status;
    }
    if ( strcmp( generalRowInsertInp->tableName, "versionFNMBase" ) == 0 ) {
        status = chlVersionFnmBase( rsComm,
                                    generalRowInsertInp->arg1,
                                    generalRowInsertInp->arg2 );
        return status;
    }
 
    if ( strcmp( generalRowInsertInp->tableName, "msrvcTable" ) == 0 ) {
        status = chlInsMsrvcTable( rsComm,
                                   generalRowInsertInp->arg1,
                                   generalRowInsertInp->arg2,
                                   generalRowInsertInp->arg3,
                                   generalRowInsertInp->arg4,
                                   generalRowInsertInp->arg5,
                                   generalRowInsertInp->arg6,
                                   generalRowInsertInp->arg7,
                                   generalRowInsertInp->arg8,
                                   generalRowInsertInp->arg9,
                                   generalRowInsertInp->arg10 );
        return status;
    }
    return CAT_INVALID_ARGUMENT;
}