[Server] Implement firefly network flow monitoring.

src/Xrd/XrdConfig.cc

@@ -64,6 +64,7 @@
 
 #include "XrdNet/XrdNetAddr.hh"
 #include "XrdNet/XrdNetIF.hh"
+#include "XrdNet/XrdNetPMarkCfg.hh"
 #include "XrdNet/XrdNetSecurity.hh"
 #include "XrdNet/XrdNetUtils.hh"
 
@@ -730,6 +731,15 @@ int XrdConfig::Configure(int argc, char **argv)
 //
    if (!NoGo) Manifest(pidFN);
 
+// Initialize the packet marking framework if configured
+//
+   if (!NoGo)
+      {bool bad = false;
+       XrdNetPMark *pmark = XrdNetPMarkCfg::Config(&Log,&Sched,&XrdTrace,bad);
+       if (pmark) theEnv.PutPtr("XrdNetPMark*", pmark);
+          else if (bad) NoGo = 1;
+      }
+
 // Now initialize the protocols and other stuff
 //
    if (!NoGo) NoGo = Setup(dfltProt, libProt);
@@ -804,6 +814,7 @@ int XrdConfig::ConfigXeq(char *var, XrdOucStream &Config, XrdSysError *eDest)
    TS_Xeq("allow",         xallow);
    TS_Xeq("homepath",      xhpath);
    TS_Xeq("pidpath",       xpidf);
+   TS_Xeq("pmark",         XrdNetPMarkCfg::Parse);
    TS_Xeq("port",          xport);
    TS_Xeq("protocol",      xprot);
    TS_Xeq("report",        xrep);

src/XrdNet/XrdNetPMark.hh

@@ -0,0 +1,70 @@
+#ifndef __XRDNETPMARK__
+#define __XRDNETPMARK__
+/******************************************************************************/
+/*                                                                            */
+/*                        X r d N e t P M a r k . h h                         */
+/*                                                                            */
+/* (c) 2021 by the Board of Trustees of the Leland Stanford, Jr., University  */
+/*                            All Rights Reserved                             */
+/*   Produced by Andrew Hanushevsky for Stanford University under contract    */
+/*              DE-AC02-76-SFO0515 with the Department of Energy              */
+/*                                                                            */
+/* This file is part of the XRootD software suite.                            */
+/*                                                                            */
+/* XRootD is free software: you can redistribute it and/or modify it under    */
+/* the terms of the GNU Lesser General Public License as published by the     */
+/* Free Software Foundation, either version 3 of the License, or (at your     */
+/* option) any later version.                                                 */
+/*                                                                            */
+/* XRootD is distributed in the hope that it will be useful, but WITHOUT      */
+/* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or      */
+/* FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public       */
+/* License for more details.                                                  */
+/*                                                                            */
+/* You should have received a copy of the GNU Lesser General Public License   */
+/* along with XRootD in a file called COPYING.LESSER (LGPL license) and file  */
+/* COPYING (GPL license).  If not, see <http://www.gnu.org/licenses/>.        */
+/*                                                                            */
+/* The copyright holder's institutional names and contributor's names may not */
+/* be used to endorse or promote products derived from this software without  */
+/* specific prior written permission of the institution or contributor.       */
+/******************************************************************************/
+
+class XrdNetAddrInfo;
+class XrdSecEntity;
+
+class XrdNetPMark
+{
+public:
+
+class Handle
+     {public:
+
+      bool        Valid() {return eCode >= 0;}
+
+                  Handle(const char *app=0, int ecode=0, int acode=0)
+                        : appName(app), eCode(ecode), aCode(acode) {}
+
+                  Handle(Handle &h)
+                        : appName(h.appName), eCode(h.eCode), aCode(h.aCode) {};
+
+      virtual    ~Handle() {};
+
+      protected:
+      const char *appName;
+      int         eCode;
+      int         aCode;
+     };
+
+virtual Handle *Begin(XrdSecEntity &Client, const char *path=0,
+                                            const char *cgi=0,
+                                            const char *app=0) = 0;
+
+virtual Handle *Begin(XrdNetAddrInfo &addr, Handle     &handle,
+                                            const char *tident) = 0;
+
+                XrdNetPMark() {}
+protected:
+virtual        ~XrdNetPMark() {} // This object cannot be deleted!
+};
+#endif