XrdSutBuffer Class Reference

#include <XrdSutBuffer.hh>

Collaboration diagram for XrdSutBuffer:

Public Member Functions
	XrdSutBuffer (const char *buffer, kXR_int32 length)
	XrdSutBuffer (const char *prot, const char *opts=0)
virtual	~XrdSutBuffer ()
int	AddBucket (char *bp=0, int sz=0, int ty=0)
int	AddBucket (XrdOucString s, int ty=0)
int	AddBucket (XrdSutBucket *b)
void	Deactivate (kXR_int32 type)
void	Dump (const char *stepstr=0, bool all=false)
XrdSutBucket *	GetBucket (kXR_int32 type, const char *tag=0)
XrdSutBuckList *	GetBuckList () const
int	GetNBuckets () const
const char *	GetOptions () const
const char *	GetProtocol () const
int	GetStep () const
void	IncrementStep ()
kXR_int32	MarshalBucket (kXR_int32 type, kXR_int32 code)
void	Message (const char *prepose=0)
void	Remove (XrdSutBucket *b)
int	Serialized (char **buffer, char opt='n')
void	SetStep (int s)
kXR_int32	UnmarshalBucket (kXR_int32 type, kXR_int32 &code)
int	UpdateBucket (const char *bp, int sz, int ty)
int	UpdateBucket (XrdOucString s, int ty)

Detailed Description

Definition at line 43 of file XrdSutBuffer.hh.

Constructor & Destructor Documentation

XrdSutBuffer() [1/2]

XrdSutBuffer::XrdSutBuffer ( const char *  prot, const char *  opts = 0  )

inline

Definition at line 53 of file XrdSutBuffer.hh.

                 {fOptions = opts; fProtocol = prot; fStep = 0;}

References opts.

XrdSutBuffer() [2/2]

XrdSutBuffer::XrdSutBuffer	(	const char *	buffer,
		kXR_int32	length
	)

Definition at line 48 of file XrdSutBuffer.cc.

{
   // Constructor from compact form (used for exchange over the network)
   // If the buffer begins with "&P=", then only the protocol name and
   // options are extracted, assuming the format "&P=<protocol>,<options>".
   // Otherwise the format "<protocol><step><bucket_1>...<bucket_n>" is
   // assumed 
   EPNAME("Buffer::XrdSutBuffer");
 
   bool ok = 1;
 
   // Default initialization
   fOptions = "";
   fProtocol = "";
   fStep = 0;
 
   //
   // Check type of buffer
   if (!strncmp(buf,"&P=",3)) {
      //
      // Initial buffer format
      // Extract protocol name and options
      int cur = 3;
      int k = 0;
      while (buf[cur+k] && buf[cur+k] != ',' &&
             k < XrdSecPROTOIDSIZE && (cur+k) < len) k++;
      if (!k) {
         PRINT("no protocol name - do nothing");
      } else {
         //
         // Extract protocol name
         char proto[XrdSecPROTOIDSIZE];
         strncpy(proto,buf+cur,k);
         proto[(k >= XrdSecPROTOIDSIZE ? XrdSecPROTOIDSIZE-1:k)]=0;  // null-terminated
         fProtocol = proto;
         cur += (k+1);
         //
         // Extract options, if any
         if (cur < len) {
            k = 0;
            while ((cur+k) < len && buf[cur+k])
               k++;
            if (k) {
               char *opts = new char[k+1];
               if (opts) {
                  strncpy(opts,buf+cur,k);
                  opts[k] = 0;  // null-terminated
                  fOptions = opts;
                  delete[] opts;
               }
            }
            cur += (k+1);
         }
      }
 
   } else {
      //
      // Assume exchange info format
      // Check integrity
      int k = 0;
      while ( k < XrdSecPROTOIDSIZE && k < len && buf[k]) { k++; }
      if (!k || k == XrdSecPROTOIDSIZE) {
         PRINT("no protocol name: do nothing");
         ok = 0;
      }
      int cur = k+1;
      if (ok) {
         //
         // Extract protocol name
         char proto[XrdSecPROTOIDSIZE];
         strcpy(proto,buf);
         fProtocol = proto;
      
         //
         // Step/Iteration number
         kXR_int32 step;
         memcpy(&step,&buf[cur],sizeof(kXR_int32));
         fStep = ntohl(step);
         cur += sizeof(kXR_int32);
      }
 
      //
      // Total length of buckets (sizes+buffers) (excluded trailing 0)
      int ltot = len - sizeof(kXR_int32);
      TRACE(Dump,"ltot: " <<ltot);
      
      //
      // Now the buckets
      kXR_int32 type;
      kXR_int32 blen;
      XrdSutBucket *tmp = 0;
      char *buck = 0;
      while (ok) {
      
         //
         // Get type 
         memcpy(&type,&buf[cur],sizeof(kXR_int32));
         type = ntohl(type);
         TRACE(Dump,"type: " <<XrdSutBuckStr(type));
      
         if (type == kXRS_none) {
            //
            // We are over
            ok = 0;
         } else {
            //
            cur += sizeof(kXR_int32);
            //
            // Get length and test consistency
            memcpy(&blen,&buf[cur],sizeof(kXR_int32));
            blen = ntohl(blen);
            TRACE(Dump,"blen: " <<blen);
            //
            cur += sizeof(kXR_int32);
            TRACE(Dump,"cur: " <<cur);
            if ((cur-1+blen) > ltot)
               ok = 0;
            else {
               //
               // Store only active buckets
               if (type != kXRS_inactive){
                  //
                  // Normal active bucket: save it in the vector
                  if ((buck = new char[blen])) {
                     memcpy(buck,&buf[cur],blen);
                     if ((tmp = new XrdSutBucket(buck,blen,type))) {
                        fBuckets.PushBack(tmp);
                     } else {
                        PRINT("error creating bucket: "<<XrdSutBuckStr(type)
                              <<" (size: "<<blen<<", !buck:"<<(!buck)<<")");
                     }
                  } else {
                     PRINT("error allocating buffer for bucket: "
                           <<XrdSutBuckStr(type)<<" (size:"<<blen<<")");
                  }
               }
               cur += blen;
            }
         }
      }
   }
}

References Dump(), EPNAME, kXRS_inactive, kXRS_none, opts, PRINT, XrdSutBuckList::PushBack(), TRACE, XrdSecPROTOIDSIZE, and XrdSutBuckStr().

Here is the call graph for this function:

~XrdSutBuffer()

XrdSutBuffer::~XrdSutBuffer ( )

virtual

Definition at line 192 of file XrdSutBuffer.cc.

{
   // Destructor
   // XrdSutBuffer is responsible of the buckets in the list
   EPNAME("Buffer::~XrdSutBuffer");
 
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      TRACE(Dump,"type: " << bp->type);
      delete bp;
      // Get next bucket
      bp = fBuckets.Next();
   }
}

References XrdSutBuckList::Begin(), Dump(), EPNAME, XrdSutBuckList::Next(), TRACE, and XrdSutBucket::type.

Here is the call graph for this function:

Member Function Documentation

AddBucket() [1/3]

int XrdSutBuffer::AddBucket ( char *  bp = 0, int  sz = 0, int  ty = 0  )

inline

Definition at line 59 of file XrdSutBuffer.hh.

                 { XrdSutBucket *b = new XrdSutBucket(bp,sz,ty);
                   if (b) { fBuckets.PushBack(b); return 0;} return -1; }

References XrdSutBuckList::PushBack().

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), XrdSecProtocolpwd::getCredentials(), MarshalBucket(), and UpdateBucket().

Here is the call graph for this function:

Here is the caller graph for this function:

AddBucket() [2/3]

int XrdSutBuffer::AddBucket ( XrdOucString  s, int  ty = 0  )

inline

Definition at line 62 of file XrdSutBuffer.hh.

                 { XrdSutBucket *b = new XrdSutBucket(s,ty);
                   if (b) { fBuckets.PushBack(b); return 0;} return -1; }

References XrdSutBuckList::PushBack().

Here is the call graph for this function:

AddBucket() [3/3]

int XrdSutBuffer::AddBucket ( XrdSutBucket *  b )

inline

Definition at line 65 of file XrdSutBuffer.hh.

                 { if (b) { fBuckets.PushBack(b); return 0;} return -1; }

References XrdSutBuckList::PushBack().

Here is the call graph for this function:

Deactivate()

void XrdSutBuffer::Deactivate

(

kXR_int32

type

)

Definition at line 417 of file XrdSutBuffer.cc.

{
   // Deactivate first bucket of type 'type', if any
   // If type == -1, deactivate all buckets (cleanup)
 
   //
   // Loop over buckets
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      if (type == bp->type) {
         bp->type = kXRS_inactive;
         break;
      } else if (type == -1) {
         bp->type = kXRS_inactive;
      }
      // Get next
      bp = fBuckets.Next();
   }
}

References XrdSutBuckList::Begin(), kXRS_inactive, XrdSutBuckList::Next(), and XrdSutBucket::type.

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), and XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

Dump()

void XrdSutBuffer::Dump	(	const char *	stepstr = 0,
		bool	all = false
	)

Definition at line 240 of file XrdSutBuffer.cc.

{
   // Dump content of buffer. If all is false, only active buckets are dumped;
   // this is the default behaviour.
   EPNAME("Buffer::Dump");
 
   PRINT("//-----------------------------------------------------//");
   PRINT("//                                                     //")
   PRINT("//            XrdSutBuffer DUMP                        //")
   PRINT("//                                                     //")
 
   int nbuck = fBuckets.Size();
 
   PRINT("//  Buffer        : " <<this);
   PRINT("// ");
   PRINT("//  Proto         : " <<fProtocol.c_str());
   if (fOptions.length()) {
      PRINT("//  Options       : " <<fOptions.c_str());
   } else {
      PRINT("//  Options       : none");
   }
   if (stepstr) {
      PRINT("//  Step          : " <<stepstr);
   } else {
      PRINT("//  Step          : " <<fStep);
   }
   if (!all) {
      PRINT("//  Dumping active buckets only ");
   } else {
      PRINT("//  # of buckets  : " <<nbuck);
   }
   PRINT("// ");
 
   int kb = 0;
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      PRINT("// ");
      if (all || bp->type != kXRS_inactive) {
         PRINT("//  buck: " <<kb++);
         bp->Dump(0);
      }
      // Get next
      bp = fBuckets.Next();
   }
   if (!all) PRINT("//  # active buckets found: " << kb);
   PRINT("//                                                     //")
   PRINT("//-----------------------------------------------------//");
}

References XrdSutBuckList::Begin(), XrdOucString::c_str(), XrdSutBucket::Dump(), EPNAME, kXRS_inactive, XrdOucString::length(), XrdSutBuckList::Next(), PRINT, XrdSutBuckList::Size(), and XrdSutBucket::type.

Referenced by XrdSutBuffer(), ~XrdSutBuffer(), XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), and XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

GetBucket()

XrdSutBucket * XrdSutBuffer::GetBucket	(	kXR_int32	type,
		const char *	tag = 0
	)

Definition at line 388 of file XrdSutBuffer.cc.

{
   // Search the vector of buckets for the first bucket of
   // type 'type'.
   // If tag is defined, search buckets whose buffer contains tag
   // in the form <tag>'\0'<rest_of_buffer>.
   // Returns the pointer to the buffer; 0 if the no bucket
   // is found
 
   //
   // Check tag, if any
   int ltag = (tag) ? strlen(tag) : 0;
   //
   // Loop over buckets
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      if (type == bp->type && (!tag || (ltag < bp->size && 
                                        !strncmp(bp->buffer,tag,ltag) && 
                                        (bp->buffer)[ltag] == '\0')))
         return bp;
      // Get next
      bp = fBuckets.Next();
   }
 
   // Nothing found
   return 0;
}

References XrdSutBuckList::Begin(), XrdSutBucket::buffer, XrdSutBuckList::Next(), and XrdSutBucket::type.

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolpwd::getCredentials(), MarshalBucket(), UnmarshalBucket(), and UpdateBucket().

Here is the call graph for this function:

Here is the caller graph for this function:

GetBuckList()

XrdSutBuckList* XrdSutBuffer::GetBuckList ( ) const

inline

Definition at line 85 of file XrdSutBuffer.hh.

{ return (XrdSutBuckList *)&fBuckets; }

GetNBuckets()

int XrdSutBuffer::GetNBuckets ( ) const

inline

Definition at line 86 of file XrdSutBuffer.hh.

{ return fBuckets.Size(); }

References XrdSutBuckList::Size().

Here is the call graph for this function:

GetOptions()

const char* XrdSutBuffer::GetOptions ( ) const

inline

Definition at line 87 of file XrdSutBuffer.hh.

{ return fOptions.c_str(); }

References XrdOucString::c_str().

Here is the call graph for this function:

GetProtocol()

const char* XrdSutBuffer::GetProtocol ( ) const

inline

Definition at line 88 of file XrdSutBuffer.hh.

{ return fProtocol.c_str(); }

References XrdOucString::c_str().

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), and XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

GetStep()

int XrdSutBuffer::GetStep ( ) const

inline

Definition at line 89 of file XrdSutBuffer.hh.

{ return (int)fStep; }

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), and XrdSecProtocolpwd::getCredentials().

Here is the caller graph for this function:

IncrementStep()

void XrdSutBuffer::IncrementStep ( )

inline

Definition at line 91 of file XrdSutBuffer.hh.

{ fStep++; }

MarshalBucket()

kXR_int32 XrdSutBuffer::MarshalBucket	(	kXR_int32	type,
		kXR_int32	code
	)

Definition at line 318 of file XrdSutBuffer.cc.

{
   // Search the vector of buckets for the first bucket of
   // type 'type'. Reset its content and fill it with 'code'
   // in network byte order. If no bucket 'type' exists, add
   // a new one.
   // Returns -1 if new bucket could be allocated; 0 otherwise .
   EPNAME("Buffer::MarshalBucket");
 
   // Convert to network byte order
   kXR_int32 mcod = htonl(code);
 
   // Get the bucket
   XrdSutBucket *bck = GetBucket(type);
   if (!bck) {
      // Allocate a new one
      bck = new XrdSutBucket(0,0,type);
      if (!bck) {
         DEBUG("could not allocate new bucket of type:"<<XrdSutBuckStr(type));
         errno = ENOMEM;
         return -1;
      }
      // Add it to the list
      AddBucket(bck);
   }
 
   // Set content
   bck->SetBuf((char *)(&mcod),sizeof(kXR_int32));
 
   // We are done
   return 0;
}

References AddBucket(), DEBUG, EPNAME, GetBucket(), XrdSutBucket::SetBuf(), and XrdSutBuckStr().

Referenced by XrdSecProtocolgsi::getCredentials(), and XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

Message()

void XrdSutBuffer::Message

(

const char *

prepose = 0

)

Definition at line 290 of file XrdSutBuffer.cc.

{
   // Print content of any bucket of type kXRS_message
   // Prepose 'prepose', if defined 
 
   bool pripre = 0;
   if (prepose)
      pripre = 1;
 
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      if (bp->type == kXRS_message) {
         if (bp->size > 0 && bp->buffer) {
            if (pripre) {
               XrdOucString premsg(prepose);
               std::cerr << premsg << std::endl;
               pripre = 0;
            }
            XrdOucString msg(bp->buffer,bp->size);
            std::cerr << msg << std::endl;
         }
      }
      // Get next
      bp = fBuckets.Next();
   }
}

References XrdSutBuckList::Begin(), XrdSutBucket::buffer, kXRS_message, XrdSutBuckList::Next(), XrdSutBucket::size, and XrdSutBucket::type.

Referenced by XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

Remove()

void XrdSutBuffer::Remove ( XrdSutBucket *  b )

inline

Definition at line 72 of file XrdSutBuffer.hh.

{ fBuckets.Remove(b); }

References XrdSutBuckList::Remove().

Here is the call graph for this function:

Serialized()

int XrdSutBuffer::Serialized	(	char **	buffer,
		char	opt = 'n'
	)

Definition at line 438 of file XrdSutBuffer.cc.

{
   // Serialize the content in a form suited for exchange
   // over the net; the result is saved in '*buffer', which
   // must be deleted (opt = 'n', default) or freed (opt == 'm') by the caller.
   // Returns the length of the buffer in case of success.
   // Returns -1 in case of problems allocating the buffer.
   EPNAME("Buffer::Serialized");
 
   //
   // Check that we got a valid argument
   if (!buffer) {
      DEBUG("invalid input argument");
      errno = EINVAL;
      return -1;
   }
 
   //
   // Calculate the length of the buffer
   int blen = fProtocol.length() + 1 + 2*sizeof(kXR_int32);
   // buckets
   XrdSutBucket *bp = fBuckets.Begin();
   while (bp) {
      if (bp->type != kXRS_inactive) {
         blen += 2*sizeof(kXR_int32);
         blen += bp->size;
      }
      // Get next
      bp = fBuckets.Next();
   }
 
   //
   // Allocate the buffer
   *buffer = (opt == 'n') ? (new char[blen]) : (char *)malloc(blen);
   if (!(*buffer))
      return -1;
   char *tbuf = *buffer;
   int cur = 0;
 
   //
   // Add protocol
   memcpy(tbuf,fProtocol.c_str(),fProtocol.length());
   tbuf[fProtocol.length()] = 0;
   cur += fProtocol.length() + 1;
 
   //
   // Add step number
   kXR_int32 step = htonl(fStep);
   memcpy(tbuf+cur,&step,sizeof(kXR_int32));
   cur += sizeof(kXR_int32);
 
   //
   // Add buckets
   bp = fBuckets.Begin();
   while (bp) {
      if (bp->type != kXRS_inactive) {
         kXR_int32 type = htonl(bp->type);
         memcpy(tbuf+cur,&type,sizeof(kXR_int32));
         cur += sizeof(kXR_int32);
         kXR_int32 size = htonl(bp->size);
         memcpy(tbuf+cur,&size,sizeof(kXR_int32));
         cur += sizeof(kXR_int32);
         memcpy(tbuf+cur,bp->buffer,bp->size);
         cur += bp->size;
      }
      // Get next bucket
      bp = fBuckets.Next();
   }
 
   //
   // Add 0 termination
   kXR_int32 ltmp = htonl(kXRS_none);
   memcpy(tbuf+cur,&ltmp,sizeof(kXR_int32));
 
   // Return total length
   return blen;
}

References XrdSutBuckList::Begin(), XrdSutBucket::buffer, XrdOucString::c_str(), DEBUG, EPNAME, kXRS_inactive, kXRS_none, XrdOucString::length(), XrdSutBuckList::Next(), XrdSutBucket::size, and XrdSutBucket::type.

Referenced by XrdSecProtocolgsi::Authenticate(), XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), and XrdSecProtocolpwd::getCredentials().

Here is the call graph for this function:

Here is the caller graph for this function:

SetStep()

void XrdSutBuffer::SetStep ( int  s )

inline

Definition at line 90 of file XrdSutBuffer.hh.

{ fStep = (kXR_int32)s; }

Referenced by XrdSecProtocolgsi::getCredentials().

Here is the caller graph for this function:

UnmarshalBucket()

kXR_int32 XrdSutBuffer::UnmarshalBucket	(	kXR_int32	type,
		kXR_int32 &	code
	)

Definition at line 352 of file XrdSutBuffer.cc.

{
   // Search the vector of buckets for the first bucket of
   // type 'type'. Unmarshalled its content to host byte order
   // and fill it in code.
   // Returns 0 if ok.
   // Returns -1 if no bucket of requested 'type' could be
   // found; -2 if the bucket size is inconsistent.
   EPNAME("Buffer::UnmarshalBucket");
 
   code = 0;
   // Get the bucket
   XrdSutBucket *bck = GetBucket(type);
   if (!bck) {
      DEBUG("could not find a bucket of type:"<<XrdSutBuckStr(type));
      errno = ENOENT;
      return -1;
   }
   if (bck->size != sizeof(kXR_int32)) {
      DEBUG("Wrong size: type:"<<XrdSutBuckStr(type)
            <<", size:"<<bck->size<<", expected:"<<sizeof(kXR_int32));
      errno = EINVAL;
      return -2;
   }
   //
   // Get the content
   memcpy(&code,bck->buffer,sizeof(kXR_int32));
   //
   // Unmarshal
   code = ntohl(code);
 
   // We are done
   return 0;
}

References XrdSutBucket::buffer, DEBUG, EPNAME, GetBucket(), XrdSutBucket::size, and XrdSutBuckStr().

Here is the call graph for this function:

UpdateBucket() [1/2]

int XrdSutBuffer::UpdateBucket	(	const char *	bp,
		int	sz,
		int	ty
	)

Definition at line 208 of file XrdSutBuffer.cc.

{
   // Update existing bucket (or add a new bucket to the list)
   // with sz bytes at 'b'.
   // Returns 0 or -1 if error allocating bucket
   EPNAME("Buffer::UpdateBucket");
 
   XrdSutBucket *bp = GetBucket(ty);
   if (!bp) {
      bp = new XrdSutBucket(0,0,ty);
      if (!bp) {
         DEBUG("Out-Of-Memory allocating bucket");
         return -1;
      }
      AddBucket(bp);
   }
   bp->SetBuf(b,sz);
   // Done
   return 0;
}

References AddBucket(), DEBUG, EPNAME, GetBucket(), and XrdSutBucket::SetBuf().

Referenced by XrdSecProtocolpwd::Authenticate(), XrdSecProtocolgsi::getCredentials(), XrdSecProtocolpwd::getCredentials(), and UpdateBucket().

Here is the call graph for this function:

Here is the caller graph for this function:

UpdateBucket() [2/2]

int XrdSutBuffer::UpdateBucket	(	XrdOucString	s,
		int	ty
	)

Definition at line 230 of file XrdSutBuffer.cc.

{
   // Update existing bucket (or add a new bucket to the list)
   // with string s.
   // Returns 0 or -1 if error allocating bucket
 
   return UpdateBucket(s.c_str(),s.length(),ty);
}

References XrdOucString::c_str(), XrdOucString::length(), and UpdateBucket().

Here is the call graph for this function:

---

The documentation for this class was generated from the following files:

• XrdSutBuffer.hh
• XrdSutBuffer.cc