XrdOdcMsg.hh

Go to the documentation of this file.

#ifndef __ODC_MSG__
#define __ODC_MSG__
/******************************************************************************/
/*                                                                            */
/*                          X r d O d c M s g . h h                           */
/*                                                                            */
/* (c) 2003 by the Board of Trustees of the Leland Stanford, Jr., University  */
/*                            All Rights Reserved                             */
/*   Produced by Andrew Hanushevsky for Stanford University under contract    */
/*              DE-AC03-76-SFO0515 with the Department of Energy              */
/******************************************************************************/
  
//          $Id: XrdOdcMsg.hh,v 1.7 2007/07/26 15:18:20 ganis Exp $

#include "XrdSys/XrdSysPthread.hh"

class XrdOucErrInfo;

class XrdOdcMsg
{
public:

static XrdOdcMsg *Alloc(XrdOucErrInfo *erp);

inline int       ID() {return id;}

static int       Init();

       void      Lock() {Hold.Lock();}

static int       mapError(const char *ecode);

       void      Recycle();

static int       Reply(int msgid, char *reply);

       void      UnLock() {Hold.UnLock();}

       int       Wait4Reply(int wtime) {return Hold.Wait(wtime);}

      XrdOdcMsg() : Hold(0) {inwaitq = 0; Resp = 0; next = 0;}
     ~XrdOdcMsg() {}

private:
static XrdOdcMsg   *RemFromWaitQ(int msgid);

static int          nextid;

static XrdOdcMsg   *msgTab;
static XrdOdcMsg   *nextfree;
static XrdSysMutex  FreeMsgQ;

XrdOdcMsg          *next;
XrdSysCondVar       Hold;
int                 inwaitq;
int                 id;
XrdOucErrInfo      *Resp;
};
#endif