XrdCmsClientMan.hh

Go to the documentation of this file.

#ifndef __CMS_CLIENTMAN__
#define __CMS_CLIENTMAN__
/******************************************************************************/
/*                                                                            */
/*                    X r d C m s C l i e n t M a n . h h                     */
/*                                                                            */
/* (c) 2007 by the Board of Trustees of the Leland Stanford, Jr., University  */
/*                            All Rights Reserved                             */
/*   Produced by Andrew Hanushevsky for Stanford University under contract    */
/*              DE-AC02-76-SFO0515 with the Department of Energy              */
/******************************************************************************/

#include <stdio.h>
#include <sys/uio.h>

#include "XProtocol/YProtocol.hh"

#include "XrdCms/XrdCmsResp.hh"
#include "XrdNet/XrdNetBuffer.hh"
#include "XrdOuc/XrdOucErrInfo.hh"
#include "XrdSys/XrdSysPthread.hh"

class XrdInet;
class XrdLink;
class XrdNetBuffer;

class XrdCmsClientMan
{
public:

static char          doDebug;

int                  delayResp(XrdOucErrInfo &Resp);

inline int           isActive() {return Active;}

XrdCmsClientMan     *nextManager() {return Next;}

char                *Name() {return Host;}
char                *NPfx() {return HPfx;}

int                  Send(char *msg, int mlen=0);
int                  Send(const struct iovec *iov, int iovcnt, int iotot=0);

void                *Start();

inline int           Suspended() {if (Suspend) chkStatus(); return Suspend;}

void                 setNext(XrdCmsClientMan *np) {Next = np;}

static void          setNetwork(XrdInet *nP) {Network = nP;}

static void          setConfig(char *cfn) {ConfigFN = cfn;}

int                  whatsUp(const char *user, const char *path);

inline int           waitTime() {return repWait;}

                  XrdCmsClientMan(char *host,int port,int cw,int nr,int rw,int rd);
                 ~XrdCmsClientMan();

private:
int   Hookup();
int   Receive();
void  relayResp();
void  chkStatus();
void  setStatus();

static XrdSysMutex   manMutex;
static XrdNetBufferQ BuffQ;
static XrdInet      *Network;
static char         *ConfigFN;
static const int     chkVal = 256;

XrdSysSemaphore   syncResp;
XrdCmsRespQ       RespQ;

XrdCmsClientMan  *Next;
XrdSysMutex       myData;
XrdLink          *Link;
char             *Host;
char             *HPfx;
int               Port;
int               manMask;
int               dally;
int               Active;
int               Silent;
int               Suspend;
int               RecvCnt;
int               SendCnt;
int               nrMax;
int               maxMsgID;
int               repWait;
int               repWMax;
int               minDelay;
int               maxDelay;
int               qTime;
int               chkCount;
time_t            lastUpdt;
time_t            lastTOut;
XrdCms::CmsRRHdr  Response;
XrdNetBuffer     *NetBuff;
};
#endif