/*___INFO__MARK_BEGIN__*/ /************************************************************************* * * The Contents of this file are made available subject to the terms of * the Sun Industry Standards Source License Version 1.2 * * Sun Microsystems Inc., March, 2001 * * * Sun Industry Standards Source License Version 1.2 * ================================================= * The contents of this file are subject to the Sun Industry Standards * Source License Version 1.2 (the "License"); You may not use this file * except in compliance with the License. You may obtain a copy of the * License at http://gridengine.sunsource.net/Gridengine_SISSL_license.html * * Software provided under this License is provided on an "AS IS" basis, * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. * See the License for the specific provisions governing your rights and * obligations concerning the Software. * * The Initial Developer of the Original Code is: Sun Microsystems, Inc. * * Copyright: 2001 by Sun Microsystems, Inc. * * All Rights Reserved. * ************************************************************************/ /*___INFO__MARK_END__*/ #include #include #include "rmon/sgermon.h" #include "uti/sge_time.h" #include "uti/sge_log.h" #include "uti/sge_prog.h" #include "uti/sge_stdlib.h" #include "uti/sge_string.h" #include "cull/cull.h" #include "symbols.h" #include "sge_var.h" #include "sge.h" #include "sge_centry.h" #include "sge_answer.h" #include "msg_sgeobjlib.h" /****** sgeobj/var/-VariableList ********************************************** * NAME * VariableList - Object to store variable name/value pairs * * FUNCTION * In several places within SGE/EE it is necessary to store * variables and their values (e.g. job environment variable, * job context, ...) of following form: * * variable[=value][,variable[=value],...] * * The VA_Type CULL element is used to hold such data. * Funktions in the SEE ALSO section might be used to * work with VA_Type lists and elements. * * SEE ALSO * sgeobj/var/--VA_Type * clients/var/var_list_parse_from_string() * sgeobj/var/var_list_dump_to_file() * sgeobj/var/var_list_copy_complex_vars_and_value() * sgeobj/var/var_list_copy_prefix_vars() * sgeobj/var/var_list_get_string() * sgeobj/var/var_list_set_string() * sgeobj/var/var_list_set_int() * sgeobj/var/var_list_set_sge_u32() * sgeobj/var/var_list_set_sharedlib_path() * sgeobj/var/var_list_remove_prefix_vars() ******************************************************************************/ /****** sgeobj/var/var_get_sharedlib_path_name() ****************************** * NAME * var_get_sharedlib_path_name -- name of sharedlib path variable * * SYNOPSIS * static const char *var_get_sharedlib_path_name(void); * * FUNCTION * Returns the operating dependent name of the shared library path * (e.g. LIBPATH, SHLIB_PATH, LD_LIBRARY_PATH). * If the name of the sharedlib path is not known for an operating * system (the port has not yet been done), a compile time error * is raised. * * RESULT * Name of the shared lib path variable * * NOTES * Raising a compile time error (instead of e.g. just returning NULL * or LD_LIBRARY_PATH as default) has the following reason: * Setting the shared lib path is a very sensible operation * concerning security. * Example: If a shared linked rshd (called for qrsh execution) is * executed with a faked shared lib path, operations defined in * a non sge library libgdi.so might be executed as user root. ******************************************************************************/ const char *var_get_sharedlib_path_name(void) { #if defined(AIX) return "LIBPATH"; #elif defined(HP11) return "SHLIB_PATH"; #elif defined(ALPHA) || defined(IRIX) || defined(LINUX) || defined(SOLARIS) || defined(DARWIN) || defined(FREEBSD) || defined(NETBSD) || defined(INTERIX) || defined(HP1164) return "LD_LIBRARY_PATH"; #elif defined(DARWIN) return "DYLD_LIBRARY_PATH"; #else #error "don't know how to set shared lib path on this architecture" return NULL; /* never reached */ #endif } /****** sgeobj/var/var_list_set_string() ************************************** * NAME * var_list_set_string -- add/change an variable * * SYNOPSIS * void var_list_set_string(lList **varl, * const char *name, * const char *value); * * FUNCTION * If the variable does not already exist in , * it is created and initialized with . * Otherwise, its value is overwritten with * * INPUTS * lList **varl - VA_Type list * const char *name - the name of the variable * const char *value - the (new) value of the variable * * SEE ALSO * sgeobj/var/var_list_set_int() * sgeobj/var/var_list_set_sge_u32() * sgeobj/var/var_list_set_sharedlib_path() ******************************************************************************/ void var_list_set_string(lList **varl, const char *name, const char *value) { lListElem *elem; DENTER(TOP_LAYER, "var_list_set_string"); if (varl == NULL || name == NULL || value == NULL) { DEXIT; return; } elem = lGetElemStr(*varl, VA_variable, name); if (elem == NULL) { elem = lAddElemStr(varl, VA_variable, name, VA_Type); } lSetString(elem, VA_value, value); DEXIT; } /****** sgeobj/var/var_list_delete_string() *********************************** * NAME * var_list_delete_string -- delete a variable * * SYNOPSIS * void var_list_delete_string(lList **varl, * const char *name); * * FUNCTION * Deletes the variable from the list if it exists. * * INPUTS * lList **varl - VA_Type list * const char *name - the name of the variable * * SEE ALSO * sgeobj/var/var_list_set_string() ******************************************************************************/ void var_list_delete_string(lList **varl, const char *name) { lListElem *elem; DENTER(TOP_LAYER, "var_list_delete_string"); if (varl == NULL || name == NULL) { DRETURN_VOID; } elem = lGetElemStr(*varl, VA_variable, name); if (elem != NULL) { lRemoveElem(*varl, &elem); } DEXIT; } /****** sgeobj/var/var_list_set_int() ***************************************** * NAME * var_list_set_int -- add/change an variable * * SYNOPSIS * void var_list_set_int(lList *varl, * const char *name, * int value); * * FUNCTION * If the variable does not already exist in , * it is created and initialized with . * Otherwise, its value is overwritten with * * INPUTS * varl - VA_Type list * name - the name of the variable * value - the (new) value of the variable * * SEE ALSO * sgeobj/var/var_list_set_string() * sgeobj/var/var_list_set_sge_u32() * sgeobj/var/var_list_set_sharedlib_path() ******************************************************************************/ void var_list_set_int(lList **varl, const char *name, int value) { char buffer[2048]; DENTER(TOP_LAYER, "var_list_set_int"); sprintf(buffer, "%d", value); var_list_set_string(varl, name, buffer); DEXIT; } /****** sgeobj/var/var_list_set_sge_u32() ***************************************** * NAME * var_list_set_sge_u32 -- add/change a variable * * SYNOPSIS * void var_list_set_sge_u32(lList **varl, * const char *name, * u_long32 value); * * FUNCTION * If the variable does not already exist in , * it is created and initialized with . * Otherwise, its value is overwritten with * * INPUTS * lList **varl - VA_Type list * const char *name - the name of the variable * u_long32 value - the (new) value of the variable * * SEE ALSO * sgeobj/var/var_list_set_string() * sgeobj/var/var_list_set_int() * sgeobj/var/var_list_set_sharedlib_path() ******************************************************************************/ void var_list_set_sge_u32(lList **varl, const char *name, u_long32 value) { char buffer[2048]; DENTER(TOP_LAYER, "var_list_set_sge_u32"); sprintf(buffer, sge_u32, value); var_list_set_string(varl, name, buffer); DEXIT; } /****** sgeobj/var/var_list_set_sharedlib_path() ****************************** * NAME * var_list_set_sharedlib_path -- set shared lib path * * SYNOPSIS * void var_list_set_sharedlib_path(lList **varl); * * FUNCTION * Sets or replaces the shared lib path in the list of variables. * The SGE shared lib path is always set to the beginning of the * resulting shared lib path * (security, see var_get_sharedlib_path_name()) * * INPUTS * lList **varl - list of nment variables * * SEE ALSO * sgeobj/var/var_get_sharedlib_path_name() * sgeobj/var/var_list_set_string() * sgeobj/var/var_list_set_int() * sgeobj/var/var_list_set_sge_u32() ******************************************************************************/ void var_list_set_sharedlib_path(lList **varl) { char *sharedlib_path; char *sge_sharedlib_path; const char *sge_root = sge_get_root_dir(0, NULL, 0, 1); const char *sharedlib_path_name = var_get_sharedlib_path_name(); lListElem *sharedlib_elem = NULL; DENTER(TOP_LAYER, "set_sharedlib_path"); /* this is the SGE sharedlib path */ sge_sharedlib_path = sge_malloc(strlen(sge_root) + strlen("/lib/") + strlen(sge_get_arch()) + 1); sprintf(sge_sharedlib_path, "%s/lib/%s", sge_root, sge_get_arch()); /* if already in environment: extend by SGE sharedlib path, else set */ sharedlib_elem = lGetElemStr(*varl, VA_variable, sharedlib_path_name); if(sharedlib_elem != NULL) { const char *old_value = lGetString(sharedlib_elem, VA_value); if(old_value && strlen(old_value) > 0) { DPRINTF(("sharedlib path %s already set:\n", sharedlib_path_name)); sharedlib_path = sge_malloc(strlen(old_value) + 1 + strlen(sge_sharedlib_path) + 1); strcpy(sharedlib_path, sge_sharedlib_path); strcat(sharedlib_path, ":"); strcat(sharedlib_path, old_value); lSetString(sharedlib_elem, VA_value, sharedlib_path); FREE(sharedlib_path); } else { DPRINTF(("overwriting empty sharedlib path %s\n", sharedlib_path_name)); lSetString(sharedlib_elem, VA_value, sge_sharedlib_path); } } else { DPRINTF(("creating new sharedlib path %s\n", sharedlib_path_name)); sharedlib_elem = lAddElemStr(varl, VA_variable, sharedlib_path_name, VA_Type); lSetString(sharedlib_elem, VA_value, sge_sharedlib_path); } FREE(sge_sharedlib_path); DEXIT; } /****** sgeobj/var/var_list_dump_to_file() ************************************ * NAME * var_list_dump_to_file -- dump variables from list to file * * SYNOPSIS * void var_list_dump_to_file(const lList *varl, FILE *file); * * FUNCTION * Parses the list of type VA_Type containing the * description of variables. * Dumps all list elements to in the format: * = * is read from VA_variable, from VA_value. * * INPUTS * varl - list of variables * file - filehandle of a previously opened (for writing) file ******************************************************************************/ void var_list_dump_to_file(const lList *varl, FILE *file) { lListElem *elem; if (varl == NULL || file == NULL) { return; } for_each(elem, varl) { /* * Replace by \n sequence for multiline environment * variable support. */ const char *env_name = lGetString(elem, VA_variable); const char *env_value = lGetString(elem, VA_value); const char *new_env_value = sge_replace_substring(env_value, "\n", "\\n"); if (new_env_value == NULL) { fprintf(file, "%s=%s\n", env_name, env_value); } else { fprintf(file, "%s=%s\n", env_name, new_env_value); free((void *)new_env_value); } } } /****** sgeobj/var/var_list_get_string() ************************************** * NAME * var_list_get_string() -- get value of certain variable * * SYNOPSIS * const char* var_list_get_string(lList *varl, * const char *variable) * * FUNCTION * Return the string value of a variable * with the name "variable" which is stored in "varl". * * INPUTS * lList *varl - VA_Type list * const char *variable - variable name * * RESULT * const char* - value or NULL * * SEE ALSO * sgeobj/var/var_list_set_string() * sgeobj/var/var_list_set_int() * sgeobj/var/var_list_set_sge_u32() * sgeobj/var/var_list_set_sharedlib_path() ******************************************************************************/ const char* var_list_get_string(lList *varl, const char *variable) { lListElem *var = NULL; /* VA_Type */ const char *ret = NULL; var = lGetElemStr(varl, VA_variable, variable); if (var != NULL) { ret = lGetString(var, VA_value); } return ret; } /****** sgeobj/var/var_list_copy_prefix_vars() ******************************** * NAME * var_list_copy_prefix_vars() -- copy vars with certain prefix * * SYNOPSIS * void var_list_copy_prefix_vars(lList **varl, * const lList *src_varl, * const char *prefix, * const char *new_prefix) * * FUNCTION * Make a copy of all entries in "src_varl" * beginning with "prefix". "prefix" is replaced by "new_prefix" * for all created elements. The new elements will be added to * "varl". * * INPUTS * lList **varl - VA_Type list * const char *prefix - prefix string (e.g. VAR_PREFIX) * const char *new_prefix - new prefix string (e.g. "SGE_") * * EXAMPLE * "__SGE_PREFIX__O_HOME" ===> "SGE_O_HOME * * SEE ALSO * sgeobj/var/var_list_remove_prefix_vars() ******************************************************************************/ void var_list_copy_prefix_vars(lList **varl, const lList *src_varl, const char *prefix, const char *new_prefix) { int prefix_len = strlen(prefix); lListElem *var_elem = NULL; lList *var_list2 = NULL; DENTER(TOP_LAYER, "var_list_copy_prefix_vars"); for_each(var_elem, src_varl) { const char *prefix_name = lGetString(var_elem, VA_variable); if (strncmp(prefix_name, prefix, prefix_len) == 0) { char name[MAX_STRING_SIZE]; const char *name_without_prefix = &prefix_name[prefix_len]; const char *value = lGetString(var_elem, VA_value); sprintf(name, "%s%s", new_prefix, name_without_prefix); var_list_set_string(&var_list2, name, value); } } if (*varl == NULL) { *varl = lCreateList("", VA_Type); } var_list_add_as_set(*varl, var_list2); DRETURN_VOID; } /****** sgeobj/var/var_list_copy_prefix_vars_undef() ************************** * NAME * var_list_copy_prefix_vars_undef() -- copy vars with certain prefix * * SYNOPSIS * void * var_list_copy_prefix_vars_undef(lList **varl, * const lList *src_varl, * const char *prefix, * const char *new_prefix) * * FUNCTION * Make a copy of all entries in "src_varl" * beginning with "prefix". "prefix" is replaced by "new_prefix" * for all created elements. The new elements will be added to * "varl" if it is undefined in "varl". * * INPUTS * lList **varl - VA_Type list * const char *prefix - prefix string (e.g. VAR_PREFIX_NR) * const char *new_prefix - new prefix string (e.g. "SGE_") * * EXAMPLE * "__SGE_PREFIX2__TASK_ID" ===> "SGE_TASK_ID * * SEE ALSO * sgeobj/var/var_list_remove_prefix_vars() ******************************************************************************/ void var_list_copy_prefix_vars_undef(lList **varl, const lList *src_varl, const char *prefix, const char *new_prefix) { int prefix_len = strlen(prefix); lListElem *var_elem = NULL; lList *var_list2 = NULL; DENTER(TOP_LAYER, "var_list_copy_prefix_vars"); for_each(var_elem, src_varl) { const char *prefix_name = lGetString(var_elem, VA_variable); if (!strncmp(prefix_name, prefix, prefix_len)) { char name[MAX_STRING_SIZE]; const char *value = lGetString(var_elem, VA_value); const char *name_without_prefix = &prefix_name[prefix_len]; lListElem *existing_variable; sprintf(name, "%s%s", new_prefix, name_without_prefix); existing_variable = lGetElemStr(*varl, VA_variable, name); if (existing_variable == NULL) { var_list_set_string(&var_list2, name, value); } } } if (*varl == NULL) { *varl = lCreateList("", VA_Type); } lAddList(*varl, &var_list2); DEXIT; } /****** sgeobj/var/var_list_copy_env_vars_and_value() ************************* * NAME * var_list_copy_env_vars_and_value() -- Copy env. vars * * SYNOPSIS * void * var_list_copy_env_vars_and_value(lList **varl, * const lList *src_varl, * const char *ignore_prefix) * * FUNCTION * Copy all variables from "src_varl" into "varl". Ignore * all variables beginning with "ignore_prefix". * * INPUTS * lList **varl - VA_Type list * const lList *src_varl - source VA_Type list * const char *ignore_prefix - prefix * * RESULT * void - none ******************************************************************************/ void var_list_copy_env_vars_and_value(lList **varl, const lList* src_varl) { lListElem *env; for_each(env, src_varl) { const char *s, *name; name = lGetString(env, VA_variable); s = lGetString(env, VA_value); var_list_set_string(varl, name, s ? s : ""); } } /****** sgeobj/var/var_list_remove_prefix_vars() ****************************** * NAME * var_list_remove_prefix_vars() -- remove vars with certain prefix * * SYNOPSIS * void var_list_remove_prefix_vars(lList **varl, * const char *prefix) * * FUNCTION * Remove all entries from "varl" where the name * beginns with "prefix" * * INPUTS * lList **varl - VA_Type list * const char *prefix - prefix string (e.g. VAR_PREFIX) * * SEE ALSO * sgeobj/var/var_list_remove_prefix_vars() ******************************************************************************/ void var_list_remove_prefix_vars(lList **varl, const char *prefix) { int prefix_len = strlen(prefix); lListElem *var_elem = NULL; lListElem *next_var_elem = NULL; DENTER(TOP_LAYER, "var_list_remove_prefix_vars"); next_var_elem = lFirst(*varl); while((var_elem = next_var_elem)) { const char *prefix_name = lGetString(var_elem, VA_variable); next_var_elem = lNext(var_elem); if (!strncmp(prefix_name, prefix, prefix_len)) { lRemoveElem(*varl, &var_elem); } } DEXIT; return; } /****** sgeobj/var/var_list_split_prefix_vars() ******************************* * NAME * var_list_split_prefix_vars() -- split a list of variables * * SYNOPSIS * void var_list_split_prefix_vars(lList **varl, * lList **pefix_vars, * const char *prefix) * * FUNCTION * Move all variable elements form "varl" to "pefix_vars" which * begin with "prefix". *pefix_vars will be created if is does not * exist. * * INPUTS * lList **varl - VA_Type list * lList **pefix_vars - pointer to VA_Type list * const char *prefix - string (e.g. VAR_PREFIX) * * RESULT * void - None * * SEE ALSO * sgeobj/var/var_list_remove_prefix_vars() ******************************************************************************/ void var_list_split_prefix_vars(lList **varl, lList **pefix_vars, const char *prefix) { int prefix_len = strlen(prefix); lListElem *var_elem = NULL; lListElem *next_var_elem = NULL; DENTER(TOP_LAYER, "var_list_remove_prefix_vars"); next_var_elem = lFirst(*varl); while((var_elem = next_var_elem)) { const char *prefix_name = lGetString(var_elem, VA_variable); next_var_elem = lNext(var_elem); if (!strncmp(prefix_name, prefix, prefix_len)) { lListElem *dechained_elem = lDechainElem(*varl, var_elem); if (*pefix_vars == NULL) { *pefix_vars = lCreateList("", VA_Type); } lAppendElem(*pefix_vars, dechained_elem); } } DEXIT; return; } /****** sgeobj/var/var_list_add_as_set() *************************************** * NAME * var_list_add_as_set() -- Concatenate two lists as sets * * SYNOPSIS * int var_list_add_as_set(lList *lp0, lList *lp1) * * FUNCTION * Concatenate two lists of equal type throwing away the second list. * Elements in the second list will replace elements with the same key in the * the first list. If the first list contains duplicate element keys, only * the first element with a given key will be replaced by an element from the * second list with the same key. * * INPUTS * lList *lp0 - first list * lList *lp1 - second list * * RESULT * int - error state * 0 - OK * -1 - Error ******************************************************************************/ int var_list_add_as_set(lList *lp0, lList *lp1) { lListElem *ep0, *ep1; const lDescr *dp0, *dp1; const char *name, *value; DENTER(CULL_LAYER, "var_list_add_as_set"); if (lp1 == NULL || lp0 == NULL) { DRETURN(-1); } /* Check if the two lists are equal */ dp0 = lGetListDescr(lp0); dp1 = lGetListDescr(lp1); if (lCompListDescr(dp0, dp1) != 0) { DRETURN(-1); } while (lp1->first != NULL) { /* Get the first element from the second list */ if ((ep1 = lDechainElem(lp1, lp1->first)) == NULL) { DRETURN(-1); } /* Get it's name, and use the name to look for a matching element in the * first list. */ name = lGetString(ep1, VA_variable); ep0 = lGetElemStr(lp0, VA_variable, name); /* If there is a matching element in the first list, set it's value to the * value of the element from the second list. */ if (ep0 != NULL) { value = lGetString(ep1, VA_value); lSetString(ep0, VA_value, value); lFreeElem(&ep1); } /* If there is no matching element, add the element from the second list * to the first list. */ else { if (lAppendElem(lp0, ep1) == -1) { DRETURN(-1); } } } /* The second list is no longer needed. */ lFreeList(&lp1); DRETURN(0); } /****** sge_var/var_list_verify() ********************************************** * NAME * var_list_verify() -- verify contents of a variable list * * SYNOPSIS * bool * var_list_verify(const lList *lp, lList **answer_list) * * FUNCTION * Verifies the contents of a variable list. * Variable names may not be NULL or empty strings. * * INPUTS * const lList *lp - the list to verify * lList **answer_list - answer list to pass back error messages * * RESULT * bool - true on success, * false in case of errors, error message in answer_list * * NOTES * MT-NOTE: var_list_verify() is MT safe *******************************************************************************/ bool var_list_verify(const lList *lp, lList **answer_list) { bool ret = true; lListElem *ep; for_each (ep, lp) { const char *variable = lGetString(ep, VA_variable); if (variable == NULL || variable[0] == '\0') { answer_list_add_sprintf(answer_list, STATUS_ESYNTAX, ANSWER_QUALITY_ERROR, MSG_OBJECT_VARIABLENAME_NOT_EMPTY); ret = false; break; } } /* TODO: further checks, e.g. length, format strings */ return ret; } /****** sge_var/var_list_parse_from_string() ******************************* * NAME * var_list_parse_from_string() -- parse vars from string list * * SYNOPSIS * int var_list_parse_from_string(lList **lpp, * const char *variable_str, * int check_environment) * * FUNCTION * Parse a list of variables ("lpp") from a comma separated * string list ("variable_str"). The boolean "check_environment" * defined wether the current value of a variable is taken from * the environment of the calling process. * * INPUTS * lList **lpp - VA_Type list * const char *variable_str - source string * int check_environment - boolean * * RESULT * int - error state * 0 - OK * >0 - Error * * NOTES * MT-NOTE: var_list_parse_from_string() is MT safe *******************************************************************************/ int var_list_parse_from_string(lList **lpp, const char *variable_str, int check_environment) { char *variable; char *val_str; int var_len; char **str_str; char **pstr; lListElem *ep; char *va_string; DENTER(TOP_LAYER, "var_list_parse_from_string"); if (!lpp) { DEXIT; return 1; } va_string = sge_strdup(NULL, variable_str); if (!va_string) { *lpp = NULL; DEXIT; return 2; } str_str = string_list(va_string, ",", NULL); if (!str_str || !*str_str) { *lpp = NULL; FREE(va_string); DEXIT; return 3; } if (!*lpp) { *lpp = lCreateList("variable list", VA_Type); if (!*lpp) { FREE(va_string); FREE(str_str); DEXIT; return 4; } } for (pstr = str_str; *pstr; pstr++) { struct saved_vars_s *context; ep = lCreateElem(VA_Type); /* SGE_ASSERT(ep); */ lAppendElem(*lpp, ep); context = NULL; variable = sge_strtok_r(*pstr, "=", &context); SGE_ASSERT((variable)); var_len=strlen(variable); lSetString(ep, VA_variable, variable); val_str=*pstr; /* * The character at the end of the first token must be either '=' or '\0'. * If it's a '=' then we treat the following string as the value * If it's a '\0' and check_environment is set, then we get the value from * the environment variable value. * If it's a '\0' and check_environment is not set, then we set the value * to NULL. */ if (val_str[var_len] == '=') { lSetString(ep, VA_value, &val_str[var_len+1]); } else if (check_environment) { lSetString(ep, VA_value, sge_getenv(variable)); } else { lSetString(ep, VA_value, NULL); } sge_free_saved_vars(context); } FREE(va_string); FREE(str_str); DRETURN(0); } /****** sge_var/getenv_and_set() ******************************* * NAME * getenv_and_set() -- obtain value for environment name, * remove \n characters from value string * and set VA_Value member of *ep. * * SYNOPSIS * void getenv_and_set(lListElem *ep, char *variable) * * FUNCTION * Obtain value for environment name; check for any \n * characters in input string. Shell enters this character * for multi-line environment variables. If nothing found, * just store value in VA_Value member of *ep. * * Otherwise, count number of newline characters, figure out * string length and allocate new memory for the modified * string. Next, copy over string, skipping over \n characters. * Then, store value in VA_Value member of *ep. * * INPUTS * lListElem *ep - target list element * char *variable - environment variable * * RESULT * void * * NOTES * MT-NOTE: remove_newline_chars() is MT safe *******************************************************************************/ void getenv_and_set(lListElem *ep, char *variable) { const char *env_value = NULL; char *new_env_value = NULL; char *a = NULL; char *b = NULL; int i, nchars; int newline_chars = 0; env_value = sge_getenv(variable); if (env_value == NULL) { lSetString(ep, VA_value, NULL); return; } /* * Any work to do? Check for any newline * character. */ a = strchr(env_value, '\n'); if (a == NULL) { /* * Nothing to do. Just leave it alone. */ lSetString(ep, VA_value, env_value); return; } /* * This is a multi-line environment variable. Allocate * new string and copy over, but without newline chars. */ nchars = strlen(env_value); a = (char *)env_value; newline_chars = 0; for (i = 0; i < nchars; i++) { if (*a == '\n') { newline_chars++; } a++; } new_env_value = sge_malloc(nchars - newline_chars + 1); a = new_env_value; b = (char *)env_value; for (i = 0; i < nchars; i++) { if (*b != '\n') { *a = *b; a++; } b++; } *a = '\0'; lSetString(ep, VA_value, new_env_value); FREE(new_env_value); return; }