balser.h

/*
   Cabal - balser.h
   Short description

   $Id: balser.h,v 1.2 2004/03/29 14:17:29 jonnymind Exp $
---------------------------------------------
   Begin      : lun mar 29 2004 03:22
   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.                       *
***************************************************************************/

#ifndef _BALSER_H
#define _BALSER_H

#include <cabal.h>

#define DEFAULT_PORT       2051
#define CHANNEL_BANDWIDTH  8096
#define LINE_BANDWITH      2048
#define START_CONNECT      0xf3f0f1f2
#define END_CONNECT        0xf9f8f7f1
#define CLIENT_REP_SIZE    16

using namespace std;
using namespace Cabal;


/**********************************************************************
* This is our protocol definition.
* May be much more complex than this.
***********************************************************************/

typedef struct tag_packet {
   unsigned long userId;
   unsigned long id;
   unsigned long timestamp; // in milliseconds since midnight.
   char data[512 - (3 * sizeof( unsigned long ))];
} PACKET;

#define REQ_TYPE_ACK      1
#define REQ_TYPE_RESEND   2

typedef struct tag_clireq 
{
   unsigned char type;
   unsigned long value;
}CLI_REQ;

/**********************************************************************
* Theese are our clients; in real apps, we'll have a client object
* encapsulating the lines, and some other kind of mapping.
***********************************************************************/

class Client 
{
public:
   MSECS m_lastHail;
   Line *m_comLine;
   unsigned long m_userId;
   unsigned long m_rtt;
   unsigned long m_packetId;
   
   
   Client( unsigned long id, Line *line ) { 
      m_userId = id;
      m_comLine = line; 
      m_lastHail = Net::timeOfDay();
      m_rtt = 0xFFFF;
   }
   
   ~Client() { delete m_comLine; }
};

typedef map<unsigned long, Client *> ClientHash;

/**********************************************************************
* Transmissions are meant to send random data to our clients.
***********************************************************************/

class DflTransmit: public Transmission
{
   unsigned long m_packetId;
   unsigned long m_size;
      
   Address m_dest;
   Priority m_prio;
   unsigned long m_userId;
   std::list<unsigned long> m_resend;
   
public:
   DflTransmit( unsigned long userId, unsigned long length, const Address &dest, Priority prio ) 
   {
      m_dest = dest;
      m_prio = prio;
      m_size = length;
      m_packetId = 0;
      // notice: in a real application we may receive a pointer to the client object (which
      // contains a line with a connection using this transmission. Or we may overload the
      // connection; as connections-transmissions are 1:1, a transmission may be specialized
      // in receiving a special connections subclass.
      m_userId = userId;
   }
   
   virtual void init( Connection *con ) {}
   virtual bool transmit( Connection *con );
   virtual void terminate( Connection *con ) { }
   
   void resend( unsigned long id ) {
      m_resend.push_back( id );
   }
};


/**********************************************************************
* The reception has the duty to detect new clients incoming, and to 
* fulfil existing clients request.
*
* This server has only one socket, and then, only one reception.
***********************************************************************/
class DflReception: public Reception
{

public:
   DflReception() {
   }

   virtual void init( Socket *skt ) {}
   virtual bool receive( Socket *skt );
   virtual void terminate( Socket *skt ) {}
   
};

#endif

/* end of balser.h */

---