#include <XrdCmsClientConfig.hh>

Collaboration diagram for XrdCmsClientConfig:

Public Types
enum	{ FailOver = 'f' , RoundRob = 'r' }

enum	configHow { configMeta = 1 , configNorm = 2 , configProxy = 4 }

enum	configWhat { configMan = 1 , configSuper = 2 , configServer = 4 }

Public Member Functions
	XrdCmsClientConfig (XrdCmsPerfMon *cmsmon=0)

	~XrdCmsClientConfig ()

int	Configure (const char *cfn, configWhat What, configHow How)

Public Attributes
char *	cidTag

char *	CMSPath

int	ConWait

int	FwdWait

int	haveMeta

XrdOucTList *	ManList

const char *	myHost

const char *	myName

char *	myVNID

XrdOucTList *	PanList

int	perfInt

XrdCmsPerfMon *	perfMon

int	PrepWait

int	RepDelay

int	RepNone

int	RepWait

int	RepWaitMS

unsigned char	SMode

unsigned char	SModeP

Detailed Description

Definition at line 43 of file XrdCmsClientConfig.hh.

Member Enumeration Documentation

◆ anonymous enum

anonymous enum

Enumerator
FailOver
RoundRob

Definition at line 74 of file XrdCmsClientConfig.hh.

74 {FailOver = 'f', RoundRob = 'r'};

XrdCmsClientConfig::FailOver

@ FailOver

Definition: XrdCmsClientConfig.hh:74

XrdCmsClientConfig::RoundRob

@ RoundRob

Definition: XrdCmsClientConfig.hh:74

◆ configHow

enum XrdCmsClientConfig::configHow

Enumerator
configMeta
configNorm
configProxy

Definition at line 47 of file XrdCmsClientConfig.hh.

47 {configMeta = 1, configNorm = 2, configProxy = 4};

XrdCmsClientConfig::configProxy

@ configProxy

Definition: XrdCmsClientConfig.hh:47

XrdCmsClientConfig::configNorm

@ configNorm

Definition: XrdCmsClientConfig.hh:47

XrdCmsClientConfig::configMeta

@ configMeta

Definition: XrdCmsClientConfig.hh:47

◆ configWhat

enum XrdCmsClientConfig::configWhat

Enumerator
configMan
configSuper
configServer

Definition at line 48 of file XrdCmsClientConfig.hh.

48 {configMan = 1, configSuper = 2, configServer = 4};

XrdCmsClientConfig::configSuper

@ configSuper

Definition: XrdCmsClientConfig.hh:48

XrdCmsClientConfig::configMan

@ configMan

Definition: XrdCmsClientConfig.hh:48

XrdCmsClientConfig::configServer

@ configServer

Definition: XrdCmsClientConfig.hh:48

Constructor & Destructor Documentation

◆ XrdCmsClientConfig()

XrdCmsClientConfig::XrdCmsClientConfig ( XrdCmsPerfMon * cmsmon = 0 )

inline

Definition at line 76 of file XrdCmsClientConfig.hh.

                            : ConWait(10), RepWait(3),  RepWaitMS(3000),
                              RepDelay(5), RepNone(8),  PrepWait(33),
                              FwdWait(0),  haveMeta(0), CMSPath(0),
                              myHost(0),   myName(0),   myVNID(0),
                              cidTag(0),   ManList(0),  PanList(0),
                              perfMon(0),  perfInt(3*60),
                              SMode(FailOver), SModeP(FailOver),
                              VNID_Lib(0),  VNID_Parms(0),
                              prfLib(0), prfParms(0), cmsMon(cmsmon),
                              isMeta(false), isMan(false), isServer(false) {}

◆ ~XrdCmsClientConfig()

XrdCmsClientConfig::~XrdCmsClientConfig ( )

Definition at line 74 of file XrdCmsClientConfig.cc.

 {
   XrdOucTList *tp, *tpp;
  
   tpp = ManList;
   while((tp = tpp)) {tpp = tp->next; delete tp;}
   tpp = PanList;
   while((tp = tpp)) {tpp = tp->next; delete tp;}
  
   if (VNID_Lib)   free(VNID_Lib);
   if (VNID_Parms) free(VNID_Parms);
   if (prfLib)     free(prfLib);
   if (prfParms)   free(prfParms);
 }

References XrdOucTList::next.

Member Function Documentation

◆ Configure()

int XrdCmsClientConfig::Configure	(	const char *	cfn,
		configWhat	What,
		configHow	How
	)

Definition at line 93 of file XrdCmsClientConfig.cc.

 {
 /*
   Function: Establish configuration at start up time.
  
   Input:    None.
  
   Output:   0 upon success or !0 otherwise.
 */
    XrdOucTList *tpe, *tpl;
    int i, NoGo = 0;
    const char *eText = 0;
    char buff[256], *slash, *temp, *bP, sfx;
  
 // Preset some values
 //
    myHost = getenv("XRDHOST");
    if (!myHost) myHost = "localhost";
    myName = XrdOucUtils::InstName(1);
    CMSPath = getenv("XRDADMINPATH");
    if (CMSPath && *CMSPath) CMSPath = strdup(CMSPath);
       else CMSPath = XrdOucUtils::genPath("/tmp/",XrdOucUtils::InstName(myName,0));
    isMeta = (How & configMeta) != 0;
    isMan  = (What& configMan)  != 0;
    isServer = What == configServer;
  
 // Process the configuration file
 //
    if (!(NoGo = ConfigProc(cfn)) && isMan)
       {if (How & configProxy) eText = (PanList ? 0 : "Proxy manager");
           else if (!ManList)
                   eText = (How & configMeta ? "Meta manager" : "Manager");
        if (eText) {Say.Emsg("Config", eText, "not specified."); NoGo=1;}
       }
  
 // Reset tracing options
 //
    if (getenv("XRDDEBUG")) Trace.What = TRACE_ALL;
  
 // Set proper local socket path
 //
    temp = XrdOucUtils::genPath(CMSPath, (const char *)0, ".olb");
    free(CMSPath); CMSPath = temp;
    XrdOucEnv::Export("XRDCMSPATH", temp);
    XrdOucEnv::Export("XRDOLBPATH", temp); //Compatibility
  
 // Determine what type of role we are playing
 //
         if (What & configServer) sfx = 's';
    else if (What & configSuper)  sfx = 'u';
    else                          sfx = 'm';
  
 // Determine which manager list we will be using
 //
    if (How & configProxy)
       {sfx = toupper(sfx);
        tpl = PanList;
       } else tpl = ManList;
  
 // Generate the system ID for this configuration.
 //
    if (!ConfigSID(cfn, tpl, sfx)) NoGo = 1;
  
 // Export the manager list
 //
    if (tpl)
       {i = 0; tpe = tpl;
        while(tpe) {i += strlen(tpe->text) + 9; tpe = tpe->next;}
        bP = temp = (char *)malloc(i);
        while(tpl)
             {bP += sprintf(bP, "%s:%d ", tpl->text, tpl->val);
              tpl = tpl->next;
             }
        *(bP-1) = '\0';
        XrdOucEnv::Export("XRDCMSMAN", temp); free(temp);
       }
  
 // Construct proper communications path for a supervisor node
 //
    i = strlen(CMSPath);
    if (What & configSuper)
       {while((tpl = ManList)) {ManList = tpl->next; delete tpl;}
        slash = (CMSPath[i-1] == '/' ? (char *)"" : (char *)"/");
        sprintf(buff, "%s%solbd.super", CMSPath, slash);
        ManList = new XrdOucTList(buff, -1, 0);
        SMode = SModeP = FailOver;
       }
  
 // Construct proper old communication path for a target node
 //
    temp = (What & (configMan|configSuper) ? (char *)"nimda" : (char *)"admin");
    slash = (CMSPath[i-1] == '/' ? (char *)"" : (char *)"/");
    sprintf(buff, "%s%solbd.%s", CMSPath, slash, temp);
    free(CMSPath); CMSPath = strdup(buff);
  
    RepWaitMS = RepWait * 1000;
  
 // Initialize the msg queue
 //
    if (XrdCmsClientMsg::Init())
       {Say.Emsg("Config", ENOMEM, "allocate initial msg objects");
        NoGo = 1;
       }
  
 // Load the performance monitor (server pre-screened) if specified.
 //
    if (prfLib && cmsMon)
       {perfMon = XrdCmsUtils::loadPerfMon(&Say, prfLib, XrdCms::myVersion);
        if (!perfMon || !perfMon->Configure(cfn, prfParms, *Say.logger(),
                                            *cmsMon, 0, false))
           {Say.Emsg("Config","Unable to configure performance monitor plugin.");
            NoGo = 1;
           }
       }
  
    return NoGo;
 }