libresiprocate-1.11-dev 1:1.11.0~beta5-1 / usr / include / resip / stack / ConnectionManager.hxx

#ifndef RESIP_ConnectionMgr_hxx
#define RESIP_ConnectionMgr_hxx 

#include <map>
#include "rutil/HashMap.hxx"
#include "resip/stack/Connection.hxx"

namespace resip
{
class FdPollGrp;

/**
   Collection of Connection per Transport. Maintains round-robin
   orders for read and write.  Maintains least-recently-used connections list
   for garbage collection.

   Maintains mapping from Tuple to Connection.
 */
class ConnectionManager
{
   friend class Connection;

   public:
      /** connection must have no inbound traffic for greater than this 
          time (in ms) before it is garbage collected */
      static UInt64 MinimumGcAge;
      /** If the difference between the number of permitted FDs
          (reported by periodic calls to getrlimit()) and the number
          of active stream connections falls below this threshold,
          the garbage collector will overlook MinimumGcAge and
          more aggressively close connections */
      static UInt64 MinimumGcHeadroom;
      /** Enable Agressive Connection Garbage Collection to have resip
          perform garbage collection on every new connection.  If disabled
          then garbage collection is only performed if we run out of Fd's */
      static bool EnableAgressiveGc;

      ConnectionManager();
      ~ConnectionManager();

      /// may return 0
      Connection* findConnection(const Tuple& tuple);
      const Connection* findConnection(const Tuple& tuple) const;

      /// populate the fdset againt the read and write lists
      void setPollGrp(FdPollGrp *grp);
      void buildFdSet(FdSet& fdset);
      void process(FdSet& fdset);

      virtual void invokeAfterSocketCreationFunc() const;

   private:
      void addToWritable(Connection* conn); // add the specified conn to end
      void removeFromWritable(Connection* conn); // remove the current mWriteMark

      typedef std::map<Tuple, Connection*> AddrMap;
      typedef std::map<Socket, Connection*> IdMap;

      void addConnection(Connection* connection);
      void removeConnection(Connection* connection);
      void closeConnections();

      /// release excessively old connections (free up file descriptors)
      /// set maxToRemove to 0 for no-max
      unsigned int gc(UInt64 threshold, unsigned int maxToRemove);
      unsigned int gcWithTarget(unsigned int target);

      /// move to youngest 
      void touch(Connection* connection);
      void moveToFlowTimerLru(Connection *connection);
      
      AddrMap mAddrMap;
      IdMap mIdMap;

      /// all intrusive lists based on the same element type
      Connection mHead;

      /// ready to write list
      ConnectionWriteList* mWriteHead;
      /// ready to read list
      ConnectionReadList* mReadHead;
      /// least recently used list
      ConnectionLruList* mLRUHead;
      /// least recently used list for flow timer enabled connections
      FlowTimerLruList* mFlowTimerLRUHead;

      /// collection for epoll
      FdPollGrp* mPollGrp;
      //<<---------------------------------

      friend class TcpBaseTransport;
};

}

#endif

/* ====================================================================
 * The Vovida Software License, Version 1.0 
 * 
 * Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 * 
 * 3. The names "VOCAL", "Vovida Open Communication Application Library",
 *    and "Vovida Open Communication Application Library (VOCAL)" must
 *    not be used to endorse or promote products derived from this
 *    software without prior written permission. For written
 *    permission, please contact vocal@vovida.org.
 *
 * 4. Products derived from this software may not be called "VOCAL", nor
 *    may "VOCAL" appear in their name, without prior written
 *    permission of Vovida Networks, Inc.
 * 
 * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
 * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
 * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
 * IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
 * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
 * DAMAGE.
 * 
 * ====================================================================
 * 
 * This software consists of voluntary contributions made by Vovida
 * Networks, Inc. and many individuals on behalf of Vovida Networks,
 * Inc.  For more information on Vovida Networks, Inc., please see
 * <http://www.vovida.org/>.
 *
 */