XrdProofdResponse.h

Go to the documentation of this file.

// @(#)root/proofd:$Id$
// Author: G. Ganis  June 2005
 
/*************************************************************************
 * Copyright (C) 1995-2005, Rene Brun and Fons Rademakers.               *
 * All rights reserved.                                                  *
 *                                                                       *
 * For the licensing terms see $ROOTSYS/LICENSE.                         *
 * For the list of contributors see $ROOTSYS/README/CREDITS.             *
 *************************************************************************/
 
#ifndef ROOT_XrdProofdResponse
#define ROOT_XrdProofdResponse
 
//////////////////////////////////////////////////////////////////////////
//                                                                      //
// XrdProofdResponse                                                    //
//                                                                      //
// Authors: G. Ganis, CERN, 2005                                        //
//                                                                      //
// Utility class to handle replies to clients.                          //
//                                                                      //
//////////////////////////////////////////////////////////////////////////
 
#include <string.h>
#include <unistd.h>
#include <sys/uio.h>
 
#include "XpdSysPthread.h"
 
#include "XrdOuc/XrdOucString.hh"
#include "XProofProtocol.h"
 
class XrdLink;
 
class XrdProofdResponse
{
 public:
   XrdProofdResponse() { Reset(); }
   virtual ~XrdProofdResponse() {}
 
   inline const  char   *STRID() { return (const char *)fTrsid;}
   inline const char    *TraceID() const { return fTraceID.c_str(); }
 
   inline XrdLink       *Link() const { return fLink; }
 
   int                   LinkSend(const char *buff, int len, XrdOucString &e);
   int                   LinkSend(const struct iovec *iov,
                                  int iocnt, int len, XrdOucString &e);
 
   int                   Send(void);
   int                   Send(const char *msg);
   int                   Send(void *data, int dlen);
   int                   Send(XResponseType rcode);
   int                   Send(XResponseType rcode, void *data, int dlen);
   int                   Send(XErrorCode ecode, const char *msg);
   int                   Send(XPErrorCode ecode, const char *msg);
   int                   Send(XResponseType rcode, int info, char *data = 0);
   int                   Send(XResponseType rcode, XProofActionCode acode, int info);
   int                   Send(XResponseType rcode,
                              XProofActionCode acode, void *data, int dlen);
   int                   Send(XResponseType rcode, XProofActionCode acode,
                              kXR_int32 sid, void *data, int dlen);
 
   int                   SendI(kXR_int32 int1, void *data = 0, int dlen = 0);
   int                   SendI(kXR_int32 int1, kXR_int32 int2, void *data = 0, int dlen = 0);
   int                   SendI(kXR_int32 int1, kXR_int16 int2, kXR_int16 int3,
                               void *data = 0, int dlen = 0);
 
   void                  Set(XrdLink *l);
   inline void           SetTag(const char *tag) { fTag = tag; }
   void                  SetTraceID();
   void                  Set(unsigned char *stream);
   void                  Set(unsigned short streamid);
   void                  Set(ServerResponseHeader *resp);
 
   void                  GetSID(unsigned short &sid);
   void                  SetTrsid();
 
   void                  Reset() { XrdSysMutexHelper mh(fMutex);
                         fLink = 0; *fTrsid = '\0'; fSID = 0;
                         fResp.dlen = 0; fResp.status = 0;
                         fResp.streamid[0] = 0; fResp.streamid[1] = 0; }
 
   // To protect from concurrent use
   XrdSysRecMutex       fMutex;
 
 private:
 
   ServerResponseHeader fResp;
   XrdLink             *fLink;
   char                 fTrsid[8];  // sizeof() does not work here
 
   unsigned short       fSID;
 
   XrdOucString         fTraceID;
   XrdOucString         fTag;
};
#endif