46 int XrdCmsClientMsg::nextid = 0;
47 int XrdCmsClientMsg::numinQ = 0;
68 if (nextfree) {mp = nextfree; nextfree = mp->next;}
70 lclid = nextid = (nextid + MidIncr) & IncMask;
77 mp->id = (mp->id & MidMask) | lclid;
104 for (i = 0; i < MaxMsgs; i++)
105 {msgp->next = nextfree; nextfree = msgp; msgp->id = i; msgp++;}
134 if (numinQ >= 0) numinQ--;
149 if (!(mp = XrdCmsClientMsg::RemFromWaitQ(hdr.
streamid)))
181 msgnum = msgid & MidMask;
182 msgTab[msgnum].Hold.
Lock();
183 if (!msgTab[msgnum].inwaitq || msgTab[msgnum].
id != msgid)
185 msgTab[msgnum].inwaitq = 0;
186 return &msgTab[msgnum];
static XrdCmsClientMsg * Alloc(XrdOucErrInfo *erp)
static int Reply(const char *Man, XrdCms::CmsRRHdr &hdr, XrdOucBuffer *buff)
static int Decode(const char *Man, XrdCms::CmsRRHdr &hdr, XrdOucBuffer *dBuff, XrdOucErrInfo *eInfo)