cabal_channel.h

/*
   cabal_channel.h
   
   CABAL - CAched BAlanced Lan
   Channel (socket collection) class.

   $Id: cabal_channel.h,v 1.4 2004/04/10 15:28:16 jonnymind Exp $
---------------------------------------------
   Begin      : 2003-12-27 06:15
   Author     : Giancarlo Niccolai

   Last modified because:

*/

#ifndef CABAL_CHANNEL_H
#define CABAL_CHANNEL_H

#include <list>
#include <cabal_defs.h>
#include <cabal_waiter.h>

namespace Cabal {

class Connection;
class Socket;

typedef std::list< Connection *> ConList;
typedef std::list< Socket *> SocketList;


class Channel: public Waiter
{
private:
   long int m_bandwidth;
   long int m_lastSentTime;
   long int m_lastSentSize;
   
   long int m_nextSchedule;
   
   ConList  m_cons[ CABAL_PRIORITIES ];

   SocketList m_sockets;
   
   void recptRoundRobin()
   {
      if ( ! m_sockets.empty() ) 
      {
         SocketList::iterator sit = m_sockets.begin();
         Socket *skt = (*sit);
         sit++;
         if ( sit != m_sockets.end() )
         {
            sit--;
            m_sockets.erase( sit );
            m_sockets.push_back( skt );
         }
      }
   }

   
   
public:
   Channel( const long bwidth=0 ) {
      m_bandwidth = bwidth;
      m_lastSentTime = -1001;
      m_lastSentSize = 0;
      m_nextSchedule = -1;
   }

   // copy constructor NOT allowed

   void addSocket( Socket *skt );
   
   void removeSocket( Socket *skt ); 

   void schedule( Connection *con, const Priority prio );
   
   void deschedule( const Connection *con, const Priority prio, const bool complete=false ); 
   
   void deschedule( const Connection *con )
   {
      deschedule( con, realtime, true );
      deschedule( con, high_prio, true ); 
      deschedule( con, medium_prio, true ); 
      deschedule( con, low_prio, true ); 
   }
      
   bool process( MSECS msecs );

};

}

#endif

/* End of cabal_channel.h */

---