XrdNetPMarkFF Class Reference

#include <XrdNetPMarkFF.hh>

Inheritance diagram for XrdNetPMarkFF:

Collaboration diagram for XrdNetPMarkFF:

Public Member Functions
	XrdNetPMarkFF (XrdNetPMark::Handle &h, const char *tid)
virtual	~XrdNetPMarkFF ()
void	addHandle (XrdNetPMark::Handle *fh)
bool	Start (XrdNetAddrInfo &addr)
Public Member Functions inherited from XrdNetPMark::Handle
	Handle (const char *app=0, int ecode=0, int acode=0)
	Handle (Handle &h)
virtual	~Handle ()
bool	getEA (int &ec, int &ac)
bool	Valid ()

Additional Inherited Members
Protected Attributes inherited from XrdNetPMark::Handle
int	aCode
char *	appName
int	eCode

Detailed Description

Definition at line 38 of file XrdNetPMarkFF.hh.

Constructor & Destructor Documentation

XrdNetPMarkFF()

XrdNetPMarkFF::XrdNetPMarkFF ( XrdNetPMark::Handle & h, const char * tid )

inline

Definition at line 46 of file XrdNetPMarkFF.hh.

                          : XrdNetPMark::Handle(h), tident(tid) {}

References XrdNetPMark::Handle::Handle().

Here is the call graph for this function:

~XrdNetPMarkFF()

XrdNetPMarkFF::~XrdNetPMarkFF ( )

virtual

Definition at line 271 of file XrdNetPMarkFF.cc.

{
// If all is well, emit the closing message
//
   if (fdOK || odOK)
      {char utcBuff[40], endBuff[80];
       snprintf(endBuff, sizeof(endBuff), ffEnd,
                         getUTC(utcBuff, sizeof(utcBuff)));
       Emit("end", utcBuff, endBuff);
      }
 
// Cleanup
//
   if (mySad)  delete(mySad);
   if (oDest)  free(oDest);
   if (ffHdr)  free(ffHdr);
   if (ffTail) free(ffTail);
   if (xtraFH) delete xtraFH;
};

Member Function Documentation

addHandle()

void XrdNetPMarkFF::addHandle ( XrdNetPMark::Handle * fh )

inline

Definition at line 42 of file XrdNetPMarkFF.hh.

{xtraFH = fh;}

Start()

bool XrdNetPMarkFF::Start

(

XrdNetAddrInfo &

addr

)

Definition at line 328 of file XrdNetPMarkFF.cc.

{
   char appInfo[128], clIP[INET6_ADDRSTRLEN+2], svIP[INET6_ADDRSTRLEN+2];
   int  clPort, svPort;
   char clType, svType;
   bool fdok = false, odok = false;
 
// Preform app if we need to
//
   if (!appName) *appInfo = 0;
      else snprintf(appInfo,sizeof(appInfo),ffApp,sizeof(appInfo)-20,appName);
 
// Get the file descriptor for the socket
//
   sockFD = addr.SockFD();
 
// Obtain connectivity information about the peer and ourselves. We really
// should obtain our external address and use that but the issue is that
// we may have multiple external addresses and the client determines which
// one actually gets used. So, it's complicated. A TODO.
//
   clPort = XrdNetUtils::GetSokInfo( sockFD, clIP, sizeof(clIP), clType);
   if (clPort < 0)
      {eDest->Emsg("PMarkFF", clPort, "get peer information.");
       return false;
      }
 
   svPort = XrdNetUtils::GetSokInfo(-sockFD, svIP, sizeof(svIP), svType);
   if (svPort < 0)
      {eDest->Emsg("PMarkFF", clPort, "get self information.");
       return false;
      }
 
// If there is no special collector, indicate so
//
   if (netMsg) fdok = true;
 
// If the messages need to flow to the origin, get the destination information
//
   if (netOrg)
      {const XrdNetSockAddr *urSad = addr.NetAddr();
       if (!urSad) eDest->Emsg("PMarkFF", "unable to get origin address.");
          else {char buff[1024];
                mySad = new XrdNetSockAddr;
                memcpy(mySad, urSad, sizeof(XrdNetSockAddr));
                mySad->v4.sin_port = htons(static_cast<uint16_t>(ffPortO));
                snprintf(buff, sizeof(buff), "%s:%d", clIP, ffPortO);
                oDest = strdup(buff);
                odok  = true;
               }
      }
 
// If we cannot report anywhere then indicate we failed
//
   if (!fdok && !odok) return false;
 
// Format the base firefly template. Note that the client determines the
// address family that is being used.
//
   char utcBuff[40], bseg0[512];
   int len0 = snprintf(bseg0, sizeof(bseg0), ffFmt0, myHostName,
                                             getUTC(utcBuff, sizeof(utcBuff)));
   if (len0 >= (int)sizeof(bseg0))
      {eDest->Emsg("PMarkFF", "invalid json; bseg0 truncated.");
       return false;
      }
 
   ffHdr = strdup(bseg0);
 
   char bseg1[256];
   int len1 = snprintf(bseg1, sizeof(bseg1), ffFmt1, eCode, aCode, appInfo);
   if (len1 >= (int)sizeof(bseg1))
      {eDest->Emsg("PMarkFF", "invalid json; bseg1 truncated.");
       return false;
      }
 
// Note that by convention FF packets the supplier of the data is designated
// as the source. We only know this at this point for http requests and even
// then it's hardly accurate. So, for put requests the src if the client.  
// Ottherwise, we designate the server as the source.
//
   char bseg2[256];
   int len2;
   if (appName && !strcmp(appName, "http-put"))
      {len2 = snprintf(bseg2, sizeof(bseg2), ffFmt2,
                              clType, clIP, svIP, clPort, svPort);
      } else {
       len2 = snprintf(bseg2, sizeof(bseg2), ffFmt2,
                              clType, svIP, clIP, svPort, clPort);
      }
   if (len2 >= (int)sizeof(bseg2))
      {eDest->Emsg("PMarkFF", "invalid json; cl bseg2 truncated.");
       return false;
      }
 
   ffTailsz = len1 + len2;
   ffTail   = (char *)malloc(ffTailsz + 1);
   strcpy(ffTail,      bseg1);
   strcpy(ffTail+len1, bseg2);
 
// OK, we now can emit the starting packet
//
   fdOK = fdok;
   odOK = odok;
   return Emit("start", utcBuff, "");
}

References XrdNetPMark::Handle::aCode, XrdNetPMark::Handle::appName, XrdNetPMark::Handle::eCode, eDest, XrdNetPMarkConfig::ffPortO, XrdNetUtils::GetSokInfo(), XrdNetPMarkConfig::myHostName, XrdNetAddrInfo::NetAddr(), XrdNetPMarkConfig::netMsg, XrdNetPMarkConfig::netOrg, and XrdNetAddrInfo::SockFD().

Referenced by XrdNetPMarkCfg::Begin().

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• XrdNetPMarkFF.hh
• XrdNetPMarkFF.cc