XRootD
Loading...
Searching...
No Matches
XrdCmsClientMsg.hh
Go to the documentation of this file.
1#ifndef __CMS_CLIENTMSG__
2#define __CMS_CLIENTMSG__
3/******************************************************************************/
4/* */
5/* X r d C m s C l i e n t M s g . h h */
6/* */
7/* (c) 2007 by the Board of Trustees of the Leland Stanford, Jr., University */
8/* All Rights Reserved */
9/* Produced by Andrew Hanushevsky for Stanford University under contract */
10/* DE-AC02-76-SFO0515 with the Department of Energy */
11/* */
12/* This file is part of the XRootD software suite. */
13/* */
14/* XRootD is free software: you can redistribute it and/or modify it under */
15/* the terms of the GNU Lesser General Public License as published by the */
16/* Free Software Foundation, either version 3 of the License, or (at your */
17/* option) any later version. */
18/* */
19/* XRootD is distributed in the hope that it will be useful, but WITHOUT */
20/* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
21/* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
22/* License for more details. */
23/* */
24/* You should have received a copy of the GNU Lesser General Public License */
25/* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
26/* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
27/* */
28/* The copyright holder's institutional names and contributor's names may not */
29/* be used to endorse or promote products derived from this software without */
30/* specific prior written permission of the institution or contributor. */
31/******************************************************************************/
32
34
36
37class XrdOucErrInfo;
38class XrdOucBuffer;
39
41{
42public:
43
45
46inline int getResult() {return Result;}
47
48inline int ID() {return id;}
49
50static int Init();
51
52static int inQ() {return numinQ;}
53
54 void Lock() {Hold.Lock();}
55
56 void Recycle();
57
58static int Reply(const char *Man,XrdCms::CmsRRHdr &hdr,XrdOucBuffer *buff);
59
60 void UnLock() {Hold.UnLock();}
61
62 int Wait4Reply(int wtime) {return Hold.Wait(wtime);}
63
64 XrdCmsClientMsg() : Hold(0) {next = 0; inwaitq = 0; Resp = 0; Result = 0;}
66
67private:
68static const int MidMask = 1023;
69static const int MaxMsgs = 1024;
70static const int MidIncr = 1024;
71static const int IncMask = 0x3ffffc00;
72static XrdCmsClientMsg *RemFromWaitQ(int msgid);
73
74static int nextid;
75static int numinQ;
76
77static XrdCmsClientMsg *msgTab;
78static XrdCmsClientMsg *nextfree;
79static XrdSysMutex FreeMsgQ;
80
81XrdCmsClientMsg *next;
82XrdSysCondVar Hold;
83int inwaitq;
84int id;
85XrdOucErrInfo *Resp;
86int Result;
87};
88#endif
static XrdCmsClientMsg * Alloc(XrdOucErrInfo *erp)
int Wait4Reply(int wtime)
static int Init()
static int Reply(const char *Man, XrdCms::CmsRRHdr &hdr, XrdOucBuffer *buff)