cabal_conn.cpp

/*
   Cabal - cabal_conn.cpp
   Short description

   $Id: cabal_conn.cpp,v 1.4 2004/04/05 21:54:18 jonnymind Exp $
---------------------------------------------
   Begin      : ven mar 26 2004 02:13
   Author     : Giancarlo Niccolai <gc@niccolai.ws>, (C) 2004

   Last modified because:

*/

/**************************************************************************
*   This program is free software; you can redistribute it and/or modify  *
*   it under the terms of the GNU Library General Public License as       *
*   published by the Free Software Foundation; either version 2.1 of the  *
*   License, or (at your option) any later version.                       *
***************************************************************************/
#include <cabal_conn.h>
#include <cabal_channel.h>
#include <cabal_defs.h>
#include <cabal_trans.h>

namespace Cabal
{
   
Connection::Connection( Socket *s, Transmission *trans, Reception *recpt )
{
   assert( (m_socket = s) != 0 && (m_trans = trans ) != 0 );
   assert( s->managed() );
   
   // reference the socket
   s->incref();
   m_recpt = recpt;
 
   m_trans->init( this );
   // not yet scheduled
   m_channel = 0;
   m_nextSchedule = -1;  
   m_line = 0;
}

Connection::~Connection()
{
   // eventually inform the channel that we are out of business.
   if ( m_channel ) m_channel->deschedule( this );
   
   m_trans->terminate( this );
   
   // release the socket
   m_socket->decref();
}

void Connection::schedule( const long int milliseconds, Priority prio )
{
   assert( m_socket->managed() );
   
   long int msecs = 0;
   
   if ( prio != realtime )
   {     
      if ( m_line ) 
         msecs = m_line->minimalWait();
      
      if ( milliseconds > msecs ) 
         msecs = milliseconds;
   }
   else
      msecs = milliseconds;
   
   m_nextSchedule = Net::timeOfDay() + msecs;
   m_channel = m_socket->channel();
   m_channel->schedule( this, prio );
}
   
}
/* end of cabal_conn.cpp */

---