XrdOucUtils Class Reference

#include <XrdOucUtils.hh>

Collaboration diagram for XrdOucUtils:

Public Member Functions
	XrdOucUtils ()
	~XrdOucUtils ()

Static Public Member Functions
static int	argList (char *args, char **argV, int argC)
static char *	bin2hex (char *inbuff, int dlen, char *buff, int blen, bool sep=true)
static int	doIf (XrdSysError *eDest, XrdOucStream &Config, const char *what, const char *hname, const char *nname, const char *pname)
static bool	endsWith (const char *text, const char *ending, int endlen)
static char *	eText (int rc, char *eBuff, int eBlen)
static bool	findPgm (const char *pgm, XrdOucString &path)
static int	fmtBytes (long long val, char *buff, int bsz)
static int	genPath (char *buff, int blen, const char *path, const char *psfx=0)
static char *	genPath (const char *path, const char *inst, const char *psfx=0)
static char *	getFile (const char *path, int &rc, int maxsz=10240, bool notempty=true)
static bool	getGID (const char *gName, gid_t &gID)
static int	getModificationTime (const char *path, time_t &modificationTime)
static bool	getUID (const char *uName, uid_t &uID, gid_t *gID=0)
static int	GidName (gid_t gID, char *gName, int gNsz, time_t keepT=0)
static int	GroupName (gid_t gID, char *gName, int gNsz)
static int	hex2bin (const char *hex, char *bin, int size)
static const char *	HSize (size_t bytes, char *buff, int bsz)
static const char *	i2bstr (char *buff, int blen, int val, bool pad=false)
static char *	Ident (long long &mySID, char *iBuff, int iBlen, const char *iHost, const char *iProg, const char *iName, int Port)
static const char *	InstName (const char *name, int Fillit=1)
static const char *	InstName (int TranOpt=0)
static int	is1of (char *val, const char **clist)
static int	isFWD (const char *path, int *port=0, char *hBuff=0, int hBLen=0, bool pTrim=false)
static int	Log10 (unsigned long long n)
static int	Log2 (unsigned long long n)
static void	makeHome (XrdSysError &eDest, const char *inst)
static bool	makeHome (XrdSysError &eDest, const char *inst, const char *path, mode_t mode)
static int	makePath (char *path, mode_t mode, bool reset=false)
static bool	mode2mask (const char *mode, mode_t &mask)
static char *	parseHome (XrdSysError &eDest, XrdOucStream &Config, int &mode)
static bool	parseLib (XrdSysError &eDest, XrdOucStream &Config, const char *libName, char *&path, char **libparm)
static bool	PidFile (XrdSysError &eDest, const char *path)
static int	ReLink (const char *path, const char *target, mode_t mode=0)
static void	Sanitize (char *instr, char subc='_')
static char *	subLogfn (XrdSysError &eDest, const char *inst, char *logfn)
static int	Token (const char **str, char delim, char *buff, int bsz)
static void	toLower (char *str)
static void	trim (std::string &str)
static void	trim (std::string_view &sv)
static int	UidName (uid_t uID, char *uName, int uNsz, time_t keepT=0)
static void	Undercover (XrdSysError &eDest, int noLog, int *pipeFD=0)
static int	UserName (uid_t uID, char *uName, int uNsz)
static const char *	ValPath (const char *path, mode_t allow, bool isdir)

Static Public Attributes
static const mode_t	pathMode = S_IRWXU|S_IRGRP|S_IXGRP|S_IROTH|S_IXOTH

Detailed Description

Definition at line 43 of file XrdOucUtils.hh.

Constructor & Destructor Documentation

XrdOucUtils()

XrdOucUtils::XrdOucUtils ( )

inline

Definition at line 144 of file XrdOucUtils.hh.

{}

~XrdOucUtils()

XrdOucUtils::~XrdOucUtils ( )

inline

Definition at line 145 of file XrdOucUtils.hh.

{}

Member Function Documentation

argList()

int XrdOucUtils::argList ( char *  args, char **  argV, int  argC  )

static

Definition at line 125 of file XrdOucUtils.cc.

{
   char *aP = args;
   int j;
 
// Construct the argv array based on passed command line.
//
for (j = 0; j < argC; j++)
    {while(*aP == ' ') aP++;
     if (!(*aP)) break;
 
     if (*aP == '"' || *aP == '\'')
        {argV[j] = aP+1;
         aP = index(aP+1, *aP);
         if (!aP || (*(aP+1) != ' ' && *(aP+1)))
            {if (!j) argV[0] = 0; return -EINVAL;}
         *aP++ = '\0';
        } else {
         argV[j] = aP;
         if ((aP = index(aP+1, ' '))) *aP++ = '\0';
            else {j++; break;}
        }
 
    }
 
// Make sure we did not overflow the vector
//
   if (j > argC-1) return -E2BIG;
 
// End list with a null pointer and return the actual number of arguments
//
   argV[j] = 0;
   return j;
}

Referenced by XrdOucProg::Setup().

Here is the caller graph for this function:

bin2hex()

char * XrdOucUtils::bin2hex ( char *  inbuff, int  dlen, char *  buff, int  blen, bool  sep = true  )

static

Definition at line 164 of file XrdOucUtils.cc.

{
    static const char hv[] = "0123456789abcdef";
    char *outbuff = buff;
    for (int i = 0; i < dlen && blen > 2; i++) {
        *outbuff++ = hv[(inbuff[i] >> 4) & 0x0f];
        *outbuff++ = hv[ inbuff[i]       & 0x0f];
        blen -= 2;
        if (sep && blen > 1 && ((i & 0x03) == 0x03 || i+1 == dlen))
           {*outbuff++ = ' '; blen--;}
        }
     *outbuff = '\0';
     return buff;
}

Referenced by XrdOssMio::Map().

Here is the caller graph for this function:

doIf()

int XrdOucUtils::doIf ( XrdSysError *  eDest, XrdOucStream &  Config, const char *  what, const char *  hname, const char *  nname, const char *  pname  )

static

Definition at line 277 of file XrdOucUtils.cc.

{
   static const char *brk[] = {"defined", "exec", "named", 0};
   XrdOucEnv *theEnv = 0;
   char *val;
   int hostok, isDef;
 
// Make sure that at least one thing appears after the if
//
   if (!(val = Config.GetWord()))
      {if (eDest) eDest->Emsg("Config","Host name missing after 'if' in", what);
       return -1;
      }
 
// Check if we are one of the listed hosts
//
   if (!is1of(val, brk))
      {do {hostok = XrdNetUtils::Match(hname, val);
           val = Config.GetWord();
          } while(!hostok && val && !is1of(val, brk));
      if (hostok)
         { while(val && !is1of(val, brk)) val = Config.GetWord();
           // No more directives
           if (!val) return 1;
         } else return 0;
      }
 
// Check if this is a defined test
//
   while(!strcmp(val, "defined"))
      {if (!(val = Config.GetWord()) || *val != '?')
          {if (eDest)
             {eDest->Emsg("Config","'?var' missing after 'defined' in",what);}
           return -1;
          }
       // Get environment if we have none
       //
          if (!theEnv && (theEnv = Config.SetEnv(0))) Config.SetEnv(theEnv);
          if (!theEnv && *(val+1) != '~') return 0;
 
       // Check if any listed variable is defined.
       //
       isDef = 0;
       while(val && *val == '?')
            {if (*(val+1) == '~' ? getenv(val+2) : theEnv->Get(val+1)) isDef=1;
             val = Config.GetWord();
            }
       if (!val || !isDef) return isDef;
       if (strcmp(val, "&&"))
          {if (eDest)
             {eDest->Emsg("Config",val,"is invalid for defined test in",what);}
           return -1;
          } else {
           if (!(val = Config.GetWord()))
              {if (eDest)
                  {eDest->Emsg("Config","missing keyword after '&&' in",what);}
               return -1;
              }
          }
       if (!is1of(val, brk))
          {if (eDest)
             {eDest->Emsg("Config",val,"is invalid after '&&' in",what);}
           return -1;
          }
      }
 
// Check if we need to compare program names (we are here only if we either
// passed the hostlist test or there was no hostlist present)
//
   if (!strcmp(val, "exec"))
      {if (!(val = Config.GetWord()) || !strcmp(val, "&&"))
          {if (eDest)
             {eDest->Emsg("Config","Program name missing after 'if exec' in",what);}
           return -1;
          }
 
       // Check if we are one of the programs.
       //
       if (!pname) return 0;
       while(val && strcmp(val, pname))
            if (!strcmp(val, "&&")) return 0;
               else  val = Config.GetWord();
       if (!val) return 0;
       while(val && strcmp(val, "&&")) val = Config.GetWord();
       if (!val) return 1;
 
       if (!(val = Config.GetWord()))
          {if (eDest)
             {eDest->Emsg("Config","Keyword missing after '&&' in",what);}
           return -1;
          }
       if (strcmp(val, "named"))
          {if (eDest)
             {eDest->Emsg("Config",val,"is invalid after '&&' in",what);}
           return -1;
          }
      }
 
// Check if we need to compare net names (we are here only if we either
// passed the hostlist test or there was no hostlist present)
//
   if (!(val = Config.GetWord()))
      {if (eDest)
         {eDest->Emsg("Config","Instance name missing after 'if named' in", what);}
       return -1;
      }
 
// Check if we are one of the names
//
   if (!nname) return 0;
   while(val && strcmp(val, nname)) val = Config.GetWord();
 
// All done
//
   return (val != 0);
}

References XrdCms::Config, eDest, XrdSysError::Emsg(), XrdOucEnv::Get(), is1of(), XrdNetUtils::Match(), and XrdCms::theEnv.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

endsWith()

bool XrdOucUtils::endsWith ( const char *  text, const char *  ending, int  endlen  )

static

Definition at line 229 of file XrdOucUtils.cc.

{
   int tlen = strlen(text);
 
   return (tlen >= endlen && !strcmp(text+(tlen-endlen), ending));
}

Referenced by XrdBwmFile::open().

Here is the caller graph for this function:

eText()

char * XrdOucUtils::eText ( int  rc, char *  eBuff, int  eBlen  )

static

Definition at line 243 of file XrdOucUtils.cc.

{
   const char *etP;
 
// Get error text
//
   etP = XrdSysE2T(rc);
 
// Copy the text and lower case the first letter
//
   strlcpy(eBuff, etP, eBlen);
 
// All done
//
   return eBuff;
}

References strlcpy(), and XrdSysE2T().

Here is the call graph for this function:

findPgm()

bool XrdOucUtils::findPgm ( const char *  pgm, XrdOucString &  path  )

static

Definition at line 400 of file XrdOucUtils.cc.

{
   struct stat Stat;
 
// Check if only executable bit needs to be checked
//
   if (*pgm == '/')
      {if (stat(pgm, &Stat) || !(Stat.st_mode & S_IXOTH)) return false;
       path = pgm;
       return true;
      }
 
// Make sure we have the paths to check
//
   const char *pEnv = getenv("PATH");
   if (!pEnv) return false;
 
// Setup to find th executable
//
   XrdOucString prog, pList(pEnv);
   int from = 0;;
   prog += '/'; prog += pgm;
 
// Find it!
//
   while((from = pList.tokenize(path, from, ':')) != -1)
        {path += prog;
         if (!stat(path.c_str(), &Stat) && Stat.st_mode & S_IXOTH) return true;
        }
   return false;
}

References XrdOucString::c_str(), Stat, stat, and XrdOucString::tokenize().

Referenced by XrdNetPMarkCfg::Parse().

Here is the call graph for this function:

Here is the caller graph for this function:

fmtBytes()

int XrdOucUtils::fmtBytes ( long long  val, char *  buff, int  bsz  )

static

Definition at line 436 of file XrdOucUtils.cc.

{
   static const long long Kval = 1024LL;
   static const long long Mval = 1024LL*1024LL;
   static const long long Gval = 1024LL*1024LL*1024LL;
   static const long long Tval = 1024LL*1024LL*1024LL*1024LL;
   char sName = ' ';
   int resid;
 
// Get correct scaling
//
        if (val < 1024)  return snprintf(buff, bsz, "%lld", val);
        if (val < Mval) {val = val*10/Kval; sName = 'K';}
   else if (val < Gval) {val = val*10/Mval; sName = 'M';}
   else if (val < Tval) {val = val*10/Gval; sName = 'G';}
   else                 {val = val*10/Tval; sName = 'T';}
   resid = val%10LL; val = val/10LL;
 
// Format it
//
   return snprintf(buff, bsz, "%lld.%d%c", val, resid, sName);
}

Referenced by XrdFrmPurge::Display().

Here is the caller graph for this function:

genPath() [1/2]

int XrdOucUtils::genPath ( char *  buff, int  blen, const char *  path, const char *  psfx = 0  )

static

Definition at line 481 of file XrdOucUtils.cc.

{
    int i, j;
 
    i = strlen(path);
    j = (psfx ? strlen(psfx) : 0);
    if (i+j+3 > blen) return -ENAMETOOLONG;
 
     strcpy(buff, path);
     if (psfx)
        {if (buff[i-1] != '/') buff[i++] = '/';
         strcpy(&buff[i], psfx);
         if (psfx[j-1] != '/') strcat(buff, "/");
        }
    return 0;
}

genPath() [2/2]

char * XrdOucUtils::genPath ( const char *  path, const char *  inst, const char *  psfx = 0  )

static

Definition at line 463 of file XrdOucUtils.cc.

{
   char buff[2048];
   int i = strlcpy(buff, p_path, sizeof(buff));
 
   if (buff[i-1] != '/') {buff[i++] = '/'; buff[i] = '\0';}
   if (inst) {strcpy(buff+i, inst); strcat(buff, "/");}
   if (s_path) strcat(buff, s_path);
 
   i = strlen(buff);
   if (buff[i-1] != '/') {buff[i++] = '/'; buff[i] = '\0';}
 
   return strdup(buff);
}

References strlcpy().

Referenced by XrdNetCmsNotify::XrdNetCmsNotify(), XrdXrootdProtocol::Configure(), XrdCmsClientConfig::Configure(), XrdCmsConfig::Configure0(), XrdCmsConfig::Configure2(), XrdOfsConfigCP::Init(), and XrdFrcUtils::makePath().

Here is the call graph for this function:

Here is the caller graph for this function:

getFile()

char * XrdOucUtils::getFile ( const char *  path, int &  rc, int  maxsz = 10240, bool  notempty = true  )

static

Definition at line 502 of file XrdOucUtils.cc.

{
   struct stat Stat;
   struct fdHelper
         {int fd = -1;
              fdHelper() {}
             ~fdHelper() {if (fd >= 0) close(fd);}
         } file;
   char *buff;
   int   flen;
 
// Preset RC
//
   rc = 0;
 
// Open the file in read mode
//
   if ((file.fd = open(path, O_RDONLY)) < 0) {rc = errno; return 0;}
 
// Get the size of the file
//
   if (fstat(file.fd, &Stat)) {rc = errno; return 0;}
 
// Check if the size exceeds the maximum allowed
//
   if (Stat.st_size > maxsz) {rc = EFBIG; return 0;}
 
// Make sure the file is not empty if empty files are disallowed
//
   if (Stat.st_size == 0 && notempty) {rc = ENODATA; return 0;}
 
// Allocate a buffer
//
   if ((buff = (char *)malloc(Stat.st_size+1)) == 0)
      {rc = errno; return 0;}
 
// Read the contents of the file into the buffer
//
   if (Stat.st_size)
      {if ((flen = read(file.fd, buff, Stat.st_size)) < 0)
          {rc = errno; free(buff); return 0;}
      } else flen = 0;
 
// Add null byte. recall the buffer is bigger by one byte
//
   buff[flen] = 0;
 
// Return the size aand the buffer
//
   rc = flen;
   return buff;
}

References close, ENODATA, fstat, open, read(), Stat, and stat.

Here is the call graph for this function:

getGID()

bool XrdOucUtils::getGID ( const char *  gName, gid_t &  gID  )

static

Definition at line 559 of file XrdOucUtils.cc.

{
   struct group Grp, *result;
   char buff[65536];
 
   getgrnam_r(gName, &Grp, buff, sizeof(buff), &result);
   if (!result) return false;
 
   gID = Grp.gr_gid;
   return true;
}

Referenced by XrdSecProtocolsss::Authenticate().

Here is the caller graph for this function:

getModificationTime()

int XrdOucUtils::getModificationTime ( const char *  path, time_t &  modificationTime  )

static

Definition at line 1478 of file XrdOucUtils.cc.

                                                                               {
    struct stat buf;
    int statRet = ::stat(path,&buf);
    if(!statRet) {
        modificationTime = buf.st_mtime;
    }
    return statRet;
}

References stat.

Referenced by XrdTlsContext::XrdTlsContext(), and XrdTlsContext::newHostCertificateDetected().

Here is the caller graph for this function:

getUID()

bool XrdOucUtils::getUID ( const char *  uName, uid_t &  uID, gid_t *  gID = 0  )

static

Definition at line 575 of file XrdOucUtils.cc.

{
   struct passwd pwd, *result;
   char buff[16384];
 
   getpwnam_r(uName, &pwd, buff, sizeof(buff), &result);
   if (!result) return false;
 
   uID = pwd.pw_uid;
   if (gID) *gID = pwd.pw_gid;
 
   return true;
}

Referenced by XrdSecProtocolsss::Authenticate().

Here is the caller graph for this function:

GidName()

int XrdOucUtils::GidName ( gid_t  gID, char *  gName, int  gNsz, time_t  keepT = 0  )

static

Definition at line 593 of file XrdOucUtils.cc.

{
   static const int maxgBsz = 256*1024;
   static const int addGsz  = 4096;
   struct group  *gEnt, gStruct;
   char gBuff[1024], *gBp = gBuff;
   int glen = 0, gBsz = sizeof(gBuff), aOK = 1;
   int n, retVal = 0;
 
// Get ID from cache, if allowed
//
   if (keepT)
      {int n = LookUp(gidMap, static_cast<unsigned int>(gID),gName,gNsz);
       if (n > 0) return (n < gNsz ? n : 0);
      }
 
// Get the the group struct. If we don't have a large enough buffer, get a
// larger one and try again up to the maximum buffer we will tolerate.
//
   while(( retVal = getgrgid_r(gID, &gStruct, gBp, gBsz, &gEnt) ) == ERANGE)
        {if (gBsz >= maxgBsz) {aOK = 0; break;}
         if (gBsz >  addGsz) free(gBp);
         gBsz += addGsz;
         if (!(gBp = (char *)malloc(gBsz))) {aOK = 0; break;}
        }
 
// Return a group name if all went well
//
   if (aOK && retVal == 0 && gEnt != NULL)
      {if (keepT)
          AddID(gidMap, static_cast<unsigned int>(gID), gEnt->gr_name, keepT);
       glen = strlen(gEnt->gr_name);
       if (glen >= gNsz) glen = 0;
          else strcpy(gName, gEnt->gr_name);
      } else {
       n = snprintf(gName, gNsz, "%ud", static_cast<unsigned int>(gID));
       if (n >= gNsz) glen = 0;
      }
 
// Free any allocated buffer and return result
//
   if (gBsz >  addGsz && gBp) free(gBp);
   return glen;
}

GroupName()

int XrdOucUtils::GroupName ( gid_t  gID, char *  gName, int  gNsz  )

static

Definition at line 642 of file XrdOucUtils.cc.

{
   static const int maxgBsz = 256*1024;
   static const int addGsz  = 4096;
   struct group  *gEnt, gStruct;
   char gBuff[1024], *gBp = gBuff;
   int glen, gBsz = sizeof(gBuff), aOK = 1;
   int retVal = 0;
 
// Get the the group struct. If we don't have a large enough buffer, get a
// larger one and try again up to the maximum buffer we will tolerate.
//
   while(( retVal = getgrgid_r(gID, &gStruct, gBp, gBsz, &gEnt) ) == ERANGE)
        {if (gBsz >= maxgBsz) {aOK = 0; break;}
         if (gBsz >  addGsz) free(gBp);
         gBsz += addGsz;
         if (!(gBp = (char *)malloc(gBsz))) {aOK = 0; break;}
        }
 
// Return a group name if all went well
//
   if (aOK && retVal == 0 && gEnt != NULL)
      {glen = strlen(gEnt->gr_name);
       if (glen >= gNsz) glen = 0;
          else strcpy(gName, gEnt->gr_name);
      } else glen = 0;
 
// Free any allocated buffer and return result
//
   if (gBsz >  addGsz && gBp) free(gBp);
   return glen;
}

Referenced by XrdSecProtocolunix::getCredentials().

Here is the caller graph for this function:

hex2bin()

int XrdOucUtils::hex2bin ( const char *  hex, char *  bin, int  size  )

static

Definition at line 184 of file XrdOucUtils.cc.

{
  int len = 0, lo = -1, hi = -1;
 
  while (int c = *hex++) {
    if (c == ' ' || c == '\n')
      break;
 
    switch (c) {
      case '0' ... '9':
        c -= '0';
        break;
      case 'a' ... 'f':
        c -= 'a' - 10;
        break;
      case 'A' ... 'F':
        c -= 'A' - 10;
        break;
      default:
        return -EINVAL;
    }
 
    if (hi == -1)
      hi = c;
    else
      lo = c;
 
    if (lo == -1)
      continue;
 
    if (len >= size)
      return -EOVERFLOW;
 
    bin[len++] = (hi << 4) | lo;
    hi = lo = -1;
  }
  if (hi >= 0 || lo >= 0 || len == 0)
    return -EINVAL;
  return len;
}

References Xrd::hex.

HSize()

const char * XrdOucUtils::HSize ( size_t  bytes, char *  buff, int  bsz  )

static

Definition at line 679 of file XrdOucUtils.cc.

{
 
// Do fast conversion of the quantity is less than 1K
//
   if (bytes < 1024)
      {snprintf(buff, bsz, "%zu", bytes);
       return buff;
      }
 
// Scale this down
//
   const char *suffix = " KMGTPEYZ";
   double dBytes = static_cast<double>(bytes);
 
do{dBytes /= 1024.0; suffix++;
  }  while(dBytes >= 1024.0 && *(suffix+1));
 
 
// Format and return result. Include fractions only if they meaningfully exist.
//
   double whole, frac = modf(dBytes, &whole);
   if (frac >= .005) snprintf(buff, bsz, "%.02lf%c", dBytes, *suffix);
      else snprintf(buff, bsz, "%g%c", whole, *suffix);
   return buff;
}

i2bstr()

const char * XrdOucUtils::i2bstr ( char *  buff, int  blen, int  val, bool  pad = false  )

static

Definition at line 710 of file XrdOucUtils.cc.

{
   char zo[2] = {'0', '1'};
 
   if (blen < 2) return "";
 
   buff[--blen] = 0;
   if (!val) buff[blen--] = '0';
      else while(val && blen >= 0)
                {buff[blen--] = zo[val & 0x01];
                 val >>= 1;
                }
 
   if (blen >= 0 && pad) while(blen >= 0) buff[blen--] = '0';
 
   return &buff[blen+1];
}

Ident()

char * XrdOucUtils::Ident ( long long &  mySID, char *  iBuff, int  iBlen, const char *  iHost, const char *  iProg, const char *  iName, int  Port  )

static

Definition at line 779 of file XrdOucUtils.cc.

{
   static char *theSIN;
   static long long theSID = genSID(theSIN, iHost, iPort, iName, iProg);
   const char *sP = getenv("XRDSITE");
   char uName[256];
   int myPid   = static_cast<int>(getpid());
 
// Get our username
//
   if (UserName(getuid(), uName, sizeof(uName)))
      sprintf(uName, "%d", static_cast<int>(getuid()));
 
// Create identification record
//
   snprintf(iBuff,iBlen,"%s.%d:%s@%s\n&site=%s&port=%d&inst=%s&pgm=%s",
            uName, myPid, theSIN, iHost, (sP ? sP : ""), iPort, iName, iProg);
 
// Return a copy of the sid key
//
   h2nll(theSID, mySID);
   return strdup(theSIN);
}

References XrdXrootdMonInfo::mySID, and UserName().

Referenced by XrdFrmMonitor::Init(), and XrdXrootdMonitor::Init().

Here is the call graph for this function:

Here is the caller graph for this function:

InstName() [1/2]

const char * XrdOucUtils::InstName ( const char *  name, int  Fillit = 1  )

static

Definition at line 826 of file XrdOucUtils.cc.

{ return (Fillit ? name && *name                        ? name : "anon"
                 : name && strcmp(name,"anon") && *name ? name :     0);
}

InstName() [2/2]

const char * XrdOucUtils::InstName ( int  TranOpt = 0 )

static

Definition at line 809 of file XrdOucUtils.cc.

{
   const char *iName = getenv("XRDNAME");
 
// If tran is zero, return what we have
//
   if (!TranOpt) return iName;
 
// If trans is positive then make sure iName has a value. Otherwise, make sure
// iName has no value if it's actually "anon".
//
   if (TranOpt > 0) {if (!iName || !*iName) iName = "anon";}
      else if (iName && !strcmp(iName, "anon")) iName = 0;
   return iName;
}

Referenced by XrdFrcProxy::XrdFrcProxy(), XrdFrmConfig::XrdFrmConfig(), XrdNetCmsNotify::XrdNetCmsNotify(), XrdSsiSfsConfig::XrdSsiSfsConfig(), XrdOssSys::ConfigStage(), XrdCmsClientConfig::Configure(), XrdConfig::Configure(), XrdFrmConfig::Configure(), XrdCmsConfig::Configure0(), XrdCmsConfig::Configure1(), XrdOfsConfigCP::Init(), XrdOssSpace::Init(), main(), and XrdFrcReqAgent::Start().

Here is the caller graph for this function:

is1of()

int XrdOucUtils::is1of ( char *  val, const char **  clist  )

static

Definition at line 835 of file XrdOucUtils.cc.

{
   int i = 0;
   while(clist[i]) if (!strcmp(val, clist[i])) return 1;
                      else i++;
   return 0;
}

Referenced by doIf().

Here is the caller graph for this function:

isFWD()

int XrdOucUtils::isFWD ( const char *  path, int *  port = 0, char *  hBuff = 0, int  hBLen = 0, bool  pTrim = false  )

static

Definition at line 847 of file XrdOucUtils.cc.

{
   const char *hName, *hNend, *hPort, *hPend, *hP = path;
   char *eP;
   int n;
 
   if (*path == '/') hP++;  // Note: It's assumed an objectid if no slash
   if (*hP   == 'x') hP++;
   if (strncmp("root:/", hP, 6)) return 0;
   if (hBuff == 0 || hBLen <= 0) return (hP - path) + 6;
   hP += 6;
 
   if (!XrdNetUtils::Parse(hP, &hName, &hNend, &hPort, &hPend)) return 0;
   if (*hNend == ']') hNend++;
      else {if (!(*hNend) && !(hNend = index(hName, '/'))) return 0;
            if (!(*hPend)) hPend = hNend;
           }
 
   if (pTrim || !(*hPort)) n = hNend - hP;
      else n = hPend - hP;
   if (n >= hBLen) return 0;
   strncpy(hBuff, hP, n);
   hBuff[n] = 0;
 
   if (port)
      {if (*hNend != ':') *port = 0;
          else {*port = strtol(hPort, &eP, 10);
                if (*port < 0 || *port > 65535 || eP != hPend) return 0;
               }
      }
 
   return hPend-path;
}

References XrdNetUtils::Parse().

Here is the call graph for this function:

Log10()

int XrdOucUtils::Log10 ( unsigned long long  n )

static

Definition at line 910 of file XrdOucUtils.cc.

{
  int i = 0;
 
  #define SHFT(k, m) if (n >= m) { i += k; n /= m; }
 
  SHFT(16,10000000000000000ULL); SHFT(8,100000000ULL); 
  SHFT(4,10000ULL);              SHFT(2,100ULL);       SHFT(1,10ULL);
  return i;
 
  #undef SHFT
}

References SHFT.

Log2()

int XrdOucUtils::Log2 ( unsigned long long  n )

static

Definition at line 895 of file XrdOucUtils.cc.

{
  int i = 0;
 
  #define SHFT(k) if (n >= (1ULL << k)) { i += k; n >>= k; }
 
  SHFT(32); SHFT(16); SHFT(8); SHFT(4); SHFT(2); SHFT(1); return i;
 
  #undef SHFT
}

References SHFT.

Referenced by XrdBuffXL::Init(), XrdBuffManager::Obtain(), XrdBuffXL::Obtain(), XrdBuffManager::Recalc(), and XrdBuffXL::Recalc().

Here is the caller graph for this function:

makeHome() [1/2]

void XrdOucUtils::makeHome ( XrdSysError &  eDest, const char *  inst  )

static

Definition at line 927 of file XrdOucUtils.cc.

{
   char buff[2048];
 
   if (!inst || !getcwd(buff, sizeof(buff))) return;
 
   strcat(buff, "/"); strcat(buff, inst);
   if (MAKEDIR(buff, pathMode) && errno != EEXIST)
      {eDest.Emsg("Config", errno, "create home directory", buff);
       return;
      }
 
   if (chdir(buff) < 0)
      eDest.Emsg("Config", errno, "chdir to home directory", buff);
}

References chdir(), eDest, XrdSysError::Emsg(), MAKEDIR, and pathMode.

Referenced by XrdConfig::Configure(), XrdFrmConfig::Configure(), and makeHome().

Here is the call graph for this function:

Here is the caller graph for this function:

makeHome() [2/2]

bool XrdOucUtils::makeHome ( XrdSysError &  eDest, const char *  inst, const char *  path, mode_t  mode  )

static

Definition at line 945 of file XrdOucUtils.cc.

{
   char cwDir[2048];
   const char *slash = "", *slash2 = "";
   int n, rc;
 
// Provide backward compatibility for instance name qualification
//
 
   if (!path || !(n = strlen(path)))
      {if (inst) makeHome(eDest, inst);
       return true;
      }
 
// Augment the path with instance name, if need be
//
   if (path[n-1] != '/') slash = "/";
   if (!inst || !(n = strlen(inst))) inst = "";
      else slash2 = "/";
    n = snprintf(cwDir, sizeof(cwDir), "%s%s%s%s", path, slash, inst, slash2);
    if (n >= (int)sizeof(cwDir))
       {eDest.Emsg("Config", ENAMETOOLONG, "create home directory", cwDir);
        return false;
       }
 
// Create the path if it doesn't exist
//
   if ((rc = makePath(cwDir, mode, true)))
      {eDest.Emsg("Config", rc, "create home directory", cwDir);
       return false;
      }
 
// Switch to this directory
//
   if (chdir(cwDir) < 0)
      {eDest.Emsg("Config", errno, "chdir to home directory", cwDir);
       return false;
      }
 
// All done
//
   return true;
}

References chdir(), eDest, XrdSysError::Emsg(), makeHome(), and makePath().

Here is the call graph for this function:

makePath()

int XrdOucUtils::makePath ( char *  path, mode_t  mode, bool  reset = false  )

static

Definition at line 994 of file XrdOucUtils.cc.

{
    char *next_path = path+1;
    struct stat buf;
    bool dochmod = false; // The 1st component stays as is
 
// Typically, the path exists. So, do a quick check before launching into it
//
   if (!reset && !stat(path, &buf)) return 0;
 
// Start creating directories starting with the root
//
   while((next_path = index(next_path, int('/'))))
        {*next_path = '\0';
         if (MAKEDIR(path, mode))
            if (errno != EEXIST) return -errno;
         if (dochmod) CHMOD(path, mode);
         dochmod = reset;
         *next_path = '/';
         next_path = next_path+1;
        }
 
// All done
//
   return 0;
}

References CHMOD, MAKEDIR, and stat.

Referenced by XrdOssSys::Create(), XrdOfsConfigCP::Init(), makeHome(), XrdFrcUtils::makePath(), XrdFrcUtils::makeQDir(), ReLink(), XrdOssSys::Reloc(), XrdOssSys::Rename(), XrdSecsssKT::Rewrite(), XrdNetSocket::socketPath(), and subLogfn().

Here is the caller graph for this function:

mode2mask()

bool XrdOucUtils::mode2mask ( const char *  mode, mode_t &  mask  )

static

Definition at line 1025 of file XrdOucUtils.cc.

{
   mode_t mval[3] = {0}, mbit[3] = {0x04, 0x02, 0x01};
   const char *mok = "rwx";
   char mlet;
 
// Accept octal mode
//
   if (isdigit(*mode))
      {char *eP;
       mask = strtol(mode, &eP, 8);
       return *eP == 0;
      }
 
// Make sure we have the correct number of characters
//
   int n = strlen(mode);
   if (!n || n > 9 || n/3*3 != n) return false;
 
// Convert groups of three
//
   int k = 0;
   do {for (int i = 0; i < 3; i++)
           {mlet = *mode++;
            if (mlet != '-')
               {if (mlet != mok[i]) return false;
                mval[k] |= mbit[i]; 
               }
           } 
       } while(++k < 3 && *mode);
 
// Combine the modes and return success
//
   mask = mval[0]<<6 | mval[1]<<3 | mval[2];
   return true;
}

parseHome()

char * XrdOucUtils::parseHome ( XrdSysError &  eDest, XrdOucStream &  Config, int &  mode  )

static

Definition at line 1116 of file XrdOucUtils.cc.

{
   char *pval, *val, *HomePath = 0;
 
// Get the path
//
   pval = Config.GetWord();
   if (!pval || !pval[0])
      {eDest.Emsg("Config", "home path not specified"); return 0;}
 
// Make sure it's an absolute path
//
   if (*pval != '/')
      {eDest.Emsg("Config", "home path not absolute"); return 0;}
 
// Record the path
//
   HomePath = strdup(pval);
 
// Get the optional access rights
//
   mode = S_IRWXU;
   if ((val = Config.GetWord()) && val[0])
      {if (!strcmp("group", val)) mode |= (S_IRGRP | S_IXGRP);
          else {eDest.Emsg("Config", "invalid home path modifier -", val);
                free(HomePath);
                return 0;
               }
      }
   return HomePath;
}

References XrdCms::Config, eDest, and XrdSysError::Emsg().

Here is the call graph for this function:

parseLib()

bool XrdOucUtils::parseLib ( XrdSysError &  eDest, XrdOucStream &  Config, const char *  libName, char *&  path, char **  libparm  )

static

Definition at line 1066 of file XrdOucUtils.cc.

{
    char *val, parms[2048];
 
// Get the next token
//
   val = Config.GetWord();
 
// We do not support stacking as the caller does not support stacking
//
   if (val && !strcmp("++", val))
      {eDest.Say("Config warning: stacked plugins are not supported in "
                 "this context; directive ignored!");
       return true;
      }
 
// Now skip over any options
//
   while(val && *val && *val == '+') val = Config.GetWord();
 
// Check if we actually have a path
//
   if (!val || !val[0])
      {eDest.Emsg("Config", libName, "not specified"); return false;}
 
// Record the path
//
   if (libPath) free(libPath);
   libPath = strdup(val);
 
// Handle optional parameter
//
   if (!libParm) return true;
   if (*libParm) free(*libParm);
   *libParm = 0;
 
// Record any parms
//
   *parms = 0;
   if (!Config.GetRest(parms, sizeof(parms)))
      {eDest.Emsg("Config", libName, "parameters too long"); return false;}
   if (*parms) *libParm = strdup(parms);
   return true;
}

References XrdCms::Config, eDest, XrdSysError::Emsg(), and XrdSysError::Say().

Here is the call graph for this function:

PidFile()

bool XrdOucUtils::PidFile ( XrdSysError &  eDest, const char *  path  )

static

Definition at line 1453 of file XrdOucUtils.cc.

{
   char buff[32];
   int  fd;
 
   if( (fd = open( path, O_WRONLY|O_CREAT|O_TRUNC, 0644 )) < 0 )
   {
      eDest.Emsg( "Config", errno, "create pidfile" );
      return false;
   }
 
   if( write( fd, buff, snprintf( buff, sizeof(buff), "%d",
                                  static_cast<int>(getpid()) ) ) < 0 )
   {
      eDest.Emsg( "Config", errno, "write to pidfile" );
      close(fd);
      return false;
   }
 
   close(fd);
   return true;
}

References close, eDest, XrdSysError::Emsg(), open, and write().

Referenced by XrdFrmConfig::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

ReLink()

int XrdOucUtils::ReLink ( const char *  path, const char *  target, mode_t  mode = 0  )

static

Definition at line 1152 of file XrdOucUtils.cc.

{
   const mode_t AMode = S_IRWXU;  // Only us as a default
   char pbuff[MAXPATHLEN+64];
   int n;
 
// Copy the path
//
   n = strlen(path);
   if (n >= (int)sizeof(pbuff)) return ENAMETOOLONG;
   strcpy(pbuff, path);
 
// Unlink the target, make the path, and create the symlink
//
   unlink(path);
   makePath(pbuff, (mode ? mode : AMode));
   if (symlink(target, path)) return errno;
   return 0;
}

References makePath(), and unlink().

Here is the call graph for this function:

Sanitize()

void XrdOucUtils::Sanitize ( char *  instr, char  subc = '_'  )

static

Definition at line 1176 of file XrdOucUtils.cc.

{
 
// Sanitize string according to POSIX.1-2008 stanadard using only the
// Portable Filename Character Set: a-z A-Z 0-9 ._- with 1st char not being -
//
   if (*str)
      {if (*str == '-') *str = subc;
          else if (*str == ' ') *str = subc;
       char *blank = rindex(str, ' ');
       if (blank) while(*blank == ' ') *blank-- = 0;
       while(*str)
            {if (!isalnum(*str) && index("_-.", *str) == 0) *str = subc;
             str++;
            }
      }
}

subLogfn()

char * XrdOucUtils::subLogfn ( XrdSysError &  eDest, const char *  inst, char *  logfn  )

static

Definition at line 1198 of file XrdOucUtils.cc.

{
   const mode_t lfm = S_IRWXU|S_IRWXG|S_IROTH|S_IXOTH;
   char buff[2048], *sp;
   int rc;
 
   if (!inst || !*inst) return logfn;
   if (!(sp = rindex(logfn, '/'))) strcpy(buff, "./");
      else {*sp = '\0'; strcpy(buff, logfn); strcat(buff, "/");}
 
   strcat(buff, inst); strcat(buff, "/");
 
   if ((rc = XrdOucUtils::makePath(buff, lfm)))
      {eDest.Emsg("Config", rc, "create log file path", buff);
       return 0;
      }
 
   if (sp) {*sp = '/'; strcat(buff, sp+1);}
      else strcat(buff, logfn);
 
   free(logfn);
   return strdup(buff);
}

References eDest, XrdSysError::Emsg(), and makePath().

Referenced by XrdOucLogging::configLog(), and XrdFrmConfig::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

Token()

int XrdOucUtils::Token ( const char **  str, char  delim, char *  buff, int  bsz  )

static

Definition at line 1239 of file XrdOucUtils.cc.

{
   const char *eP, *bP = *str;
   int aLen, mLen;
 
// Trim off the delimeters. Return zero if nothing left.
//
   while(*bP && *bP == delim) bP++;
   if (*bP == 0) {*buff = 0; return 0;}
 
// Find the next delimiter
//
   eP = bP;
   while(*eP && *eP != delim) eP++;
 
// If we ended at a null, make sure next call will return zero
//
   if (*eP == 0) *str = eP;
      else       *str = eP+1;
 
// Calculate length and make sure we don't overrun the buffer
//
   aLen = eP-bP;
   if (aLen >= bsz) mLen = bsz-1;
      else          mLen = aLen;
 
// Copy token into buffer and end with null byte
//
   strncpy(buff, bP, mLen);
   buff[mLen] = 0;
 
// Return actual length
//
   return aLen;
}

toLower()

void XrdOucUtils::toLower ( char *  str )

static

Definition at line 1226 of file XrdOucUtils.cc.

{
   unsigned char* ustr = (unsigned char*)str;  // Avoid undefined behaviour
 
// Change each character to lower case
//
   while(*ustr) {*ustr = tolower(*ustr); ustr++;}
}

Referenced by XrdCksManager::Config(), XrdOfsConfigPI::DefaultCS(), getMyFQN(), XrdNetUtils::NetConfig(), and XrdCksConfig::ParseLib().

Here is the caller graph for this function:

trim() [1/2]

void XrdOucUtils::trim ( std::string &  str )

static

Definition at line 1487 of file XrdOucUtils.cc.

                                     {
    // Trim leading non-letters
    while( str.size() && !isgraph(str[0]) ) str.erase(str.begin());
 
    // Trim trailing non-letters
 
    while( str.size() && !isgraph(str[str.size()-1]) )
        str.resize (str.size () - 1);
}

Referenced by XrdHttpCorsHandler::addAllowedOrigin(), XrdHttpReadRangeHandler::Configure(), XrdHttpHeaderUtils::parseReprDigest(), and trim().

Here is the caller graph for this function:

trim() [2/2]

void XrdOucUtils::trim ( std::string_view &  sv )

static

Definition at line 1497 of file XrdOucUtils.cc.

                                          {
  const auto toTrim = [](char c) { return !isgraph(c); };
  size_t start = 0;
  size_t end = sv.size();
 
  while (start < end && toTrim(sv[start])) ++start;
  while (end > start && toTrim(sv[end - 1])) --end;
 
  sv = sv.substr(start, end - start);
}

UidName()

int XrdOucUtils::UidName ( uid_t  uID, char *  uName, int  uNsz, time_t  keepT = 0  )

static

Definition at line 1357 of file XrdOucUtils.cc.

{
   struct passwd *pEnt, pStruct;
   char pBuff[1024];
   int n, rc;
 
// Get ID from cache, if allowed
//
   if (keepT)
      {int n = LookUp(uidMap, static_cast<unsigned int>(uID),uName,uNsz);
       if (n > 0) return (n < uNsz ? n : 0);
      }
 
// Try to obtain the username. We use this form to make sure we are using
// the standards conforming version (compilation error otherwise).
//
   rc = getpwuid_r(uID, &pStruct, pBuff, sizeof(pBuff), &pEnt);
   if (rc || !pEnt)
      {n = snprintf(uName, uNsz, "%ud", static_cast<unsigned int>(uID));
       return (n >= uNsz ? 0 : n);
      }
 
// Add entry to the cache if need be
//
   if (keepT)
      AddID(uidMap, static_cast<unsigned int>(uID), pEnt->pw_name, keepT);
 
// Return length of username or zero if it is too big
//
   n = strlen(pEnt->pw_name);
   if (uNsz <= (int)strlen(pEnt->pw_name)) return 0;
   strcpy(uName, pEnt->pw_name);
   return n;
}

Undercover()

void XrdOucUtils::Undercover ( XrdSysError &  eDest, int  noLog, int *  pipeFD = 0  )

static

Definition at line 1283 of file XrdOucUtils.cc.

{
   static const int maxFiles = 256;
   pid_t mypid;
   int myfd, logFD = eDest.baseFD();
 
// Issue warning if there is no logfile attached
//
   if (noLog) eDest.Emsg("Config", "Warning! No log file specified; "
                                   "backgrounding disables all logging!");
 
// Fork so that we are not tied to a shell
//
   if ((mypid = fork()) < 0)
      {eDest.Emsg("Config", errno, "fork process 1 for backgrounding");
       return;
      }
   else if (mypid)
   {
      // we have been given a pair of pipe descriptors to be able to read the
      // status of the child process
      if( pipeFD )
      {
         int status = 1;
         close( pipeFD[1] );
         // read will wait untill the status is communicated by the
         // child process, if the child process dies before being able
         // to comunicate the status then read will see EOF
         if( read( pipeFD[0], &status, sizeof(status) ) != sizeof(status) )
            _exit(1);
         _exit(status);
      }
      // no pipes given, return success
      else _exit(0);
   }
 
   if( pipeFD )
      close( pipeFD[0] );
 
// Become the process group leader
//
   if (setsid() < 0)
      {eDest.Emsg("Config", errno, "doing setsid() for backgrounding");
       return;
      }
 
// Fork to that we are cannot get a controlling terminal
//
   if ((mypid = fork()) < 0)
      {eDest.Emsg("Config", errno, "fork process 2 for backgrounding");
       return;
      }
      else if (mypid) _exit(0);
 
// Switch stdin, stdout, and stderr to /dev/null (we can't use /dev/console
// unless we are root which is unlikely).
//
   if ((myfd = open("/dev/null", O_RDWR)) < 0)
      {eDest.Emsg("Config", errno, "open /dev/null for backgrounding");
       return;
      }
   dup2(myfd, 0); dup2(myfd, 1); dup2(myfd, 2); dup2(myfd, logFD);
 
// Close any open file descriptors left open by the parent process
// but the communication pipe and the logger's shadow file descriptor.
//
  for (myfd = 3; myfd < maxFiles; myfd++)
      if( (!pipeFD || myfd != pipeFD[1]) && myfd != logFD ) close(myfd);
}

References XrdSysError::baseFD(), close, eDest, XrdSysError::Emsg(), XrdOfsPrepGPIReal::maxFiles, open, and read().

Referenced by XrdConfig::Configure(), and XrdFrmConfig::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

UserName()

int XrdOucUtils::UserName ( uid_t  uID, char *  uName, int  uNsz  )

static

Definition at line 1396 of file XrdOucUtils.cc.

{
   struct passwd *pEnt, pStruct;
   char pBuff[1024];
   int rc;
 
// Try to obtain the username. We use this form to make sure we are using
// the standards conforming version (compilation error otherwise).
//
   rc = getpwuid_r(uID, &pStruct, pBuff, sizeof(pBuff), &pEnt);
   if (rc)    return rc;
   if (!pEnt) return ESRCH;
 
// Return length of username or zero if it is too big
//
   if (uNsz <= (int)strlen(pEnt->pw_name)) return ENAMETOOLONG;
   strcpy(uName, pEnt->pw_name);
   return 0;
}

Referenced by XrdPfc::Cache::Config(), XrdSecProtocolunix::getCredentials(), and Ident().

Here is the caller graph for this function:

ValPath()

const char * XrdOucUtils::ValPath ( const char *  path, mode_t  allow, bool  isdir  )

static

Definition at line 1420 of file XrdOucUtils.cc.

{
   static const mode_t mMask = S_IRWXU | S_IRWXG | S_IRWXO;
   struct stat buf;
 
// Check if this really exists
//
   if (stat(path, &buf))
      {if (errno == ENOENT) return "does not exist.";
       return XrdSysE2T(errno);
      }
 
// Verify that this is the correct type of file
//
   if (isdir)
      {if (!S_ISDIR(buf.st_mode)) return "is not a directory.";
      } else {
       if (!S_ISREG(buf.st_mode)) return "is not a file.";
      }
 
// Verify that the does not have excessive privileges
//
   if ((buf.st_mode & mMask) & ~allow) return "has excessive access rights.";
 
// All went well
//
   return 0;
}

References stat, and XrdSysE2T().

Referenced by XrdCl::InitTLS().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

pathMode

const mode_t XrdOucUtils::pathMode = S_IRWXU|S_IRGRP|S_IXGRP|S_IROTH|S_IXOTH

static

Definition at line 47 of file XrdOucUtils.hh.

Referenced by makeHome().

---

The documentation for this class was generated from the following files:

• XrdOucUtils.hh
• XrdOucUtils.cc