client.cpp

/***************************************************************************
 * The contents of this file are subject to the Mozilla Public             *
 * License Version 1.1 (the "License"); you may not use this file          *
 * except in compliance with the License. You may obtain a copy of         *
 * the License at http://www.mozilla.org/MPL/                              *
 *                                                                         *
 * Software distributed under the License is distributed on an "AS         *
 * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or              *
 * implied. See the License for the specific language governing            *
 * rights and limitations under the License.                               *
 *                                                                         *
 * The Original Code is Game Network Framework (GaNeF).                    *
 *                                                                         *
 * The Initial Developers of the Original Code are                         *
 * Lars Langer and Emanuel Greisen                                         *
 * Copyright (C) 2005. Lars Langer & Emanuel Greisen                       *
 * All Rights Reserved.                                                    *
 *                                                                         *
 * Contributor(s):                                                         *
 *   none yet....                                                          *
 *                                                                         *
 ***************************************************************************/
#include "client.h"

#include "serverpacket.h"
#include "serverframework.h"

#include <ptime.h>

unsigned int Client::next_uid = 100;

Client::Client(ServerFramework *fw, const ipaddress &addr, int port)
   : server_framework(fw),
      addr(addr),
      port(port),
      uid(next_uid++),
      state(NEWCLIENT),
      has_called_on_connect(false),
      has_called_on_disconnect(false),
      last_packet_received(msecs(now()))
{
   //std::cout << "[Client addr: " << addr << ",port: " << port << std::endl;
}


Client::~Client()
{
}


bool operator==(const Client & c1, const Client & c2)
{
   return (c1.addr == c2.addr && c1.port == c2.port);
}

std::ostream & operator <<( std::ostream & o, Client & client )
{
   return o << "[Client]" << client.getAddress() << ":" << client.getPort() << "[/Client]";
}

bool Client::isPacketReadyForDelivery( ServerPacket * packet )
{
   if(packet->isReliable())
   {
      if(sequencenumbers.isNext(packet))
      {
         return true;
      }
      else if(sequencenumbers.isFuture(packet))
      {
         // Only enqueue future packets
         sequencenumbers.bufferPacket(packet);
      }
      else
      {
         // It's a duplicate
         //std::cout << "Discard duplicate reliable packet" << std::endl;
         delete packet;
      }
      return false;
   }
   else
   {
      if(packet->getSequenceNumber() >= sequencenumbers.getNextIngoingSeqNo(packet))
      {
         sequencenumbers.incrementNextIngoingSeqNo(packet);
         return true;
      }
      //std::cout << "Discard too old unreliable packet:" << packet->getSequenceNumber() << std::endl;
      delete packet;
      return false;
   }
}

ServerPacket * Client::incrementNextIngoingSeqNo( ServerPacket * packet )
{
   //std::cout << "Client::incrementNextIngoingSeqNo( "<<packet->getSequenceNumber()<<")\n";
   return sequencenumbers.incrementNextIngoingSeqNo(packet);
}

unsigned int Client::getNextOutgoingPacketSeqNumber( ServerPacket * packet )
{
   return sequencenumbers.getNextOutgoingSeqNo(packet);
}

---