#include "index.hpp"
#include "functions.hpp"
#include "arithmetics.hpp"
#include "datetime.hpp"
#include "cache.hpp"
#include "configuration.hpp"
#include "rsExecMyRule.hpp"
#include "rsDataObjOpen.hpp"
#include "rsDataObjLseek.hpp"
#include "rsDataObjWrite.hpp"
#include "rsDataObjClose.hpp"
#include "apiHeaderAll.h"
#include "rsApiHandler.hpp"
#include "dataObjOpr.hpp"
#include <boost/regex.h>
#include "execMyRule.h"
#include "msParam.h"
#include "reFuncDefs.hpp"
#include "stringOpr.h"
#include "miscServerFunct.hpp"
#include "irods_get_full_path_for_config_file.hpp"

Include dependency graph for functions.cpp:

Classes
struct	reIterable_genQuery_data

struct	reIterable_list_data

struct	reIterable_irods_data

struct	reIterable_collection_data

Macros
#define	GC_BEGIN Region _rnew = make_region(0, NULL), _rnew2 = NULL;

#define	GC_REGION _rnew

#define	GC_ON(env)

#define	GC_END region_free(_rnew);

#define	RE_BACKWARD_COMPATIBLE

#define	NUM_RE_ITERABLE 7

Typedefs
typedef struct reIterable_genQuery_data	ReIterable_genQuery_data

typedef struct reIterable_list_data	ReIterable_list_data

typedef struct reIterable_irods_data	ReIterable_irods_data

typedef struct reIterable_collection_data	ReIterable_collection_data

Functions
int	rsOpenCollection (rsComm_t rsComm, collInp_t openCollInp)

int	rsCloseCollection (rsComm_t rsComm, int handleInxInp)

int	rsReadCollection (rsComm_t rsComm, int handleInxInp, collEnt_t **collEnt)

int	msiExecGenQuery (msParam_t genQueryInParam, msParam_t genQueryOutParam, ruleExecInfo_t *rei)

int	msiCloseGenQuery (msParam_t genQueryInpParam, msParam_t genQueryOutParam, ruleExecInfo_t *rei)

int	msiGetMoreRows (msParam_t genQueryInpParam, msParam_t genQueryOutParam, msParam_t contInxParam, ruleExecInfo_t rei)

Res *	smsi_getGlobalSessionId (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_setGlobalSessionId (Node *subtrees, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_properties (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

void	reIterable_genQuery_init (ReIterableData itrData, Region r)

int	reIterable_genQuery_hasNext (ReIterableData itrData, Region r)

Res *	reIterable_genQuery_next (ReIterableData itrData, Region r)

void	reIterable_genQuery_finalize (ReIterableData itrData, Region r)

void	reIterable_list_init (ReIterableData itrData, Region r)

int	reIterable_list_hasNext (ReIterableData itrData, Region r)

Res *	reIterable_list_next (ReIterableData itrData, Region r)

void	reIterable_list_finalize (ReIterableData itrData, Region r)

void	reIterable_irods_init (ReIterableData itrData, Region r)

int	reIterable_irods_hasNext (ReIterableData itrData, Region r)

Res *	reIterable_irods_next (ReIterableData itrData, Region r)

void	reIterable_irods_finalize (ReIterableData itrData, Region r)

void	reIterable_collection_init (ReIterableData itrData, Region r)

int	reIterable_collection_hasNext (ReIterableData itrData, Region r)

Res *	reIterable_collection_next (ReIterableData itrData, Region r)

void	reIterable_collection_finalize (ReIterableData itrData, Region r)

ReIterableData *	newReIterableData (char varName, Res res, Node *subtrees, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t *errmsg)

void	deleteReIterableData (ReIterableData *itrData)

int	fileConcatenate (const char file1, const char file2, const char *file3)

Node *	wrapToActions (Node node, Region r)

Res *	smsi_ifExec (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_if2Exec (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_do (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_letExec (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_matchExec (Node *params, int n, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_whileExec (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_forExec (Node *params, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_split (Node *params, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_collection (Node *subtrees, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

ReIterableType	collType (Res *coll)

ReIterable *	getReIterable (ReIterableType nodeType)

Res *	smsi_forEach2Exec (Node *subtrees, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_forEachExec (Node *subtrees, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

void	columnToString (Node n, char queryStr, int size)

Res *	smsi_query (Node *subtrees, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_break (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_succeed (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_fail (Node *subtrees, int n, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_assign (Node *subtrees, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_getValByKey (Node *params, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_listvars (Node *, int, Node , ruleExecInfo_t , int, Env env, rError_t , Region r)

Res *	smsi_listcorerules (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_listapprules (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_listextrules (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_true (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_false (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_max (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_min (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_average (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_hd (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_tl (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_cons (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_setelem (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_list (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_tuple (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_elem (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_size (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_datetime (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_time (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_timestr (Node *params, int n, Node , ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_type (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_arity (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_str (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_double (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_int (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_bool (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_lmsg (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_not (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_negate (Node *args, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_abs (Node *args, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_exp (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_log (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_floor (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_ceiling (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_and (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_or (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_add (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_subtract (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_multiply (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_divide (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_modulo (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_power (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_root (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_concat (Node *params, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_lt (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_le (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_gt (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_ge (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_eq (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_neq (Node *params, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_like (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_not_like (Node *paramsr, int n, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_like_regex (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_not_like_regex (Node *paramsr, int n, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_eval (Node *paramsr, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_evalrule (Node *paramsr, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_errorcode (Node *paramsr, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_errormsg (Node *paramsr, int, Node , ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_delayExec (Node *paramsr, int, Node node, ruleExecInfo_t rei, int, Env env, rError_t errmsg, Region r)

Res *	smsi_remoteExec (Node *paramsr, int, Node node, ruleExecInfo_t rei, int, Env env, rError_t errmsg, Region r)

Res *	smsi_writeLine (Node *paramsr, int, Node , ruleExecInfo_t rei, int, Env env, rError_t , Region r)

Res *	smsi_writeString (Node *paramsr, int, Node , ruleExecInfo_t rei, int, Env env, rError_t , Region r)

Res *	smsi_triml (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_strlen (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_substr (Node *paramsr, int, Node node, ruleExecInfo_t , int, Env , rError_t errmsg, Region r)

Res *	smsi_undefined (Node *, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_trimr (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_getReLogging (Node *paramsr, int, Node node, ruleExecInfo_t rei, int, Env , rError_t errmsg, Region r)

Res *	smsi_setReLogging (Node *paramsr, int, Node node, ruleExecInfo_t rei, int, Env , rError_t errmsg, Region r)

Res *	smsi_getstdout (Node *paramsr, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_getstderr (Node *paramsr, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_assignStr (Node *subtrees, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	smsi_applyAllRules (Node *subtrees, int, Node , ruleExecInfo_t rei, int, Env env, rError_t errmsg, Region r)

Res *	smsi_path (Node *subtrees, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

Res *	smsi_execCmdArg (Node *subtrees, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

int	checkStringForSystem (const char *s)

Res *	smsi_msiCheckStringForSystem (Node *paramsr, int, Node , ruleExecInfo_t , int, Env , rError_t , Region r)

int	parseResForCollInp (Node inpParam, collInp_t collInpCache, collInp_t **outCollInp, int outputToCache)

Res *	smsiCollectionSpider (Node *subtrees, int, Node node, ruleExecInfo_t rei, int reiSaveFlag, Env env, rError_t errmsg, Region r)

Res *	eval (char expr, Env env, ruleExecInfo_t rei, int saveREI, rError_t errmsg, Region *r)

Node *	construct (char fn, Node args, int argc, Node constype, Region *r)

Node *	deconstruct (Node **args, int proj)

char *	matchWholeString (char *buf)

char *	wildCardToRegex (char *buf)

Res *	smsi_segfault (Node *, int, Node node, ruleExecInfo_t rei, int, Env , rError_t errmsg, Region r)

void	getSystemFunctions (Hashtable ft, Region r)

Variables
static char	globalSessionId [(1024+64)] = "Unspecified"

static keyValPair_t	globalHashtable = {0, 0 , 0 }

ReIterableTableRow	reIterableTable [7]

int	GlobalAllRuleExecFlag

Macro Definition Documentation

◆ GC_BEGIN

#define GC_BEGIN Region *_rnew = make_region(0, NULL), *_rnew2 = NULL;

Definition at line 40 of file functions.cpp.

◆ GC_END

#define GC_END region_free(_rnew);

Definition at line 48 of file functions.cpp.

◆ GC_ON

#define GC_ON ( env )

Value:

if(region_size(_rnew) > DEFAULT_BLOCK_SIZE) {\
_rnew2 = make_region(0, NULL); \
cpEnv2((env), _rnew, _rnew2); \
region_free(_rnew); \
_rnew = _rnew2;}

Definition at line 42 of file functions.cpp.

◆ GC_REGION

#define GC_REGION _rnew

Definition at line 41 of file functions.cpp.

◆ NUM_RE_ITERABLE

#define NUM_RE_ITERABLE 7

Definition at line 99 of file functions.cpp.

◆ RE_BACKWARD_COMPATIBLE

#define RE_BACKWARD_COMPATIBLE

Definition at line 50 of file functions.cpp.

Typedef Documentation

◆ ReIterable_collection_data

typedef struct reIterable_collection_data ReIterable_collection_data

◆ ReIterable_genQuery_data

typedef struct reIterable_genQuery_data ReIterable_genQuery_data

◆ ReIterable_irods_data

typedef struct reIterable_irods_data ReIterable_irods_data

◆ ReIterable_list_data

typedef struct reIterable_list_data ReIterable_list_data

Function Documentation

◆ checkStringForSystem()

int checkStringForSystem ( const char * s )

Definition at line 296 of file stringOpr.cpp.

References NULL, and USER_INPUT_STRING_ERR.

Referenced by smsi_msiCheckStringForSystem().

◆ collType()

ReIterableType collType ( Res * coll )

◆ columnToString()

void columnToString	(	Node *	n,
		char **	queryStr,
		int *	size
	)

Definition at line 736 of file functions.cpp.

References PRINT, size, node::subtrees, and node::text.

◆ construct()

Node* construct	(	char *	fn,
		Node **	args,
		int	argc,
		Node *	constype,
		Region *	r
	)

Definition at line 2508 of file functions.cpp.

References cpStringExt(), node::degree, node::exprType, newRes(), region_alloc(), node::subtrees, and node::text.

Referenced by evaluateFunction3().

Here is the call graph for this function:

◆ deconstruct()

Node* deconstruct	(	Node **	args,
		int	proj
	)

Definition at line 2518 of file functions.cpp.

References node::subtrees.

Referenced by evaluateFunction3().

◆ deleteReIterableData()

void deleteReIterableData ( ReIterableData * itrData )

Definition at line 133 of file functions.cpp.

Referenced by smsi_forEach2Exec().

◆ eval()

Res* eval	(	char *	expr,
		Env *	env,
		ruleExecInfo_t *	rei,
		int	saveREI,
		rError_t *	errmsg,
		Region *	r
	)

Definition at line 2503 of file functions.cpp.

References parseAndComputeExpression().

Referenced by smsi_eval().

Here is the call graph for this function:

◆ fileConcatenate()

int fileConcatenate	(	const char *	file1,
		const char *	file2,
		const char *	file3
	)

Definition at line 2454 of file functions.cpp.

References buf, error, NULL, UNIX_FILE_OPEN_ERR, and USER_FILE_DOES_NOT_EXIST.

◆ getReIterable()

ReIterable* getReIterable ( ReIterableType nodeType )

Definition at line 615 of file functions.cpp.

References NULL, NUM_RE_ITERABLE, reIterableTableRow::reIterable, and reIterableTable.

Referenced by smsi_forEach2Exec().

◆ getSystemFunctions()

void getSystemFunctions	(	Hashtable *	ft,
		Region *	r
	)

Definition at line 2573 of file functions.cpp.

References insertIntoHashTable(), newFunctionFD(), NULL, smsi_abs(), smsi_add(), smsi_and(), smsi_applyAllRules(), smsi_arity(), smsi_assign(), smsi_assignStr(), smsi_average(), smsi_bool(), smsi_break(), smsi_ceiling(), smsi_collection(), smsi_concat(), smsi_cons(), smsi_datetime(), smsi_delayExec(), smsi_divide(), smsi_do(), smsi_double(), smsi_elem(), smsi_eq(), smsi_errorcode(), smsi_errormsg(), smsi_eval(), smsi_evalrule(), smsi_execCmdArg(), smsi_exp(), smsi_fail(), smsi_floor(), smsi_forEach2Exec(), smsi_forEachExec(), smsi_forExec(), smsi_ge(), smsi_getGlobalSessionId(), smsi_getstderr(), smsi_getstdout(), smsi_getValByKey(), smsi_gt(), smsi_hd(), smsi_if2Exec(), smsi_ifExec(), smsi_int(), smsi_le(), smsi_letExec(), smsi_like(), smsi_like_regex(), smsi_list(), smsi_listapprules(), smsi_listcorerules(), smsi_listextrules(), smsi_listvars(), smsi_lmsg(), smsi_log(), smsi_lt(), smsi_matchExec(), smsi_max(), smsi_min(), smsi_modulo(), smsi_msiCheckStringForSystem(), smsi_multiply(), smsi_negate(), smsi_neq(), smsi_not(), smsi_not_like(), smsi_not_like_regex(), smsi_or(), smsi_path(), smsi_power(), smsi_properties(), smsi_query(), smsi_remoteExec(), smsi_root(), smsi_segfault(), smsi_setelem(), smsi_setGlobalSessionId(), smsi_size(), smsi_split(), smsi_str(), smsi_strlen(), smsi_substr(), smsi_subtract(), smsi_succeed(), smsi_time(), smsi_timestr(), smsi_tl(), smsi_triml(), smsi_trimr(), smsi_type(), smsi_undefined(), smsi_whileExec(), smsi_writeLine(), smsi_writeString(), and smsiCollectionSpider().

Referenced by load_rules(), and loadRuleFromCacheOrFile().

Here is the call graph for this function:

◆ matchWholeString()

char* matchWholeString ( char * buf )

Definition at line 2523 of file functions.cpp.

References buf.

Referenced by smsi_like_regex().

◆ msiCloseGenQuery()

msiCloseGenQuery	(	msParam_t *	genQueryInp_msp,
		msParam_t *	genQueryOut_msp,
		ruleExecInfo_t *	rei
	)

Description:\n This microservice closes an unfinished query. This is based on the code from #msiGetMoreRows.

Module:\n core

Since: 3.1

Example Usage:\n None

Parameters

[in]	genQueryInp_msp	- Required - a GenQueryInp_MS_T containing the query parameters and conditions.
[in]	genQueryOut_msp	- Required - a GenQueryOut_MS_T to write results to. If its continuation index is 0 the query will be closed.
[in,out]	rei	- The RuleExecInfo structure that is automatically handled by the rule engine. The user does not include rei as a parameter in the rule invocation.

Session Variables Used:\n none

Session Variables Modified:\n none

iCAT Attributes Used:\n none

iCAT Attributes Modified:\n none

Side Effect:\n none

Returns: integer

Return values

0	on success

Precondition: none

Postcondition: none

See also: none

Definition at line 395 of file genQueryMS.cpp.

Referenced by reIterable_genQuery_finalize().

◆ msiExecGenQuery()

msiExecGenQuery	(	msParam_t *	genQueryInParam,
		msParam_t *	genQueryOutParam,
		ruleExecInfo_t *	rei
	)

Description:\n This function executes a given general query structure and returns results

Module:\n core

Since: pre-2.1

Note: Takes a SQL-like iRODS query (no FROM clause) and returns a table structure. Use msiGetMoreRows to get all rows.

Example Usage:\n See clients/icommands/test/rules/

Parameters

[in]	genQueryInParam	- a msParam of type GenQueryInp_MS_T
[out]	genQueryOutParam	- a msParam of type GenQueryOut_MS_T
[in,out]	rei	- The RuleExecInfo structure that is automatically handled by the rule engine. The user does not include rei as a parameter in the rule invocation.

Session Variables Used:\n none

Session Variables Modified:\n none

iCAT Attributes Used:\n none

iCAT Attributes Modified:\n none

Side Effect:\n none

Returns: integer

Return values

0	on success

Precondition: none

Postcondition: none

See also: msiGetMoreRows and msiExecStrCondQuery

Definition at line 117 of file genQueryMS.cpp.

Referenced by smsi_query().

◆ msiGetMoreRows()

msiGetMoreRows	(	msParam_t *	genQueryInp_msp,
		msParam_t *	genQueryOut_msp,
		msParam_t *	continueInx,
		ruleExecInfo_t *	rei
	)

Description:\n This microservice continues an unfinished query.

Module:\n core

Since: pre-2.1

Note: This microservice gets the next batch of rows for an open iCAT query. Likely to follow msiMakeGenQuery and msiExecGenQuery.

Example Usage:\n None

Parameters

[in]	genQueryInp_msp	- Required - a GenQueryInp_MS_T containing the query parameters and conditions.
[in]	genQueryOut_msp	- Required - a GenQueryOut_MS_T to write results to. If its continuation index is 0 the query will be closed.
[out]	continueInx	- a INT_MS_T containing the new continuation index (after the query).
[in,out]	rei	- The RuleExecInfo structure that is automatically handled by the rule engine. The user does not include rei as a parameter in the rule invocation.

Session Variables Used:\n none

Session Variables Modified:\n none

iCAT Attributes Used:\n none

iCAT Attributes Modified:\n none

Side Effect:\n none

Returns: integer

Return values

0	on success

Precondition: none

Postcondition: none

See also: none

Definition at line 292 of file genQueryMS.cpp.

Referenced by reIterable_genQuery_hasNext().

◆ newReIterableData()

ReIterableData* newReIterableData	(	char *	varName,
		Res *	res,
		Node **	subtrees,
		Node *	node,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg
	)

Definition at line 109 of file functions.cpp.

References reIterableData::env, reIterableData::errmsg, reIterableData::errorRes, reIterableData::itrSpecData, reIterableData::node, NULL, reIterableData::rei, reIterableData::reiSaveFlag, reIterableData::res, reIterableData::subtrees, and reIterableData::varName.

Referenced by smsi_forEach2Exec().

◆ parseResForCollInp()

int parseResForCollInp	(	Node *	inpParam,
		collInp_t *	collInpCache,
		collInp_t **	outCollInp,
		int	outputToCache
	)

Definition at line 2292 of file functions.cpp.

References buf, CollInp_MS_T, CollInp::collName, CollInp::condInput, deleteHashTable(), ERR_MSG_LEN, node::exprType, LOG_ERROR, MAX_NAME_LEN, newHashTable(), NULL, RES_IRODS_TYPE, RES_UNINTER_STRUCT, rodsLog(), rstrcpy(), SYS_INTERNAL_NULL_INPUT_ERR, T_IRODS, T_STRING, node::text, TYPE, typeToString(), and USER_PARAM_TYPE_ERR.

Referenced by smsiCollectionSpider().

Here is the call graph for this function:

◆ reIterable_collection_finalize()

void reIterable_collection_finalize	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 600 of file functions.cpp.

References reIterable_collection_data::collInp, reIterable_collection_data::dataObjInp, reIterableData::errorRes, reIterable_collection_data::handleInx, reIterableData::itrSpecData, newErrorRes(), reIterableData::rei, rsCloseCollection(), RuleExecInfo::rsComm, RuleExecInfo::status, reIterableData::subtrees, T_PATH, and TYPE.

Here is the call graph for this function:

◆ reIterable_collection_hasNext()

int reIterable_collection_hasNext	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 562 of file functions.cpp.

References reIterable_collection_data::collEnt, DATA_OBJ_T, reIterable_collection_data::handleInx, reIterableData::itrSpecData, NULL, reIterableData::rei, RuleExecInfo::rsComm, rsReadCollection(), and RuleExecInfo::status.

Here is the call graph for this function:

◆ reIterable_collection_init()

void reIterable_collection_init	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 522 of file functions.cpp.

References buf, reIterable_collection_data::collInp, CollInp::collName, reIterable_collection_data::dataObjInp, reIterableData::env, ERR_MSG_LEN, reIterableData::errmsg, reIterableData::errorRes, CollInp::flags, generateAndAddErrMsg(), reIterable_collection_data::handleInx, reIterableData::itrSpecData, newErrorRes(), reIterableData::node, NULL, RECUR_QUERY_FG, reIterableData::rei, reIterableData::reiSaveFlag, RES_UNINTER_STRUCT, RuleExecInfo::rsComm, rsOpenCollection(), smsi_collection(), reIterableData::subtrees, node::subtrees, SYS_INTERNAL_NULL_INPUT_ERR, T_ERROR, T_PATH, and TYPE.

Here is the call graph for this function:

◆ reIterable_collection_next()

Res * reIterable_collection_next	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 580 of file functions.cpp.

References reIterable_collection_data::collEnt, CollEnt::collName, CollEnt::dataName, reIterable_collection_data::dataObjInp, DataObjInp_MS_T, reIterableData::env, reIterableData::errmsg, evaluateActions(), reIterableData::itrSpecData, MAX_NAME_LEN, newUninterpretedRes(), NULL, DataObjInp::objPath, reIterableData::rei, reIterableData::reiSaveFlag, reIterableData::subtrees, updateInEnv(), and reIterableData::varName.

Here is the call graph for this function:

◆ reIterable_genQuery_finalize()

void reIterable_genQuery_finalize	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 434 of file functions.cpp.

References clearMsParam(), reIterableData::errmsg, reIterableData::errorRes, freeGenQueryInp(), generateAndAddErrMsg(), reIterable_genQuery_data::genQInpParam, reIterable_genQuery_data::genQOutParam, MsParam::inOutStruct, reIterableData::itrSpecData, msiCloseGenQuery(), newErrorRes(), reIterableData::node, reIterableData::rei, and irods.pypyodbc::status.

Here is the call graph for this function:

◆ reIterable_genQuery_hasNext()

int reIterable_genQuery_hasNext	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 388 of file functions.cpp.

References CAT_NO_ROWS_FOUND, clearMsParam(), reIterable_genQuery_data::cont, reIterableData::errmsg, reIterableData::errorRes, node::exprType, generateAndAddErrMsg(), reIterable_genQuery_data::genQInpParam, reIterable_genQuery_data::genQOutParam, reIterable_genQuery_data::genQueryOut, getCollectionSize(), reIterable_genQuery_data::i, MsParam::inOutStruct, reIterableData::itrSpecData, reIterable_genQuery_data::len, msiGetMoreRows(), newErrorRes(), reIterableData::node, reIterableData::rei, reIterableData::res, irods.pypyodbc::status, node::subtrees, and node::text.

Here is the call graph for this function:

◆ reIterable_genQuery_init()

void reIterable_genQuery_init	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 373 of file functions.cpp.

References reIterable_genQuery_data::cont, GenQueryOut::continueInx, convertResToMsParam(), reIterableData::errmsg, node::exprType, reIterable_genQuery_data::genQInpParam, reIterable_genQuery_data::genQOutParam, reIterable_genQuery_data::genQueryOut, getCollectionSize(), reIterable_genQuery_data::i, reIterableData::itrSpecData, reIterable_genQuery_data::len, reIterableData::res, RES_UNINTER_STRUCT, node::subtrees, and node::text.

Here is the call graph for this function:

◆ reIterable_genQuery_next()

Res * reIterable_genQuery_next	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 419 of file functions.cpp.

References clearKeyVal(), reIterableData::env, reIterableData::errmsg, reIterableData::errorRes, evaluateActions(), node::exprType, reIterable_genQuery_data::genQueryOut, getNodeType, getValueFromCollection(), reIterable_genQuery_data::i, reIterableData::itrSpecData, N_ERROR, reIterableData::node, NULL, reIterableData::rei, reIterableData::reiSaveFlag, reIterableData::res, RES_UNINTER_STRUCT, setVariableValue(), reIterableData::subtrees, node::subtrees, node::text, and reIterableData::varName.

Here is the call graph for this function:

◆ reIterable_irods_finalize()

void reIterable_irods_finalize	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 509 of file functions.cpp.

References reIterableData::itrSpecData.

◆ reIterable_irods_hasNext()

int reIterable_irods_hasNext	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 496 of file functions.cpp.

References reIterable_irods_data::i, reIterableData::itrSpecData, and reIterable_irods_data::n.

◆ reIterable_irods_init()

void reIterable_irods_init	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 488 of file functions.cpp.

References node::exprType, getCollectionSize(), reIterable_irods_data::i, reIterableData::itrSpecData, reIterable_irods_data::n, reIterableData::res, RES_UNINTER_STRUCT, and node::text.

Here is the call graph for this function:

◆ reIterable_irods_next()

Res * reIterable_irods_next	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 501 of file functions.cpp.

References reIterableData::env, reIterableData::errmsg, evaluateActions(), node::exprType, getValueFromCollection(), reIterable_irods_data::i, reIterableData::itrSpecData, reIterableData::node, reIterableData::rei, reIterableData::reiSaveFlag, reIterableData::res, RES_UNINTER_STRUCT, setVariableValue(), reIterableData::subtrees, node::text, and reIterableData::varName.

Here is the call graph for this function:

◆ reIterable_list_finalize()

void reIterable_list_finalize	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 477 of file functions.cpp.

References reIterableData::itrSpecData.

◆ reIterable_list_hasNext()

int reIterable_list_hasNext	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 464 of file functions.cpp.

References reIterable_list_data::i, reIterableData::itrSpecData, and reIterable_list_data::n.

◆ reIterable_list_init()

void reIterable_list_init	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 455 of file functions.cpp.

References node::degree, reIterable_list_data::elems, reIterable_list_data::i, reIterableData::itrSpecData, reIterable_list_data::n, reIterableData::res, and node::subtrees.

◆ reIterable_list_next()

Res * reIterable_list_next	(	ReIterableData *	itrData,
		Region *	r
	)

Definition at line 469 of file functions.cpp.

References reIterable_list_data::elems, reIterableData::env, reIterableData::errmsg, evaluateActions(), reIterable_list_data::i, reIterableData::itrSpecData, reIterableData::node, reIterableData::rei, reIterableData::reiSaveFlag, setVariableValue(), reIterableData::subtrees, and reIterableData::varName.

Here is the call graph for this function:

◆ rsCloseCollection()

int rsCloseCollection	(	rsComm_t *	rsComm,
		int *	handleInxInp
	)

Definition at line 14 of file rsCloseCollection.cpp.

Referenced by _rsCollRsync(), _rsPhyBundleColl(), _rsPhyRmColl(), _rsStructFileBundle(), chkCollForBundleOpr(), isCollEmpty(), reIterable_collection_finalize(), rsCollRepl(), rsOpenCollection(), and smsiCollectionSpider().

◆ rsOpenCollection()

int rsOpenCollection	(	rsComm_t *	rsComm,
		collInp_t *	openCollInp
	)

Definition at line 16 of file rsOpenCollection.cpp.

Referenced by _rsCollRsync(), _rsPhyBundleColl(), _rsPhyRmColl(), _rsStructFileBundle(), chkCollForBundleOpr(), isCollEmpty(), reIterable_collection_init(), rsCollRepl(), and smsiCollectionSpider().

◆ rsReadCollection()

int rsReadCollection	(	rsComm_t *	rsComm,
		int *	handleInxInp,
		collEnt_t **	collEnt
	)

Definition at line 15 of file rsReadCollection.cpp.

Referenced by _rsCollRsync(), _rsPhyBundleColl(), _rsPhyRmColl(), _rsStructFileBundle(), chkCollForBundleOpr(), isCollEmpty(), reIterable_collection_hasNext(), rsCollRepl(), and smsiCollectionSpider().

◆ smsi_abs()

Res* smsi_abs	(	Node **	args,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Definition at line 1473 of file functions.cpp.

References newDoubleRes(), newIntRes(), RES_DOUBLE_VAL, RES_INT_VAL, T_INT, and TYPE.

Res* smsi_add	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_and	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_applyAllRules	(	Node **	subtrees,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_arity	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_assign	(	Node **	subtrees,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_assignStr	(	Node **	subtrees,
		int	,
		Node *	node,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_average	(	Node **	params,
		int	n,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_bool	(	Node **	params,
		int	,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_break	(	Node **	,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_ceiling	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_collection	(	Node **	subtrees,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_concat	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_cons	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_datetime	(	Node **	params,
		int	n,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_delayExec	(	Node **	paramsr,
		int	,
		Node *	node,
		ruleExecInfo_t *	rei,
		int	,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_divide	(	Node **	params,
		int	,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_do	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_double	(	Node **	params,
		int	,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_elem	(	Node **	params,
		int	,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_eq	(	Node **	params,
		int	,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Classes

Macros

Typedefs

Functions

Variables

Macro Definition Documentation

◆ GC_BEGIN

◆ GC_END

◆ GC_ON

◆ GC_REGION

◆ NUM_RE_ITERABLE

◆ RE_BACKWARD_COMPATIBLE

Typedef Documentation

◆ ReIterable_collection_data

◆ ReIterable_genQuery_data

◆ ReIterable_irods_data

◆ ReIterable_list_data

Function Documentation

◆ checkStringForSystem()

◆ collType()

◆ columnToString()

◆ construct()

◆ deconstruct()

◆ deleteReIterableData()

◆ eval()

◆ fileConcatenate()

◆ getReIterable()

◆ getSystemFunctions()

◆ matchWholeString()

◆ msiCloseGenQuery()

◆ msiExecGenQuery()

◆ msiGetMoreRows()

◆ newReIterableData()

◆ parseResForCollInp()

◆ reIterable_collection_finalize()

◆ reIterable_collection_hasNext()

◆ reIterable_collection_init()

◆ reIterable_collection_next()

◆ reIterable_genQuery_finalize()

◆ reIterable_genQuery_hasNext()

◆ reIterable_genQuery_init()

◆ reIterable_genQuery_next()

◆ reIterable_irods_finalize()

◆ reIterable_irods_hasNext()

◆ reIterable_irods_init()

◆ reIterable_irods_next()

◆ reIterable_list_finalize()

◆ reIterable_list_hasNext()

◆ reIterable_list_init()

◆ reIterable_list_next()

◆ rsCloseCollection()

◆ rsOpenCollection()

◆ rsReadCollection()

◆ smsi_abs()

◆ smsi_add()

◆ smsi_and()

◆ smsi_applyAllRules()

◆ smsi_arity()

◆ smsi_assign()

◆ smsi_assignStr()

◆ smsi_average()

◆ smsi_bool()

◆ smsi_break()

◆ smsi_ceiling()

◆ smsi_collection()

◆ smsi_concat()

◆ smsi_cons()

◆ smsi_datetime()

◆ smsi_delayExec()

◆ smsi_divide()

◆ smsi_do()

◆ smsi_double()

◆ smsi_elem()

◆ smsi_eq()

◆ smsi_errorcode()

◆ smsi_errormsg()

◆ smsi_eval()

◆ smsi_evalrule()

◆ smsi_execCmdArg()

◆ smsi_exp()

Res* smsi_errorcode	(	Node **	paramsr,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_errormsg	(	Node **	paramsr,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_eval	(	Node **	paramsr,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_evalrule	(	Node **	paramsr,
		int	,
		Node *	,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_execCmdArg	(	Node **	subtrees,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_exp	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_fail	(	Node **	subtrees,
		int	n,
		Node *	node,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	errmsg,
		Region *	r
	)

Res* smsi_false	(	Node **	,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_floor	(	Node **	params,
		int	,
		Node *	,
		ruleExecInfo_t *	,
		int	,
		Env *	,
		rError_t *	,
		Region *	r
	)

Res* smsi_forEach2Exec	(	Node **	subtrees,
		int	,
		Node *	node,
		ruleExecInfo_t *	rei,
		int	reiSaveFlag,
		Env *	env,
		rError_t *	errmsg,
		Region *	r
	)