EIC code displayed by LXR master/​include/​xrootd/​XrdNet/​XrdNet.hh	Source navigation Diff markup Identifier search General search
	Version: master test Revert   Change

File indexing completed on 2025-01-18 10:15:40

 #ifndef __XRDNET_H__
 #define __XRDNET_H__
 /******************************************************************************/
 /*                                                                            */
 /*                             X r d N e t . h h                              */
 /*                                                                            */
 /* (c) 2004 by the Board of Trustees of the Leland Stanford, Jr., University  */
 /*   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.       */
 /******************************************************************************/
 
 #include <cstdlib>
 #include <cstring>
 #ifndef WIN32
 #include <strings.h>
 #include <unistd.h>
 #include <netinet/in.h>
 #include <sys/socket.h>
 #else
 #include <Winsock2.h>
 #endif
 
 #include "XrdNet/XrdNetOpts.hh"
 
 class XrdNetAddr;
 class XrdNetBufferQ;
 class XrdNetPeer;
 class XrdNetSecurity;
 class XrdSysError;
 
 class XrdNet
 {
 public:
 
 //------------------------------------------------------------------------------
 //! Accept incoming TCP connection. This is the preferred method for TCP.
 //!
 //! @param  myAddr   the address object to contain connection information.
 //! @param  opts     processing options:
 //!                  XRDNET_DELAY     - do not set nodelay on socket.
 //!                  XRDNET_KEEPALIVE - use TCP keep alive on socket.
 //!                  XRDNET_NOCLOSEX  - do not allow socket to close on exec()
 //!                  XRDNET_NOEMSG    - supress printing error messages
 //!                  XRDNET_NOLINGER  - Do not linger when closing socket.
 //! @param  timeout  maximum seconds to wait for a conection. When negative,
 //!                  the default, no time limit applies.
 //! @return !0       Successful connection occurred, myAddr holds information.
 //! @return =0       Failure, a timeout or permanent error occurred.
 //------------------------------------------------------------------------------
 
 int             Accept(XrdNetAddr &myAddr,
                        int opts=0,
                        int timeout=-1);
 
 //------------------------------------------------------------------------------
 //! Accept incoming TCP or UDP connection. This method should only be used for
 //! UDP-style networks. The previous method is preferred for TCP-style networks.
 //!
 //! @param  myPeer   the peer object to contain connection information.
 //! @param  opts     processing options:
 //!                  XRDNET_DELAY     - TCP: do not set nodelay on socket.
 //!                  XRDNET_KEEPALIVE - TCP: use TCP keep alive on socket.
 //!                  XRDNET_NEWFD     - UDP: obtain new file descriptor
 //!                  XRDNET_NOCLOSEX  - ALL: keep socket across exec() calls
 //!                  XRDNET_NODNTRIM  - ALL: don't trim domain name in myPeer
 //!                  XRDNET_NOEMSG    - ALL: supress printing error messages
 //!                  XRDNET_NORLKUP   - ALL: avoid doing reverse DNS look-up
 //!                  XRDNET_USETLS    - ALL: enable TLS upon connection
 //! @param  timeout  maximum seconds to wait for a conection. When negative,
 //!                  the default, no time limit applies.
 //! @return !0       Successful connection occurred, myPeer holds information.
 //! @return =0       Failure, a timeout or permanent error occurred.
 //------------------------------------------------------------------------------
 
 int             Accept(XrdNetPeer &myPeer,
                        int opts=0,
                        int timeout=-1);
 
 //------------------------------------------------------------------------------
 //! Bind a network object to a TCP or UDP port number.
 //!
 //! @param  port     the port number to bind to. Use 0 for arbitrary port.
 //! @param  contype  Either "tcp" for TCP networks or "udp" for UDP networks.
 //!
 //! @return  0       Successfully bound the port.
 //! @return !0       Failure, return value is -errno describing the error.
 //------------------------------------------------------------------------------
 
 int             Bind(      int   port,             // Port number
                      const char *contype="tcp"     // "tcp" or "udp"
                     );
 
 //------------------------------------------------------------------------------
 //! Bind a network object to a Unix named socket.
 //!
 //! @param  path     the file system path to a named socket to bind with.
 //! @param  contype  Either "stream" to use TCP-tyle streaming protocol or
 //!                  "datagram" to use UDP-style messaging.
 //!
 //! @return  0       Successfully bound the port.
 //! @return !0       Failure, return value is -errno describing the error.
 //------------------------------------------------------------------------------
 
 int             Bind(      char *path,             // Unix path < |109|
                      const char *contype="stream"  // stream | datagram
                     );
 
 //------------------------------------------------------------------------------
 //! Create a TCP socket and connect it to the given host and port. This is the
 //! preferred method for making TCP based connections.
 //!
 //! @param  myAddr   address object where connection information is returned.
 //! @param  dest     destination hostname or IP address.
 //! @param  port     the port number to connect to. If < 0 then the dest param
 //!                  must contain the port number preceeded by a colon.
 //! @param  opts     processing options:
 //!                  XRDNET_NOCLOSEX  - do not allow socket to close on exec()
 //!                  XRDNET_NOEMSG    - supress printing error messages
 //!                  XRDNET_NORLKUP   - avoid doing reverse DNS look-up
 //! @param  timeout  the maximum number of seconds to wait for the connection to
 //!                  complete. A negative value waits forever. Values greater
 //!                  than 255 seconds are set to 255.
 //!
 //! @return true     Connection completed, myAddr holds connection information.
 //! @return false    Connection failed.
 //------------------------------------------------------------------------------
 
 int             Connect(XrdNetAddr &myAddr,
                         const char *dest,  // Destination host or ip address
                         int   port=-1,     // Port number
                         int   opts=0,      // Options
                         int   timeout=-1   // Second timeout
                        );
 
 //------------------------------------------------------------------------------
 //! Create a TCP or UDP socket and connect it to the given host and port. The
 //! previous method is preferred for creating TCP sockets.
 //!
 //! @param  myPeer   peer object where connection information is returned.
 //! @param  dest     destination hostname or IP address.
 //! @param  port     the port number to connect to. If < 0 then the dest param
 //!                  must contain the port number preceeded by a colon.
 //! @param  opts     processing options:
 //!                  XRDNET_NOCLOSEX  - do not allow socket to close on exec()
 //!                  XRDNET_NODNTRIM  - do not trim domain name in myPeer.
 //!                  XRDNET_NOEMSG    - supress printing error messages
 //!                  XRDNET_NORLKUP   - avoid doing reverse DNS look-up
 //!                  XRDNET_UDPSOCKET - create a UDP socket (o/w use TCP).
 //! @param  timeout  the maximum number of seconds to wait for the connection to
 //!                  complete. A negative value waits forever. Values greater
 //!                  than 255 seconds are set to 255.
 //!
 //! @return true     Connection completed, myPeer holds connection information.
 //! @return false    Connection failed.
 //------------------------------------------------------------------------------
 
 int             Connect(XrdNetPeer &myPeer,
                         const char *dest,  // Destination host or ip address
                         int   port=-1,     // Port number
                         int   opts=0,      // Options
                         int   timeout=-1   // Second timeout
                        );
 
 //------------------------------------------------------------------------------
 //! Get the port number, if any, bound to this network.
 //!
 //! @return  >0      The bound port number.
 //! @return <=0      The network is not bound to a port.
 //------------------------------------------------------------------------------
 
 int             Port() {return Portnum;}
 
 // Relay() creates a UDP socket and optionally decomposes a destination
 //         of the form host:port. Upon success it fills in the Peer object
 //         and return true (1). Upon failure, it returns false (0).
 //
 int             Relay(XrdNetPeer &Peer,   // Peer object to be initialized
                       const char *dest,   // Optional destination
                       int         opts=0  // Optional options as above
                      );
 
 int             Relay(const char *dest);  // Optional destination
 
 //------------------------------------------------------------------------------
 //! Add a NetSecurity object to the existing accept() security constraints.
 //!
 //! @param  secp     Pointer to the network security object. This object must
 //!                  not be deleted nor directly used after the call as this
 //!                  object assumes its ownership and may delete it at any time.
 //------------------------------------------------------------------------------
 
 virtual void    Secure(XrdNetSecurity *secp);
 
 //------------------------------------------------------------------------------
 //! Set network defaults.
 //!
 //! @param  options  The options to be added to Accept(), Bind() and Connect()
 //!                  calls. These options cannot be turned off, so be careful.
 //! @param  buffsz   The UDP buffer size (the initial default is 32K) or the TCP
 //!                  window size (initial default is OS dependent).
 //------------------------------------------------------------------------------
 
 void            setDefaults(int options, int buffsz=0)
                            {netOpts = options; Windowsz = buffsz;}
 
 //------------------------------------------------------------------------------
 //! Set network domain name.
 //!
 //! @param  dname    The domain name which indicates to Trim() what part of the
 //!                  host name is so common that it can be trimmed.
 //------------------------------------------------------------------------------
 
 void            setDomain(const char *dname)
                          {if (Domain) free(Domain);
                           Domain = strdup(dname);
                           Domlen = strlen(dname);
                          }
 
 //------------------------------------------------------------------------------
 //! Trims off the domain name in a host name.
 //!
 //! @param  hname    The host name to be trimmed (it is modified).
 //------------------------------------------------------------------------------
 
 void            Trim(char *hname);
 
 //------------------------------------------------------------------------------
 //! Unbind the network from any bound resouces.
 //------------------------------------------------------------------------------
 
 void            unBind();
 
 //------------------------------------------------------------------------------
 //! Get the current TCP RCVBUF window size.
 //!
 //! @return   >0     The current window size.
 //! @return  <=0     Either the network is not bound to a port or an error has
 //!                  occurred. Window size is unavailable.
 //------------------------------------------------------------------------------
 
 int            WSize();
 
 //------------------------------------------------------------------------------
 //! Constructor
 //!
 //! @param  erp      The error object for printing error messages. It must be
 //!                  supplied.
 //! @param  secp     The initial NetSecurity object. This secp object must not
 //!                  be deleted nor directly used after the call as this
 //!                  object assumes its ownership and may delete it at any time.
 //------------------------------------------------------------------------------
 
                 XrdNet(XrdSysError *erp, XrdNetSecurity *secp=0);
 
 //------------------------------------------------------------------------------
 //! Destructor
 //------------------------------------------------------------------------------
 
 virtual        ~XrdNet();
 
 protected:
 
 XrdSysError       *eDest;
 XrdNetSecurity    *Police;
 char              *Domain;
 int                Domlen;
 int                iofd;
 int                Portnum;
 int                PortType;
 int                Windowsz;
 int                netOpts;
 int                BuffSize;
 XrdNetBufferQ     *BuffQ;
 
 private:
 
 int                do_Accept_TCP(XrdNetAddr &myAddr, int opts);
 int                do_Accept_TCP(XrdNetPeer &myPeer, int opts);
 int                do_Accept_UDP(XrdNetPeer &myPeer, int opts);
 };
 #endif

This page was automatically generated by the 2.3.7 LXR engine. The LXR team